[GitHub] [flink] flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536153382 ## CI report: * ea5b4330b5c9fb6eff889eb1c55c3f9a7bcfb6a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536153382 ## CI report: * ea5b4330b5c9fb6eff889eb1c55c3f9a7bcfb6a9 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536151451 ## CI report: * 507c29a013e30a6993d8b123b266c44ddbdde037 : FAILURE

[jira] [Updated] (FLINK-14050) Refactor YarnClusterDescriptor inheritance

[ https://issues.apache.org/jira/browse/FLINK-14050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14050: -- Description: Currently, the inheritance looks like AbstractYarnClusterDescriptor ->

[jira] [Comment Edited] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939848#comment-16939848 ] Zili Chen edited comment on FLINK-14250 at 9/28/19 4:50 AM: Actually I am

[jira] [Comment Edited] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939848#comment-16939848 ] Zili Chen edited comment on FLINK-14250 at 9/28/19 4:49 AM: Actually I am

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939848#comment-16939848 ] Zili Chen commented on FLINK-14250: --- Actually I am thinking of making {{CliFrontend}} the unique CLI

[GitHub] [flink] flinkbot commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

flinkbot commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536153382 ## CI report: * ea5b4330b5c9fb6eff889eb1c55c3f9a7bcfb6a9 : UNKNOWN

[jira] [Commented] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run"

[ https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939847#comment-16939847 ] Zili Chen commented on FLINK-14250: --- Vote for this. I second that {{if (!programOptions.isPython())}}

[GitHub] [flink] flinkbot commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

flinkbot commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536152879 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-14130) Remove ClusterClient.run() methods

[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14130: --- Labels: pull-request-available (was: ) > Remove ClusterClient.run() methods >

[GitHub] [flink] TisonKun opened a new pull request #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

TisonKun opened a new pull request #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793 ## What is the purpose of the change Based on #9792 . - inline `run` s of batch codepath. - extract the other `run` to

[GitHub] [flink] flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536151451 ## CI report: * 507c29a013e30a6993d8b123b266c44ddbdde037 : PENDING

[jira] [Commented] (FLINK-14130) Remove ClusterClient.run() methods

[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939842#comment-16939842 ] Zili Chen commented on FLINK-14130: --- Base on FLINK-14263 it is obviously how we can exclude {{#run}} s

[jira] [Assigned] (FLINK-14130) Remove ClusterClient.run() methods

[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14130: - Assignee: Zili Chen > Remove ClusterClient.run() methods > --

[GitHub] [flink] flinkbot commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

flinkbot commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536151451 ## CI report: * 507c29a013e30a6993d8b123b266c44ddbdde037 : UNKNOWN

[jira] [Updated] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14264: -- Fix Version/s: 1.10.0 Affects Version/s: (was: 1.9.0) > Expose

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939837#comment-16939837 ] Congxian Qiu(klion26) commented on FLINK-14264: --- [~Zentol] What do you think about this

[jira] [Created] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

Congxian Qiu(klion26) created FLINK-14264: - Summary: Expose CheckpointBackend in checkpoint config RestAPI Key: FLINK-14264 URL: https://issues.apache.org/jira/browse/FLINK-14264 Project:

[GitHub] [flink] flinkbot commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

flinkbot commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536149907 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] TisonKun opened a new pull request #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

TisonKun opened a new pull request #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792 ## What is the purpose of the change Extract static method from `ClusterClient` to `ClientUtils`. -

[jira] [Updated] (FLINK-14263) Extract static method from ClusterClient to ClientUtils

[ https://issues.apache.org/jira/browse/FLINK-14263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14263: --- Labels: pull-request-available (was: ) > Extract static method from ClusterClient to

[jira] [Created] (FLINK-14263) Extract static method from ClusterClient to ClientUtils

Zili Chen created FLINK-14263: - Summary: Extract static method from ClusterClient to ClientUtils Key: FLINK-14263 URL: https://issues.apache.org/jira/browse/FLINK-14263 Project: Flink Issue

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329293256 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[jira] [Closed] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

[ https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-14195. --- > Nightly connectors-jdk11 fails because of missing jaxb classes >

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : SUCCESS

[jira] [Commented] (FLINK-14261) Add support for permanently fenced RpcEndpoints

[ https://issues.apache.org/jira/browse/FLINK-14261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939723#comment-16939723 ] Zili Chen commented on FLINK-14261: --- Permanently Fenced RpcEndpoint could be a good intermediate

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : PENDING

[GitHub] [flink] TisonKun commented on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices

TisonKun commented on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-536072001 From FLINK-14259 I guess it is towards a testable codebase but I still cannot get the point without a

[GitHub] [flink] TisonKun commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

TisonKun commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-536066780 The corresponding JIRA is FLINK-14252 instead of FLINK-14525 :P

[GitHub] [flink] TisonKun commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

TisonKun commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-53605 @flinkbot run travis This is an automated message

[jira] [Commented] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container

[ https://issues.apache.org/jira/browse/FLINK-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939711#comment-16939711 ] Zili Chen commented on FLINK-14252: --- Make sense to me. A more general issue related is that we can

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939689#comment-16939689 ] Stephan Ewen commented on FLINK-13808: -- Thank you [~klion26] for the debugging and the suggestion

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939683#comment-16939683 ] Stephan Ewen commented on FLINK-13808: -- [~Caesar] yes, each checkpoint spawns per task a background

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939671#comment-16939671 ] Zili Chen commented on FLINK-13992: --- Thanks for your review [~azagrebin]! master via

[jira] [Closed] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-13992. - Resolution: Fixed > Refactor Optional parameter in InputGateWithMetrics#updateMetrics >

[GitHub] [flink] TisonKun merged pull request #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

TisonKun merged pull request #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684 This is an automated message from the Apache

[jira] [Created] (FLINK-14262) support referencing function with fully/partially qualified names in SQL

Bowen Li created FLINK-14262: Summary: support referencing function with fully/partially qualified names in SQL Key: FLINK-14262 URL: https://issues.apache.org/jira/browse/FLINK-14262 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790#issuecomment-535998099 ## CI report: * f1bcc25d3af40fc482018fb8459bd8b942b15f68 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface

flinkbot edited a comment on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#issuecomment-535997974 ## CI report: * f0ef95eb93dd1becb31008367bb1b724f834fe25 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789#issuecomment-535998019 ## CI report: * 8e00c88ee19da724ffd4dcf0a6bfea732141d2e9 : SUCCESS

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r329163486 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r329161780 ## File path: docs/_includes/generated/yarn_config_configuration.html

[GitHub] [flink] HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-536014545 @bowenli86 Thanks for pointing it out for more it test. I will create a CatalogFunctionITCase to test the function operations.

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r329159775 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

flinkbot edited a comment on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790#issuecomment-535998099 ## CI report: * f1bcc25d3af40fc482018fb8459bd8b942b15f68 : PENDING

[GitHub] [flink] flinkbot commented on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

flinkbot commented on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-536005650 ## CI report: * 757ae54b3f31a82334fae36d6e714c6aa9ac6581 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789#issuecomment-535998019 ## CI report: * 8e00c88ee19da724ffd4dcf0a6bfea732141d2e9 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface

flinkbot edited a comment on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#issuecomment-535997974 ## CI report: * f0ef95eb93dd1becb31008367bb1b724f834fe25 : PENDING

[GitHub] [flink] flinkbot commented on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

flinkbot commented on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789#issuecomment-535998019 ## CI report: * 8e00c88ee19da724ffd4dcf0a6bfea732141d2e9 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface

flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#issuecomment-535997974 ## CI report: * f0ef95eb93dd1becb31008367bb1b724f834fe25 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

flinkbot commented on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790#issuecomment-535998099 ## CI report: * f1bcc25d3af40fc482018fb8459bd8b942b15f68 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

flinkbot commented on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790#issuecomment-535995691 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] [flink] flinkbot commented on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

flinkbot commented on issue #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791#issuecomment-535995676 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-14248) LazyFromSourcesSchedulingStrategy should be able to restart terminated tasks

[ https://issues.apache.org/jira/browse/FLINK-14248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14248: --- Labels: pull-request-available (was: ) > LazyFromSourcesSchedulingStrategy should be able

[GitHub] [flink] zhuzhurk opened a new pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks

zhuzhurk opened a new pull request #9791: [FLINK-14248][runtime] Let LazyFromSourcesSchedulingStrategy restart terminated tasks URL: https://github.com/apache/flink/pull/9791 ## What is the purpose of the change LazyFromSourcesSchedulingStrategy now will only schedule tasks in

[jira] [Updated] (FLINK-14261) Add support for permanently fenced RpcEndpoints

[ https://issues.apache.org/jira/browse/FLINK-14261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14261: --- Labels: pull-request-available (was: ) > Add support for permanently fenced RpcEndpoints >

[GitHub] [flink] tillrohrmann opened a new pull request #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

tillrohrmann opened a new pull request #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790 ## What is the purpose of the change This PR is based on #9789. This PR adds `PermanentlyFencedRpcEndpoint` which requires a non-null

[jira] [Created] (FLINK-14261) Add support for permanently fenced RpcEndpoints

Till Rohrmann created FLINK-14261: - Summary: Add support for permanently fenced RpcEndpoints Key: FLINK-14261 URL: https://issues.apache.org/jira/browse/FLINK-14261 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

flinkbot commented on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789#issuecomment-535993137 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-14260) Remove Mockito usage from TestingJobManagerRunnerFactory

[ https://issues.apache.org/jira/browse/FLINK-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14260: --- Labels: pull-request-available (was: ) > Remove Mockito usage from

[GitHub] [flink] tillrohrmann opened a new pull request #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

tillrohrmann opened a new pull request #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789 ## What is the purpose of the change This PR is based on #9788. The PR removes the Mockito usage from

[jira] [Closed] (FLINK-13386) Frictions in the new default Web Frontend

[ https://issues.apache.org/jira/browse/FLINK-13386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13386. Resolution: Fixed Implemented in master: dbe883c57e689ed544de09423192843c758bfa54 -

[jira] [Created] (FLINK-14260) Remove Mockito usage from TestingJobManagerRunnerFactory

Till Rohrmann created FLINK-14260: - Summary: Remove Mockito usage from TestingJobManagerRunnerFactory Key: FLINK-14260 URL: https://issues.apache.org/jira/browse/FLINK-14260 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface

flinkbot commented on issue #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#issuecomment-535990059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535968595 ## CI report: * 426cd9dc6c60f5582848fa52f2fa5f76182c8125 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : FAILURE

[jira] [Updated] (FLINK-14259) Extract JobManagerRunner interface for improved testability

[ https://issues.apache.org/jira/browse/FLINK-14259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14259: --- Labels: pull-request-available (was: ) > Extract JobManagerRunner interface for improved

[GitHub] [flink] tillrohrmann opened a new pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

tillrohrmann opened a new pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788 ## What is the purpose of the change This PR is based on #9787. This commit extracts the JobManagerRunner interface and renames the

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[jira] [Created] (FLINK-14259) Extract JobManagerRunner interface for improved testability

Till Rohrmann created FLINK-14259: - Summary: Extract JobManagerRunner interface for improved testability Key: FLINK-14259 URL: https://issues.apache.org/jira/browse/FLINK-14259 Project: Flink

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939533#comment-16939533 ] Alex commented on FLINK-14224: -- [~trohrmann], I want to look into those issues. My suspect may be the

[jira] [Updated] (FLINK-10745) Serialization and copy improvements for record writer

[ https://issues.apache.org/jira/browse/FLINK-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10745: - Component/s: Runtime / Task > Serialization and copy improvements for record writer >

[jira] [Resolved] (FLINK-10745) Serialization and copy improvements for record writer

[ https://issues.apache.org/jira/browse/FLINK-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-10745. -- Resolution: Fixed > Serialization and copy improvements for record writer >

[jira] [Resolved] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-10995. -- Resolution: Fixed Merged in master : 7f2382a532ab72e6ead12945eb2395e6af829eb5 > Copy intermediate

[GitHub] [flink] flinkbot commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices

flinkbot commented on issue #9787: [FLINK-14525] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535968595 ## CI report: * 426cd9dc6c60f5582848fa52f2fa5f76182c8125 : PENDING

[GitHub] [flink] dawidwys merged pull request #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend

dawidwys merged pull request #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend URL: https://github.com/apache/flink/pull/9247 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] dawidwys commented on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend

dawidwys commented on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend URL: https://github.com/apache/flink/pull/9247#issuecomment-535981017 I verified the ui and it looks good... merging. This

[GitHub] [flink] zhijiangW merged pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

zhijiangW merged pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[jira] [Updated] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhilasha Seth updated FLINK-14175: --- Affects Version/s: 1.7.3 1.6.5 > Upgrade KPL version in

[jira] [Created] (FLINK-14258) Integrate hive to FileSystemTableFactory

Jingsong Lee created FLINK-14258: Summary: Integrate hive to FileSystemTableFactory Key: FLINK-14258 URL: https://issues.apache.org/jira/browse/FLINK-14258 Project: Flink Issue Type:

[jira] [Created] (FLINK-14257) Integrate csv to FileSystemTableFactory

Jingsong Lee created FLINK-14257: Summary: Integrate csv to FileSystemTableFactory Key: FLINK-14257 URL: https://issues.apache.org/jira/browse/FLINK-14257 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14256) Introduce FileSystemTableFactory

Jingsong Lee created FLINK-14256: Summary: Introduce FileSystemTableFactory Key: FLINK-14256 URL: https://issues.apache.org/jira/browse/FLINK-14256 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Description: Introduce BatchFileSystemSink to support all table file system connector with

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14254: - Summary: Introduce BatchFileSystemSink (was: Introduce FileSystemOutputFormat) > Introduce

[jira] [Created] (FLINK-14255) Introduce StreamingFileSystemSink

Jingsong Lee created FLINK-14255: Summary: Introduce StreamingFileSystemSink Key: FLINK-14255 URL: https://issues.apache.org/jira/browse/FLINK-14255 Project: Flink Issue Type: Sub-task

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328977911 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328978082 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328964109 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329106466 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

becketqin commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r329113614 ## File path:

  1   2   3   4   5   >