[jira] [Updated] (FLINK-6268) Object reuse for Either type

2017-04-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6268: -- Fix Version/s: 1.3.0 > Object reuse for Either type > > > K

[jira] [Created] (FLINK-6274) Replace usages of org.codehaus.jackson

2017-04-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6274: --- Summary: Replace usages of org.codehaus.jackson Key: FLINK-6274 URL: https://issues.apache.org/jira/browse/FLINK-6274 Project: Flink Issue Type: Improv

[GitHub] flink issue #3682: [FLINK-6269][JobManager]var could be val

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3682 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-6269) var could be a val

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

[jira] [Commented] (FLINK-6256) Fix documentation of ProcessFunction.

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

[GitHub] flink issue #3684: [FLINK-6256] Fix outputTag variable name in Side Output d...

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3684 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[GitHub] flink issue #3685: [FLINK-6079] [kafka] Provide meaningful error message if ...

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3685 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

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

[GitHub] flink pull request #3688: [FLINK-6273] [core] don't convert hostname to lowe...

2017-04-06 Thread barcahead
GitHub user barcahead opened a pull request: https://github.com/apache/flink/pull/3688 [FLINK-6273] [core] don't convert hostname to lower cases to prevent akka connection failure For akka `Address`, the host part is case sensitive, So if we build remote jobmanager url with lower c

[jira] [Commented] (FLINK-6273) Client can't connect to jobmanager whose hostname contains capital letters

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

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

2017-04-06 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110159791 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void te

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958918#comment-15958918 ] ASF GitHub Bot commented on FLINK-6271: --- Github user fpompermaier commented on a dif

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110160658 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void testJDBC

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

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

[GitHub] flink issue #3683: [FLINK-6270] Port several network config parameters to Co...

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3683 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-6270) Port several network config parameters to ConfigOption

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

[GitHub] flink pull request #3686: [FLINK-6271][jdbc]Fix nullPointer when there's a s...

2017-04-06 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/3686#discussion_r110164047 --- Diff: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java --- @@ -180,6 +180,52 @@ public void te

[jira] [Commented] (FLINK-6271) NumericBetweenParametersProvider NullPinter

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958953#comment-15958953 ] ASF GitHub Bot commented on FLINK-6271: --- Github user fpompermaier commented on a dif

[jira] [Updated] (FLINK-6274) Replace usages of org.codehaus.jackson

2017-04-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6274: -- Component/s: Build System > Replace usages of org.codehaus.jackson > ---

[GitHub] flink pull request #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTran...

