Skip to content

Commit ad7638d

Browse files
committed
Add a bit to the delay. Update HBase in the Hive sink
1 parent 1980bd4 commit ad7638d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flume-ng-sinks/flume-hdfs-sink/src/test/java/org/apache/flume/sink/hdfs/TestHDFSEventSink.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1328,7 +1328,7 @@ public void testCloseOnIdle() throws IOException, EventDeliveryException, Interr
13281328

13291329
sink.process();
13301330
sink.process();
1331-
Thread.sleep(1001);
1331+
Thread.sleep(1101);
13321332
// previous file should have timed out now
13331333
// this can throw BucketClosedException(from the bucketWriter having
13341334
// closed),this is not an issue as the sink will retry and get a fresh

flume-parent/pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,8 @@ limitations under the License.
7474
<guava-old.version>11.0.2</guava-old.version>
7575
<hadoop3.version>3.2.2</hadoop3.version>
7676
<hadoop.version>${hadoop3.version}</hadoop.version>
77-
<hbase.version>1.7.2</hbase.version>
7877
<hbase2.version>2.5.3-hadoop3</hbase2.version>
78+
<hbase.version>${hbase2.version}</hbase.version>
7979
<hive.version>3.1.2</hive.version>
8080
<httpcore.version>4.4.15</httpcore.version>
8181
<httpclient.version>4.5.13</httpclient.version>

0 commit comments

Comments
 (0)