[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284994475 ## File path: flink-runtime/src/main/java/org/apache/flink/

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284993808 ## File path: flink-runtime/src/main/java/org/apache/flink/

[GitHub] [flink] zhuzhurk commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation

zhuzhurk commented on a change in pull request #8452: [FLINK-12432][runtime] Add SchedulerNG stub implementation URL: https://github.com/apache/flink/pull/8452#discussion_r284990035 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/SchedulerNGFactoryFact

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-493335619 @tillrohrmann I have updated the codes for the following issues: - Refactor the previous

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-493335619 @tillrohrmann I have updated the codes for the following issues: - Refactor the previous

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-493335619 @tillrohrmann I have updated the codes for the following issues: - Refactor the previous

[GitHub] [flink] zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure

zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the PartitionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-493335619 @tillrohrmann I have updated the codes for the following issues: - Refactor the previous existi

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284989689 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284989549 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284989584 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284989472 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Updated] (FLINK-11560) Translate "Flink Applications" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11560: --- Labels: pull-request-available (was: ) > Translate "Flink Applications" page into Chinese >

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284988260 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284988228 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284988213 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284986678 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284986224 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Commented] (FLINK-5243) Implement an example for BipartiteGraph

[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841927#comment-16841927 ] Ivan Mushketyk commented on FLINK-5243: --- [~jasleenk22] I think a better person to a

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284983143 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[jira] [Closed] (FLINK-12452) alterTable() should ensure existing base table and the new one are of the same type

[ https://issues.apache.org/jira/browse/FLINK-12452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12452. Resolution: Fixed merged in 1.9.0: ba307072011ed2c44f5f4937e12be5da5e6bf805 > alterTable() should ensure

[GitHub] [flink] asfgit closed pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

asfgit closed pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458 This is an automated message fro

[GitHub] [flink] bowenli86 opened a new pull request #8473: prototype to show how to hook function catalog to catalog APIs

bowenli86 opened a new pull request #8473: prototype to show how to hook function catalog to catalog APIs URL: https://github.com/apache/flink/pull/8473 This is a PR to show some simple ideas on how to hook function catalog to catalog APIs. It doesn't compile, and doesn't consider Function

[GitHub] [flink] flinkbot commented on issue #8473: prototype to show how to hook function catalog to catalog APIs

flinkbot commented on issue #8473: prototype to show how to hook function catalog to catalog APIs URL: https://github.com/apache/flink/pull/8473#issuecomment-493316974 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot commented on issue #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

flinkbot commented on issue #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472#issuecomment-493313848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] hxbks2ks opened a new pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

hxbks2ks opened a new pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472 ## What is the purpose of the change *This pull request adds support to submit Python Table API job in CliFronten

[jira] [Updated] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

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

[GitHub] [flink] bowenli86 commented on issue #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on issue #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#issuecomment-493311881 thanks for your review @xuefuz , can you take another look? -

[jira] [Created] (FLINK-12542) Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka test failed

vinoyang created FLINK-12542: Summary: Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka test failed Key: FLINK-12542 URL: https://issues.apache.org/jira/browse/FLINK-12542 Project: Flink I

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284967631 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284965729 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284958896 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284965937 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284968075 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table

[GitHub] [flink] sunhaibotb opened a new pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

sunhaibotb opened a new pull request #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471 ## What is the purpose of the change This pull request releases the buf

[jira] [Updated] (FLINK-12529) Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12529: --- Labels: pull-request-available (was: ) > Release record-deserializer buffers timely to impr

[GitHub] [flink] WeiZhong94 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#issuecomment-493307159 @sunjincheng121 Thanks for your review again! For the documents translating, I have only translated the documentati

[GitHub] [flink] flinkbot commented on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

flinkbot commented on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471#issuecomment-493306637 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284964094 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284962461 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284967422 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284966782 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284962847 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284965519 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284964961 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284959223 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284966895 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284968334 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284966457 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284959627 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/

[GitHub] [flink] lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284967779 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284967316 ## File path: flink-python/pyflink/table/tests/test_table_completeness.py ## @@

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284967409 ## File path: flink-python/pyflink/table/tests/test_environment_completeness.py #

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284967458 ## File path: docs/dev/table/tableApi.zh.md ## @@ -510,6 +510,73 @@ val result =

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284967427 ## File path: docs/dev/table/tableApi.md ## @@ -328,12 +328,12 @@ orders = table

[jira] [Updated] (FLINK-12529) Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-12529: -- Summary: Release record-deserializer buffers timely to improve the efficiency of heap usage on taskman

[jira] [Updated] (FLINK-12529) Release buffers of the record deserializers timely to improve the efficiency of heap memory usage on taskmanager

[ https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-12529: -- Summary: Release buffers of the record deserializers timely to improve the efficiency of heap memory u

[jira] [Assigned] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-12541: --- Assignee: Dian Fu > Add deploy a Python Flink job and session cluster on Kubernetes support. >

[jira] [Created] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

sunjincheng created FLINK-12541: --- Summary: Add deploy a Python Flink job and session cluster on Kubernetes support. Key: FLINK-12541 URL: https://issues.apache.org/jira/browse/FLINK-12541 Project: Flink

[jira] [Commented] (FLINK-5243) Implement an example for BipartiteGraph

[ https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841857#comment-16841857 ] Jasleen Kaur commented on FLINK-5243: - [~ivan.mushketyk] Gentle reminder. Wanted to c

[GitHub] [flink] flinkbot edited a comment on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

flinkbot edited a comment on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#issuecomment-490064489 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] sunjincheng121 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#issuecomment-493294861 @flinkbot approve all This is an automated me

[GitHub] [flink] hequn8128 removed a comment on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API.

hequn8128 removed a comment on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API. URL: https://github.com/apache/flink/pull/8470#issuecomment-493292731 @sunjincheng121 Thanks for fixing the document and improving the docs about result updating. +1 to merg

[GitHub] [flink] hequn8128 commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API.

hequn8128 commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API. URL: https://github.com/apache/flink/pull/8470#issuecomment-493292731 @sunjincheng121 Thanks for fixing the document and improving the docs about result updating. +1 to merge once t

[GitHub] [flink] sunjincheng121 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on issue #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#issuecomment-493290705 LGTM. +1 to merged This is an automated m

[GitHub] [flink] TwitRco commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API.

TwitRco commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API. URL: https://github.com/apache/flink/pull/8470#issuecomment-493288165 Join list This is an automated message from the Apa

[jira] [Created] (FLINK-12540) Kafka011ProducerExactlyOnceITCase#testExactlyOnceCustomOperator

vinoyang created FLINK-12540: Summary: Kafka011ProducerExactlyOnceITCase#testExactlyOnceCustomOperator Key: FLINK-12540 URL: https://issues.apache.org/jira/browse/FLINK-12540 Project: Flink Issu

[GitHub] [flink] flinkbot commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API.

flinkbot commented on issue #8470: [hotfix][table][docs] correct `distinct operator` doc for table API. URL: https://github.com/apache/flink/pull/8470#issuecomment-493284070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] sunjincheng121 opened a new pull request #8470: [hotfix][table][docs] correct `distinct operator` doc for table API.

sunjincheng121 opened a new pull request #8470: [hotfix][table][docs] correct `distinct operator` doc for table API. URL: https://github.com/apache/flink/pull/8470 ## What is the purpose of the change In this JIRA only correct `distinct operator` doc for table API. ## Brief ch

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284941860 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284944545 ## File path: flink-python/pyflink/table/tests/test_environment_completeness.py #

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284944279 ## File path: flink-python/pyflink/table/tests/test_table_completeness.py ##

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284946089 ## File path: docs/dev/table/tableApi.md ## @@ -328,12 +328,12 @@ orders = t

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

sunjincheng121 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284946953 ## File path: docs/dev/table/tableApi.zh.md ## @@ -510,6 +510,73 @@ val resu

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284941860 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] sunjincheng121 commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API

sunjincheng121 commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API URL: https://github.com/apache/flink/pull/8465#issuecomment-493271697 LGTM. will be merged when @zentol say ok This is

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284928417 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284923963 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Ta

[GitHub] [flink] kailashhd commented on a change in pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable

kailashhd commented on a change in pull request #8469: [FLINK-12539][Connectors / FileSystem] StreamingFileSink: Make the class customizable URL: https://github.com/apache/flink/pull/8469#discussion_r284923096 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284900728 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284900728 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284898257 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284898257 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284896109 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

bowenli86 commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284896109 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cat

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284892066 ## File path: flink-connectors/flink-connector

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284882741 ## File path: flink-connectors/flink-connector

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284882741 ## File path: flink-connectors/flink-connector

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284882487 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284883458 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r284808474 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r284601999 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r284883275 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r284881882 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy

GJL commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r284881460 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS

[GitHub] [flink] xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284883858 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284880162 ## File path: flink-connectors/flink-connector-hi

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284872104 ## File path: flink-connectors/flink-connector-hi

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284851441 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284854636 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

[GitHub] [flink] bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

bowenli86 commented on a change in pull request #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#discussion_r284856797 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/tab

  1   2   3   4   5   >