You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xc...@apache.org on 2018/05/31 12:45:28 UTC
flink git commit: [hotfix][table] Remove a println statement
Repository: flink
Updated Branches:
refs/heads/master 57b950796 -> bda8bad9b
[hotfix][table] Remove a println statement
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bda8bad9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bda8bad9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bda8bad9
Branch: refs/heads/master
Commit: bda8bad9b2a8061fd318b3b4bb055414c5444c02
Parents: 57b9507
Author: Xingcan Cui <xi...@gmail.com>
Authored: Thu May 31 19:05:53 2018 +0800
Committer: Xingcan Cui <xi...@gmail.com>
Committed: Thu May 31 20:42:13 2018 +0800
----------------------------------------------------------------------
.../org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/bda8bad9/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
index b5546db..a44bdef 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala
@@ -301,7 +301,6 @@ abstract class TimeBoundedStreamJoin(
if (!tuple.f1) {
// Emit a null padding result if the left row has never been successfully joined.
joinCollector.collect(paddingUtil.padLeft(tuple.f0))
- println(s"Emitting a null padding result for left row ${tuple.f0}")
}
i += 1
}