[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028097#comment-16028097 ] sunjincheng commented on FLINK-6736: Actually, we can use a window after a TableFuncti

[jira] [Comment Edited] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028097#comment-16028097 ] sunjincheng edited comment on FLINK-6736 at 5/29/17 7:35 AM: -

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

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

[GitHub] flink pull request #4004: [FLINK-6695] Activate strict checkstyle in flink-c...

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4004#discussion_r118881170 --- Diff: flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/split/SplitBoltTopology.java --- @@ -28,7 +28,7 @@ import org.apache.s

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

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

[jira] [Comment Edited] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028097#comment-16028097 ] sunjincheng edited comment on FLINK-6736 at 5/29/17 7:37 AM: -

[GitHub] flink pull request #4004: [FLINK-6695] Activate strict checkstyle in flink-c...

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4004#discussion_r118881130 --- Diff: flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/FiniteRandomSpout.java --- @@ -32,8 +32,8 @@ import ja

[jira] [Comment Edited] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028097#comment-16028097 ] sunjincheng edited comment on FLINK-6736 at 5/29/17 7:39 AM: -

[jira] [Comment Edited] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028097#comment-16028097 ] sunjincheng edited comment on FLINK-6736 at 5/29/17 7:40 AM: -

[GitHub] flink issue #3942: FLINK-6379 Mesos ResourceManager (FLIP-6)

2017-05-29 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3942 Thanks for your contribution @EronWright. I will try to review and merge this PR this week. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager

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

[GitHub] flink issue #4004: [FLINK-6695] Activate strict checkstyle in flink-contrib

2017-05-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4004 @greghogan fixed. --- 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 i

[jira] [Commented] (FLINK-6695) Activate strict checkstyle in flink-contrib

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

[jira] [Created] (FLINK-6754) Savepoints don't respect client timeout config

2017-05-29 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-6754: - Summary: Savepoints don't respect client timeout config Key: FLINK-6754 URL: https://issues.apache.org/jira/browse/FLINK-6754 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-1313) Add support for out-of-place aggregations for streaming

2017-05-29 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1313. - Resolution: Won't Fix > Add support for out-of-place aggregations for streaming >

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink issue #4003: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-05-29 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/4003 @fhueske - Fine for me! I just wanted to finish this as well :) --- 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] [Created] (FLINK-6755) Allow triggering Checkpoints through command line client

2017-05-29 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-6755: - Summary: Allow triggering Checkpoints through command line client Key: FLINK-6755 URL: https://issues.apache.org/jira/browse/FLINK-6755 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6754) Savepoints don't respect client timeout config

2017-05-29 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-6754: -- Affects Version/s: 1.3.0 1.2.1 > Savepoints don't respect client timeout config >

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4006 [FLINK-6478] [doc] Document how to upgrade state serializers This PR adds documentation on how use custom serializers for managed, as well as handling upgrades to the serializers. We could

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-29 Thread nragon
Github user nragon commented on the issue: https://github.com/apache/flink/pull/2332 From my point of view, my sample works fine (my use case) --- 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

[jira] [Created] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2017-05-29 Thread Andrea Spina (JIRA)
Andrea Spina created FLINK-6756: --- Summary: Provide RichAsyncFunction to Scala API suite Key: FLINK-6756 URL: https://issues.apache.org/jira/browse/FLINK-6756 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-6757) Investigate Apache Atlas integration

2017-05-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6757: Summary: Investigate Apache Atlas integration Key: FLINK-6757 URL: https://issues.apache.org/jira/browse/FLINK-6757 Project: Flink Issue Type: Wish

[GitHub] flink issue #4005: [FLINK-6699] Add checkstyle plugin to flink-yarn-tests po...

2017-05-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4005 merging. --- 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 fea

[jira] [Commented] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

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

[jira] [Closed] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

2017-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6699. --- Resolution: Fixed Checkstyle plugin was added to pom for 1.4 in 89f0ad90b8551a1b617b7f9179b65

[jira] [Commented] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

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

[GitHub] flink pull request #4005: [FLINK-6699] Add checkstyle plugin to flink-yarn-t...

2017-05-29 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4005 --- 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] [Created] (FLINK-6758) Loaded configuration values are logged twice

2017-05-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6758: --- Summary: Loaded configuration values are logged twice Key: FLINK-6758 URL: https://issues.apache.org/jira/browse/FLINK-6758 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2017-05-29 Thread Andrea Spina (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrea Spina updated FLINK-6756: Description: I can't find any tracking info about the chance to have RichAsyncFunction in the Scala

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2017-05-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028170#comment-16028170 ] Till Rohrmann commented on FLINK-6756: -- I think there is nothing forbidding the imple

[jira] [Created] (FLINK-6759) storm-examples cannot be built without cached dependencies

