[jira] [Updated] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-14 Thread Zhe Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhe Li updated FLINK-6602: -- Attachment: getRowType.png > Table source with defined time attributes allows empty string >

[GitHub] flink pull request #4127: [FLINK-6892][table]Add L/RPAD supported in SQL

2017-06-14 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4127 [FLINK-6892][table]Add L/RPAD supported in SQL In this PR. have Add L/RPAD supported in SQL,For Example: ``` LPAD('hi',4,'??') -> '??hi' LPAD('hi',1,'??') -> 'h'

[jira] [Commented] (FLINK-6892) Add L/RPAD supported in SQL

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050011#comment-16050011 ] ASF GitHub Bot commented on FLINK-6892: --- GitHub user sunjincheng121 opened a pull request:

[jira] [Updated] (FLINK-6892) Add L/RPAD supported in SQL

2017-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6892: --- Description: L/RPAD(str,len,padstr) Returns the string str, left/right-padded with the string padstr

[jira] [Updated] (FLINK-6892) Add L/RPAD supported in SQL

2017-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6892: --- Summary: Add L/RPAD supported in SQL (was: Add LPAD supported in SQL) > Add L/RPAD supported in SQL

[jira] [Assigned] (FLINK-4602) Move RocksDB backend to proper package

2017-06-14 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-4602: --- Assignee: mingleizhang > Move RocksDB backend to proper package >

[jira] [Commented] (FLINK-4602) Move RocksDB backend to proper package

2017-06-14 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049990#comment-16049990 ] mingleizhang commented on FLINK-4602: - What you mean that currently we needn't move RocksDB backend to

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049980#comment-16049980 ] ASF GitHub Bot commented on FLINK-4520: --- Github user haoch commented on the issue:

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2017-06-14 Thread haoch
Github user haoch commented on the issue: https://github.com/apache/flink/pull/2487 @asdf2014 sorry for delayed response, will find some time to finalize this PR and propose to Bahir project . --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Assigned] (FLINK-6892) Add LPAD supported in SQL

2017-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6892: -- Assignee: sunjincheng > Add LPAD supported in SQL > - > >

[jira] [Assigned] (FLINK-6810) Add Some built-in Scalar Function supported

2017-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6810: -- Assignee: (was: sunjincheng) > Add Some built-in Scalar Function supported >

[jira] [Assigned] (FLINK-6810) Add Some built-in Scalar Function supported

2017-06-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6810: -- Assignee: sunjincheng > Add Some built-in Scalar Function supported >

[jira] [Commented] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049937#comment-16049937 ] ASF GitHub Bot commented on FLINK-6498: --- Github user zjureel commented on a diff in the pull

[GitHub] flink pull request #4123: [FLINK-6498] Migrate Zookeeper configuration optio...

2017-06-14 Thread zjureel
Github user zjureel commented on a diff in the pull request: https://github.com/apache/flink/pull/4123#discussion_r122110338 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java --- @@ -100,6 +100,45 @@

[jira] [Updated] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

2017-06-14 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-6923: Description: We have a use case where we have our custom Fetcher implementation that extends

[jira] [Created] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

2017-06-14 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-6923: --- Summary: Kafka connector needs to expose information about in-flight record in AbstractFetcher base class Key: FLINK-6923 URL: https://issues.apache.org/jira/browse/FLINK-6923

[jira] [Commented] (FLINK-6836) Failing YARNSessionCapacitySchedulerITCase.testTaskManagerFailure

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049339#comment-16049339 ] ASF GitHub Bot commented on FLINK-6836: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4120: [FLINK-6836] [tests] Fix YARNSessionCapacitySchedulerITCa...

2017-06-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4120 Rebasing onto the latest master --- 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

[jira] [Created] (FLINK-6922) Enum(Value)SerializerConfigSnapshot uses Java serialization to store enum values

2017-06-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6922: Summary: Enum(Value)SerializerConfigSnapshot uses Java serialization to store enum values Key: FLINK-6922 URL: https://issues.apache.org/jira/browse/FLINK-6922

[jira] [Commented] (FLINK-6921) EnumValueSerializer cannot properly handle appended enum values

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049311#comment-16049311 ] ASF GitHub Bot commented on FLINK-6921: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4126: [FLINK-6921] [serializer] Allow EnumValueSerialize...

2017-06-14 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4126 [FLINK-6921] [serializer] Allow EnumValueSerializer to deal with appended enum values The problem was that we don't check the bounds of the array with the enum names contained in the

[jira] [Commented] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049288#comment-16049288 ] ASF GitHub Bot commented on FLINK-6682: --- GitHub user zhangminglei opened a pull request:

[jira] [Assigned] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-14 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6682: --- Assignee: mingleizhang > Improve error message in case parallelism exceeds maxParallelism >

[GitHub] flink pull request #4125: [FLINK-6682] [checkpoints] Improve error message i...

2017-06-14 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4125 [FLINK-6682] [checkpoints] Improve error message in case parallelism … …exceeds maxParallelism Thanks for contributing to Apache Flink. Before you open your pull request, please

[jira] [Commented] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-14 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049285#comment-16049285 ] mingleizhang commented on FLINK-6682: - Thanks for telling me. [~Zentol] and I have put the updated

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049259#comment-16049259 ] Chesnay Schepler commented on FLINK-6918: - So, i guess what happens is that the savepoint is

[jira] [Created] (FLINK-6921) EnumValueSerializer cannot properly handle appended enum values

2017-06-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6921: Summary: EnumValueSerializer cannot properly handle appended enum values Key: FLINK-6921 URL: https://issues.apache.org/jira/browse/FLINK-6921 Project: Flink

[jira] [Closed] (FLINK-6913) Instable StatefulJobSavepointMigrationITCase.testRestoreSavepoint

2017-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6913. Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 1.4.0:

[jira] [Commented] (FLINK-6913) Instable StatefulJobSavepointMigrationITCase.testRestoreSavepoint

2017-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049248#comment-16049248 ] Till Rohrmann commented on FLINK-6913: -- [~tzulitai] already fixed the test case. Will close the issue

[jira] [Closed] (FLINK-6914) TrySerializer#ensureCompatibility causes StackOverflowException

2017-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6914. Resolution: Fixed Fix Version/s: 1.3.1 1.4.0:

[jira] [Commented] (FLINK-6914) TrySerializer#ensureCompatibility causes StackOverflowException

2017-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049245#comment-16049245 ] Till Rohrmann commented on FLINK-6914: -- Thanks for fixing the issue [~tzulitai]. >

[jira] [Closed] (FLINK-6915) EnumValueSerializer broken

2017-06-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6915. Resolution: Fixed 1.4.0:

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049218#comment-16049218 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4111: [FLINK-6896][table] Fix generate PojoType input result ex...

2017-06-14 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4111 Thanks for your changes. @fhueske --- 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

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049207#comment-16049207 ] Chesnay Schepler commented on FLINK-6918: - oh, I just got it as well locally. Time to investigate.

[jira] [Comment Edited] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049202#comment-16049202 ] Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:58 PM: Yes, also 1.3.

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121953747 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Comment Edited] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049202#comment-16049202 ] Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:57 PM: Yes, also 1.3. I'm

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049205#comment-16049205 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dianfu commented on a diff in the pull request:

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049206#comment-16049206 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dianfu commented on a diff in the pull request:

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049203#comment-16049203 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dianfu commented on a diff in the pull request:

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121953691 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049202#comment-16049202 ] Greg Hogan commented on FLINK-6918: --- Yes, also 1.3. I'm wondering if we aren't cleaning up {{/tmp}} as

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121953266 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049197#comment-16049197 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dianfu commented on a diff in the pull request:

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dianfu
Github user dianfu commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121952296 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1391,6 +1391,248 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049194#comment-16049194 ] Chesnay Schepler commented on FLINK-6918: - This test is run twice, once for 1.2 and 1.3

[jira] [Comment Edited] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049166#comment-16049166 ] Greg Hogan edited comment on FLINK-6918 at 6/14/17 1:32 PM: @zentol no, not a

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2017-06-14 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049178#comment-16049178 ] Dian Fu commented on FLINK-4641: Hi [~chermenin], are you still working on this JIRA? It seems that the

[jira] [Commented] (FLINK-6738) HBaseConnectorITCase is flaky

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049174#comment-16049174 ] Greg Hogan commented on FLINK-6738: --- This is also a reliable failure for me when testing locally. >

[GitHub] flink pull request #4124: [FLINK-6920] Remove minor guava usages

2017-06-14 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4124 [FLINK-6920] Remove minor guava usages This PR removes undeclared usages of guava in the following modules ``` flink-connector-elasticsearch flink-connector-filesystem

