You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/07/25 11:31:22 UTC
[6/8] flink git commit: [hotfix] [core] Fix null check in
Plan#addDataSink
[hotfix] [core] Fix null check in Plan#addDataSink
This closes #4385.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/788d9452
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/788d9452
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/788d9452
Branch: refs/heads/master
Commit: 788d9452d8541b3ec7a11cae5d9fa605c2626fc1
Parents: 8624c29
Author: p1tz <p1...@users.noreply.github.com>
Authored: Mon Jul 24 01:19:17 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Tue Jul 25 11:27:54 2017 +0200
----------------------------------------------------------------------
flink-core/src/main/java/org/apache/flink/api/common/Plan.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/788d9452/flink-core/src/main/java/org/apache/flink/api/common/Plan.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/Plan.java b/flink-core/src/main/java/org/apache/flink/api/common/Plan.java
index 0235af0..db10ce4 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/Plan.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/Plan.java
@@ -201,7 +201,7 @@ public class Plan implements Visitable<Operator<?>> {
* @param sink The data sink to add.
*/
public void addDataSink(GenericDataSinkBase<?> sink) {
- checkNotNull(jobName, "The data sink must not be null.");
+ checkNotNull(sink, "The data sink must not be null.");
if (!this.sinks.contains(sink)) {
this.sinks.add(sink);