[jira] [Updated] (FLINK-5546) java.io.tmpdir setted as project build directory in surefire plugin

2017-01-22 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5546: - Summary: java.io.tmpdir setted as project build directory in surefire plugin (was: When multiple users

[jira] [Commented] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834014#comment-15834014 ] ASF GitHub Bot commented on FLINK-5546: --- GitHub user shijinkui opened a pull request:

[GitHub] flink pull request #3190: [FLINK-5546][build] When multiple users run test, ...

2017-01-22 Thread shijinkui
GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/3190 [FLINK-5546][build] When multiple users run test, /tmp/cacheFile conf… Unit test will create file in java.io.tmpdir, default it's `/tmp` which has capacity limit. Create temporary in

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

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

[GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C...

2017-01-22 Thread chermenin
Github user chermenin commented on a diff in the pull request: https://github.com/apache/flink/pull/2361#discussion_r97264252 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/State.java --- @@ -43,7 +43,14 @@ public State(final String name, final

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833957#comment-15833957 ] ASF GitHub Bot commented on FLINK-5508: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3158: [backport] [FLINK-5508] [FLINK-5496] [FLINK-5495] Fix Mes...

2017-01-22 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3158 This is an identical backport / forwardport of the other 3 Mesos fixes, correct? If so, since #3155 and #3156 all have +1s, and #3157 is also a +1 once the minor code style comments are

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[jira] [Commented] (FLINK-5508) Remove Mesos dynamic class loading

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

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97253388 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java --- @@ -394,6 +395,14 @@ protected

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97257309 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java --- @@ -0,0 +1,120 @@ +/* + * Licensed to the

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97257878 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java --- @@ -0,0 +1,120 @@ +/* + * Licensed to the

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97256203 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperVersionedValue.java --- @@ -0,0 +1,43 @@ +/* + * Licensed to the

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97255788 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java --- @@ -376,15 +376,19 @@ public static

[GitHub] flink pull request #3157: [FLINK-5508] [mesos] Introduce ZooKeeperUtilityFac...

2017-01-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3157#discussion_r97255571 --- Diff: flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManagerTest.java --- @@ -73,13 +74,16 @@ /**

[jira] [Commented] (FLINK-5495) ZooKeeperMesosWorkerStore cannot be instantiated

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833895#comment-15833895 ] ASF GitHub Bot commented on FLINK-5495: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3155: [FLINK-5495] [mesos] Provide executor to ZooKeeperMesosWo...

2017-01-22 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3155 +1 to merge, LGTM. --- 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,

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] Add a general distributiv...

2017-01-22 Thread shaoxuan-wang
Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97246135 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833830#comment-15833830 ] ASF GitHub Bot commented on FLINK-5582: --- Github user shaoxuan-wang commented on a diff in the pull

[jira] [Assigned] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts

2017-01-22 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui reassigned FLINK-5546: Assignee: shijinkui > When multiple users run test, /tmp/cacheFile conflicts >

[jira] [Updated] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts

2017-01-22 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5546: - Assignee: (was: shijinkui) > When multiple users run test, /tmp/cacheFile conflicts >

[jira] [Assigned] (FLINK-5546) When multiple users run test, /tmp/cacheFile conflicts

2017-01-22 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui reassigned FLINK-5546: Assignee: shijinkui > When multiple users run test, /tmp/cacheFile conflicts >

[jira] [Resolved] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5582. - Resolution: Implemented Implemented in 09380e49256bff924734b9a932808e0f4daa7e5c > Add a general

[jira] [Closed] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5582. --- > Add a general distributive aggregate function > - > >

[jira] [Closed] (FLINK-5590) Create a proper internal state hierarchy

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5590. --- > Create a proper internal state hierarchy > > >

[jira] [Resolved] (FLINK-5590) Create a proper internal state hierarchy

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5590. - Resolution: Fixed Fixed in 3b97128f05bacfb80afe4a2a49741c31ff306cd2 > Create a proper internal

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833726#comment-15833726 ] ASF GitHub Bot commented on FLINK-5582: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] Add a general distributiv...

2017-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3186 --- 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-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833701#comment-15833701 ] ASF GitHub Bot commented on FLINK-5582: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3186: [FLINK-5582] [streaming] Add a general distributive aggre...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3186 Since this requires constantly extensive merge conflict resolving with the master, I want to merge this soon. @shaoxuan-wang has tested it life and the CI pass as well... --- If your

[jira] [Commented] (FLINK-5608) Cancel button not always visible

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833696#comment-15833696 ] ASF GitHub Bot commented on FLINK-5608: --- GitHub user rehevkor5 opened a pull request:

[GitHub] flink pull request #3189: [FLINK-5608] [webfrontend] Cancel button stays vis...

2017-01-22 Thread rehevkor5
GitHub user rehevkor5 opened a pull request: https://github.com/apache/flink/pull/3189 [FLINK-5608] [webfrontend] Cancel button stays visible in narrow windows - Most importantly, the Cancel button has been changed to float right, and will only wrap downward if pushed out by the

[jira] [Created] (FLINK-5608) Cancel button not always visible

2017-01-22 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5608: Summary: Cancel button not always visible Key: FLINK-5608 URL: https://issues.apache.org/jira/browse/FLINK-5608 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833675#comment-15833675 ] ASF GitHub Bot commented on FLINK-5582: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3186: [FLINK-5582] [streaming] Add a general distributive aggre...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3186 @shaoxuan-wang I cannot reproduce the compile error you posted. The latest commit also gets a green light from Travis CI: https://travis-ci.org/StephanEwen/incubator-flink/builds/194239397

[jira] [Resolved] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5454. - Resolution: Fixed Fixed in - 1.2.0 via 099cdd01013c6959d3785088204601b926c04193 - 1.3.0 via

[jira] [Closed] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state

2017-01-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5454. --- > Add Documentation about how to tune Checkpointing for large state >

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

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

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] Add a general distributiv...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97227451 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5562) Driver fixes

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833603#comment-15833603 ] ASF GitHub Bot commented on FLINK-5562: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5562) Driver fixes

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833601#comment-15833601 ] ASF GitHub Bot commented on FLINK-5562: --- Github user StephanEwen commented on the issue:

[jira] [Updated] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue

2017-01-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5376: -- Description: The following are two examples where ordered stream element queue is mentioned: {code}

[GitHub] flink issue #3188: [FLINK-5562] [gelly] Driver fixes

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3188 Looks good. I would like to merge this tomorrow together with #3187 (which is time critical for the release). --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3187: [FLINK-5562] [gelly] Driver fixes for release-1.2

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3187 Changes look good to me. As per Robert's email on the mailing list, he is shooting for a new release candidate very soon, so we would need to merge this before tomorrow, if possible.

[jira] [Updated] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2017-01-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4848: -- Description: {code} String keystoreFilePath = sslConfig.getString(

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

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

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] dd a general distributive...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97227303 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

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

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] dd a general distributive...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97227249 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833581#comment-15833581 ] ASF GitHub Bot commented on FLINK-5582: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3186: [FLINK-5582] [streaming] dd a general distributive aggreg...

2017-01-22 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3186 Update: The first version had an issue with binary compatibility in the Scala DataStream API: This Scala API accidentally exposed in Flink 1.0 a public method with an internal type as a

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833577#comment-15833577 ] ASF GitHub Bot commented on FLINK-5582: --- Github user shaoxuan-wang commented on a diff in the pull

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] dd a general distributive...

2017-01-22 Thread shaoxuan-wang
Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97226958 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833576#comment-15833576 ] ASF GitHub Bot commented on FLINK-5582: --- Github user shaoxuan-wang commented on a diff in the pull

[GitHub] flink pull request #3186: [FLINK-5582] [streaming] dd a general distributive...

2017-01-22 Thread shaoxuan-wang
Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/3186#discussion_r97226914 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5576. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 7a0e3d6 (release-1.2),

[jira] [Closed] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5559. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in ef13f48 fd63981 f592d4c

[jira] [Commented] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833539#comment-15833539 ] ASF GitHub Bot commented on FLINK-5576: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833538#comment-15833538 ] ASF GitHub Bot commented on FLINK-5528: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833540#comment-15833540 ] ASF GitHub Bot commented on FLINK-5559: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3172: [FLINK-5559] let KvStateRequestSerializer#deserial...

2017-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3172 --- 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

[GitHub] flink pull request #3174: [FLINK-5576] extend deserialization functions of K...

2017-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3174 --- 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

[GitHub] flink pull request #3139: [FLINK-5528][query][tests] reduce the retry delay ...

2017-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3139 --- 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] [Created] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5607: -- Summary: Move location lookup retry out of KvStateLocationLookupService Key: FLINK-5607 URL: https://issues.apache.org/jira/browse/FLINK-5607 Project: Flink

[jira] [Created] (FLINK-5606) Remove magic number in key and namespace serialization

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5606: -- Summary: Remove magic number in key and namespace serialization Key: FLINK-5606 URL: https://issues.apache.org/jira/browse/FLINK-5606 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5605) Make KvStateRequestSerializer package private

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5605: -- Assignee: Ufuk Celebi > Make KvStateRequestSerializer package private >

[jira] [Created] (FLINK-5605) Make KvStateRequestSerializer package private

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5605: -- Summary: Make KvStateRequestSerializer package private Key: FLINK-5605 URL: https://issues.apache.org/jira/browse/FLINK-5605 Project: Flink Issue Type:

[jira] [Created] (FLINK-5604) Replace QueryableStateClient constructor

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5604: -- Summary: Replace QueryableStateClient constructor Key: FLINK-5604 URL: https://issues.apache.org/jira/browse/FLINK-5604 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5509: -- Assignee: Ufuk Celebi > Replace QueryableStateClient keyHashCode argument >

[jira] [Created] (FLINK-5603) Use Flink's futures in QueryableStateClient

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5603: -- Summary: Use Flink's futures in QueryableStateClient Key: FLINK-5603 URL: https://issues.apache.org/jira/browse/FLINK-5603 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4220) ClientTest fails after port conflict

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4220. -- Resolution: Cannot Reproduce > ClientTest fails after port conflict >

[jira] [Closed] (FLINK-5116) Missing RocksDB state backend factory

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5116. -- Resolution: Won't Fix Implemented in >= 1.2 > Missing RocksDB state backend factory >

[jira] [Commented] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833467#comment-15833467 ] Ufuk Celebi commented on FLINK-5436: [~stefanrichte...@gmail.com] and [~aljoscha] should we address

[jira] [Closed] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

2017-01-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5530. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in d8222c1 (release-1.2),

[jira] [Commented] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

2017-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833448#comment-15833448 ] ASF GitHub Bot commented on FLINK-5530: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3143: [FLINK-5530] fix race condition in AbstractRocksDB...

2017-01-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3143 --- 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