- 09 9月, 2020 9 次提交
-
-
由 Zhu Zhu 提交于
-
由 JingsongLi 提交于
[FLINK-19166][table-runtime] StreamingFileWriter should register Listener before the initialization of buckets
-
由 Leonard Xu 提交于
This closes #13282
-
由 Jiangjie (Becket) Qin 提交于
-
由 Jiangjie (Becket) Qin 提交于
-
由 Jiangjie (Becket) Qin 提交于
[FLINK-18641][runtime/checkpointing] Checkpoint the operator coordinators before triggering the master hooks. We have to take the snapshot of the master hooks after the coordinator checkpoints has completed. This is to ensure the tasks are checkpointed after the OperatorCoordinators in case ExternallyInducedSource is used.
-
由 Jiangjie (Becket) Qin 提交于
This patch fixes the CheckpointCoordinator to make it work with ExternallyInducedSource in cases that the task snapshots are triggered by the external systems via master hooks, rather than the checkpoint coordinator. The problem in the current code is that when the task snapshots are triggered externally via the master hooks, the checkpoint coordinator may receive all the acks from the tasks before the master state snapshot completes. And this leads to checkpoint failure. The fix is to only finalize the checkpoint when all of the operator coordinator checkpoint, master snapshots and task snapshots are fully taken.
-
由 Jiangjie (Becket) Qin 提交于
-
由 Jiangjie (Becket) Qin 提交于
-
- 08 9月, 2020 3 次提交
-
-
由 Zhijiang 提交于
From the requirement it is no need to enable buffer timeout for batch jobs since the downstream can only consume data when the upstream finishes. Furthermore the current implementation of BoundedBlockingSubpartition does not consider the concurrent issue from the flusher thread by enabling buffer timeout. So it is nice to check this compatibility during job graph generation in advance and give a friendly message hint for users. This closes #13209.
-
由 Zhijiang 提交于
-
由 Wei Zhong 提交于
[FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section This closes #13314.
-
- 07 9月, 2020 4 次提交
-
-
由 Roman Khachatryan 提交于
When closing, this flag is set, but mailbox can still contain (and receive new) mails (e.g. from timers) that should be processed. In particular, this check currently prevents periodic watermarks from being emitted.
-
由 Shawn Huang 提交于
This closes #13338
-
由 Rui Li 提交于
[FLINK-19061][hive] HiveCatalog fails to get partition column stats if partition value contains special characters This closes #13274
-
由 Dawid Wysakowicz 提交于
-
- 05 9月, 2020 1 次提交
-
-
由 acqua.csq 提交于
[FLINK-18598][python][docs] Add documentation on how to wait for the job execution to finish when using asynchronous APIs This closes #13295.
-
- 04 9月, 2020 3 次提交
-
-
由 liujiangang 提交于
[FLINK-18959][Runtime] Try to revert MiniDispatcher for archiveExecutionGraph and shutdown cluster upon cancel. This closes #13227.
-
由 Yun Gao 提交于
-
由 Danny Chan 提交于
[FLINK-19108][table] Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix This closes #13293
-
- 03 9月, 2020 2 次提交
-
-
由 Jimmy.Zhou 提交于
This closes #13297.
-
由 Wei Zhong 提交于
This closes #13312.
-
- 02 9月, 2020 1 次提交
-
-
由 Wei Zhong 提交于
[FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section. This closes #13273.
-
- 31 8月, 2020 3 次提交
-
-
由 Fin-chan 提交于
This closes #13257.
-
由 Andrey Zagrebin 提交于
The waiting happens in a separate thread in production and does not disrupt anything. The problem is that tests use the same method which blocks the testing thread for too long. We do not need such big waiting time in tests. The PR refactors code to get back to the smaller waiting time in tests. This closes #13265.
-
由 Andrey Zagrebin 提交于
-
- 28 8月, 2020 1 次提交
-
-
由 Jingsong Lee 提交于
This closes #13269
-
- 27 8月, 2020 5 次提交
-
-
由 sanshi@wwdz.onaliyun.com 提交于
This closes #13135
-
由 sanshi@wwdz.onaliyun.com 提交于
-
由 Dawid Wysakowicz 提交于
All our documentation pages are encoded in UTF-8. However if not specified, File.read will use the system default encoding. Therefore making it impossible to build docs in a system with a different default encoding. It is the case e.g. when building docs through the docker container.
-
由 Jark Wu 提交于
This closes #13038
-
由 Wei Zhong 提交于
[FLINK-18917][docs][python] Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section This closes #13226.
-
- 25 8月, 2020 5 次提交
-
-
由 Aljoscha Krettek 提交于
Before, it could happen that the embedded node is not ready. Now we wait for nodes/data nodes to be live before returning from the initialization method.
-
由 yuzhao.cyz 提交于
[FLINK-18750][table] SqlValidatorException thrown when select from a view which contains a UDTF call
-
由 Piotr Nowojski 提交于
-
由 Piotr Nowojski 提交于
-
由 Robert Metzger 提交于
This reverts commit dad18a52.
-
- 24 8月, 2020 2 次提交
-
-
由 wangzzu 提交于
Before this, options like the classloader order was not respected if specified in the command like because the packaged program was created before we create the effective configuration at the client. This commit changes the order of events. This closes #13024. (cherry picked from commit 3394da15)
-
由 SteNicholas 提交于
This closes #13221
-
- 22 8月, 2020 1 次提交
-
-
由 Peng 提交于
[FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly This closes #13198.
-