This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 7fec439 [FLINK-9526][e2e] Fix unstable BucketingSink end-to-end test
7fec439 is described below
commit 7fec4392b21b07c69ba15ea554731886f181609e
Author: ifndef-SleePy <mmyy1...@gmail.com>
AuthorDate: Tue Jul 23 14:29:36 2019 +0200
[FLINK-9526][e2e] Fix unstable BucketingSink end-to-end test
---
flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh
b/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh
index a22c6d4..2ecea72 100755
--- a/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh
+++ b/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh
@@ -21,8 +21,9 @@ source "$(dirname "$0")"/common.sh
TEST_PROGRAM_JAR=${END_TO_END_DIR}/flink-bucketing-sink-test/target/BucketingSinkTestProgram.jar
-# enable DEBUG logging level to retrieve truncate length later
-sed -i -e
's/#log4j.logger.org.apache.flink=INFO/log4j.logger.org.apache.flink=DEBUG/g'
$FLINK_DIR/conf/log4j.properties
+# enable DEBUG logging level for the BucketingSink to retrieve truncate length
later
+echo "" >> $FLINK_DIR/conf/log4j.properties
+echo
"log4j.logger.org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink=DEBUG"
>> $FLINK_DIR/conf/log4j.properties
set_conf_ssl
start_cluster
