[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404031#comment-16404031 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404029#comment-16404029 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175292522 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java --- @@ -97,6 +98,15 @@ public static void

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404030#comment-16404030 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175292394 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -206,7 +209,7 @@ public void checkClusterEmpty() throws

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175292359 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -105,7 +105,7 @@ public void testDetachedMode()

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175292445 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -379,6 +382,50 @@ public boolean accept(File dir, String name)

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404032#comment-16404032 ] ASF GitHub Bot commented on FLINK-8562: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Closed] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7804. Resolution: Fixed Fixed via 1.6.0: 9538675caca24c83201e47bd26e4e725b2695217 1.5.0:

[jira] [Closed] (FLINK-9016) Unregister jobs from JobMetricGroup after termination

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9016. Resolution: Fixed Fixed via 1.6.0: c4a1d09ccdbd19416e15534ceba45ead5d2d6ed2 1.5.0:

[jira] [Resolved] (FLINK-8812) Possible resource leak in Flip6

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8812. -- Resolution: Fixed Fixed via 1.6.0: 7caeefdcbe6dab89bed4a9e2fa42e07722fbf08d 1.5.0:

[GitHub] flink pull request #5706: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDDEV...

2018-03-18 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5706#discussion_r175296744 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala --- @@ -103,6 +106,22 @@

[jira] [Commented] (FLINK-8903) Built-in agg functions VAR_POP, VAR_SAMP, STDEV_POP, STDEV_SAMP are broken in Group Windows

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404070#comment-16404070 ] ASF GitHub Bot commented on FLINK-8903: --- Github user walterddr commented on a diff in the pull

[GitHub] flink pull request #5703: [FLINK-8915] CheckpointingStatisticsHandler fails ...

2018-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5703 ---

[jira] [Commented] (FLINK-8843) Decouple bind REST address from advertised address

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

[jira] [Commented] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

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

[jira] [Commented] (FLINK-8812) Possible resource leak in Flip6

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

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

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

[jira] [Commented] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread

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

[GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP...

2018-03-18 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5638#discussion_r175296949 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala --- @@ -1130,4 +1130,13 @@ object concat_ws {

[jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404072#comment-16404072 ] ASF GitHub Bot commented on FLINK-6924: --- Github user walterddr commented on a diff in the pull

[jira] [Created] (FLINK-9017) FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis

2018-03-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9017: Summary: FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis Key: FLINK-9017 URL: https://issues.apache.org/jira/browse/FLINK-9017

[GitHub] flink pull request #5713: [FLINK-8812] [flip6] Set managed memory for TaskEx...

2018-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5713 ---

[GitHub] flink pull request #5711: [FLINK-8894][REST] CurrentJobIdsHandler fails to s...

2018-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5711 ---

[GitHub] flink pull request #5675: [FLINK-7804][flip6] YarnResourceManager does not e...

2018-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5675 ---

[GitHub] flink pull request #5707: [FLINK-8843][flip6] Decouple bind REST address fro...

2018-03-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5707 ---

[jira] [Closed] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8915. Resolution: Fixed Fixed via 1.6.0: 31c0754ee70265a1b440cbfbc21e1220e5d9718a 1.5.0:

[jira] [Resolved] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8894. -- Resolution: Fixed Fixed via 1.6.0: 096a89ae6d0db9d763648a0acca2334f14efd3b3 1.5.0:

[jira] [Closed] (FLINK-8843) Decouple bind REST address from advertised address

2018-03-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8843. Resolution: Fixed Fixed via 1.6.0: efd7336fa693a9f82b9ecfb5d81c0ef747ab7801 1.5.0:

[jira] [Commented] (FLINK-8968) Fix native resource leak caused by ReadOptions

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403897#comment-16403897 ] ASF GitHub Bot commented on FLINK-8968: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5705: [FLINK-8968][state]Fix native resource leak caused by Rea...

2018-03-18 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5705 I made a fixup for some additional minor bug in `RocksDBStateBackendConfigTest.java`. ---

[jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing

2018-03-18 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16403893#comment-16403893 ] Sihua Zhou commented on FLINK-8922: --- ...Sorry to tell you guys that [~srichter] was right, it is just

[jira] [Updated] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instanc

2018-03-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-9009: Priority: Major (was: Blocker) > Error| You are creating too many HashedWheelTimer instances. >

[jira] [Commented] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few insta

2018-03-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404223#comment-16404223 ] Stephan Ewen commented on FLINK-9009: - This does not look like a Flink issue. Rather related to

[jira] [Closed] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instance

2018-03-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9009. --- Resolution: Invalid > Error| You are creating too many HashedWheelTimer instances. >

[jira] [Created] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot

2018-03-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9018: - Summary: Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Key: FLINK-9018 URL: https://issues.apache.org/jira/browse/FLINK-9018

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

2018-03-18 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r175317673 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,162 @@ +/* + * Licensed

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

2018-03-18 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r175315979 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,162 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404298#comment-16404298 ] ASF GitHub Bot commented on FLINK-6968: --- Github user walterddr commented on a diff in the pull

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404297#comment-16404297 ] ASF GitHub Bot commented on FLINK-6968: --- Github user walterddr commented on a diff in the pull

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175325407 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java --- @@ -97,6 +98,15 @@ public static void

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404346#comment-16404346 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull

[jira] [Commented] (FLINK-7151) FLINK SQL support create temporary function and table

2018-03-18 Thread yinhua.dai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404280#comment-16404280 ] yinhua.dai commented on FLINK-7151: --- [~suez1224] When do you think the feature will be on board? >

[jira] [Updated] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot

2018-03-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9018: -- Component/s: State Backends, Checkpointing > Unclosed snapshotCloseableRegistry in >

[jira] [Created] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs

2018-03-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9019: - Summary: Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs Key: FLINK-9019 URL: https://issues.apache.org/jira/browse/FLINK-9019 Project: Flink

[jira] [Assigned] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs

2018-03-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9019: --- Assignee: vinoyang > Unclosed closeableRegistry in >

[GitHub] flink pull request #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecured...

2018-03-18 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5416#discussion_r175325243 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -105,7 +105,7 @@ public void testDetachedMode() throws

[jira] [Commented] (FLINK-8562) Fix YARNSessionFIFOSecuredITCase

2018-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404344#comment-16404344 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on a diff in the pull