[jira] [Assigned] (FLINK-6584) Support multiple consecutive windows in SQL

2017-05-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6584: --- Assignee: Timo Walther > Support multiple consecutive windows in SQL > --

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

2017-05-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020822#comment-16020822 ] Timo Walther commented on FLINK-6584: - [~sunjincheng121] if it is ok, I would work on

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

[GitHub] flink pull request #3943: [FLINK-6617][table] Improve JAVA and SCALA logical...

2017-05-23 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3943#discussion_r117928792 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/validation/GroupWindowAggregationsTest.scala --- @@ -16,1

[GitHub] flink pull request #3943: [FLINK-6617][table] Improve JAVA and SCALA logical...

2017-05-23 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3943#discussion_r117929380 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/TableTestBase.scala --- @@ -120,7 +125,8 @@ object TableTestUtil { }

[jira] [Commented] (FLINK-6617) Improve JAVA and SCALA logical plans consistent test

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

[jira] [Comment Edited] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020789#comment-16020789 ] Stefan Richter edited comment on FLINK-6537 at 5/23/17 8:33 AM:

[GitHub] flink pull request #3943: [FLINK-6617][table] Improve JAVA and SCALA logical...

2017-05-23 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3943#discussion_r117929561 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/stringexpr/UnionStringExpressionTest.scala --- @@ -0,0 +1

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

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

[GitHub] flink pull request #3965: [FLINK-6328] [chkPts] Don't add savepoints to Comp...

2017-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3965 --- 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-6328) Savepoints must not be counted as retained checkpoints

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

[GitHub] flink issue #3965: [FLINK-6328] [chkPts] Don't add savepoints to CompletedCh...

2017-05-23 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3965 Thanks for the review @tony810430 and @rmetzger. 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

[jira] [Commented] (FLINK-6603) Enable checkstyle on test sources

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

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

2017-05-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020795#comment-16020795 ] Robert Metzger commented on FLINK-6656: --- Merged to 1.3 in http://git-wip-us.apache.o

[GitHub] flink pull request #3941: [FLINK-6603] [streaming] Enable checkstyle on test...

2017-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3941 --- 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-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020789#comment-16020789 ] Stefan Richter edited comment on FLINK-6537 at 5/23/17 8:23 AM:

[jira] [Comment Edited] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020789#comment-16020789 ] Stefan Richter edited comment on FLINK-6537 at 5/23/17 8:23 AM:

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

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

[GitHub] flink issue #3961: [FLINK-6656] [cep] Change element PriorityQueue to MapSta...

2017-05-23 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3961 @kl0u asked me to merge this PR to the release-1.3 branch. It seems the change is good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Assigned] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6662: Assignee: Till Rohrmann > ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recov

[jira] [Comment Edited] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020789#comment-16020789 ] Stefan Richter edited comment on FLINK-6537 at 5/23/17 8:20 AM:

[jira] [Commented] (FLINK-6662) ClassNotFoundException: o.a.f.r.j.t.JobSnapshottingSettings recovering job

2017-05-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020788#comment-16020788 ] Till Rohrmann commented on FLINK-6662: -- +1 for improving the exception message. I wil

[jira] [Commented] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-23 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020789#comment-16020789 ] Stefan Richter commented on FLINK-6537: --- I had a look at those logs, but they seem s

[jira] [Commented] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

2017-05-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020778#comment-16020778 ] Till Rohrmann commented on FLINK-4112: -- I think this issue is outdated by now. Closin

[jira] [Closed] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

2017-05-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4112. Resolution: Won't Fix > Replace SuppressRestartException with disabling RestartStrategy > --

[jira] [Commented] (FLINK-6650) Fix Non-windowed group-aggregate error when using append-table mode.

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

[jira] [Updated] (FLINK-6670) remove CommonTestUtils.createTempDirectory()

2017-05-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6670: --- Description: {{CommonTestUtils.createTempDirectory()}} encourages a dangerous design pattern with pot

[GitHub] flink pull request #3958: [FLINK-6650][table] Improve the error message for ...

2017-05-23 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/3958#discussion_r117724493 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala --- @@ -629,8 +629,7 @@ abstract class StreamTa

[jira] [Commented] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

2017-05-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020772#comment-16020772 ] Nico Kruber commented on FLINK-6659: (I created the follow-up FLINK-6670 to remove the

[jira] [Created] (FLINK-6670) remove CommonTestUtils.createTempDirectory()

2017-05-23 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6670: -- Summary: remove CommonTestUtils.createTempDirectory() Key: FLINK-6670 URL: https://issues.apache.org/jira/browse/FLINK-6670 Project: Flink Issue Type: Bug

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

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

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

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117917812 --- Diff: flink-libraries/flink-streaming-python/pom.xml --- @@ -0,0 +1,99 @@ + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001

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

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

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

2017-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3838#discussion_r117917576 --- Diff: flink-libraries/flink-streaming-python/pom.xml --- @@ -0,0 +1,99 @@ + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020758#comment-16020758 ] Chesnay Schepler commented on FLINK-6494: - no. > Migrate ResourceManager configur

[jira] [Comment Edited] (FLINK-6668) Add flink history server to DCOS

2017-05-23 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020749#comment-16020749 ] Stavros Kontopoulos edited comment on FLINK-6668 at 5/23/17 7:20 AM: ---

[jira] [Commented] (FLINK-6668) Add flink history server to DCOS

2017-05-23 Thread Stavros Kontopoulos (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020749#comment-16020749 ] Stavros Kontopoulos commented on FLINK-6668: In DC/OS spark history server is

[jira] [Assigned] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-6038: -- Assignee: David Anderson (was: Tzu-Li (Gordon) Tai) > Add deep links to Apache

[jira] [Commented] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations

2017-05-23 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020741#comment-16020741 ] Tzu-Li (Gordon) Tai commented on FLINK-6038: Sure! I've also reviewed FLINK-66

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3964#discussion_r117914510 --- Diff: docs/dev/connectors/index.md --- @@ -25,22 +25,54 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3964#discussion_r117913544 --- Diff: docs/dev/connectors/index.md --- @@ -25,22 +25,54 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[jira] [Commented] (FLINK-6660) expand the streaming connectors overview page

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

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3964#discussion_r117914005 --- Diff: docs/dev/connectors/index.md --- @@ -25,22 +25,54 @@ specific language governing permissions and limitations under the License. -->

[GitHub] flink pull request #3964: [FLINK-6660][docs] expand the connectors overview ...

2017-05-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3964#discussion_r117913269 --- Diff: docs/dev/connectors/index.md --- @@ -25,22 +25,54 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-6654) missing maven dependency on "flink-shaded-hadoop2-uber" in flink-dist

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

[GitHub] flink issue #3960: [FLINK-6654][build] let 'flink-dist' properly depend on '...

2017-05-23 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3960 I wasn't quite sure and went the safe way - can remove the exclusion though... --- 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 p

<    1   2   3