[GitHub] [flink] AHeise commented on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction

AHeise commented on issue #9385: [FLINK-13635][datastream] Avoid unexpected interruption of AsyncFunction URL: https://github.com/apache/flink/pull/9385#issuecomment-533432744 Hi @ifndef-SleePy , I just stumbled upon this PR (it's assigned to the wrong component). The issue th

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326482996 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SubmissionTrackingTask

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326485570 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/Ne

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326489325 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326484256 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SubmissionTrackingTask

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326487486 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/Failover

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326483593 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SubmissionTrackingTask

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934108#comment-16934108 ] Wei Zhong commented on FLINK-14019: --- Hi [~sunjincheng121], [~hequn8128] and [~dian.fu]

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934106#comment-16934106 ] Wei Zhong commented on FLINK-14019: --- Hi [~sunjincheng121], [~hequn8128] and [~dian.fu]

[jira] [Issue Comment Deleted] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-14019: -- Comment: was deleted (was: Hi [~sunjincheng121], [~hequn8128] and [~dian.fu], I have finished the wri

[GitHub] [flink] flinkbot edited a comment on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

flinkbot edited a comment on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#issuecomment-533419662 ## CI report: * 7c3eef29f2f40406bdd24f9c78889f5a68853308 : PENDING [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] TisonKun commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

TisonKun commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#discussion_r326481883 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/Res

[GitHub] [flink] flinkbot commented on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

flinkbot commented on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#issuecomment-533419662 ## CI report: * 7c3eef29f2f40406bdd24f9c78889f5a68853308 : UNKNOWN --

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326479552 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/c

[GitHub] [flink] zhuzhurk commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

zhuzhurk commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#discussion_r326478660 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/Res

[GitHub] [flink] zhuzhurk commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

zhuzhurk commented on a change in pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#discussion_r326478660 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/Res

[GitHub] [flink] flinkbot commented on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

flinkbot commented on issue #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723#issuecomment-533414803 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[jira] [Updated] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14114: --- Labels: pull-request-available (was: ) > Shift down ClusterClient#timeout to RestClusterCli

[GitHub] [flink] zhuzhurk opened a new pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient

zhuzhurk opened a new pull request #9723: [FLINK-14114] [client] Shift down ClusterClient#timeout to RestClusterClient URL: https://github.com/apache/flink/pull/9723 ## What is the purpose of the change *ClusterClient#timeout is only used in RestClusterClient. Shifting it down t

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-533404154 > Thanks for the contribution @xuyang1706 . I took a quick look and I think there are some confusions I have wit

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r326469340 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r326469205 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r326469171 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r326468259 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r326468211 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326465346 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/c

[jira] [Created] (FLINK-14138) Show Pending Slots in Job Detail

Yadong Xie created FLINK-14138: -- Summary: Show Pending Slots in Job Detail Key: FLINK-14138 URL: https://issues.apache.org/jira/browse/FLINK-14138 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration

flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration URL: https://github.com/apache/flink/pull/9722#issuecomment-533180619 ## CI report: * 29da7100a0af920b19723543fe4517dd0d95681e : SUCCESS [Build](

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326460965 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[jira] [Created] (FLINK-14137) Show Attempt History in Vertex SubTask

Yadong Xie created FLINK-14137: -- Summary: Show Attempt History in Vertex SubTask Key: FLINK-14137 URL: https://issues.apache.org/jira/browse/FLINK-14137 Project: Flink Issue Type: Improvement

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326459821 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[GitHub] [flink] liyafan82 closed pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism

liyafan82 closed pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism URL: https://github.com/apache/flink/pull/8934 This is an au

[GitHub] [flink] liyafan82 commented on issue #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism

liyafan82 commented on issue #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism URL: https://github.com/apache/flink/pull/8934#issuecomment-533390260 > @liyafan82 > I rebased the PR on the latest master an

[GitHub] [flink] lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326459475 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/c

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326457315 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/c

[GitHub] [flink] flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration

flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration URL: https://github.com/apache/flink/pull/9722#issuecomment-533180619 ## CI report: * 29da7100a0af920b19723543fe4517dd0d95681e : SUCCESS [Build](

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[jira] [Comment Edited] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933969#comment-16933969 ] Yadong Xie edited comment on FLINK-11374 at 9/20/19 2:58 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration

flinkbot edited a comment on issue #9722: [FLINK-14128] [runtime] Remove the description of customized restart strategy configuration URL: https://github.com/apache/flink/pull/9722#issuecomment-533180619 ## CI report: * 29da7100a0af920b19723543fe4517dd0d95681e : SUCCESS [Build](

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933969#comment-16933969 ] Yadong Xie commented on FLINK-11374: Hi [~trohrmann], I just check the flink codes(

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326449917 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326448890 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326450435 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[GitHub] [flink] JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326450474 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/con

[jira] [Created] (FLINK-14136) Operator Topology and Metrics Inside Vertex

Yadong Xie created FLINK-14136: -- Summary: Operator Topology and Metrics Inside Vertex Key: FLINK-14136 URL: https://issues.apache.org/jira/browse/FLINK-14136 Project: Flink Issue Type: Improveme

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[jira] [Created] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime

Jingsong Lee created FLINK-14135: Summary: Introduce vectorized orc InputFormat for blink runtime Key: FLINK-14135 URL: https://issues.apache.org/jira/browse/FLINK-14135 Project: Flink Issue

[GitHub] [flink] zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment

zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-533374806 > subjective Thanks Reply. yes, it is subjective whether a comment is useful or useless. that comment "row interval is not valid for session

[jira] [Updated] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11899: - Parent: FLINK-14133 Issue Type: Sub-task (was: New Feature) > Introduce vectorized parq

[GitHub] [flink] liyafan82 closed pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism

liyafan82 closed pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism URL: https://github.com/apache/flink/pull/8934 This is an au

[GitHub] [flink] liyafan82 opened a new pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism

liyafan82 opened a new pull request #8934: [FLINK-12628][Runtime / Coordination] Check test failure if partitionhas no consumers in Execution.getPartitionMaxParallelism URL: https://github.com/apache/flink/pull/8934 ## What is the purpose of the change Resolve issue FLINK-12

[jira] [Commented] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933940#comment-16933940 ] Congxian Qiu(klion26) commented on FLINK-14110: --- [~aaronlevin] thanks for

[jira] [Created] (FLINK-14134) Introduce LimitableTableSource to optimize limit

Jingsong Lee created FLINK-14134: Summary: Introduce LimitableTableSource to optimize limit Key: FLINK-14134 URL: https://issues.apache.org/jira/browse/FLINK-14134 Project: Flink Issue Type:

[GitHub] [flink] zhangjun888 closed pull request #9645: [FLINK-12584][connectors]Add Bucket File Syetem Table Sink

zhangjun888 closed pull request #9645: [FLINK-12584][connectors]Add Bucket File Syetem Table Sink URL: https://github.com/apache/flink/pull/9645 This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[jira] [Updated] (FLINK-14129) HiveTableSource should implement ProjectableTableSource

[ https://issues.apache.org/jira/browse/FLINK-14129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14129: - Parent: FLINK-14133 Issue Type: Sub-task (was: Improvement) > HiveTableSource should im

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933931#comment-16933931 ] vinoyang commented on FLINK-13025: -- Ping [~aljoscha] and [~trohrmann] for helping. I wa

[jira] [Created] (FLINK-14133) Improve batch sql and hive integrate performance

Jingsong Lee created FLINK-14133: Summary: Improve batch sql and hive integrate performance Key: FLINK-14133 URL: https://issues.apache.org/jira/browse/FLINK-14133 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933924#comment-16933924 ] vinoyang commented on FLINK-13025: -- [~lilyevsky] I will try to build a jar of connector

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933921#comment-16933921 ] Hequn Cheng commented on FLINK-8545: Hi [~enricoc], yes this feature is still be cons

[jira] [Issue Comment Deleted] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-4233: Comment: was deleted (was: Further, if it is assumed that there are never too many contenders, in FLINK-10

[jira] [Commented] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933899#comment-16933899 ] TisonKun commented on FLINK-4233: - Further, if it is assumed that there are never too man

[jira] [Commented] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933879#comment-16933879 ] TisonKun commented on FLINK-4233: - Thanks for picking up this topic! I'm thinking of some

[GitHub] [flink] bowenli86 commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

bowenli86 commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326422275 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/conn

[GitHub] [flink] bowenli86 commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

bowenli86 commented on a change in pull request #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#discussion_r326422275 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/conn

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933807#comment-16933807 ] Enrico Canzonieri commented on FLINK-8545: -- Is this ticket still being considere

[jira] [Updated] (FLINK-14090) Rework FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14090: - Summary: Rework FunctionCatalog (was: FLIP-57 Rework FunctionCatalog) > Rework FunctionCatalog > --

[jira] [Created] (FLINK-14132) Extend core table system with modular plugins

Bowen Li created FLINK-14132: Summary: Extend core table system with modular plugins Key: FLINK-14132 URL: https://issues.apache.org/jira/browse/FLINK-14132 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933794#comment-16933794 ] Leonid Ilyevsky commented on FLINK-13025: - [~yanghua] I saw you wrote the code a

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] pnowojski commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

pnowojski commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-533282433 Nice change. Already visible in the codespeed: http://codes

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819 ## CI report: * 9cfda801891969ac460f45ea639d636b519f22db : FAILURE [Build](https://travis-ci.com/

[jira] [Updated] (FLINK-14107) Kinesis consumer record emitter deadlock under event time alignment

[ https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-14107: - Fix Version/s: 1.8.3 1.9.1 > Kinesis consumer record emitter deadlock under e

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-533209039 > Hi @yxu-valleytider , I still have the fol

[GitHub] [flink] yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

yxu-valleytider edited a comment on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-533209039 > Hi @yxu-valleytider , I still have the fol

[GitHub] [flink] flinkbot edited a comment on issue #9701: [FLINK-14096][client] Merge NewClusterClient into ClusterClient

flinkbot edited a comment on issue #9701: [FLINK-14096][client] Merge NewClusterClient into ClusterClient URL: https://github.com/apache/flink/pull/9701#issuecomment-532200151 ## CI report: * af3e828fe1f134c22c7512565b1a3ba8281c1523 : FAILURE [Build](https://travis-ci.com/flink-

  1   2   3   4   >