[GitHub] [flink] dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297037608 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferen

[GitHub] [flink] dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297053444 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferen

[GitHub] [flink] flinkbot commented on issue #8870: [FLINK-12974][checkstyle] Dump checkstyle to 8.14

flinkbot commented on issue #8870: [FLINK-12974][checkstyle] Dump checkstyle to 8.14 URL: https://github.com/apache/flink/pull/8870#issuecomment-505359567 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] dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297032591 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferen

[GitHub] [flink] dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297033180 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferen

[GitHub] [flink] dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

dawidwys commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297029225 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferen

[GitHub] [flink] ifndef-SleePy opened a new pull request #8870: [FLINK-12974][checkstyle] Dump checkstyle to 8.14

ifndef-SleePy opened a new pull request #8870: [FLINK-12974][checkstyle] Dump checkstyle to 8.14 URL: https://github.com/apache/flink/pull/8870 ## What is the purpose of the change * Bump checkstyle to 8.14 since 8.12 is no longer supported ## Brief change log * Update

[jira] [Updated] (FLINK-12974) Bump checkstyle version to 8.14

[ https://issues.apache.org/jira/browse/FLINK-12974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12974: --- Labels: pull-request-available (was: ) > Bump checkstyle version to 8.14 >

[GitHub] [flink] flinkbot edited a comment on issue #8825: [hotfix][python][docs] Fix python doc nav bar not showing issue.

flinkbot edited a comment on issue #8825: [hotfix][python][docs] Fix python doc nav bar not showing issue. URL: https://github.com/apache/flink/pull/8825#issuecomment-504400865 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[GitHub] [flink] sunjincheng121 commented on issue #8825: [hotfix][python][docs] Fix python doc nav bar not showing issue.

sunjincheng121 commented on issue #8825: [hotfix][python][docs] Fix python doc nav bar not showing issue. URL: https://github.com/apache/flink/pull/8825#issuecomment-505357983 Thanks for the update! @WeiZhong94 👍 LGTM. +1 to merged. @flinkbot approve all Best, Jincheng --

[GitHub] [flink] flinkbot commented on issue #8869: [FLINK-12975][table-planner-blink] UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

flinkbot commented on issue #8869: [FLINK-12975][table-planner-blink] UserDefinedFunctionUtils should distinguish overload any parameters methods in blink URL: https://github.com/apache/flink/pull/8869#issuecomment-505357074 Thanks a lot for your contribution to the Apache Flink project. I

[jira] [Created] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

vinoyang created FLINK-12976: Summary: Bump Kafka client version to 2.3.0 for universal Kafka connector Key: FLINK-12976 URL: https://issues.apache.org/jira/browse/FLINK-12976 Project: Flink Iss

[jira] [Updated] (FLINK-12975) UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297082648 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] JingsongLi opened a new pull request #8869: [FLINK-12975][table-planner-blink] UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

JingsongLi opened a new pull request #8869: [FLINK-12975][table-planner-blink] UserDefinedFunctionUtils should distinguish overload any parameters methods in blink URL: https://github.com/apache/flink/pull/8869 ## What is the purpose of the change If user has a function overload

[jira] [Created] (FLINK-12975) UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

Jingsong Lee created FLINK-12975: Summary: UserDefinedFunctionUtils should distinguish overload any parameters methods in blink Key: FLINK-12975 URL: https://issues.apache.org/jira/browse/FLINK-12975

[jira] [Updated] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