[jira] [Commented] (FLINK-6920) Remove minor guava usages in several modules

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049173#comment-16049173 ] ASF GitHub Bot commented on FLINK-6920: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-6913) Instable StatefulJobSavepointMigrationITCase.testRestoreSavepoint

2017-06-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049170#comment-16049170 ] Aljoscha Krettek commented on FLINK-6913: - [~till.rohrmann] The link to the logs is not

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049169#comment-16049169 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121943356 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049168#comment-16049168 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121943417 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049166#comment-16049166 ] Greg Hogan commented on FLINK-6918: --- @zentol no, not a consistent error. > Failing tests:

[jira] [Commented] (FLINK-6907) Remove TupleGenerator in flink-java

2017-06-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049164#comment-16049164 ] Aljoscha Krettek commented on FLINK-6907: - Maybe this was originated from some merging/renaming

[jira] [Created] (FLINK-6920) Remove minor guava usages in several modules

2017-06-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6920: --- Summary: Remove minor guava usages in several modules Key: FLINK-6920 URL: https://issues.apache.org/jira/browse/FLINK-6920 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049161#comment-16049161 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121942275 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1905,6 +2147,275 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049151#comment-16049151 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #4121: [FLINK-6904] [cep] Support for quantifier range to...

2017-06-14 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4121#discussion_r121939394 --- Diff: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --- @@ -1391,6 +1391,248 @@ public boolean filter(Event value)

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049146#comment-16049146 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049148#comment-16049148 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049147#comment-16049147 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r121938446 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowAggregationsITCase.scala --- @@ -179,6

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r121938625 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/utils/StreamTestData.scala --- @@ -80,4 +83,28 @@ object

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r121937961 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/utils/Pojos.java --- @@ -0,0 +1,61 @@ +package

