[jira] [Commented] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

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

[GitHub] flink pull request #3101: [FLINK-5406] [table] add normalization phase for p...

2017-02-05 Thread godfreyhe
Github user godfreyhe commented on a diff in the pull request: https://github.com/apache/flink/pull/3101#discussion_r99524112 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RuleSetConfig.scala --- @@ -0,0 +1,140 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

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

[GitHub] flink pull request #3101: [FLINK-5406] [table] add normalization phase for p...

2017-02-05 Thread godfreyhe
Github user godfreyhe commented on a diff in the pull request: https://github.com/apache/flink/pull/3101#discussion_r99522172 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/AggregationTest.scala --- @@ -165,14 +165,20 @@ class AggregationTest extends

[jira] [Commented] (FLINK-4047) Fix documentation about determinism of KeySelectors

2017-02-05 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853460#comment-15853460 ] Artem Stasiuk commented on FLINK-4047: -- So we just need to specify that for same value

[jira] [Commented] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

2017-02-05 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853453#comment-15853453 ] Syinchwun Leo commented on FLINK-5572: -- I try to find a common way to abstract the States in

[jira] [Commented] (FLINK-5219) Add non-grouped session windows for batch tables

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

[GitHub] flink issue #3266: [FLINK-5219][TableAPI] Add non-grouped session window...

2017-02-05 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3266 @fhueske @twalthr In this PR,I In order to code reuse "DataSetSessionWindowAggregatePreProcessor" has implemented the "MapPartitionFunction" and "GroupCombineFunction" two interfaces, I'm

[jira] [Assigned] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-05 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhong Hong reassigned FLINK-5657: -- Assignee: sunjincheng (was: Yuhong Hong) > Add processing time OVER RANGE BETWEEN UNBOUNDED

[jira] [Assigned] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-05 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuhong Hong reassigned FLINK-5657: -- Assignee: Yuhong Hong (was: sunjincheng) > Add processing time OVER RANGE BETWEEN UNBOUNDED

[jira] [Commented] (FLINK-5153) Allow setting custom application tags for Flink on YARN

2017-02-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853417#comment-15853417 ] ASF GitHub Bot commented on FLINK-5153: --- Github user patricklucas commented on the issue:

[GitHub] flink issue #3268: [FLINK-5153] Support YARN application tags

2017-02-05 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/3268 I manually tested the behavior of this new feature as well as the other YARN application options touched by this change with various Hadoop versions (2.3/2.4/2.6) on a YARN cluster.

[jira] [Commented] (FLINK-5153) Allow setting custom application tags for Flink on YARN

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

[GitHub] flink pull request #3268: [FLINK-5153] Support YARN application tags

2017-02-05 Thread patricklucas
GitHub user patricklucas opened a pull request: https://github.com/apache/flink/pull/3268 [FLINK-5153] Support YARN application tags Adds a new config option `yarn.tags`, a comma-separated list of strings passed to YARN as application tags. You can merge this pull request into

[jira] [Closed] (FLINK-5652) Memory leak in AsyncDataStream

2017-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5652. Resolution: Fixed 1.3.0: 215776b81a52cd380e8ccabd65da612f77da25e6 1.2.1:

[jira] [Commented] (FLINK-2211) Generalize ALS API

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

[jira] [Commented] (FLINK-5652) Memory leak in AsyncDataStream

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

[GitHub] flink pull request #3265: [FLINK-2211] [ml] Generalize ALS API

2017-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3265 --- 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] [Closed] (FLINK-2211) Generalize ALS API

2017-02-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2211. Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 43d2fd23a75a5ac7769d37cb5c2559803bd65800 >

[GitHub] flink pull request #3264: [FLINK-5652] [asyncIO] Cancel timers when completi...

2017-02-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3264 --- 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-2211) Generalize ALS API

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

[jira] [Commented] (FLINK-5652) Memory leak in AsyncDataStream

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

[GitHub] flink issue #3264: [FLINK-5652] [asyncIO] Cancel timers when completing a St...

2017-02-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3264 Travis passed. Merging this PR. --- 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

[GitHub] flink issue #3265: [FLINK-2211] [ml] Generalize ALS API

2017-02-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3265 Travis passed. Merging this PR. --- 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-4602) Move RocksDB backed to proper package

2017-02-05 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853356#comment-15853356 ] Eron Wright commented on FLINK-4602: - It might be wise to keep RocksDB as a separate dependency, and

[jira] [Assigned] (FLINK-5153) Allow setting custom application tags for Flink on YARN

2017-02-05 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Lucas reassigned FLINK-5153: Assignee: Patrick Lucas > Allow setting custom application tags for Flink on YARN >

[jira] [Assigned] (FLINK-1588) Load flink configuration also from classloader

2017-02-05 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Lucas reassigned FLINK-1588: Assignee: Patrick Lucas > Load flink configuration also from classloader >

[jira] [Created] (FLINK-5713) Protect against NPE in WindowOperator window cleanup

2017-02-05 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5713: --- Summary: Protect against NPE in WindowOperator window cleanup Key: FLINK-5713 URL: https://issues.apache.org/jira/browse/FLINK-5713 Project: Flink

[jira] [Commented] (FLINK-5690) protobuf is not shaded properly

2017-02-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853217#comment-15853217 ] Robert Metzger commented on FLINK-5690: --- Thank you for providing an example. I'll look into the