[jira] [Assigned] (FLINK-7426) Table API does not support null values in keys

[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-7426: --- Assignee: Timo Walther > Table API does not support null values in keys >

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182125#comment-16182125 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141260762 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182123#comment-16182123 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141260601 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182108#comment-16182108 ] ASF GitHub Bot commented on FLINK-7683: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141258536 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1946,4

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182098#comment-16182098 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182097#comment-16182097 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141256073 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141256026 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182096#comment-16182096 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182093#comment-16182093 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141255931 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141255917 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182068#comment-16182068 ] Hai Zhou UTC+8 commented on FLINK-7697: --- Hi [~tzulitai], Do you have any good suggestions? > Add

[jira] [Created] (FLINK-7697) Add metrics for Elasticsearch Sink

Hai Zhou UTC+8 created FLINK-7697: - Summary: Add metrics for Elasticsearch Sink Key: FLINK-7697 URL: https://issues.apache.org/jira/browse/FLINK-7697 Project: Flink Issue Type: Wish

<    1   2   3   4   5