[jira] [Updated] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()

2017-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5541: -- Description: {code} if (localJar == null) { try { for (final URL url :

[jira] [Comment Edited] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16041664#comment-16041664 ] Ted Yu edited comment on FLINK-5488 at 6/14/17 1:00 PM: Please also fix the

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2017-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346 ] Ted Yu edited comment on FLINK-5486 at 6/14/17 12:59 PM: - Lock on

[jira] [Comment Edited] (FLINK-6738) HBaseConnectorITCase is flaky

2017-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16035273#comment-16035273 ] Ted Yu edited comment on FLINK-6738 at 6/14/17 12:59 PM: - This fails in master

[jira] [Commented] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049139#comment-16049139 ] Chesnay Schepler commented on FLINK-6918: - Does this happen all the time? The checkpoint is

[jira] [Created] (FLINK-6918) Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest

2017-06-14 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6918: - Summary: Failing tests: ChainLengthDecreaseTest and ChainLengthIncreaseTest Key: FLINK-6918 URL: https://issues.apache.org/jira/browse/FLINK-6918 Project: Flink

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049098#comment-16049098 ] ASF GitHub Bot commented on FLINK-4520: --- Github user asdf2014 commented on the issue:

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2017-06-14 Thread asdf2014
Github user asdf2014 commented on the issue: https://github.com/apache/flink/pull/2487 @rmetzger Alright. Thank you for your asking, but i think our company still plan to use `Flink-CEP` and contributing `Bahir-Siddhi` feature is a huge job, so... I'm so sorry. --- If your project

[jira] [Created] (FLINK-6917) Introduce test base for end-to-end testing serializer config snapshotting, restoring, and compatibility check roundtrips

2017-06-14 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6917: -- Summary: Introduce test base for end-to-end testing serializer config snapshotting, restoring, and compatibility check roundtrips Key: FLINK-6917 URL:

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049065#comment-16049065 ] ASF GitHub Bot commented on FLINK-6896: --- Github user hustfxj commented on the issue:

[GitHub] flink issue #4111: [FLINK-6896][table] Fix generate PojoType input result ex...

2017-06-14 Thread hustfxj
Github user hustfxj commented on the issue: https://github.com/apache/flink/pull/4111 Looks good to me. +1 to merged. --- 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

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049046#comment-16049046 ] ASF GitHub Bot commented on FLINK-6896: --- Github user hustfxj commented on the issue:

[GitHub] flink issue #4111: [FLINK-6896][table] Fix generate PojoType input result ex...

2017-06-14 Thread hustfxj
Github user hustfxj commented on the issue: https://github.com/apache/flink/pull/4111 @sunjincheng121 I get it. Thank you very much! --- 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

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049027#comment-16049027 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4111: [FLINK-6896][table] Fix generate PojoType input result ex...

2017-06-14 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4111 For example (from test case): You can run `org.apache.flink.table.api.java.batch.TableEnvironmentITCase#testAsFromAndToPrivateFieldPojo` * input1: ``` 0=age(Integer)

[jira] [Commented] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049021#comment-16049021 ] ASF GitHub Bot commented on FLINK-6498: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4123: [FLINK-6498] Migrate Zookeeper configuration optio...

2017-06-14 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4123#discussion_r121910223 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java --- @@ -100,6 +100,45 @@

[jira] [Commented] (FLINK-5886) Python API for streaming applications

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049018#comment-16049018 ] ASF GitHub Bot commented on FLINK-5886: --- Github user zentol commented on the issue:

[jira] [Closed] (FLINK-6329) refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream

2017-06-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-6329. -- Resolution: Won't Fix Assignee: Nico Kruber let's re-work the whole API in FLIP-19 > refactor

[GitHub] flink issue #3838: [FLINK-5886] Python API for streaming applications

2017-06-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3838 When running the example against a local cluster i got this exception ``` java.io.IOException: java.io.IOException: The given HDFS file URI (hdfs:/tmp/flink_cache_-4117839671387669278) did not

[jira] [Commented] (FLINK-6914) TrySerializer#ensureCompatibility causes StackOverflowException

2017-06-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049012#comment-16049012 ] Tzu-Li (Gordon) Tai commented on FLINK-6914: This has been fixed in This has been fixed in

[jira] [Comment Edited] (FLINK-6914) TrySerializer#ensureCompatibility causes StackOverflowException

2017-06-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049012#comment-16049012 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6914 at 6/14/17 10:20 AM: --

[jira] [Created] (FLINK-6916) FLIP-19: Improved BLOB storage architecture

2017-06-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6916: -- Summary: FLIP-19: Improved BLOB storage architecture Key: FLINK-6916 URL: https://issues.apache.org/jira/browse/FLINK-6916 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6915) EnumValueSerializer broken

2017-06-14 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049011#comment-16049011 ] Tzu-Li (Gordon) Tai commented on FLINK-6915: This has been fixed in

[jira] [Assigned] (FLINK-6380) BlobService concurrency issues between delete and put/get methods

2017-06-14 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-6380: -- Assignee: Nico Kruber > BlobService concurrency issues between delete and put/get methods >

[jira] [Commented] (FLINK-6498) Migrate Zookeeper configuration options

2017-06-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16049004#comment-16049004 ] ASF GitHub Bot commented on FLINK-6498: --- Github user zjureel commented on a diff in the pull

[GitHub] flink pull request #4123: [FLINK-6498] Migrate Zookeeper configuration optio...

2017-06-14 Thread zjureel
Github user zjureel commented on a diff in the pull request: https://github.com/apache/flink/pull/4123#discussion_r121906966 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java --- @@ -100,6 +100,45 @@

[jira] [Closed] (FLINK-6817) Fix NPE when preceding is not set in OVER window

2017-06-14 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-6817. -- Resolution: Fixed Fixed in 5f63bf98c3dc7c1fe28630300b68179b6700dcad for master Fixed in

[GitHub] flink pull request #4104: [FLINK-6817] [table] Add OverWindowWithPreceding c...

2017-06-14 Thread wuchong
Github user wuchong closed the pull request at: https://github.com/apache/flink/pull/4104 --- 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

  1   2   >