[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will cause

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-08-07 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-7373: - Description: Using URLClassLoader to load, say from Artifactory, and instantiate UDF instances will cause

[jira] [Closed] (FLINK-7221) JDBCOutputFormat swallows errors on last batch

2017-08-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7221. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with cd4c2b59

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

2017-08-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117500#comment-16117500 ] Haohui Mai commented on FLINK-6429: --- bq. In order to change the default behavior of the

[jira] [Commented] (FLINK-7365) excessive warning logs of attempt to override final parameter: fs.s3.buffer.dir

2017-08-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117498#comment-16117498 ] Bowen Li commented on FLINK-7365: - How about turning off Hadoop logging by default? Is it

[jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint

2017-08-07 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117574#comment-16117574 ] Eron Wright commented on FLINK-7072: - Note that 'submit job' refers to job graph subm

[GitHub] flink issue #3829: [FLINK-6442] [table] Extend TableAPI Support Sink Table R...

2017-08-07 Thread lincoln-lil
Github user lincoln-lil commented on the issue: https://github.com/apache/flink/pull/3829 @fhueske I will continue this PR according to the above conclusions. Thanks, Lincoln --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117709#comment-16117709 ] ASF GitHub Bot commented on FLINK-6442: --- Github user lincoln-lil commented on the is

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804398 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -386,6 +387,19 @@ private void checkPatternNameUn

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804764 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -637,9 +675,23 @@ private boolean isPatternOption

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804887 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache So

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117809#comment-16117809 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117811#comment-16117811 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804932 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache So

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804902 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache So

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117806#comment-16117806 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117810#comment-16117810 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117807#comment-16117807 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117808#comment-16117808 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on a diff in t

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

2017-08-07 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r131804949 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GreedyITCase.java --- @@ -0,0 +1,1068 @@ +/* + * Licensed to the Apache So

[jira] [Created] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-7385: - Summary: Fix ArrayIndexOutOfBoundsException when object-reuse is enabled Key: FLINK-7385 URL: https://issues.apache.org/jira/browse/FLINK-7385 Project: Flink Is

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117836#comment-16117836 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 @bowenli86 the third option actually strikes me as an overall good solution, I didn't know that was possible. I think it would make sense to deprecate the previous configuration keys in fav

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 Also cc'ing @aljoscha to this PR, since we also had a bit of offline discussion on this configuration gap issue. --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117838#comment-16117838 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on the issue

[GitHub] flink pull request #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException wh...

2017-08-07 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/4496 [FLINK-7385] Fix ArrayIndexOutOfBoundsException when object-reuse is … …enabled *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117860#comment-16117860 ] ASF GitHub Bot commented on FLINK-7385: --- GitHub user Xpray opened a pull request:

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117869#comment-16117869 ] Tzu-Li (Gordon) Tai commented on FLINK-7385: This looks like a blockers for th

[jira] [Updated] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7385: --- Priority: Blocker (was: Major) > Fix ArrayIndexOutOfBoundsException when object-reuse

[jira] [Updated] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7385: --- Affects Version/s: 1.1.5 1.2.1 1.3.2 > F

[jira] [Updated] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7385: --- Fix Version/s: 1.3.3 1.4.0 > Fix ArrayIndexOutOfBoundsException whe

[jira] [Updated] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7385: --- Component/s: DataStream API > Fix ArrayIndexOutOfBoundsException when object-reuse is

[GitHub] flink pull request #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException wh...

2017-08-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4496#discussion_r131822675 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/StreamOperatorChainingTest.java --- @@ -37,7 +38,7 @@ import

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117873#comment-16117873 ] ASF GitHub Bot commented on FLINK-7385: --- Github user tzulitai commented on a diff in

[GitHub] flink issue #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException when obje...

2017-08-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4496 Thanks for the PR @Xpray! Changes looks good to me. Good that a test is also added. I think it would be safer if @aljoscha also takes a look before merging. One reminder: filling out the

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117876#comment-16117876 ] ASF GitHub Bot commented on FLINK-7385: --- Github user tzulitai commented on the issue

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

2017-08-07 Thread tedyu
Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131823213 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala --- @@ -0,0 +1,95 @@ +/* + * Licensed to the Ap

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117877#comment-16117877 ] ASF GitHub Bot commented on FLINK-4565: --- Github user tedyu commented on a diff in th

[jira] [Commented] (FLINK-7385) Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117878#comment-16117878 ] ASF GitHub Bot commented on FLINK-7385: --- Github user Xpray commented on a diff in th

[GitHub] flink pull request #4496: [FLINK-7385] Fix ArrayIndexOutOfBoundsException wh...

2017-08-07 Thread Xpray
Github user Xpray commented on a diff in the pull request: https://github.com/apache/flink/pull/4496#discussion_r131823239 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/StreamOperatorChainingTest.java --- @@ -37,7 +38,7 @@ import or

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-07 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 I'm in favor of the 3rd option. In that way, we don't need to 1) duplicate all KPL keys and documentation to flink-kinesis-connector and 2) always keep an eye on KPL configs when upgrading its vers

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117887#comment-16117887 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4418: [FLINK-7293] [cep] Support custom order by in PatternStre...

2017-08-07 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4418 merging --- 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 fe

[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

2017-08-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16117937#comment-16117937 ] ASF GitHub Bot commented on FLINK-7293: --- Github user dawidwys commented on the issue

[GitHub] flink pull request #4418: [FLINK-7293] [cep] Support custom order by in Patt...

2017-08-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4418 --- 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 enab

<    1   2   3   4