[ https://issues.apache.org/jira/browse/FLINK-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-12972: - Issue Type: Bug (was: New Feature) > Ensure calling open/close in join condition of generated f

[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on issue #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-505354858 Hi, @zhijiangW I have solve the conflicts and generate the html, could you

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297080370 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[jira] [Closed] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

[ https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-9375. --- Resolution: Duplicate > Introduce AbortCheckpoint message from JM to TMs > --

[jira] [Created] (FLINK-12974) Bump checkstyle version to 8.14

Biao Liu created FLINK-12974: Summary: Bump checkstyle version to 8.14 Key: FLINK-12974 URL: https://issues.apache.org/jira/browse/FLINK-12974 Project: Flink Issue Type: Improvement Com

[jira] [Assigned] (FLINK-9347) BlobServerConnection throws misleading exception for empty files

[ https://issues.apache.org/jira/browse/FLINK-9347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9347: --- Assignee: (was: vinoyang) > BlobServerConnection throws misleading exception for empty files > -

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297079565 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[jira] [Resolved] (FLINK-12925) Docker embedded job end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-12925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex resolved FLINK-12925. -- Resolution: Fixed Should be fixed with commit {{58c0cbc194ee673c4eef93cade63e992dd6ff089}} ( https://github.c

[GitHub] [flink] pnowojski merged pull request #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788

pnowojski merged pull request #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788 URL: https://github.com/apache/flink/pull/8828 This is an automated

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297075773 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] godfreyhe commented on issue #8782: [FLINK-12888] [table-planner-blink] Introduce planner rule to push filter into TableSource

godfreyhe commented on issue #8782: [FLINK-12888] [table-planner-blink] Introduce planner rule to push filter into TableSource URL: https://github.com/apache/flink/pull/8782#issuecomment-505351449 @KurtYoung, @JingsongLi, i have updated this pr based on comments. do you have any other sug

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297075773 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297075773 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297075297 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297045851 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297052555 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297073638 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297050710 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297046584 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297058667 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297047332 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297062263 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297042815 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297044632 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297051600 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297054244 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297043212 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297044835 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297056466 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297057241 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297057725 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297070471 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r296618511 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[GitHub] [flink] klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

klion26 commented on a change in pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese URL: https://github.com/apache/flink/pull/8622#discussion_r297060963 ## File path: docs/internals/task_lifecycle.zh.md ## @@ -23,172 +23,97 @@ specific

[jira] [Created] (FLINK-12973) Support reading Hive complex types like array and map

zjuwangg created FLINK-12973: Summary: Support reading Hive complex types like array and map Key: FLINK-12973 URL: https://issues.apache.org/jira/browse/FLINK-12973 Project: Flink Issue Type: Sub

[GitHub] [flink] flinkbot commented on issue #8868: [FLINK-12972][table-planner-blink] Ensure calling open/close in join condition of generated functions for blink

flinkbot commented on issue #8868: [FLINK-12972][table-planner-blink] Ensure calling open/close in join condition of generated functions for blink URL: https://github.com/apache/flink/pull/8868#issuecomment-505348849 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297072524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297072524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297072524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[jira] [Updated] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

[ https://issues.apache.org/jira/browse/FLINK-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12972: --- Labels: pull-request-available (was: ) > Ensure calling open/close in join condition of gen

[GitHub] [flink] JingsongLi opened a new pull request #8868: [FLINK-12972][table-planner-blink] Ensure calling open/close in join condition of generated functions for blink

JingsongLi opened a new pull request #8868: [FLINK-12972][table-planner-blink] Ensure calling open/close in join condition of generated functions for blink URL: https://github.com/apache/flink/pull/8868 ## What is the purpose of the change Generated functions' open method are not

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297072524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[jira] [Created] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

Jingsong Lee created FLINK-12972: Summary: Ensure calling open/close in join condition of generated functions for blink Key: FLINK-12972 URL: https://issues.apache.org/jira/browse/FLINK-12972 Project:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297071613 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297070028 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297065948 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/

[jira] [Assigned] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9732: --- Assignee: (was: vinoyang) > Report more detailed error message on JobSubmissionFailure > ---

[jira] [Assigned] (FLINK-9805) HTTP Redirect to Active JM in Flink CLI

[ https://issues.apache.org/jira/browse/FLINK-9805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9805: --- Assignee: (was: vinoyang) > HTTP Redirect to Active JM in Flink CLI > --

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297063545 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/

[GitHub] [flink] pnowojski commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297061142 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zentol merged pull request #8855: [DOC]update description for Key `taskmanager.memory.preallocate `

zentol merged pull request #8855: [DOC]update description for Key `taskmanager.memory.preallocate ` URL: https://github.com/apache/flink/pull/8855 This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297060553 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297050717 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297055710 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297055318 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r296994653 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297052076 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297052204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297052169 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297051981 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[jira] [Closed] (FLINK-12890) Add partition lifecycle related Shuffle API

[ https://issues.apache.org/jira/browse/FLINK-12890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12890. Resolution: Fixed master: 3d7fa8841882c3cfa3a1a6ebb08b480fd2059471 fb8ce3eadcbde57502de481

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297050717 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] zentol merged pull request #8789: [FLINK-12890] Add partition lifecycle related Shuffle API

zentol merged pull request #8789: [FLINK-12890] Add partition lifecycle related Shuffle API URL: https://github.com/apache/flink/pull/8789 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297048665 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] HuangZhenQiu commented on issue #8064: [FLINK-7244] Add parquet table source

HuangZhenQiu commented on issue #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#issuecomment-505328223 @fhueske I resolve all of the comments, except the last one. Not sure why "the pushed down predicates should be removed from exps.

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297047975 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

gaoyunhaii commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297043448 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

gaoyunhaii commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297043227 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297042878 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297042825 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297041796 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution

[jira] [Created] (FLINK-12971) Remove the constraint that lookup join needs a primary key or index key

Jark Wu created FLINK-12971: --- Summary: Remove the constraint that lookup join needs a primary key or index key Key: FLINK-12971 URL: https://issues.apache.org/jira/browse/FLINK-12971 Project: Flink

[jira] [Assigned] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

[ https://issues.apache.org/jira/browse/FLINK-7624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7624: --- Assignee: (was: vinoyang) > Add kafka-topic for "KafkaProducer" metrics > --

[jira] [Assigned] (FLINK-7550) Give names to REST client/server for clearer logging.

[ https://issues.apache.org/jira/browse/FLINK-7550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7550: --- Assignee: (was: vinoyang) > Give names to REST client/server for clearer logging. >

[jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872103#comment-16872103 ] vinoyang commented on FLINK-12953: -- [~chadrik] I know the pain for viewing TaskManager

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297040651 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297040651 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297040365 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.

[GitHub] [flink] shuai-xu commented on issue #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter

shuai-xu commented on issue #8688: [FLINK-12760] [runtime] Implement ExecutionGraph to InputsLocationsRetriever Adapter URL: https://github.com/apache/flink/pull/8688#issuecomment-505320340 @GJL ， It seems the failure of tests is due to the travis system, not by the code.

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297039878 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.

[GitHub] [flink] flinkbot commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC

flinkbot commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC URL: https://github.com/apache/flink/pull/8867#issuecomment-505317704 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[jira] [Updated] (FLINK-12956) Add a upsert table sink for JDBC

[ https://issues.apache.org/jira/browse/FLINK-12956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12956: --- Labels: pull-request-available (was: ) > Add a upsert table sink for JDBC > ---

[GitHub] [flink] JingsongLi opened a new pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC

JingsongLi opened a new pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC URL: https://github.com/apache/flink/pull/8867 ## What is the purpose of the change Now we just support append JDBC sink, this is very limited. Consider a simple wordCount, we ne

[jira] [Closed] (FLINK-12904) Remove TableSource#getTableStats() interface

[ https://issues.apache.org/jira/browse/FLINK-12904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12904. --- Resolution: Fixed Fixed in 1.9.0: bf55c547655006be2c03dd1afa1f7db6dda6c0f4 > Remove TableSource#getTableSta

<    1   2   3   4   5   6   >