You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2019/07/08 09:44:01 UTC
[flink] branch master updated: [hotfix][table-planner-blink] Fix
static variable name
This is an automated email from the ASF dual-hosted git repository.
kurt 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 3fa91f2 [hotfix][table-planner-blink] Fix static variable name
3fa91f2 is described below
commit 3fa91f277480e4089c47dba6af63c5f38a7ca5dd
Author: Kurt Young <yk...@gmail.com>
AuthorDate: Mon Jul 8 17:43:04 2019 +0800
[hotfix][table-planner-blink] Fix static variable name
---
.../src/main/java/org/apache/flink/table/executor/ExecutorBase.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/executor/ExecutorBase.java b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/executor/ExecutorBase.java
index 4d28407..fb6bbf1 100644
--- a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/executor/ExecutorBase.java
+++ b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/executor/ExecutorBase.java
@@ -32,7 +32,9 @@ import java.util.List;
*/
@Internal
public abstract class ExecutorBase implements Executor {
- private final String DEFAULT_JOB_NAME = "Flink Exec Table Job";
+
+ private static final String DEFAULT_JOB_NAME = "Flink Exec Table Job";
+
private final StreamExecutionEnvironment executionEnvironment;
protected List<Transformation<?>> transformations = new ArrayList<>();