[GitHub] GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka

GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka URL: https://github.com/apache/flink/pull/7173#discussion_r237471496 ## File path: flink-jepsen/docker/test-specs/standalone-session-kafka.edn ## @@ -0,0 +1,23 @@ +;; L

[jira] [Commented] (FLINK-10986) Jepsen: Deploy Kafka Broker on DB Nodes

[ https://issues.apache.org/jira/browse/FLINK-10986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703113#comment-16703113 ] ASF GitHub Bot commented on FLINK-10986: GJL commented on a change in pull reque

[jira] [Created] (FLINK-11028) Disable deployment of flink-fs-tests

Chesnay Schepler created FLINK-11028: Summary: Disable deployment of flink-fs-tests Key: FLINK-11028 URL: https://issues.apache.org/jira/browse/FLINK-11028 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-11029) Incorrect parameter in Working with state doc

Yangze Guo created FLINK-11029: -- Summary: Incorrect parameter in Working with state doc Key: FLINK-11029 URL: https://issues.apache.org/jira/browse/FLINK-11029 Project: Flink Issue Type: Bug

[GitHub] KarmaGYZ opened a new pull request #7198: [FLINK-11029] fixed the Incorrect parameter in Working with state doc

KarmaGYZ opened a new pull request #7198: [FLINK-11029] fixed the Incorrect parameter in Working with state doc URL: https://github.com/apache/flink/pull/7198 ## What is the purpose of the change This pull request correct the parameter of getAggregatingState in the Working with Stat

[jira] [Updated] (FLINK-11029) Incorrect parameter in Working with state doc

[ https://issues.apache.org/jira/browse/FLINK-11029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11029: --- Labels: pull-request-available (was: ) > Incorrect parameter in Working with state doc > --

[jira] [Commented] (FLINK-11029) Incorrect parameter in Working with state doc

[ https://issues.apache.org/jira/browse/FLINK-11029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703137#comment-16703137 ] ASF GitHub Bot commented on FLINK-11029: KarmaGYZ opened a new pull request #719

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237442180 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sq

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237460915 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237434654 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sq

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237468069 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237479598 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237476877 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237436464 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237450352 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sq

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237450569 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sq

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237470829 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237439056 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/match/MatchOperat

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237471737 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237465668 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237464842 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237474378 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237439450 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/match/MatchOperat

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237437779 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/match/MatchOperat

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237441497 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sq

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237436990 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237466297 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237479817 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/MatchCode

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703152#comment-16703152 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703161#comment-16703161 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703169#comment-16703169 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703167#comment-16703167 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703172#comment-16703172 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703157#comment-16703157 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703166#comment-16703166 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703162#comment-16703162 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703165#comment-16703165 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703171#comment-16703171 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703170#comment-16703170 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703168#comment-16703168 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703153#comment-16703153 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703155#comment-16703155 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703160#comment-16703160 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703154#comment-16703154 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703164#comment-16703164 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703159#comment-16703159 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703158#comment-16703158 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703163#comment-16703163 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703156#comment-16703156 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Created] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

Maciej Bryński created FLINK-11030: -- Summary: Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema Key: FLINK-11030 URL: https://issues.apache.org/jira/browse/FLINK-11030 Pro

[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10368: -- Fix Version/s: (was: 1.7.0) 1.7.1 > 'Kerberized YARN on Docker test' un

[GitHub] sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API

sunjincheng121 commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442840488 @twalthr Sounds good! I I totally agree that we have to take this change very carefully. :) Thanks, Jincheng -

[GitHub] sunjincheng121 edited a comment on issue #7167: [FLINK-10973] [table] Add support for map to table API

sunjincheng121 edited a comment on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-442840488 @twalthr Sounds good! I totally agree that we have to take this change very carefully. :) Thanks, Jincheng

[jira] [Commented] (FLINK-10973) Add Map operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703198#comment-16703198 ] ASF GitHub Bot commented on FLINK-10973: sunjincheng121 edited a comment on issu

[jira] [Commented] (FLINK-10973) Add Map operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703197#comment-16703197 ] ASF GitHub Bot commented on FLINK-10973: sunjincheng121 commented on issue #7167

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237488275 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237485540 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237486274 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237484391 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237491268 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237491775 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237485908 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237493263 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -211,6 +211,66 @@ If a c

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703203#comment-16703203 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703201#comment-16703201 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703204#comment-16703204 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703199#comment-16703199 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703205#comment-16703205 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703206#comment-16703206 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE

twalthr commented on a change in pull request #7177: [FLINK-7599] [table] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177#discussion_r237494549 ## File path: flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/validate/SqlValida

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703209#comment-16703209 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703200#comment-16703200 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703202#comment-16703202 ] ASF GitHub Bot commented on FLINK-7599: --- twalthr commented on a change in pull requ

[GitHub] zhijiangW opened a new pull request #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel

zhijiangW opened a new pull request #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel URL: https://github.com/apache/flink/pull/7199 ## What is the purpose of the change *In `ChannelSelector#selectChannels`, it would return an array for

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703231#comment-16703231 ] ASF GitHub Bot commented on FLINK-10662: zhijiangW opened a new pull request #71

[jira] [Updated] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

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

[GitHub] zhijiangW commented on issue #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel

zhijiangW commented on issue #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel URL: https://github.com/apache/flink/pull/7199#issuecomment-442849534 cc @pnowojski :) This is an a

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703232#comment-16703232 ] ASF GitHub Bot commented on FLINK-10662: zhijiangW commented on issue #7199: [FL

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237500242 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237505985 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237484681 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237490138 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237495768 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237507423 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237506741 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runti

[GitHub] pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

pnowojski commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237478157 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runti

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703256#comment-16703256 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703257#comment-16703257 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703258#comment-16703258 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703261#comment-16703261 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703259#comment-16703259 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703255#comment-16703255 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703260#comment-16703260 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509459 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703272#comment-16703272 ] ASF GitHub Bot commented on FLINK-10583: kl0u commented on a change in pull requ

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509724 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[GitHub] kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on a change in pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#discussion_r237509884 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/ha

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703273#comment-16703273 ] ASF GitHub Bot commented on FLINK-10583: kl0u commented on a change in pull requ

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703275#comment-16703275 ] ASF GitHub Bot commented on FLINK-10583: kl0u commented on a change in pull requ

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16703254#comment-16703254 ] ASF GitHub Bot commented on FLINK-10583: pnowojski commented on a change in pull

<    1   2   3   >