- 17 10月, 2019 6 次提交
-
-
由 Chesnay Schepler 提交于
-
由 lining 提交于
-
由 fanrui 提交于
This closes #9911
-
由 Jiayi Liao 提交于
1. Add @Nullable annotation to nullable fields 2. Use Optional instead of nullable as return value 3. Add requrieNonNull check in constructor for non-null fields 4. List fields do not need to check against null This closes #9843
-
由 wangxlong 提交于
-
- 16 10月, 2019 31 次提交
-
-
由 Timo Walther 提交于
-
由 Jark Wu 提交于
[FLINK-14409][table] Fix MapType and MultisetType doesn't accept any subclass of java.util.Map for inputs This closes #9913.
-
由 cyq89051127 提交于
This closes #9529.
-
由 wangpeibin 提交于
-
由 Cyrille Chépélov 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Chesnay Schepler 提交于
-
由 Aljoscha Krettek 提交于
We also need to change/simplify some translation logic because of this.
-
由 Aljoscha Krettek 提交于
Creating a JobGraph from a StreamGraph using this method creates a random JobID that doesn't give any information.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This allows setting the JobID after creation of the JobGraph.
-
由 Aljoscha Krettek 提交于
This way, we can reuse the discovery from different methods that we'll add in follow-up commits.
-
由 Aljoscha Krettek 提交于
Before, the executors were potentially storing the jar and classpath internally while the jars and classpaths are really a property of the pipeline that should be executed. This change reflects that.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
We need this to be able to set SavepointRestoreSettings on a StreamGraph that we want to execute via an Executor (PlanExecutor). If we don't set the settings on the StreamGraph we would have to pass them to the Executor, as we now pass them to the ClusterClient. This can make the Executor/ClusterClient unaware of this streaming-only setting.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This decouples JobGraph generation from the executors and environments.
-
由 Aljoscha Krettek 提交于
For now, we can only translate DataSet Plans, in the future we also need this for DataStream StreamGraps.
-
由 Aljoscha Krettek 提交于
For now, only DataSet Plan implements this, as a follow-up, StreamGraph should also implement this.
-
由 Zhu Zhu 提交于
This closes #9901.
-
由 Gary Yao 提交于
-
由 Gary Yao 提交于
This closes #9896.
-
由 Gary Yao 提交于
-
由 Jiayi Liao 提交于
-
由 Jark Wu 提交于
This fixes the broken HBase descriptor
-
由 bowen.li 提交于
adapt existing APIs to the introduction of temporary system and temp functions according to FLIP-57. This closes #9822.
-
- 15 10月, 2019 3 次提交