- 25 3月, 2020 13 次提交
-
-
由 Piotr Nowojski 提交于
This removes another dependency on the StreamTask from AbstractStreamOperator
-
由 Piotr Nowojski 提交于
Those methods do not have any reason to be on the StreamOperator level since we introduced StreamOperatorFactory concept, so they should be moved to SetupableStreamOperator
-
由 Piotr Nowojski 提交于
-
由 liuyongvs 提交于
This closes #11471.
-
由 Chesnay Schepler 提交于
-
由 Robert Metzger 提交于
-
由 Yadong Xie 提交于
-
由 Canbin Zheng 提交于
[FLINK-16625][utils] Extract BootstrapTools#getEnvironmentVariables to ConfigurationUtils#getPrefixedKeyValuePairs This closes #11458 .
-
由 Yang Wang 提交于
This closes #11489 .
-
由 Zhijiang 提交于
At the moment there are four fields initialized in the method of StreamTask#beforeInvoke, such as `stateBackend`, `checkpointStorage`, `timerService`, `asyncOperationsThreadPool`. In general it is suggested to use final fields to get known benefits. So we can refactor the StreamTask to initialize these fields in the constructor instead. This closes #11486
-
由 JingsongLi 提交于
-
由 zhengshuli 提交于
-
由 Leonard Xu 提交于
[FLINK-16170][elasticsearch] Fix SearchTemplateRequest ClassNotFoundException when using flink-sql-connector-elasticsearch7 We shouldn't `exclude org.elasticsearch:elasticsearch-geo` and `org.elasticsearch.plugin:lang-mustache-client` when shading. This closes #11396
-
- 24 3月, 2020 25 次提交
-
-
由 felixzheng 提交于
This closes #10973.
-
由 felixzheng 提交于
-
由 Xintong Song 提交于
This closes #11284.
-
由 Xintong Song 提交于
-
由 Xintong Song 提交于
[FLINK-15911][runtime] Support configure address/port and bind-address/bind-port separately for netty shuffle service.
-
由 Xintong Song 提交于
[FLINK-15911][runtime] Support configure address/port and bind-address/bind-port separately for JM/TM RPC services.
-
由 Xintong Song 提交于
[FLINK-15911][runtime] Refactor to create AkkaRpsService with builder class, in order to reduce the number of nested creating methods.
-
由 Xintong Song 提交于
-
由 Xintong Song 提交于
-
由 Rui Li 提交于
This closes #11494
-
由 Rui Li 提交于
This closes #11492
-
由 Andrey Zagrebin 提交于
-
由 Andrey Zagrebin 提交于
-
由 Andrey Zagrebin 提交于
-
由 Andrey Zagrebin 提交于
Improve error message, explaining the possible reasons and ways to resolve. In case of metaspace OOM error, try a graceful TM shutdown. This closes #11408.
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 Dian Fu 提交于
-
由 漫步云端 提交于
This closes #11410
-
- 23 3月, 2020 2 次提交
-
-
由 zhule 提交于
This closes #11461
-
由 ifndef-SleePy 提交于
[FLINK-14971][checkpointing] Remove lock of PendingCheckpoint and introduce IO lock for PendingCheckpoint Since all non-IO operations are executed in main thread, the lock of PendingCheckpoint could be avoided now.
-