2017-05-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6759: --- Summary: storm-examples cannot be built without cached dependencies Key: FLINK-6759 URL: https://issues.apache.org/jira/browse/FLINK-6759 Project: Flink

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118901207 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118905107 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118900486 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118903664 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118904745 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118906172 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,140 @@ public static class CounterSource Some operators might need the information when a

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[GitHub] flink pull request #4006: [FLINK-6478] [doc] Document how to upgrade state s...

2017-05-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4006#discussion_r118906667 --- Diff: docs/dev/stream/state.md --- @@ -429,3 +429,120 @@ public static class CounterSource Some operators might need the information when a ch

[GitHub] flink issue #4006: [FLINK-6478] [doc] Document how to upgrade state serializ...

2017-05-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4006 Thanks a lot for the helpful suggestions @alpinegizmo! I've addressed them. Also, an additional subsection "Managing `TypeSerializer` and `TypeSerializerConfigSnapshot` classes in user code"

[jira] [Commented] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

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

[jira] [Updated] (FLINK-6717) NullPointerException from MessageAcknowledgingSourceBase

2017-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6717: Component/s: (was: Streaming) Streaming Connectors > NullPointerExcepti

[jira] [Updated] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2017-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6719: Component/s: DataStream API > Add details about fault-tolerance of timers to ProcessFunction

[jira] [Updated] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

2017-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6726: Component/s: (was: Streaming) DataStream API > Allow setting Timers in

[jira] [Commented] (FLINK-6759) storm-examples cannot be built without cached dependencies

2017-05-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028209#comment-16028209 ] Aljoscha Krettek commented on FLINK-6759: - I would actually be in favour of removi

[jira] [Commented] (FLINK-6333) Utilize Bloomfilters in RocksDb

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028212#comment-16028212 ] Stefan Richter commented on FLINK-6333: --- This issue still exists after some testing

[jira] [Created] (FLINK-6760) Fix OverWindowTest alias test error

2017-05-29 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6760: -- Summary: Fix OverWindowTest alias test error Key: FLINK-6760 URL: https://issues.apache.org/jira/browse/FLINK-6760 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #4007: [FLINK-6760][table]Fix OverWindowTest alias test e...

2017-05-29 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4007 [FLINK-6760][table]Fix OverWindowTest alias test error - [x] General - The pull request references the related JIRA issue ("[FLINK-6760][table]Fix OverWindowTest alias test error")

[jira] [Commented] (FLINK-6760) Fix OverWindowTest alias test error

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

[jira] [Updated] (FLINK-6619) Check Table API & SQL support for 1.3.0 RC01 Release

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6619: --- Description: In this JIRA. I will do the following tasks for Flink 1.3.0 RC01 Release. * Check that th

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028282#comment-16028282 ] Timo Walther commented on FLINK-6736: - I think I found the bug that caused this except

[jira] [Created] (FLINK-6761) Limitation for maximum state size per key in RocksDB backend

2017-05-29 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6761: - Summary: Limitation for maximum state size per key in RocksDB backend Key: FLINK-6761 URL: https://issues.apache.org/jira/browse/FLINK-6761 Project: Flink

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028291#comment-16028291 ] sunjincheng commented on FLINK-6736: Sounds very good to me!! > Fix UDTF codegen bug

