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

2018-03-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392557#comment-16392557 ] Gary Yao edited comment on FLINK-8894 at 3/9/18 8:07 AM: - [~mingle

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

2018-03-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392557#comment-16392557 ] Gary Yao commented on FLINK-8894: - [~mingleizhang] You just add a new line to {{flink-conf

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

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392560#comment-16392560 ] mingleizhang commented on FLINK-8894: - Thanks for your response [~gjy] I am so surpris

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

2018-03-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5573 please do not trigger builds just to get that perfect green build. The test failure here is quite common at the moment. ---

[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[GitHub] flink pull request #5651: [FLINK-8889][tests] Do not override cluster config...

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

[GitHub] flink pull request #5657: [FLINK-8887][tests] Add single retry in MiniCluste...

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

[GitHub] flink pull request #5554: [FLINK-8729][streaming] Refactor JSONGenerator to ...

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

[GitHub] flink pull request #5652: [hotfix][tests] Do not use singleActorSystem in Lo...

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

[GitHub] flink pull request #5637: [FLINK-8860][flip6] stop SlotManager spamming logs...

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

[jira] [Commented] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

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

[jira] [Closed] (FLINK-8860) SlotManager spamming log files

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

[jira] [Closed] (FLINK-8729) Migrate JSONGenerator from Sling to Jackson

2018-03-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8729. --- Resolution: Fixed Fix Version/s: 1.5.0 master: b8eb6af99dd310eeec3497b44f252a0402068d6b

[jira] [Commented] (FLINK-8860) SlotManager spamming log files

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

[jira] [Commented] (FLINK-8729) Migrate JSONGenerator from Sling to Jackson

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

[jira] [Commented] (FLINK-8889) Do not override config values in TestBaseUtils#startCluster

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

[jira] [Closed] (FLINK-8889) Do not override config values in TestBaseUtils#startCluster

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

[jira] [Commented] (FLINK-8887) ClusterClient.getJobStatus can throw FencingTokenException

2018-03-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392597#comment-16392597 ] Chesnay Schepler commented on FLINK-8887: - Temporary workaround for the {{MiiniClu

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

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392610#comment-16392610 ] mingleizhang commented on FLINK-8894: - Hi, [~gjy] It seems that I can not run the {{bi

[GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5664 [FLINK-8703][tests] Port CancelingTestBase to MiniClusterResource ## What is the purpose of the change Ports the {{CancelingTestBase}} to use {{MiniClusterResource}}. ## Verifying th

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5665: [FLINK-8703][tests] Port WebFrontendITCase to Mini...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5665 [FLINK-8703][tests] Port WebFrontendITCase to MiniClusterResource ## What is the purpose of the change Ports the `WebFrontendITCase` to use `MiniClusterResource`. ## Brief change l

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5666: [FLINK-8703][tests] Port KafkaShortRetentionTestBa...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5666 [FLINK-8703][tests] Port KafkaShortRetentionTestBase to MiniClusterRe… ## What is the purpose of the change Ports the `KafkaShortRetentionTestBase` to use `MiniClusterResource`. ##

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5667: [FLINK-8703][tests] Port NotSoMiniClusterIteration...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5667 [FLINK-8703][tests] Port NotSoMiniClusterIterations to MiniClusterResource ## What is the purpose of the change Ports the `NotSoMiniClusterIterations` to use `MiniClusterResource`. #

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5668: [FLINK-8703][tests] Port StreamingScalabilityAndLa...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5668 [FLINK-8703][tests] Port StreamingScalabilityAndLatency to MiniCluste… ## What is the purpose of the change Ports the `StreamingScalabilityAndLatency` to use `MiniClusterResource`.

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClus...

2018-03-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5669 [FLINK-8703][tests] Port KafkaTestBase to MiniClusterResource ## What is the purpose of the change Ports the `KafkaTestBase` and extending classes to use `MiniClusterResource`. ##

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Created] (FLINK-8903) Error calculation based on rolling window in table API and SQL API

2018-03-09 Thread lilizhao (JIRA)
lilizhao created FLINK-8903: --- Summary: Error calculation based on rolling window in table API and SQL API Key: FLINK-8903 URL: https://issues.apache.org/jira/browse/FLINK-8903 Project: Flink Issue

[jira] [Created] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

2018-03-09 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8904: -- Summary: Flink-client tests do not restore previous sysout after changing it Key: FLINK-8904 URL: https://issues.apache.org/jira/browse/FLINK-8904 Project: Flink

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

2018-03-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392666#comment-16392666 ] Gary Yao commented on FLINK-8894: - [~mingleizhang] I have just recompiled the current mast

[jira] [Created] (FLINK-8905) RestClusterClient#getMaxSlots returns 0

2018-03-09 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8905: -- Summary: RestClusterClient#getMaxSlots returns 0 Key: FLINK-8905 URL: https://issues.apache.org/jira/browse/FLINK-8905 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-8905) RestClusterClient#getMaxSlots returns 0

2018-03-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8905: --- Labels: flip-6 (was: ) > RestClusterClient#getMaxSlots returns 0 > --

[jira] [Created] (FLINK-8906) Flip6DefaultCLI is not tested in org.apache.flink.client.cli tests

2018-03-09 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8906: -- Summary: Flip6DefaultCLI is not tested in org.apache.flink.client.cli tests Key: FLINK-8906 URL: https://issues.apache.org/jira/browse/FLINK-8906 Project: Flink

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

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392678#comment-16392678 ] mingleizhang commented on FLINK-8894: - Hmm, Thanks [~gjy] I do not know either. But th

[GitHub] flink issue #5644: [FLINK-8847][build] Prevent unnecessary recompilation

2018-03-09 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5644 Thanks @zentol for taking care of it and also mentioning the related issues. LGTM! ---

[jira] [Commented] (FLINK-8847) Modules containing package-info.java are always recompiled

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

[GitHub] flink issue #5656: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5656 Looks good to me now. +1 ---

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

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

[GitHub] flink pull request #5594: [FLINK-8800][REST] Reduce logging of all requests ...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5594#discussion_r173415584 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java --- @@ -84,8 +84,8 @@ protected AbstractHandler(

[jira] [Commented] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler

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

[GitHub] flink issue #5594: [FLINK-8800][REST] Reduce logging of all requests to TRAC...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5594 +1 to merge ---

[jira] [Commented] (FLINK-8800) Set Logging to TRACE for org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler

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

[jira] [Created] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
mingleizhang created FLINK-8907: --- Summary: Unable to start the process by start-cluster.sh Key: FLINK-8907 URL: https://issues.apache.org/jira/browse/FLINK-8907 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392697#comment-16392697 ] mingleizhang commented on FLINK-8907: - I will add the description soon. > Unable to s

[GitHub] flink issue #5589: [FLINK-8797] Port AbstractOperatorRestoreTestBase to Mini...

2018-03-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5589 Rebased on more time ---

[jira] [Commented] (FLINK-8797) Port AbstractOperatorRestoreTestBase to MiniClusterResource

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

[jira] [Closed] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8856. --- > Move all interrupt() calls to TaskCanceler > -- > >

[jira] [Resolved] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8856. - Resolution: Fixed Fixed in - 1.4.3 via d57d4e0af0c28c85d880a8261aac90e4a07eda32 - 1.5.0 via 36

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392701#comment-16392701 ] Stephan Ewen commented on FLINK-8907: - Starting the cluster via the script works for m

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Looks reasonable. Would be great if another Kinesis user could second this change, just to be safe. @tweise do you see any issues with upgrading AWS SDK here? ---

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

[jira] [Created] (FLINK-8908) MapSerializer creates new serializer even if key and value serializers are stateless

2018-03-09 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-8908: - Summary: MapSerializer creates new serializer even if key and value serializers are stateless Key: FLINK-8908 URL: https://issues.apache.org/jira/browse/FLINK-8908

[GitHub] flink pull request #5670: [FLINK-8904][cli][tests] always restore the previo...

2018-03-09 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5670 [FLINK-8904][cli][tests] always restore the previous sysout when changing it in the test ## What is the purpose of the change Several tests inside the `org.apache.flink.client.cli` package ch

[jira] [Commented] (FLINK-8904) Flink-client tests do not restore previous sysout after changing it

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

[GitHub] flink pull request #5671: [FLINK-8906][flip6][tests] also test Flip6DefaultC...

2018-03-09 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5671 [FLINK-8906][flip6][tests] also test Flip6DefaultCLI in org.apache.flink.client.cli tests ## What is the purpose of the change Various tests in `org.apache.flink.client.cli` only test with th

[jira] [Commented] (FLINK-8906) Flip6DefaultCLI is not tested in org.apache.flink.client.cli tests

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

[jira] [Commented] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer.

2018-03-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392735#comment-16392735 ] Kostas Kloudas commented on FLINK-8841: --- Can someone comment on this issue? I think

[GitHub] flink pull request #5672: [FLINK-8872][flip6] fix yarn detached mode command...

2018-03-09 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5672 [FLINK-8872][flip6] fix yarn detached mode command parsing ## What is the purpose of the change Running yarn per-job cluster in detached mode via `-yd` currently does not detach and instead w

[jira] [Commented] (FLINK-8872) Yarn detached mode via -yd does not detach

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

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

2018-03-09 Thread Hitesh Tiwari (JIRA)
Hitesh Tiwari created FLINK-8909: Summary: pyflink.sh not working with yarn Key: FLINK-8909 URL: https://issues.apache.org/jira/browse/FLINK-8909 Project: Flink Issue Type: Bug Re

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-09 Thread Steve Loughran (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392743#comment-16392743 ] Steve Loughran commented on FLINK-: --- If you are pulling in the shaded SDK, note

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

2018-03-09 Thread Hitesh Tiwari (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitesh Tiwari updated FLINK-8909: - Priority: Blocker (was: Major) Description: Hi, i want to run the python application from

[jira] [Commented] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392769#comment-16392769 ] mingleizhang commented on FLINK-8907: - Hi, [~StephanEwen] The error I saw below: {co

[jira] [Updated] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8907: Description: Build a flink based on the latest code from master branch. And I get the flink binary o

[jira] [Updated] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8907: Description: Build a flink based on the latest code from master branch. And I get the flink binary

[jira] [Updated] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8907: Description: Build a flink based on the latest code from master branch. And I get the flink binary

[jira] [Updated] (FLINK-8907) Unable to start the process by start-cluster.sh

2018-03-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8907: Description: Build a flink based on the latest code from master branch. And I get the flink binary

[GitHub] flink issue #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to look u...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5661 Good fix, merging for 1.4, 1.5, 1.6 ---

[GitHub] flink pull request #5665: [FLINK-8703][tests] Port WebFrontendITCase to Mini...

2018-03-09 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5665#discussion_r173436756 --- Diff: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java --- @@ -66,40 +73,44 @@ private static final i

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[jira] [Commented] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

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

[GitHub] flink pull request #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClus...

2018-03-09 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5669#discussion_r173437603 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java --- @@ -81,12 +81,6 @@

[jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource

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

[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...

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

[jira] [Commented] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

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

[jira] [Resolved] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8896. - Resolution: Fixed Fix Version/s: 1.4.3 Fixed in - 1.4.3 via 64db78c68368b22eff087eb4e74b6

[jira] [Closed] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8896. --- > Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" >

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392816#comment-16392816 ] Stephan Ewen commented on FLINK-: - Thanks for the heads up. Does the Kinesis conn

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 Forwarding comment from JIRA from @steveloughran > If you are pulling in the shaded SDK, note that it's been declaring its netty dependencies unshaded: HADOOP-15264 ---

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5663 I think the above means we need to check and either manually shade netty or, preferably, exclude the netty dependency (if it is not actually needed for Kinesis) ---

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

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

[GitHub] flink pull request #5645: FLINK-8876 Improve concurrent access handling in s...

2018-03-09 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/5645 ---

[jira] [Commented] (FLINK-8876) Improve concurrent access handling in stateful serializers

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

[jira] [Commented] (FLINK-8876) Improve concurrent access handling in stateful serializers

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

[GitHub] flink issue #5645: FLINK-8876 Improve concurrent access handling in stateful...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5645 Manually merged ---

[jira] [Commented] (FLINK-8860) SlotManager spamming log files

2018-03-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392825#comment-16392825 ] Aljoscha Krettek commented on FLINK-8860: - I pushed a follow-up commit for this to

[GitHub] flink pull request #5673: [FLINK-8832] [sql-client] Create a SQL Client Kafk...

2018-03-09 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5673 [FLINK-8832] [sql-client] Create a SQL Client Kafka 0.11 fat-jar ## What is the purpose of the change This PR adds a shaded jar to every Maven release with for Kafka 0.11 that can be used f

[jira] [Commented] (FLINK-8832) Create a SQL Client Kafka fat-jar

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

[GitHub] flink issue #5644: [FLINK-8847][build] Prevent unnecessary recompilation

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5644 Looks good. ---

[jira] [Commented] (FLINK-8847) Modules containing package-info.java are always recompiled

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

[GitHub] flink issue #5642: [FLINK-8091] [flink-dist] Support running historyserver i...

2018-03-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5642 Looks good, thanks! Merging this for 1.5+ ---

[jira] [Commented] (FLINK-8091) Support running historyserver in foreground

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

[GitHub] flink pull request #5642: [FLINK-8091] [flink-dist] Support running historys...

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

[jira] [Closed] (FLINK-8091) Support running historyserver in foreground

2018-03-09 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8091. --- > Support running historyserver in foreground > --- > >

[jira] [Commented] (FLINK-8091) Support running historyserver in foreground

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

  1   2   3   >