[jira] [Commented] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476138#comment-15476138 ] ASF GitHub Bot commented on FLINK-4462: --- Github user ramkrish86 commented on the iss

[jira] [Created] (FLINK-4601) Check for empty string properly

2016-09-08 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4601: -- Summary: Check for empty string properly Key: FLINK-4601 URL: https://issues.apache.org/jira/browse/FLINK-4601 Project: Flink Issue Type: Bug

[GitHub] flink issue #2412: FLINK-4462 Add RUN_TIME retention policy for all the flin...

2016-09-08 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2412 @StephanEwen As said above am not sure how to use the japicmp library. I can see that from the IDE am not able to use any of the APIs provided from the library. May be am missing something?

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476131#comment-15476131 ] ramkrishna.s.vasudevan commented on FLINK-3322: --- [~ggevay] I once again chec

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476073#comment-15476073 ] Fabian Hueske commented on FLINK-4591: -- I'm not sure about this. What would you do w

[jira] [Updated] (FLINK-4591) Select star does not work with grouping

2016-09-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4591: - Description: It would be consistent if this would also work: {{table.groupBy( '* ).select( "* )}}

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476058#comment-15476058 ] Jark Wu commented on FLINK-4591: Make sense. I will look into it. > Select star does not

[jira] [Assigned] (FLINK-4591) Select star does not work with grouping

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4591: -- Assignee: Jark Wu > Select star does not work with grouping > --- >

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476035#comment-15476035 ] ASF GitHub Bot commented on FLINK-4579: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #2482: [FLINK-4579] [StateBackend] Add StateBackendFactor...

2016-09-08 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2482 [FLINK-4579] [StateBackend] Add StateBackendFactory for RocksDB Backend Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consider

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475975#comment-15475975 ] ramkrishna.s.vasudevan commented on FLINK-3322: --- [~ggevay] Thanks for the in

[jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475827#comment-15475827 ] ASF GitHub Bot commented on FLINK-4546: --- Github user wuchong commented on the issue:

[GitHub] flink issue #2454: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

2016-09-08 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2454 Hi @fhueske @twalthr , do you have time to have a look again? Any advices are welcome. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-09-08 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 I have noticed the issue occasionally in master branch too but very inconsistent. I just rebased against the latest master and ran "mvn clean verify". I don't see any errors. I have tried couple o

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475694#comment-15475694 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15475107#comment-15475107 ] ASF GitHub Bot commented on FLINK-3921: --- Github user rekhajoshm commented on the iss

[GitHub] flink issue #2060: [FLINK-3921] StringParser encoding

2016-09-08 Thread rekhajoshm
Github user rekhajoshm commented on the issue: https://github.com/apache/flink/pull/2060 Hi @greghogan sorry, lost thread on this, updated for Preconditions check now. Unless i am missing something, the enableQuotedStringParsing() is present in subclasses as it is slightly different t

[jira] [Closed] (FLINK-4571) Configurable little parallelism in Gelly drivers

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4571. - Resolution: Fixed Fix Version/s: (was: 1.2.0) Fixed in bdd3c0d94b2a6cdecb482ee3fdefe082fc1b7c4d

[jira] [Updated] (FLINK-4571) Configurable little parallelism in Gelly drivers

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4571: -- Fix Version/s: 1.2.0 > Configurable little parallelism in Gelly drivers > --

[jira] [Updated] (FLINK-4257) Handle delegating algorithm change of class

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4257: -- Fix Version/s: 1.2.0 > Handle delegating algorithm change of class > ---

[jira] [Closed] (FLINK-4257) Handle delegating algorithm change of class

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4257. - Resolution: Fixed Fixed in 8210ff468d64fc50520011fc6fed9909d2a6b89a > Handle delegating algorithm change

[jira] [Closed] (FLINK-4522) Gelly link broken in homepage

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4522. - Resolution: Fixed Fixed in 95ad865bd9d7121c80ecd4d1ed92e2912052a502 > Gelly link broken in homepage > ---

[jira] [Updated] (FLINK-4522) Gelly link broken in homepage

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4522: -- Fix Version/s: 1.2.0 > Gelly link broken in homepage > - > >

[jira] [Commented] (FLINK-4257) Handle delegating algorithm change of class

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

[jira] [Commented] (FLINK-4571) Configurable little parallelism in Gelly drivers

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

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

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

[GitHub] flink pull request #2475: [FLINK-4571] [gelly] Configurable little paralleli...

2016-09-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2475 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request #2474: [FLINK-4257] [gelly] Handle delegating algorithm c...

2016-09-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2474 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request #2464: [FLINK-4522] [docs] Gelly link broken in homepage

2016-09-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2464 --- 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-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474985#comment-15474985 ] ASF GitHub Bot commented on FLINK-3599: --- Github user Xazax-hun commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread Xazax-hun
Github user Xazax-hun commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78087961 --- Diff: flink-core/src/main/resources/PojoComparatorTemplate.ftl --- @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474979#comment-15474979 ] ASF GitHub Bot commented on FLINK-3599: --- Github user Xazax-hun commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread Xazax-hun
Github user Xazax-hun commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78087704 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerGenerator.java --- @@ -0,0 +1,259 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474953#comment-15474953 ] ASF GitHub Bot commented on FLINK-3599: --- Github user Xazax-hun commented on a diff i

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread Xazax-hun
Github user Xazax-hun commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78086011 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java --- @@ -419,4 +481,61 @@ public String toString() {

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474575#comment-15474575 ] Gabor Gevay commented on FLINK-3322: I've just realized that what I wrote above doesn'

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-08 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474531#comment-15474531 ] Gabor Gevay commented on FLINK-3322: I had an offline chat with [~StephanEwen], and an

[jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example

2016-09-08 Thread Olga Golovneva (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474504#comment-15474504 ] Olga Golovneva commented on FLINK-1526: --- Hi Greg, I didn't found much details about

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474418#comment-15474418 ] Greg Hogan commented on FLINK-4522: --- I am only seeing this affect version 1.2. The 1.1 d

[jira] [Closed] (FLINK-4585) Fix broken links in index.md

2016-09-08 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov closed FLINK-4585. -- > Fix broken links in index.md > > > Key: FLINK

[jira] [Commented] (FLINK-4591) Select star does not work with grouping

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474335#comment-15474335 ] Timo Walther commented on FLINK-4591: - Just because it is not allowed in SQL does not

[jira] [Updated] (FLINK-4550) Clearly define SQL operator table

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4550: Labels: starter (was: ) > Clearly define SQL operator table > - > >

[jira] [Updated] (FLINK-3656) Rework Table API tests

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-3656: Labels: starter (was: ) > Rework Table API tests > -- > > Key:

[jira] [Updated] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4592: Labels: starter (was: ) > Fix flaky test ScalarFunctionsTest.testCurrentTimePoint > ---

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474327#comment-15474327 ] Timo Walther commented on FLINK-4565: - I'm very sorry. Maybe I underestimated this iss

[jira] [Updated] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4599: Labels: starter (was: ) > Add 'explain()' also to StreamTableEnvironment >

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-09-08 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 We will have to fix the issue before we can merge this PR. The timeout doesn't occur in non-secure Kafka tests. I think we need to increase the timeout or change the test layout. Could you look into that

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474208#comment-15474208 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4456) Replace ActorGateway in Task by interface

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

[GitHub] flink pull request #2456: [FLINK-4456] Replace ActorGateway in Task and Runt...

2016-09-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2456 --- 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] [Closed] (FLINK-4456) Replace ActorGateway in Task by interface

2016-09-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4456. Resolution: Fixed Fixed via 0735b5b935b0c0757943e2d58047afcfb9949560 > Replace ActorGateway in Task

[jira] [Closed] (FLINK-4458) Remove ForkableFlinkMiniCluster

2016-09-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4458. Resolution: Fixed Fixed via 02b852e3571e46f25fdfc79f43ceb726ddff9ba7 > Remove ForkableFlinkMiniClus

[jira] [Commented] (FLINK-4458) Remove ForkableFlinkMiniCluster

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

[GitHub] flink pull request #2450: [FLINK-4458] Replace ForkableFlinkMiniCluster by L...

2016-09-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2450 --- 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-4565) Support for SQL IN operator

2016-09-08 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474082#comment-15474082 ] Simone Robutti commented on FLINK-4565: --- After a couple of days of work I believe th

[jira] [Commented] (FLINK-4572) Convert to negative in LongValueToIntValue

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474038#comment-15474038 ] ASF GitHub Bot commented on FLINK-4572: --- Github user greghogan commented on the issu

[GitHub] flink issue #2469: [FLINK-4572] [gelly] Convert to negative in LongValueToIn...

2016-09-08 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2469 I split the long to int translator into both signed and unsigned translators so the conversion would not be ambiguous. The test will fail without the fix in FLINK-4594. --- If your project is set

[jira] [Commented] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474029#comment-15474029 ] ASF GitHub Bot commented on FLINK-4594: --- GitHub user greghogan opened a pull request

[GitHub] flink pull request #2481: [FLINK-4594] [core] Validate lower bound in MathUt...

2016-09-08 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2481 [FLINK-4594] [core] Validate lower bound in MathUtils.checkedDownCast You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 4594_va

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473966#comment-15473966 ] Timo Walther commented on FLINK-4565: - Yes, this would fail then. But I think there is

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-08 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473867#comment-15473867 ] Simone Robutti commented on FLINK-4565: --- I'm no expert in the Table API, but if a us

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78003840 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerGenerator.java --- @@ -0,0 +1,259 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473854#comment-15473854 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473852#comment-15473852 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78003691 --- Diff: flink-core/src/main/resources/PojoSerializerTemplate.ftl --- @@ -0,0 +1,372 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example

2016-09-08 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473850#comment-15473850 ] Greg Hogan commented on FLINK-1526: --- Hi Olga, do you have a reference for the for-loop i

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473836#comment-15473836 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78002589 --- Diff: flink-core/src/main/resources/PojoSerializerTemplate.ftl --- @@ -0,0 +1,372 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-09-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473833#comment-15473833 ] Timo Walther commented on FLINK-4565: - I think it is ok, if you just parse the table n

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473826#comment-15473826 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78001809 --- Diff: flink-core/src/main/resources/PojoSerializerTemplate.ftl --- @@ -0,0 +1,372 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Assigned] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-09-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4579: -- Assignee: Jark Wu > Add StateBackendFactory for RocksDB Backend > -

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473806#comment-15473806 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r78000250 --- Diff: flink-core/src/main/resources/PojoComparatorTemplate.ftl --- @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473799#comment-15473799 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r77999725 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparatorGenerator.java --- @@ -0,0 +1,207 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77997800 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java --- @@ -273,7 +276,7 @@ public void releaseOutputs()

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77997086 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoStreamFlatMap.java --- @@ -83,6 +83,7 @@ public void processWaterma

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77997021 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -347,4 +521,5 @@ public void close()

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77996891 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -94,20 +102,38 @@ /** Backend

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77996545 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -94,20 +102,38 @@ /** Backend

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77996378 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -149,6 +154,8 @@ private LinkedHashSet> registeredPojo

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473744#comment-15473744 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r77996133 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerGenerator.java --- @@ -0,0 +1,259 @@ +/* + * Licensed to

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77996178 --- Diff: docs/monitoring/metrics.md --- @@ -475,52 +474,76 @@ Flink exposes the following system metrics: - -

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-09-08 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2386#discussion_r77996152 --- Diff: docs/monitoring/metrics.md --- @@ -475,52 +474,76 @@ Flink exposes the following system metrics: - -

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473738#comment-15473738 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r77995790 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/GenTypeSerializerProxy.java --- @@ -0,0 +1,148 @@ +/* + * Licensed to t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r77995491 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/GenTypeComparatorProxy.java --- @@ -0,0 +1,174 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473732#comment-15473732 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

2016-09-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15473725#comment-15473725 ] ASF GitHub Bot commented on FLINK-3599: --- Github user ggevay commented on a diff in t

[GitHub] flink pull request #2211: [WIP][FLINK-3599] Code generation for PojoSerializ...

2016-09-08 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2211#discussion_r77995157 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/GenTypeComparatorProxy.java --- @@ -0,0 +1,174 @@ +/* + * Licensed to t

  1   2   >