This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push: new 32ec971 [FLINK-9526][e2e] Fix unstable BucketingSink end-to-end test 32ec971 is described below commit 32ec971b3617e8fe4fc87334f747ed44afceb4c2 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