2017-04-06 Thread KurtYoung
GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/3689 [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and Flink… …RelDecorrelator after calcite updated to 1.12 You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

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

[GitHub] flink issue #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRu...

2017-04-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3689 Thanks for the PR @KurtYoung. +1 to 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 featur

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

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

[GitHub] flink issue #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRu...

2017-04-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3689 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

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

[GitHub] flink issue #3681: [FLINK-6257][table] Consistent naming of {{ProcessFunctio...

2017-04-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3681 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fea

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

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

[jira] [Created] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-04-06 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6275: - Summary: Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster Key: FLINK-6275 URL: https://issues.apache.org/jira/browse/FLINK-6275 Projec

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-04-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959046#comment-15959046 ] Ted Yu commented on FLINK-6275: --- Similarly, access to haServices in shutdown() doesn't have

[jira] [Commented] (FLINK-5695) Optimize table type systems based on database semantics

2017-04-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959057#comment-15959057 ] Fabian Hueske commented on FLINK-5695: -- Hi [~sunjincheng121], did you come to a concl

[jira] [Updated] (FLINK-6271) NumericBetweenParametersProvider NullPointer

2017-04-06 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier updated FLINK-6271: -- Summary: NumericBetweenParametersProvider NullPointer (was: NumericBetweenParametersPro

[jira] [Resolved] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

2017-04-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6052. --- Resolution: Won't Fix > Potential null access in > ZooKeeperCompletedCheckpointStore#getLatestCheckpoint() >

[GitHub] flink pull request #3646: [FLINK-6216] [table] DataStream unbounded groupby ...

2017-04-06 Thread shaoxuan-wang
Github user shaoxuan-wang closed the pull request at: https://github.com/apache/flink/pull/3646 --- 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

[jira] [Commented] (FLINK-6216) DataStream unbounded groupby aggregate with early firing

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959155#comment-15959155 ] ASF GitHub Bot commented on FLINK-6216: --- Github user shaoxuan-wang closed the pull r

[jira] [Closed] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

2017-04-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5435. Resolution: Fixed Fix Version/s: 1.3.0 Fixed by c5173fa26d3d8a32b0b182a37d34a8eeff6e36d0 > C

[GitHub] flink pull request #3689: [FLINK-5435] [table] Remove FlinkAggregateJoinTran...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3689 --- 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 #3681: [FLINK-6257][table] Consistent naming of {{Process...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3681 --- 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-6257) Post-pass OVER windows

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

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

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

[jira] [Commented] (FLINK-6268) Object reuse for Either type

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

[GitHub] flink pull request #3680: [FLINK-6268] [core] Object reuse for Either type

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3680 --- 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-6268) Object reuse for Either type

2017-04-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6268. - Resolution: Implemented Implemented in ae17718fb9262f65b89b4551d2aecaab3ee23d9e > Object reuse for Either

[GitHub] flink pull request #3690: [FLINK-6173] [build] Move gelly-examples jar from ...

2017-04-06 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3690 [FLINK-6173] [build] Move gelly-examples jar from opt to examples The opt directory should be reserved for Flink JARs which users may optionally move to lib to be loaded by the runtime. flink-gell

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

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

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959344#comment-15959344 ] ASF GitHub Bot commented on FLINK-6173: --- Github user greghogan closed the pull reque

[GitHub] flink pull request #3690: [FLINK-6173] [build] Move gelly-examples jar from ...

2017-04-06 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/3690 --- 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 e

[GitHub] flink pull request #3691: [FLINK-6195] [build] Move gelly-examples jar from ...

2017-04-06 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3691 [FLINK-6195] [build] Move gelly-examples jar from opt to examples The opt directory should be reserved for Flink JARs which users may optionally move to lib to be loaded by the runtime. flink-gell

[jira] [Commented] (FLINK-6195) Move gelly-examples jar from opt to examples

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

[GitHub] flink pull request #3682: [FLINK-6269][JobManager]var could be val

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3682 --- 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 #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3683 --- 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 #3684: [FLINK-6256] Fix outputTag variable name in Side O...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3684 --- 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 #3685: [FLINK-6079] [kafka] Provide meaningful error mess...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3685 --- 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-6256) Fix documentation of ProcessFunction.

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6256. --- Resolution: Fixed 1.3: a6355edd904c2efe2ee37118132b0add5a2e5588 > Fix documentation of Proces

[jira] [Closed] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6079. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 8890a8db41c45504aa658a1942f40bb9af7dcf30 >

[jira] [Commented] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

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

[jira] [Commented] (FLINK-6270) Port several network config parameters to ConfigOption

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

[jira] [Commented] (FLINK-6269) var could be a val

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

[jira] [Assigned] (FLINK-6269) var could be a val

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6269: --- Assignee: Chesnay Schepler > var could be a val > -- > >

[jira] [Commented] (FLINK-6256) Fix documentation of ProcessFunction.

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

[jira] [Closed] (FLINK-6269) var could be a val

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6269. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: 2cb60043d8fce4a291fbefeddce6598b442b8f01 >

[jira] [Assigned] (FLINK-6269) var could be a val

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6269: --- Assignee: CanBin Zheng (was: Chesnay Schepler) > var could be a val > --

[jira] [Closed] (FLINK-6270) Port several network config parameters to ConfigOption

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6270. --- Resolution: Fixed Fix Version/s: 1.3.0 1.3: e2a4f47ed8c95c7045f79bf9fe59cab39518710b >

[GitHub] flink pull request #3692: FLINK-5974 Added configurations to support mesos-d...

2017-04-06 Thread vijikarthi
GitHub user vijikarthi opened a pull request: https://github.com/apache/flink/pull/3692 FLINK-5974 Added configurations to support mesos-dns hostname resolution This PR addresses FLINK-5974 requirements which takes care of handling dynamic host name resolution for JM and TM componen

[jira] [Commented] (FLINK-5974) Support Mesos DNS

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959444#comment-15959444 ] ASF GitHub Bot commented on FLINK-5974: --- GitHub user vijikarthi opened a pull reques

[jira] [Closed] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-720. -- Resolution: Won't Fix > Forbid catching exceptions only with "e.printStackTrace()" using Checksty

[jira] [Closed] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

2017-04-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4644. --- Resolution: Fixed Assignee: Stephan Ewen (was: Maximilian Michels) Fix Version

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

2017-04-06 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3675 The PR looks pretty good. Thanks @fhueske for improving the documentation. +1 (non-binding) --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

2017-04-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3675 Thanks for the review @haohui! Just to make sure: You're OK with removing support for windows defined as `GROUP BY CEIL(rowtime() TO HOUR)`? Thanks, Fabian --- If your project is s

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 I'm playing around with this right now. Seems like it works; don't know though if the resulting html is what people expected; since you know, it is pretty bare-bones. :) Anyway, I'm looking i

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

