[GitHub] [flink] xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281066379 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281065645 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281065647 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

xuefuz commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281065464 ## File path:

[jira] [Commented] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833528#comment-16833528 ] Jark Wu commented on FLINK-12348: - Yes, I totally agree with your points [~hequn8128] > Use TableConfig

[GitHub] [flink] Leeviiii opened a new pull request #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations

Leev opened a new pull request #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations URL: https://github.com/apache/flink/pull/8344 ## What is the purpose of the change *Allow @TypeInfo annotation on POJO field

[jira] [Updated] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12141: --- Labels: pull-request-available starter (was: starter) > Allow @TypeInfo annotation on POJO

[GitHub] [flink] Leeviiii closed pull request #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations

Leev closed pull request #8344: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations URL: https://github.com/apache/flink/pull/8344 This is an automated message from the

[GitHub] [flink] Leeviiii commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

Leev commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#issuecomment-489497303 > @Leev thanks for addressing the comments, LGTM now. Thanks for your review .

[GitHub] [flink] shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281059574 ## File path:

[jira] [Commented] (FLINK-12404) Translate the "Register a custom serializer for your Flink program" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833523#comment-16833523 ] YangFei commented on FLINK-12404: - [~jark] can you review this issue ? thanks > Translate the "Register

[GitHub] [flink] flinkbot commented on issue #8348: [FLINK-12404] [docs-zh] Translate the "Register a custom serializer f…

flinkbot commented on issue #8348: [FLINK-12404] [docs-zh] Translate the "Register a custom serializer f… URL: https://github.com/apache/flink/pull/8348#issuecomment-489496900 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281059488 ## File path:

[GitHub] [flink] Leeviiii opened a new pull request #8348: [FLINK-12404] [docs-zh] Translate the "Register a custom serializer f…

Leev opened a new pull request #8348: [FLINK-12404] [docs-zh] Translate the "Register a custom serializer f… URL: https://github.com/apache/flink/pull/8348 …or your Flink program" page into Chinese ## What is the purpose of the change *This pull request completes the

[GitHub] [flink] shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281059477 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281059332 ## File path:

[GitHub] [flink] shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281059348 ## File path:

[GitHub] [flink] zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8310#issuecomment-489495824 Thanks for further reviews @azagrebin My previous understanding of

[jira] [Created] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

Chethan U created FLINK-12410: - Summary: KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields Key: FLINK-12410 URL: https://issues.apache.org/jira/browse/FLINK-12410

[GitHub] [flink] Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281057098 ## File path:

[jira] [Created] (FLINK-12409) Adds from_elements in TableEnvironment

Dian Fu created FLINK-12409: --- Summary: Adds from_elements in TableEnvironment Key: FLINK-12409 URL: https://issues.apache.org/jira/browse/FLINK-12409 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12408) Support to define all kinds of types in Python API

Dian Fu created FLINK-12408: --- Summary: Support to define all kinds of types in Python API Key: FLINK-12408 URL: https://issues.apache.org/jira/browse/FLINK-12408 Project: Flink Issue Type:

[GitHub] [flink] Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281054990 ## File path:

[GitHub] [flink] Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281054990 ## File path:

[GitHub] [flink] Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281054851 ## File path:

[GitHub] [flink] Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

Ryantaocer commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281053691 ## File path:

[jira] [Commented] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

