[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116790511 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116796524 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116847715 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116791596 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

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

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116992617 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,69 @@ +/*

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116791316 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116797215 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116795204 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116794136 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116847591 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116791975 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116794639 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116792670 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116993635 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,69 @@ +/*

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116791707 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116854249 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116791061 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r117000947 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r117001241 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116792128 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116993947 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala --- @@ -0,0 +1,69 @@ +/*

[GitHub] flink pull request #3715: [FLINK-6232][Table&SQL]Support proctime inner equi...

2017-05-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3715#discussion_r116861487 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to th

[jira] [Assigned] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6198: - Assignee: Kostas Kloudas > Update the documentation of the CEP library to include all the

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-17 Thread Dmytro Shkvyra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014155#comment-16014155 ] Dmytro Shkvyra commented on FLINK-6613: --- [~dernasherbrezon] What JVM option and GC d

[jira] [Closed] (FLINK-6600) Add key serializer's config snapshot to KeyedBackendSerializationProxy

2017-05-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6600. -- Resolution: Fixed Fixed for 1.3 via 8b5ba676fb3b52f69b0a523d57264462ac73c23f Fixed for m

[jira] [Commented] (FLINK-6600) Add key serializer's config snapshot to KeyedBackendSerializationProxy

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014147#comment-16014147 ] ASF GitHub Bot commented on FLINK-6600: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3925: [FLINK-6600] Add key serializer config snapshot to...

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

[jira] [Comment Edited] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

2017-05-17 Thread Dmytro Shkvyra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014134#comment-16014134 ] Dmytro Shkvyra edited comment on FLINK-3451 at 5/17/17 2:44 PM:

[jira] [Comment Edited] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

2017-05-17 Thread Dmytro Shkvyra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014134#comment-16014134 ] Dmytro Shkvyra edited comment on FLINK-3451 at 5/17/17 2:43 PM:

[jira] [Commented] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort()

2017-05-17 Thread Dmytro Shkvyra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014134#comment-16014134 ] Dmytro Shkvyra commented on FLINK-3451: --- [~uce] IMHO the problem is in {NetUtils.get

[jira] [Closed] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5855. - Resolution: Invalid > Unprotected access to pendingFilesPerCheckpoint in BucketingSink > -

[jira] [Closed] (FLINK-6609) Wrong version assignment when multiple TAKEs transitions

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6609. - Resolution: Fixed Fixed on master with 00ce3f1b12c7d7bf996d5f91bf006f0e18a719e7 > Wrong version a

[jira] [Commented] (FLINK-6614) Applying function on window auxiliary function fails

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

[GitHub] flink pull request #3930: [FLINK-6614] [table] Fix translation of group auxi...

2017-05-17 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/3930 [FLINK-6614] [table] Fix translation of group auxiliary functions (e.g., TUMBLE_END). When translating group auxiliary functions, we only check the root expressions of a projection but do not dig i

[jira] [Assigned] (FLINK-6614) Applying function on window auxiliary function fails

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6614: Assignee: Fabian Hueske > Applying function on window auxiliary function fails > --

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

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

[GitHub] flink pull request #3928: [FLINK-6608] [security, config] Relax Kerberos log...

2017-05-17 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3928#discussion_r117009648 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -230,10 +231,21 @@ private void validate() {

[jira] [Created] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-05-17 Thread Andrey (JIRA)
Andrey created FLINK-6615: - Summary: tmp directory not cleaned up on shutdown Key: FLINK-6615 URL: https://issues.apache.org/jira/browse/FLINK-6615 Project: Flink Issue Type: Bug Affects Versions

[jira] [Closed] (FLINK-6583) Enable QueryConfig in count base GroupWindow

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6583. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3.0 with 36cac0fb

[jira] [Closed] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6589. Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 Implemented for 1.3.0 w

[jira] [Closed] (FLINK-6598) Remove useless param rowRelDataType of DataStreamGroupAggregate.

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6598. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for 1.3.0 with 056d9553d713834d18c1b3490a6e3f106

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

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

[GitHub] flink pull request #3928: [FLINK-6608] [security, config] Relax Kerberos log...

2017-05-17 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3928#discussion_r117003024 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -230,10 +231,21 @@ private void validate() {

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014051#comment-16014051 ] ASF GitHub Bot commented on FLINK-6608: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #3928: [FLINK-6608] [security, config] Relax Kerberos log...

2017-05-17 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/3928#discussion_r117001581 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -230,10 +231,21 @@ private void validate() {

[jira] [Updated] (FLINK-6583) Enable QueryConfig in count base GroupWindow

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6583: - Issue Type: Bug (was: New Feature) > Enable QueryConfig in count base GroupWindow > -

[jira] [Reopened] (FLINK-6583) Enable QueryConfig in count base GroupWindow

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-6583: -- > Enable QueryConfig in count base GroupWindow > > >

[jira] [Closed] (FLINK-6583) Enable QueryConfig in count base GroupWindow

2017-05-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6583. Resolution: Fixed > Enable QueryConfig in count base GroupWindow > -

[jira] [Commented] (FLINK-6598) Remove useless param rowRelDataType of DataStreamGroupAggregate.

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014028#comment-16014028 ] ASF GitHub Bot commented on FLINK-6598: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014030#comment-16014030 ] ASF GitHub Bot commented on FLINK-6589: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-6583) Enable QueryConfig in count base GroupWindow

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16014029#comment-16014029 ] ASF GitHub Bot commented on FLINK-6583: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3922: [FLINK-6598][table]Remove useless param rowRelData...

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

[GitHub] flink pull request #3912: [FLINK-6589] [core] Deserialize ArrayList with cap...

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

[GitHub] flink pull request #3919: [FLINK-6583][talbe]Enable QueryConfig in count bas...

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

[jira] [Commented] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013995#comment-16013995 ] ASF GitHub Bot commented on FLINK-6578: --- Github user kl0u closed the pull request at

[jira] [Commented] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

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

[GitHub] flink issue #3909: [FLINK-6578] Fix self-loop handling in SharedBuffer.

2017-05-17 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3909 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 and wishes so, or if the featur

[jira] [Commented] (FLINK-6536) Improve error message in SharedBuffer::put()

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

[jira] [Commented] (FLINK-6536) Improve error message in SharedBuffer::put()

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013993#comment-16013993 ] ASF GitHub Bot commented on FLINK-6536: --- Github user kl0u closed the pull request at

[GitHub] flink issue #3872: [FLINK-6536] [cep] Improve error message in SharedBuffer:...

2017-05-17 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3872 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 and wishes so, or if the featur

[jira] [Commented] (FLINK-6609) Wrong version assignment when multiple TAKEs transitions

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

[GitHub] flink pull request #3872: [FLINK-6536] [cep] Improve error message in Shared...

2017-05-17 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/3872 --- 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 enable

[GitHub] flink pull request #3909: [FLINK-6578] Fix self-loop handling in SharedBuffe...

2017-05-17 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/3909 --- 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 enable

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6321: -- Priority: Critical (was: Blocker) > RocksDB state backend Checkpointing is not working with Key

[GitHub] flink issue #3927: [FLINK-6609] Wrong version assignment when multiple TAKEs...

2017-05-17 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3927 @dawidwys thanks a lot for the work! I merged it on the master and the 1.3 release. Could you close this PR and the related JIRA? --- If your project is set up for it, you can reply to this email and

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6116: -- Priority: Critical (was: Blocker) > Watermarks don't work when unioning with same DataStream >

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6116: -- Fix Version/s: (was: 1.3.0) > Watermarks don't work when unioning with same DataStream > ---

[jira] [Comment Edited] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013986#comment-16013986 ] Kostas Kloudas edited comment on FLINK-6321 at 5/17/17 1:05 PM:

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013986#comment-16013986 ] Kostas Kloudas commented on FLINK-6321: --- [~shashank734] I will have another look. Th

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013979#comment-16013979 ] Kostas Kloudas commented on FLINK-6321: --- [~rmetzger] I think it is ok to downgrade i

[jira] [Closed] (FLINK-6255) Remove PatternStream.getSideOutput()

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6255. - Resolution: Fixed Merged in 05ad87f4ce8c0aea6944feb14bf19795c1fc56c9 in master. > Remove PatternS

[jira] [Closed] (FLINK-6371) Return matched patterns as Map> instead of Map

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6371. - Resolution: Fixed Merged at ae9c9d061a8b49931c88908b8713cb2efe5f9202 in master. > Return matched

[jira] [Closed] (FLINK-6536) Improve error message in SharedBuffer::put()

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6536. - Resolution: Fixed Merged at 02ea418fb307876e1b957cad6be619a4d035d829 in master. > Improve error m

[jira] [Closed] (FLINK-6578) SharedBuffer creates self-loops when having elements with same value/timestamp.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6578. - Resolution: Fixed Merged at 8e4db423b79580de0cf66e905f8a66c12ea3748a in master. > SharedBuffer cr

[jira] [Closed] (FLINK-6604) Remove Java Serialization from the CEP library.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6604. - Resolution: Fixed > Remove Java Serialization from the CEP library. >

[jira] [Commented] (FLINK-6604) Remove Java Serialization from the CEP library.

2017-05-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013968#comment-16013968 ] Kostas Kloudas commented on FLINK-6604: --- Merged at 7a54d05ecd33b6dc140a7146f0efa90d6

[jira] [Updated] (FLINK-6613) OOM during reading big messages from Kafka

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6613: -- Component/s: Kafka Connector > OOM during reading big messages from Kafka >

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013952#comment-16013952 ] Robert Metzger commented on FLINK-5636: --- I ran into the issue as well. [~david.wang

[jira] [Commented] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

2017-05-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013951#comment-16013951 ] Greg Hogan commented on FLINK-6611: --- It is sometimes desirable to run multiple TaskManag

[jira] [Created] (FLINK-6614) Applying function on window auxiliary function fails

2017-05-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6614: Summary: Applying function on window auxiliary function fails Key: FLINK-6614 URL: https://issues.apache.org/jira/browse/FLINK-6614 Project: Flink Issue Type

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013942#comment-16013942 ] Shashank Agarwal commented on FLINK-6321: - Hi [~kkl0u] , Please find SignalDeseri

[jira] [Commented] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013929#comment-16013929 ] Robert Metzger commented on FLINK-6318: --- What is the plan for this issue wrt to Flin

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013928#comment-16013928 ] Robert Metzger commented on FLINK-6321: --- Is this a issue still a blocker? is it okay

[jira] [Resolved] (FLINK-6587) Java Table API cannot parse function names starting with keywords

2017-05-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6587. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4: 9244106b334ef

[jira] [Commented] (FLINK-6328) Savepoints must not be counted as retained checkpoints

2017-05-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013923#comment-16013923 ] Robert Metzger commented on FLINK-6328: --- [~StephanEwen] is this a blocker for the 1.

[jira] [Commented] (FLINK-6587) Java Table API cannot parse function names starting with keywords

2017-05-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013921#comment-16013921 ] ASF GitHub Bot commented on FLINK-6587: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3923: [FLINK-6587] [table] Simplification and bug fixing...

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

[GitHub] flink issue #3877: [backport] [FLINK-6514] [build] Create a proper separate ...

2017-05-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3877 @StephanEwen can you manually close the PR? Thx. --- 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 thi

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

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

<    1   2   3   >