[jira] [Updated] (FLINK-6761) Limitation for maximum state size per key in RocksDB backend

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6761: -- Description: RocksDB`s JNI bridge allows for putting and getting {{byte[]}} as keys and values.

[GitHub] flink pull request #4008: [FLINK-6736] [table] Fix UDTF field access with ti...

2017-05-29 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4008 [FLINK-6736] [table] Fix UDTF field access with time attribute record A wrong physical index caused the code generation to fail. You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

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

[GitHub] flink issue #3984: [FLINK-6710] Remove Twitter-InputFormat

2017-05-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3984 Maybe we should discuss this on the ML. I know at least one user that used it for fast prototyping a Flink demo application. Maybe it adds not much value but allows for quickly showing a nice streami

[jira] [Commented] (FLINK-6710) Remove twitter-inputformat

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

[jira] [Commented] (FLINK-6737) Fix over expression parse String error.

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028306#comment-16028306 ] Timo Walther commented on FLINK-6737: - I'm also against this change. We should keep Ja

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

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

[GitHub] flink issue #4008: [FLINK-6736] [table] Fix UDTF field access with time attr...

2017-05-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4008 @sunjincheng121 does it fix your issue? --- 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 enab

[jira] [Assigned] (FLINK-6760) Fix OverWindowTest alias test error

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6760: -- Assignee: Timo Walther (was: sunjincheng) > Fix OverWindowTest alias test error >

[jira] [Assigned] (FLINK-6760) Fix OverWindowTest alias test error

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6760: -- Assignee: sunjincheng (was: Timo Walther) > Fix OverWindowTest alias test error >

[jira] [Assigned] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6736: -- Assignee: Timo Walther (was: sunjincheng) > Fix UDTF codegen bug when window follow by join( U

[jira] [Closed] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

2017-05-29 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-6689. -- Resolution: Won't Fix Fix Version/s: (was: 1.3.0) {{org.apache.flink.streaming.util.TestStrea

[GitHub] flink issue #3984: [FLINK-6710] Remove Twitter-InputFormat

2017-05-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3984 Then let's replace it with a generic JsonInputFormat that supports even more use-cases without 1900 lines of bloat. --- If your project is set up for it, you can reply to this email and have your rep

[GitHub] flink issue #4007: [FLINK-6760][table]Fix OverWindowTest alias test error

2017-05-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4007 Thanks @sunjincheng121, I will merge this. --- 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 e

[jira] [Commented] (FLINK-6710) Remove twitter-inputformat

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

[jira] [Commented] (FLINK-6760) Fix OverWindowTest alias test error

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

[GitHub] flink pull request #4009: [FLINK-6732] Activate strict-checkstyle for flink-...

2017-05-29 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4009 [FLINK-6732] Activate strict-checkstyle for flink-java Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If yo

[jira] [Commented] (FLINK-6732) Activate strict checkstyle for flink-java

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

[jira] [Assigned] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6747: --- Assignee: Timo Walther > Table API / SQL Docs: Streaming Page > -

[GitHub] flink issue #4009: [FLINK-6732] Activate strict-checkstyle for flink-java

2017-05-29 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4009 I've created set of changes that remove ~3k checkstyle violations in flink-java. I had doubts about changing some `public static final classes` into `private static final classes` e.g in `

[GitHub] flink pull request #4008: [FLINK-6736] [table] Fix UDTF field access with ti...

2017-05-29 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4008#discussion_r118935465 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverterTest.scala --- @@ -391,8 +391,8 @@ objec

[jira] [Assigned] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-6750: --- Assignee: Timo Walther > Table API / SQL Docs: Table Sources & Sinks Page > -

[jira] [Commented] (FLINK-5354) Split up Table API documentation into multiple pages

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028332#comment-16028332 ] Timo Walther commented on FLINK-5354: - [~fhueske] I will work on the streaming page.

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

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

[jira] [Commented] (FLINK-6732) Activate strict checkstyle for flink-java

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

[jira] [Comment Edited] (FLINK-5354) Split up Table API documentation into multiple pages

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028332#comment-16028332 ] Timo Walther edited comment on FLINK-5354 at 5/29/17 1:30 PM: --

[jira] [Assigned] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2017-05-29 Thread Andrea Spina (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrea Spina reassigned FLINK-6756: --- Assignee: Andrea Spina > Provide RichAsyncFunction to Scala API suite > -

[GitHub] flink issue #4009: [FLINK-6732] Activate strict-checkstyle for flink-java

2017-05-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4009 If a function is tagged as `@Internal` or in a class tagged as such then we should be able to restrict the visibility. Would be good if you could reply in the JIRA for the tuple checkstyle exclusion.

[jira] [Commented] (FLINK-6732) Activate strict checkstyle for flink-java

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

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

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

[GitHub] flink pull request #4008: [FLINK-6736] [table] Fix UDTF field access with ti...

2017-05-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4008#discussion_r118938233 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverterTest.scala --- @@ -391,8 +391,8 @@ object RelTi

[jira] [Commented] (FLINK-6736) Fix UDTF codegen bug when window follow by join( UDTF)

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

[GitHub] flink issue #4008: [FLINK-6736] [table] Fix UDTF field access with time attr...

2017-05-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4008 @sunjincheng121 I will add another ITCase just to be sure. --- 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 hav

[jira] [Commented] (FLINK-6737) Fix over expression parse String error.

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028344#comment-16028344 ] sunjincheng commented on FLINK-6737: [~twalthr][~fhueske] Agree with you. I have updat

[jira] [Commented] (FLINK-6760) Fix OverWindowTest alias test error

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

[GitHub] flink pull request #4007: [FLINK-6760][table]Fix OverWindowTest alias test e...

2017-05-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4007 --- 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] [Resolved] (FLINK-6760) Fix OverWindowTest alias test error

2017-05-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6760. - Resolution: Fixed Fix Version/s: 1.4.0 Fixed in 1.4.0: 6b69c588df866c7b1694a58a433f7957bee4

[jira] [Commented] (FLINK-6734) Exclude org.apache.flink.api.java.tuple from checkstyle AvoidStarImport

2017-05-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028348#comment-16028348 ] Dawid Wysakowicz commented on FLINK-6734: - 6 in flink-java After a quick search i

  1   2   >