[ https://issues.apache.org/jira/browse/FLINK-12348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833507#comment-16833507 ] Hequn Cheng commented on FLINK-12348: - Hi [~jark], thanks for the detailed description and

[GitHub] [flink] klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

klion26 commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#issuecomment-489487389 @wuchong thanks for the review and advice. This is an

[GitHub] [flink] wsry commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

wsry commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281051963 ## File path:

[GitHub] [flink] dianfu opened a new pull request #8347: [FLINK-12326][python] Add basic test framework for python api

dianfu opened a new pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347 ## What is the purpose of the change *This pull request adds the basic test framework for python api just like the existing

[jira] [Updated] (FLINK-12326) Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase.

[ https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12326: --- Labels: pull-request-available (was: ) > Add a basic test framework, just like the

[GitHub] [flink] flinkbot commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api

flinkbot commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#issuecomment-489486437 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] shaoxuan-wang commented on issue #7446: Added Model serving - implementation of the Flip -23.

shaoxuan-wang commented on issue #7446: Added Model serving - implementation of the Flip -23. URL: https://github.com/apache/flink/pull/7446#issuecomment-489486186 Hi @blublinsky, thanks for the contribution. As we talked offline, I have observed there are at least three issues of this PR

[jira] [Closed] (FLINK-11633) Translate "Working with State" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11633. --- Resolution: Fixed Fix Version/s: 1.9.0 Resolved in 1.9.0: 906d593ae21c98e335e0a078fe37d6d295e6f993

[GitHub] [flink] asfgit closed pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

asfgit closed pull request #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wuchong commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese

wuchong commented on issue #8341: [FLINK-11633][docs-zh] Translate "Working with state" into Chinese URL: https://github.com/apache/flink/pull/8341#issuecomment-489485181 Merged. This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on issue #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

flinkbot commented on issue #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346#issuecomment-489484986 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-12405) Introduce BLOCKING_PERSISTENT result partition type

[ https://issues.apache.org/jira/browse/FLINK-12405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12405: --- Labels: pull-request-available (was: ) > Introduce BLOCKING_PERSISTENT result partition

[GitHub] [flink] Xpray opened a new pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type

Xpray opened a new pull request #8346: [FLINK-12405] [DataSet] Introduce BLOCKING_PERSISTENT result partition type URL: https://github.com/apache/flink/pull/8346 ## What is the purpose of the change Introducing a new``` ResultPartitionType```, result partition of this type

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

eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229] [runtime] Implement LazyFromSourcesScheduling Strategy URL: https://github.com/apache/flink/pull/8309#discussion_r281049742 ## File path:

[jira] [Assigned] (FLINK-12407) Add all table operators align Java Table API

[ https://issues.apache.org/jira/browse/FLINK-12407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-12407: - Assignee: Wei Zhong > Add all table operators align Java Table API >

[jira] [Created] (FLINK-12407) Add all table operators align Java Table API

sunjincheng created FLINK-12407: --- Summary: Add all table operators align Java Table API Key: FLINK-12407 URL: https://issues.apache.org/jira/browse/FLINK-12407 Project: Flink Issue Type:

[jira] [Closed] (FLINK-12311) Add base python framework and Add Scan, Projection, and Filter operator support

[ https://issues.apache.org/jira/browse/FLINK-12311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12311. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master:

[jira] [Issue Comment Deleted] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12308: Comment: was deleted (was: Fixed in master: a09bd4c6f1dc5d83d6634bad53af6237a9cd4fe5) > Support

[jira] [Reopened] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reopened FLINK-12308: - > Support python language in Flink Table API > -- > >

[jira] [Closed] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12308. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master:

[GitHub] [flink] asfgit closed pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

asfgit closed pull request #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267 This is an automated message from

[GitHub] [flink] sunjincheng121 commented on issue #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support

sunjincheng121 commented on issue #8267: [FLINK-12311][table][python] Add base python framework and Add Scan, Projection, and Filter operator support URL: https://github.com/apache/flink/pull/8267#issuecomment-489480948 @flinkbot approve all Merging...

[GitHub] [flink] KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281043055 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281042908 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs

KurtYoung commented on a change in pull request #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#discussion_r281042990 ## File path:

[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_r281037098 ## File path:

[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_r281037134 ## File path:

[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_r281037098 ## File path:

[GitHub] [flink] GJL commented on issue #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

GJL commented on issue #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#issuecomment-489458134 @shuai-xu Thanks for the update. I will have another look.

[GitHub] [flink] GJL commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

GJL commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r281036419 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

GJL commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r280435403 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it

GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it URL: https://github.com/apache/flink/pull/8318#discussion_r281035837 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it

GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it URL: https://github.com/apache/flink/pull/8318#discussion_r281035777 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it

GJL commented on a change in pull request #8318: [FLINK-12231][runtime] Introduce Scheduler interface and adapt ExecutionGraph to it URL: https://github.com/apache/flink/pull/8318#discussion_r281035739 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8314: [FLINK-12365][table] Add stats related catalog APIs

bowenli86 commented on issue #8314: [FLINK-12365][table] Add stats related catalog APIs URL: https://github.com/apache/flink/pull/8314#issuecomment-489442410 @flinkbot attention @KurtYoung This is an automated message from

[GitHub] [flink] bowenli86 commented on issue #8337: [FLINK-12232][hive] Create HiveCatalog and support database related operations in HiveCatalog

bowenli86 commented on issue #8337: [FLINK-12232][hive] Create HiveCatalog and support database related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8337#issuecomment-489442361 @flinkbot attention @KurtYoung

[GitHub] [flink] bowenli86 commented on issue #8329: [FLINK-12239][hive] Support table related operations in GenericHiveMetastoreCatalog

bowenli86 commented on issue #8329: [FLINK-12239][hive] Support table related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8329#issuecomment-489442352 @flinkbot attention @KurtYoung

[GitHub] [flink] klion26 commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese

klion26 commented on issue #8319: [FLINK-11636] [docs-zh] Translate "State Schema Evolution" into Chinese URL: https://github.com/apache/flink/pull/8319#issuecomment-489428851 @Leev thanks for addressing the comments, LGTM now.

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281020930 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021249 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021219 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021772 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021281 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021760 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021507 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022513 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022503 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281020771 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021244 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021262 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021226 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021752 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022499 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021967 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021825 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021776 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021766 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022518 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022717 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022682 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022507 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021272 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022522 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022646 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022759 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021000 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022574 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021266 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022356 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022189 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021238 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021234 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281022808 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on a change in pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#discussion_r281021830 ## File path:

  1   2   3   >