[jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator

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

[GitHub] flink pull request #2490: [FLINK-4609] Remove redundant check for null in Cr...

2016-09-09 Thread apivovarov
GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2490 [FLINK-4609] Remove redundant check for null in CrossOperator https://issues.apache.org/jira/browse/FLINK-4609 You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-4609) Remove redundant check for null in CrossOperator

2016-09-09 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4609: -- Summary: Remove redundant check for null in CrossOperator Key: FLINK-4609 URL: https://issues.apache.org/jira/browse/FLINK-4609 Project: Flink

[jira] [Updated] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-09 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4608: --- Description: Max/Min AggregationFunction use & instead of &&. Usually we use

[jira] [Updated] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-09 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4608: --- Description: Max/Min AggregationFunction use & instead of &&. Usually we use && in if

[jira] [Commented] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

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

[GitHub] flink pull request #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggr...

2016-09-09 Thread apivovarov
GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2489 [FLINK-4608] Use short-circuit AND in Max/Min AggregationFunction https://issues.apache.org/jira/browse/FLINK-4608 You can merge this pull request into a Git repository by running: $ git

[jira] [Updated] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-09 Thread Alexander Pivovarov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4608: --- Description: Max/Min AggregationFunction use & instead of && > Use short-circuit AND

[jira] [Created] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

2016-09-09 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4608: -- Summary: Use short-circuit AND in Max/Min AggregationFunction Key: FLINK-4608 URL: https://issues.apache.org/jira/browse/FLINK-4608 Project: Flink

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2485#discussion_r78270898 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/ExplainStreamTest.scala --- @@ -0,0 +1,64 @@ +/* + *

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2485#discussion_r78270846 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/StreamTableEnvironment.scala --- @@ -271,5 +271,21 @@ abstract class

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2485#discussion_r78270826 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/StreamTableEnvironment.scala --- @@ -271,5 +271,21 @@ abstract class

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2485#discussion_r78270796 --- Diff: docs/dev/table_api.md --- @@ -2457,3 +2457,27 @@ The Table API provides a configuration (the so-called `TableConfig`) to modify r By

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15479106#comment-15479106 ] ASF GitHub Bot commented on FLINK-4520: --- Github user apivovarov commented on a diff in the pull

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15479103#comment-15479103 ] ASF GitHub Bot commented on FLINK-4520: --- Github user apivovarov commented on a diff in the pull

[GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2487#discussion_r78270764 --- Diff: flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java --- @@ -0,0 +1,118 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15479102#comment-15479102 ] ASF GitHub Bot commented on FLINK-4520: --- Github user apivovarov commented on a diff in the pull

[GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2487#discussion_r78270757 --- Diff: flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java --- @@ -0,0 +1,118 @@ +/* + * Licensed to the

[GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

2016-09-09 Thread apivovarov
Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2487#discussion_r78270750 --- Diff: flink-contrib/flink-siddhi/src/main/java/org/apache/flink/contrib/siddhi/SiddhiCEP.java --- @@ -0,0 +1,118 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4607) Close FileInputStream in ParameterTool and other

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

[GitHub] flink pull request #2488: [FLINK-4607] Close FileInputStream in ParameterToo...

2016-09-09 Thread apivovarov
GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2488 [FLINK-4607] Close FileInputStream in ParameterTool and other https://issues.apache.org/jira/browse/FLINK-4607 You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-4607) Close FileInputStream in ParameterTool and other

2016-09-09 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4607: -- Summary: Close FileInputStream in ParameterTool and other Key: FLINK-4607 URL: https://issues.apache.org/jira/browse/FLINK-4607 Project: Flink

[jira] [Created] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

2016-09-09 Thread zhangjing (JIRA)
zhangjing created FLINK-4606: Summary: Integrate the new ResourceManager with the existing FlinkResourceManager Key: FLINK-4606 URL: https://issues.apache.org/jira/browse/FLINK-4606 Project: Flink

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread Hao Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15478991#comment-15478991 ] Hao Chen commented on FLINK-4520: - Hi Flink community, The PR is available now, could anybogy help assign

[jira] [Updated] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread Hao Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Chen updated FLINK-4520: Labels: cep library patch-available (was: cep library) Fix Version/s: 1.2.0 > Integrate Siddhi

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink issue #2486: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2016-09-09 Thread haoch
Github user haoch commented on the issue: https://github.com/apache/flink/pull/2486 Closed this PR for cleaning commit history and recreated another PR #2487 --- 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

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink pull request #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

2016-09-09 Thread haoch
GitHub user haoch opened a pull request: https://github.com/apache/flink/pull/2487 [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-weight Streaming CEP Library Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink pull request #2486: [FLINK-4520][flink-siddhi] Integrate Siddhi as a l...

2016-09-09 Thread haoch
Github user haoch closed the pull request at: https://github.com/apache/flink/pull/2486 --- 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

[GitHub] flink issue #2465: [FLINK-4447] [docs] Include NettyConfig options on Config...

2016-09-09 Thread nssalian
Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2465 Hi @greghogan thanks for the PR. Took a look at it and seems good to go. The test failure doesn't seem related. Since I'm new to the community, I would probably ask someone else to have a look as

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

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

[GitHub] flink issue #2442: [FLINK-4148] incorrect calculation minDist distance in Qu...

2016-09-09 Thread nssalian
Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2442 Hi @xhumanoid , thanks for the PR. Could you please check the Failure messages and fix the build? Can help review once the PR is cleanly mergable. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree

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

[jira] [Commented] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website

2016-09-09 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15478687#comment-15478687 ] Neelesh Srinivas Salian commented on FLINK-3457: Hi [~xazax], are you working on this? If

[jira] [Closed] (FLINK-2859) Add links to docs and JIRA issues in FlinkML roadmap

2016-09-09 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-2859. -- Resolution: Fixed This is fixed since the page has the link to the FLINK-ML

[jira] [Closed] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2016-09-09 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-1914. -- Resolution: Fixed > Wrong FS while starting YARN session without correct

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

2016-09-09 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15478539#comment-15478539 ] Neelesh Srinivas Salian commented on FLINK-1914: Sounds good [~rmetzger]. Closing the

[jira] [Closed] (FLINK-710) Aggregate transformation works only with FieldPositionKeys

2016-09-09 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-710. - Resolution: Duplicate > Aggregate transformation works only with FieldPositionKeys

[jira] [Comment Edited] (FLINK-2144) Incremental count, average, and variance for windows

2016-09-09 Thread Daniel Blazevski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477990#comment-15477990 ] Daniel Blazevski edited comment on FLINK-2144 at 9/9/16 8:49 PM: - Hi, I

[jira] [Commented] (FLINK-2144) Incremental count, average, and variance for windows

2016-09-09 Thread Daniel Blazevski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477990#comment-15477990 ] Daniel Blazevski commented on FLINK-2144: - Hi, I am curious to know the status of this issue.

[jira] [Updated] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread Hao Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Chen updated FLINK-4520: Description: h1. flink-siddhi proposal h2. Abstraction Siddhi CEP is a lightweight and easy-to-use Open

[jira] [Updated] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-09 Thread Hao Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Chen updated FLINK-4520: Description: h1. flink-siddhi proposal h2. Abstraction Siddhi CEP is a lightweight and easy-to-use Open

[GitHub] flink pull request #2486: FLINK-4520 Integrate Siddhi as a light-weight Stre...

2016-09-09 Thread haoch
GitHub user haoch opened a pull request: https://github.com/apache/flink/pull/2486 FLINK-4520 Integrate Siddhi as a light-weight Streaming CEP Library Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

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

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

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

2016-09-09 Thread rekhajoshm
Github user rekhajoshm commented on the issue: https://github.com/apache/flink/pull/2060 Thanks @greghogan for your review. Please have a look. thanks! --- 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

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

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

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

2016-09-09 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 Thanks, will try that. --- 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

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

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

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

2016-09-09 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 I would suggest to just you your own Travis account. It is free, you just need to connect it with your account. Then push to any branch in your GitHub account and Travis will run. --- If your project

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink issue #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allocation ...

2016-09-09 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2463 I've rebased the pull request and incorporated your suggestions. --- 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

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477560#comment-15477560 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-09 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r78212144 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java --- @@ -89,32 +93,37 @@ public

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477387#comment-15477387 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78203358 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -75,8 +76,30 @@ /** Invalid Boolean value **/

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

2016-09-09 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 hmmm.. it's getting complicated. will try to debug the issue. Do you know why on Travis it has to fail but not on Jenkins? How do I simulate this on Travis for my own testing? --- If

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477337#comment-15477337 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78199868 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -75,8 +76,30 @@ /** Invalid Boolean value **/

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477333#comment-15477333 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78199594 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java --- @@ -314,6 +320,25 @@ protected void

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477321#comment-15477321 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477325#comment-15477325 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78199365 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java --- @@ -314,6 +320,25 @@ protected void

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78199262 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java --- @@ -314,6 +320,25 @@ protected void

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

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477323#comment-15477323 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on a diff in the pull

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

2016-09-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2060#discussion_r78199216 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java --- @@ -314,6 +320,25 @@ protected void

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

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

[GitHub] flink issue #2485: [Flink 4599] - Add 'explain()' also to StreamTableEnviron...

2016-09-09 Thread chobeat
Github user chobeat commented on the issue: https://github.com/apache/flink/pull/2485 Done, sorry. --- 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

[GitHub] flink issue #2485: [Flink 4599] - Add 'explain()' also to StreamTableEnviron...

2016-09-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2485 Could you rebase your PR on the current master and then do a force push? There are a lot of commits that should not appear here. --- If your project is set up for it, you can reply to this email

[jira] [Created] (FLINK-4605) Add an expression that returns the return type of an expression

2016-09-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4605: --- Summary: Add an expression that returns the return type of an expression Key: FLINK-4605 URL: https://issues.apache.org/jira/browse/FLINK-4605 Project: Flink

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

2016-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477252#comment-15477252 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-09 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2463#discussion_r78194763 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/LeaderIdRegistry.java --- @@ -15,11 +15,27 @@ * See the License for the

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

2016-09-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477240#comment-15477240 ] Timo Walther commented on FLINK-4591: - Ok, Calcite does also not support {{SELECT * FROM WordCount

[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes

2016-09-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477093#comment-15477093 ] Aljoscha Krettek commented on FLINK-4603: - We wouldn't if we always keep everything in serialized

[jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

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

[GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi...

2016-09-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2459 I would really like to not change the way it is done right now. It works and it is the result of many user interactions, testing across Maven, SBT, Gradle, etc. These various build

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

2016-09-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477004#comment-15477004 ] Fabian Hueske commented on FLINK-4599: -- Definitely. Would be great if you could add this to the docs.

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

2016-09-09 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15477000#comment-15477000 ] Simone Robutti commented on FLINK-4599: --- I'd rather go for the second choice. I've opened the PR.

[GitHub] flink pull request #2485: [Flink 4599] - Add 'explain()' also to StreamTable...

2016-09-09 Thread chobeat
GitHub user chobeat opened a pull request: https://github.com/apache/flink/pull/2485 [Flink 4599] - Add 'explain()' also to StreamTableEnvironment You can merge this pull request into a Git repository by running: $ git pull https://github.com/radicalbit/flink FLINK-4599

[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes

2016-09-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476941#comment-15476941 ] Till Rohrmann commented on FLINK-4603: -- Wouldn't we even then need the user code class loader to load

[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes

2016-09-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476881#comment-15476881 ] Aljoscha Krettek commented on FLINK-4603: - Yep, the user code {{ClassLoder}} can be retrieved from

[jira] [Created] (FLINK-4604) Add support for standard deviation/variance

2016-09-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4604: --- Summary: Add support for standard deviation/variance Key: FLINK-4604 URL: https://issues.apache.org/jira/browse/FLINK-4604 Project: Flink Issue Type: New

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

2016-09-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4592. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 8c0d62433a3f57d0753edb00e5c2bbc1adc467df.

[jira] [Updated] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager

2016-09-09 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-4505: - Description: Implement {{TaskManagerRunner}} to construct related components ({{MemoryManager}},

[jira] [Updated] (FLINK-4505) Implement TaskManagerRunner to construct related components for TaskManager

2016-09-09 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-4505: - Summary: Implement TaskManagerRunner to construct related components for TaskManager (was:

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

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

[GitHub] flink pull request #2484: [FLINK-4177] Harden CassandraConnectorTest

2016-09-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2484 [FLINK-4177] Harden CassandraConnectorTest This PR (hopefully) resolves the instability issues with the Cassandra connector tests. Changelog: * updated cassandra/driver versions *

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

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

[GitHub] flink pull request #2483: [FLINK-4601] Check for empty string properly

2016-09-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2483 --- 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-4601) Check for empty string properly

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

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

2016-09-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4601. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in e92f91aeba3c9e8da5a5ff9efda342cb19da928c.

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

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

[GitHub] flink issue #2483: [FLINK-4601] Check for empty string properly

2016-09-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2483 Thanks for the fix. Will merge... --- 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

[jira] [Created] (FLINK-4603) KeyedStateBackend cannot restore user code classes

2016-09-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4603: Summary: KeyedStateBackend cannot restore user code classes Key: FLINK-4603 URL: https://issues.apache.org/jira/browse/FLINK-4603 Project: Flink Issue Type:

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

2016-09-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15476495#comment-15476495 ] Fabian Hueske commented on FLINK-4599: -- I would leave that up to you. If you come up with a good

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

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

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

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

  1   2   >