[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=16028282#comment-16028282 ] Timo Walther commented on FLINK-6736: - I think I found the bug that caused this exception. I will open

[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=16028291#comment-16028291 ] sunjincheng commented on FLINK-6736: Sounds very good to me!! > Fix UDTF codegen bug when window

[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=16028297#comment-16028297 ] ASF GitHub Bot commented on FLINK-6710: --- Github user twalthr 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=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

[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=16028333#comment-16028333 ] ASF GitHub Bot commented on FLINK-6736: --- Github user sunjincheng121 commented on a diff in the pull

[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=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=16028332#comment-16028332 ] Timo Walther edited comment on FLINK-5354 at 5/29/17 1:30 PM: -- [~fhueske] I

[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=16028346#comment-16028346 ] ASF GitHub Bot commented on FLINK-6760: --- Github user asfgit closed the pull request at:

[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

[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=16028344#comment-16028344 ] sunjincheng commented on FLINK-6737: [~twalthr][~fhueske] Agree with you. I have updated the PR. And

[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:

[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] [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 >

[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

[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=16028327#comment-16028327 ] ASF GitHub Bot commented on FLINK-6732: --- GitHub user dawidwys opened a pull request:

[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.

[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-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=16028306#comment-16028306 ] Timo Walther commented on FLINK-6737: - I'm also against this change. We should keep Java and Scala API

[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 >

[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 >

[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=16028342#comment-16028342 ] ASF GitHub Bot commented on FLINK-6736: --- Github user twalthr commented on a diff in the pull

[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=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

[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

[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=16028365#comment-16028365 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028368#comment-16028368 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028366#comment-16028366 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028369#comment-16028369 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028367#comment-16028367 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028364#comment-16028364 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

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

2017-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028378#comment-16028378 ] Chesnay Schepler commented on FLINK-6734: - yes, they will have to be expanded. > Exclude

[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

[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

[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(

[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 >

[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

[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=16028339#comment-16028339 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on the issue:

[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=16028352#comment-16028352 ] ASF GitHub Bot commented on FLINK-6732: --- Github user dawidwys commented on the issue:

[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 Right, but won't there be any serialization issues? I found a comment like which made me ask that question: `// Nested classes are only "public static" for Kryo serialization, otherwise they'd

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

2017-05-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028361#comment-16028361 ] Chesnay Schepler commented on FLINK-6734: - With so few affected classes I would like to remove

[jira] [Commented] (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:comment-tabpanel=16028363#comment-16028363 ] Stefan Richter commented on FLINK-6761: --- Opened a corresponding issue in the RocksDB tracker:

[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=16028362#comment-16028362 ] Dawid Wysakowicz commented on FLINK-6734: - Ok, but then we would need to expand the star imports,

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118939832 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/io/LocalCollectionOutputFormat.java --- @@ -33,7 +33,7 @@ import java.util.Map;

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118940089 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java --- @@ -114,41 +114,41 @@ public O

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118940280 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java --- @@ -192,41 +192,41 @@ public O

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118940257 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java --- @@ -117,41 +117,41 @@ public O withBroadcastSet(DataSet

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118941471 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java --- @@ -141,7 +141,7 @@ public void mapPartition(Iterable values,

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118940189 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java --- @@ -114,41 +114,41 @@ public O

[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 eh...the commits just jumped around so i assume you just force pushed? From this point on please don't. As for kryo, well you got me there. Frankly i don't know where we use kryo or

[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=16028376#comment-16028376 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on the issue:

[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

[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=16028294#comment-16028294 ] ASF GitHub Bot commented on FLINK-6736: --- GitHub user twalthr opened a pull request:

[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)

[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=16028320#comment-16028320 ] ASF GitHub Bot commented on FLINK-6760: --- Github user twalthr commented on the issue:

[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=16028319#comment-16028319 ] ASF GitHub Bot commented on FLINK-6710: --- Github user zentol commented on the issue:

[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

[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 @@

[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

[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=16028332#comment-16028332 ] Timo Walther commented on FLINK-5354: - [~fhueske] I will work on the streaming page. > Split up Table

[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-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=16028348#comment-16028348 ] Dawid Wysakowicz commented on FLINK-6734: - 6 in flink-java After a quick search in other modules

[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 Yes sorry for that, Just wanted to remove the `AvoidStarImport` commit from in the middle. Any further changes will do with new commits. --- If your project is set up for it, you can reply to this

[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=16028380#comment-16028380 ] ASF GitHub Bot commented on FLINK-6736: --- Github user asfgit closed the pull request at:

[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=16028379#comment-16028379 ] ASF GitHub Bot commented on FLINK-6732: --- Github user dawidwys commented on the issue:

[jira] [Comment Edited] (FLINK-6762) Cannot rescale externalized incremental checkpoints

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028487#comment-16028487 ] Stefan Richter edited comment on FLINK-6762 at 5/29/17 4:02 PM: FYI, I

[jira] [Commented] (FLINK-6762) Cannot rescale externalized incremental checkpoints

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028487#comment-16028487 ] Stefan Richter commented on FLINK-6762: --- FYI, I think we can can ALMOST support this by changing

[jira] [Commented] (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:comment-tabpanel=16028506#comment-16028506 ] Andrea Spina commented on FLINK-6756: - Ok, thank you. I'll provide an implementation of it asap. >

[jira] [Commented] (FLINK-6753) Flaky SqlITCase

2017-05-29 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028503#comment-16028503 ] sunjincheng commented on FLINK-6753: Can you tell me what you did to get this exception? I can do the

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

2017-05-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4008 --- 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] [Resolved] (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:all-tabpanel ] Timo Walther resolved FLINK-6737. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4.0:

[jira] [Created] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

2017-05-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6763: Summary: Inefficient PojoSerializerConfigSnapshot serialization format Key: FLINK-6763 URL: https://issues.apache.org/jira/browse/FLINK-6763 Project: Flink

[jira] [Commented] (FLINK-6762) Cannot rescale externalized incremental checkpoints

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028449#comment-16028449 ] Stefan Richter commented on FLINK-6762: --- Officially, we currently do not want to support rescaling

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

2017-05-29 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028458#comment-16028458 ] radu commented on FLINK-6075: - TOP syntax is not supported by Calcite. Basically top is obtained by using

[jira] [Commented] (FLINK-6766) Update documentation with async backends and incremental checkpoints

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

[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=16028394#comment-16028394 ] Dawid Wysakowicz commented on FLINK-6734: - Ok, so I will close this issue. > Exclude

[GitHub] flink pull request #4000: [FLINK-6737][table]Add over method supported strin...

2017-05-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4000 --- 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-6737) Fix over expression parse String error.

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

[jira] [Closed] (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:all-tabpanel ] Dawid Wysakowicz closed FLINK-6734. --- Resolution: Not A Problem > Exclude org.apache.flink.api.java.tuple from checkstyle

[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=16028401#comment-16028401 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118943716 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1666,29 +1666,29 @@ public void printToErr() throws Exception {

[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=16028402#comment-16028402 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on the issue:

[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 I've noticed some `` tags here and there, could replace those 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] [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=16028422#comment-16028422 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028415#comment-16028415 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028421#comment-16028421 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028417#comment-16028417 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028419#comment-16028419 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028418#comment-16028418 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028420#comment-16028420 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[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=16028416#comment-16028416 ] ASF GitHub Bot commented on FLINK-6732: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4010: [FLINK-6753] [table] Fix flaky SqlITCase due to Ja...

2017-05-29 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4010 [FLINK-6753] [table] Fix flaky SqlITCase due to Janino bug I hope this fixes the flaky test. Otherwise we have to ask the Janino guys about this error. You can merge this pull request into a Git

[jira] [Comment Edited] (FLINK-6762) Cannot rescale externalized incremental checkpoints

2017-05-29 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028449#comment-16028449 ] Stefan Richter edited comment on FLINK-6762 at 5/29/17 3:19 PM:

[jira] [Created] (FLINK-6765) PojoSerializer returns wrong ConvertDeserializer when migration is required

2017-05-29 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6765: Summary: PojoSerializer returns wrong ConvertDeserializer when migration is required Key: FLINK-6765 URL: https://issues.apache.org/jira/browse/FLINK-6765 Project:

[jira] [Resolved] (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:all-tabpanel ] Timo Walther resolved FLINK-6736. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4.0:

[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 Yes, a generic JsonInputFormat would be a nice addition. --- 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] [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=16028399#comment-16028399 ] ASF GitHub Bot commented on FLINK-6710: --- Github user twalthr commented on the issue:

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118946203 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/aggregation/SumAggregationFunction.java --- @@ -26,6 +26,10 @@ import

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118946093 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/aggregation/Aggregations.java --- @@ -20,6 +20,9 @@ import

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

2017-05-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4009#discussion_r118948292 --- Diff: flink-java/src/test/java/org/apache/flink/api/common/operators/base/InnerJoinOperatorBaseTest.java --- @@ -45,6 +45,9 @@ import static

  1   2   >