[GitHub] flink pull request #4607: [FLINK-6306][connectors] Sink for eventually consi...

GitHub user sjwiesman opened a pull request: https://github.com/apache/flink/pull/4607 [FLINK-6306][connectors] Sink for eventually consistent file systems ## What is the purpose of the change This pull request implements a sink for writing out to an eventually consistent

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143229#comment-16143229 ] ASF GitHub Bot commented on FLINK-6306: --- Github user sjwiesman closed the pull request at:

[GitHub] flink pull request #3752: [FLINK-6306] [filesystem-connectors] Sink for even...

Github user sjwiesman closed the pull request at: https://github.com/apache/flink/pull/3752 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143244#comment-16143244 ] ASF GitHub Bot commented on FLINK-6306: --- GitHub user sjwiesman opened a pull request:

[GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f...

Github user sjwiesman commented on the issue: https://github.com/apache/flink/pull/4607 CC: @aljoscha I screwed up the rebase so I cherry picked the updates into a new branch and re-opened the pr. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143246#comment-16143246 ] ASF GitHub Bot commented on FLINK-6306: --- Github user sjwiesman commented on the issue:

[GitHub] flink issue #3511: [Flink-5734] code generation for normalizedkey sorter

Github user ggevay commented on the issue: https://github.com/apache/flink/pull/3511 Thank @heytitle , I'll try to do the code generation for `FixedLengthRecordSorter` tomorrow, and I will also take a look at the failing tests. Btw. you can force push (`git push -f`) the

[jira] [Created] (FLINK-7539) Make AvroOutputFormat default codec configurable

Sebastian Klemke created FLINK-7539: --- Summary: Make AvroOutputFormat default codec configurable Key: FLINK-7539 URL: https://issues.apache.org/jira/browse/FLINK-7539 Project: Flink Issue

[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=16143104#comment-16143104 ] Jark Wu commented on FLINK-7491: Hi [~suez1224] , what I mean use {{Array}} instead of

[jira] [Commented] (FLINK-7539) Make AvroOutputFormat default codec configurable

[ https://issues.apache.org/jira/browse/FLINK-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143139#comment-16143139 ] ASF GitHub Bot commented on FLINK-7539: --- GitHub user packet23 opened a pull request:

[jira] [Commented] (FLINK-7410) Add getName method to UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143111#comment-16143111 ] Jark Wu commented on FLINK-7410: Hi [~hequn8128] do you mean users may use {{toString}} for other

[GitHub] flink pull request #4606: [FLINK-7539] Made AvroOutputFormat default codec c...

GitHub user packet23 opened a pull request: https://github.com/apache/flink/pull/4606 [FLINK-7539] Made AvroOutputFormat default codec configurable. Implement site-wide codec defaults. ## Brief change log - Added connect.avro.output.codec option ##

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135430161 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -36,10 +36,8 @@ import

[jira] [Commented] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143342#comment-16143342 ] sunjincheng commented on FLINK-7465: Hi [~jparkie]When we deal with a [Dynamic

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-6938) IterativeCondition should support RichFunction interface

[ https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143403#comment-16143403 ] ASF GitHub Bot commented on FLINK-6938: --- Github user dianfu commented on the issue:

[GitHub] flink issue #4513: [FLINK-6938] [cep] IterativeCondition should support Rich...

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4513 @dawidwys It would be great if you could take a look. Very appreciated! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135425326 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -18,39 +18,40 @@

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135425816 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -74,48 +75,102 @@ class

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135425060 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -350,8 +350,8 @@ abstract class

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135425261 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -18,39 +18,40 @@

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135426134 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -36,10 +36,8 @@ import

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135426250 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedTableFunctions.java --- @@ -35,4 +35,15 @@

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135425277 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -18,39 +18,40 @@

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135426183 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -71,6 +69,9 @@ class

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[GitHub] flink pull request #4536: [FLINK-7439] [table] Support variable arguments fo...

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4536#discussion_r135430307 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala --- @@ -71,6 +69,9 @@ class

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[jira] [Commented] (FLINK-7439) Support variable arguments for UDTF in SQL

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

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r135440842 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -526,18 +551,32 @@ private boolean

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r135441351 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -421,6 +437,15 @@ private void

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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