2017-04-06 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3675 Yes. I agree with you that `FLOOR` / `CEIL` are quite fragile and it is much clearer to use the `TUMBLING` / `HOP` / `SESSION` constructs. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[GitHub] flink issue #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group w...

2017-04-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3675 Thanks, will merge this PR :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and w

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[GitHub] flink pull request #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION ...

2017-04-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3675 --- 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-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[jira] [Closed] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

2017-04-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6261. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with 635394751dce6e532fcd5a758c3d1bd

[jira] [Commented] (FLINK-5966) Document Running Flink on Kubernetes

2017-04-06 Thread Larry Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959759#comment-15959759 ] Larry Wu commented on FLINK-5966: - This is a very good step towards Flink on Kubernetes. I

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 Alright here's what i came up with. We define a single antrun task which does the following: Since all *Options classes reside in the same directory we just take a look in there and filter ou

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

[jira] [Closed] (FLINK-4869) Store record pointer after record keys

2017-04-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4869. - Resolution: Later > Store record pointer after record keys > -- > >

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-04-06 Thread hongyuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960223#comment-15960223 ] hongyuhong commented on FLINK-6233: --- Hi [~fhueske], i would deal with the out-of-order r

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-06 Thread clarkyzl
Github user clarkyzl commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110317256 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -131,8 +129,14 @@ abstract class TableFunc

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[GitHub] flink issue #3595: [FLINK-6162]Fix bug in ByteArrayOutputStreamWithPos#setPo...

2017-04-06 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/3595 hi, @greghogan , do you have any new comment about the changes? --- 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-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960315#comment-15960315 ] ASF GitHub Bot commented on FLINK-6162: --- Github user wenlong88 commented on the issu

[GitHub] flink pull request #3495: [FLINK-5781][config] Generation HTML from ConfigOp...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3495#discussion_r110321324 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigGroup.java --- @@ -0,0 +1,90 @@ +/* + * Licensed to the Apache Software Founda

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

[jira] [Created] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6276: - Summary: InvalidTypesException: Unknown Error. Type is null. Key: FLINK-6276 URL: https://issues.apache.org/jira/browse/FLINK-6276 Project: Flink Issue Typ

[jira] [Updated] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6276: -- Description: Quite frequently when writing Flink code, I get the exception {{InvalidTypesExcept

[GitHub] flink issue #3495: [FLINK-5781][config] Generation HTML from ConfigOption

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3495 This feature only really makes sense if we can integrate it directly into the web documentation. This should actually be rather simple easy. 1) Create a copy of the existing `/docs/setup/c

[jira] [Commented] (FLINK-5781) Generation HTML from ConfigOption

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

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960349#comment-15960349 ] Luke Hutchison commented on FLINK-6276: --- Looking at the flink code, the issue here i

[jira] [Assigned] (FLINK-5545) Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

2017-04-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5545: - Assignee: Kurt Young (was: Zhenghua Gao) > Remove FlinkAggregateExpandDistinctAggregatesRule whe

[jira] [Updated] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6276: -- Description: Quite frequently when writing Flink code, I get the exception {{InvalidTypesExcept

[jira] [Comment Edited] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960349#comment-15960349 ] Luke Hutchison edited comment on FLINK-6276 at 4/7/17 6:43 AM: -

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960367#comment-15960367 ] Luke Hutchison commented on FLINK-6276: --- I just tested, and the code as currently sh

<    1   2