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

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

[jira] [Commented] (FLINK-9028) flip6 should check config before starting cluster

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406021#comment-16406021 ] ASF GitHub Bot commented on FLINK-9028: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-8959) Port AccumulatorLiveITCase to flip6

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

[GitHub] flink pull request #5719: [FLINK-8959][tests] Port AccumulatorLiveITCase to ...

2018-03-20 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5719#discussion_r175702017 --- Diff: flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java --- @@ -18,292 +18,188 @@ package org.apache.fli

[GitHub] flink pull request #5726: [FLINK-9028][flip6] perform parameters checking be...

2018-03-20 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5726#discussion_r175701852 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -476,6 +477,11 @@ public ApplicationId getClusterId(Command

[jira] [Commented] (FLINK-7270) Add support for dynamic properties to cluster entry point

2018-03-20 Thread Juan Miguel Cejuela (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406016#comment-16406016 ] Juan Miguel Cejuela commented on FLINK-7270: Thanks [~till.rohrmann] – I'll ke

[jira] [Assigned] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it

2018-03-20 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou reassigned FLINK-9026: - Assignee: Sihua Zhou > Unregister finished tasks from TaskManagerMetricGroup and close it > -

[jira] [Commented] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it

2018-03-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406000#comment-16406000 ] Till Rohrmann commented on FLINK-9026: -- No, I haven't started yet. Please go ahead an

[jira] [Commented] (FLINK-8830) YarnResourceManager throws NullPointerException

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

[jira] [Resolved] (FLINK-8830) YarnResourceManager throws NullPointerException

2018-03-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8830. -- Resolution: Fixed Fixed via master: bcb0f324f50adc74fb6122621794d6d7e37bc933 4536e9cbe1925c0a6dd

[GitHub] flink pull request #5629: [FLINK-8830][YARN] YarnResourceManager throws Null...

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

[jira] [Closed] (FLINK-8935) Implement remaining methods in MiniClusterClient

2018-03-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8935. --- Resolution: Fixed master: 5fa84c28fc1bfc62fa2e1165e3407fc81b3d09a9 3e6aa676e36824ac76258ff2072

[jira] [Closed] (FLINK-8948) RescalingITCase fails on Travis

2018-03-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8948. --- Resolution: Fixed master: b6bbd123c951d1f6e1cda108514d8e749c5ed033 1.5: d5b712715fc89a0f56f29b

[jira] [Commented] (FLINK-8948) RescalingITCase fails on Travis

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

[jira] [Commented] (FLINK-8935) Implement remaining methods in MiniClusterClient

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

[GitHub] flink pull request #5710: [FLINK-8948][runtime] Fix IllegalStateException wh...

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

[GitHub] flink pull request #5690: [FLINK-8935][tests] Extend MiniClusterClient

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

[jira] [Commented] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2018-03-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405986#comment-16405986 ] Chesnay Schepler commented on FLINK-5372: - Another instance: https://travis-ci.org

[jira] [Commented] (FLINK-8909) pyflink.sh not working with yarn

2018-03-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405980#comment-16405980 ] Chesnay Schepler commented on FLINK-8909: - Have you configured `python.dc.tmp.dir`

[jira] [Commented] (FLINK-9028) flip6 should check config before starting cluster

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405981#comment-16405981 ] ASF GitHub Bot commented on FLINK-9028: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5726: [FLINK-9028][flip6] perform parameters checking before st...

2018-03-20 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5726 CC: @tillrohrmann ---

[jira] [Commented] (FLINK-9028) flip6 should check config before starting cluster

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405979#comment-16405979 ] ASF GitHub Bot commented on FLINK-9028: --- GitHub user sihuazhou opened a pull request

[GitHub] flink pull request #5726: [FLINK-FLINK-9028][flip6] perform parameters check...

2018-03-20 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5726 [FLINK-FLINK-9028][flip6] perform parameters checking before starting cluster ## What is the purpose of the change Perform parameters checking before starting cluster to prevent to setup

[GitHub] flink pull request #5721: Update kubernetes.md

2018-03-20 Thread sampathBhat
Github user sampathBhat closed the pull request at: https://github.com/apache/flink/pull/5721 ---

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-03-20 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405966#comment-16405966 ] Wind commented on FLINK-8785: - [~Zentol] I can see that many handlers send error response whos

[jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405958#comment-16405958 ] ASF GitHub Bot commented on FLINK-8620: --- Github user dawidwys commented on the issue

[GitHub] flink issue #5580: [FLINK-8620] Enable shipping custom files to BlobStore an...

2018-03-20 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5580 @aljoscha Yes that's right. The latest commit does not work because Python API expects complete directories to be uploaded. I think it is quite important cause this way the uploaded Python code can

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

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405945#comment-16405945 ] ASF GitHub Bot commented on FLINK-6968: --- Github user liurenjie1024 commented on a di

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

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

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

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405944#comment-16405944 ] ASF GitHub Bot commented on FLINK-6968: --- Github user liurenjie1024 commented on a di

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

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

[jira] [Created] (FLINK-9028) flip6 should check config before starting cluster

2018-03-20 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9028: - Summary: flip6 should check config before starting cluster Key: FLINK-9028 URL: https://issues.apache.org/jira/browse/FLINK-9028 Project: Flink Issue Type: Bug

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

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

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

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

[jira] [Commented] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405921#comment-16405921 ] ASF GitHub Bot commented on FLINK-8394: --- GitHub user yanghua opened a pull request:

[GitHub] flink pull request #5725: [FLINK-8394] Lack of synchronization accessing exp...

2018-03-20 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5725 [FLINK-8394] Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown ## What is the purpose of the change * This pull request fixed a Lack of synchronization accessing

[GitHub] flink issue #5416: [FLINK-8562] [Security] Fix YARNSessionFIFOSecuredITCase

2018-03-20 Thread suez1224
Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5416 @tillrohrmann what signal should I wait for? I can address the flip6 mode test in the end-to--end test JIRA https://issues.apache.org/jira/browse/FLINK-8981. What do you think? ---

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

2018-03-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405909#comment-16405909 ] ASF GitHub Bot commented on FLINK-8562: --- Github user suez1224 commented on the issue

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

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

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

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

<    1   2   3   4