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

2017-04-06 Thread Yelei Feng (JIRA)
Yelei Feng created FLINK-6273: - Summary: Client can't connect to jobmanager whose hostname contains capital letters Key: FLINK-6273 URL: https://issues.apache.org/jira/browse/FLINK-6273 Project: Flink

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

[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

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

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

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

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

[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

[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

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

[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

[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=15959046#comment-15959046 ] Ted Yu commented on FLINK-6275: --- Similarly, access to haServices in shutdown() doesn't have protection

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

2017-04-06 Thread Yelei Feng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yelei Feng reassigned FLINK-6273: - Assignee: Yelei Feng > Client can't connect to jobmanager whose hostname contains capital

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

[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

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

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

[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=15959014#comment-15959014 ] 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

[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

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

[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

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

[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=15958840#comment-15958840 ] ASF GitHub Bot commented on FLINK-6079: --- 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

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

[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

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

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

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

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

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

[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=15959155#comment-15959155 ] ASF GitHub Bot commented on FLINK-6216: --- Github user shaoxuan-wang closed the pull request at:

[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

[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

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

[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

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

[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

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

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

[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

[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

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

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

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

[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=15959057#comment-15959057 ] Fabian Hueske commented on FLINK-5695: -- Hi [~sunjincheng121], did you come to a conclusion regarding

[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

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

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

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

[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

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

[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

[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

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

[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

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

[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

[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

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

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

[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=15959687#comment-15959687 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol 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 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

[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=15959777#comment-15959777 ] ASF GitHub Bot commented on FLINK-5781: --- Github user zentol 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

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

[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

[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=15959759#comment-15959759 ] Larry Wu commented on FLINK-5966: - This is a very good step towards Flink on Kubernetes. Is the your PR

[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_r110086591 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -53,22 +54,9 @@ class

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

[jira] [Commented] (FLINK-6141) Add buffering service for stream operators

2017-04-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958428#comment-15958428 ] Aljoscha Krettek commented on FLINK-6141: - [~ventura] Your ideas definitely don't sound off.

[jira] [Commented] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()

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

[GitHub] flink issue #3678: [FLINK-5629] [runtime-web] Close RAF in FileServerHandler...

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3678 This PR also fixed FLINK-6172. --- 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

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3683 [FLINK-6270] Port several network config parameters to ConfigOption This ports some memory and network buffers related config options to new `ConfigOption` instances. These include: *

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110106044 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -39,10 +39,53 @@

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

[jira] [Closed] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

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

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

2017-04-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3680 +1. --- 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-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=15958475#comment-15958475 ] ASF GitHub Bot commented on FLINK-6268: --- Github user zentol commented on the issue:

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

2017-04-06 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110097648 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -53,22 +54,9 @@ class

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110103104 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java --- @@ -595,6 +595,35 @@ public boolean containsKey(String key){

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110102530 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java --- @@ -39,10 +39,53 @@

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

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110104138 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java --- @@ -595,6 +595,35 @@ public boolean containsKey(String key){

[GitHub] flink pull request #3683: [FLINK-6270] Port several network config parameter...

2017-04-06 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3683#discussion_r110102292 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala --- @@ -350,23 +350,18 @@ class

  1   2   >