[jira] [Updated] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9120: - Priority: Critical (was: Blocker) > Task Manager Fault Tolerance issue >

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423821#comment-16423821 ] ASF GitHub Bot commented on FLINK-8961: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r178778708 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

[jira] [Resolved] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8973. - Resolution: Fixed Fixed in 1.6.0: a666455c98c269c63373e991c6ca2751e132a7c8 Fixed in 1.5.0:

[GitHub] flink pull request #5806: [FLINK-8960][tests] Port SavepointITCase to flip6

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5806 [FLINK-8960][tests] Port SavepointITCase to flip6 ## What is the purpose of the change This PR ports the `SavepointITCase` to flip6. Significant changes were made to the

[jira] [Commented] (FLINK-8960) Port SavepointITCase to flip6

[ https://issues.apache.org/jira/browse/FLINK-8960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423841#comment-16423841 ] ASF GitHub Bot commented on FLINK-8960: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178788782 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/NopTaskLocalStateStoreImpl.java --- @@ -0,0 +1,71 @@ +/* + * Licensed

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423671#comment-16423671 ] ASF GitHub Bot commented on FLINK-8704: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5766#discussion_r178752746 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -69,6 +73,10 @@

[GitHub] flink issue #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedResultTe...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5695 IMO it is not a problem to have duplicate code for legacy/new code. Creating a base class is more effort that it is worth, as the legacy version will be removed again in 1.6 we would then have to

[jira] [Commented] (FLINK-9107) Document timer coalescing for ProcessFunctions

[ https://issues.apache.org/jira/browse/FLINK-9107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423692#comment-16423692 ] ASF GitHub Bot commented on FLINK-9107: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

[ https://issues.apache.org/jira/browse/FLINK-9078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423709#comment-16423709 ] ASF GitHub Bot commented on FLINK-9078: --- Github user florianschmidt1994 commented on a diff in the

[GitHub] flink issue #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5771 I've run the test 10k+ times on my machine without a failure, +1 from my side. ---

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178770011 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423776#comment-16423776 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink issue #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClusterReso...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5669 I've rebased and updated the PR. The `JobManagerCommunicationUtils` were reworked into a `ClusterCommunicationUtils`. All contained methods were now unused. We are also using

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178770202 --- Diff: flink-end-to-end-tests/test-scripts/common.sh --- @@ -176,10 +176,40 @@ function s3_delete {

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r178777980 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

[GitHub] flink pull request #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5750 ---

[jira] [Commented] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423826#comment-16423826 ] ASF GitHub Bot commented on FLINK-8973: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423861#comment-16423861 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Assigned] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9125: --- Assignee: vinoyang > MiniClusterResource should set CoreOptions.TMP_DIRS >

[GitHub] flink issue #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5771 Thanks for the review @zentol. Merging this PR. ---

[GitHub] flink issue #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsTest

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5782 Thanks for the review @zentol. Merging this PR. ---

[jira] [Commented] (FLINK-8982) End-to-end test: Queryable state

[ https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423973#comment-16423973 ] ASF GitHub Bot commented on FLINK-8982: --- GitHub user florianschmidt1994 opened a pull request:

[GitHub] flink issue #5596: [FLINK-8804][Build] Integrate flink-shaded 3.0

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5596 I've rebased the PR and minimized it to only contain the jackson changes. ---

[jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0

[ https://issues.apache.org/jira/browse/FLINK-8804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423701#comment-16423701 ] ASF GitHub Bot commented on FLINK-8804: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423739#comment-16423739 ] Sihua Zhou commented on FLINK-9120: --- Hi [~dhirajpraj] happy to know that it working fine now and thanks

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423793#comment-16423793 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423794#comment-16423794 ] ASF GitHub Bot commented on FLINK-8973: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423795#comment-16423795 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178771812 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178771774 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423797#comment-16423797 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178771748 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink issue #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMachineEx...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5750 Thanks a lot @twalthr for the review! ---

[GitHub] flink issue #5795: [hotfix] [docs] fix mistake about Sample code in Concepts...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5795 merging. ---

[GitHub] flink pull request #5804: [hotfix] [docs] fix typo in table streaming docs

Github user mayyamus closed the pull request at: https://github.com/apache/flink/pull/5804 ---

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178789236 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423928#comment-16423928 ] mingleizhang commented on FLINK-8835: - Sorry for later. [~Zentol] I forgot this issue, I will give a

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178804294 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.java --- @@ -107,4 +131,12 @@ public int getAttemptNumber() { public

[GitHub] flink pull request #5762: [FLINK-9078][E2ETests] Add test that verifies corr...

Github user florianschmidt1994 commented on a diff in the pull request: https://github.com/apache/flink/pull/5762#discussion_r178758895 --- Diff: flink-end-to-end-tests/flink-avro-classloading-test/src/main/avro/user.avsc --- @@ -0,0 +1,9 @@ +{ + "type": "record",

[jira] [Assigned] (FLINK-9008) End-to-end test: Quickstarts

[ https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9008: --- Assignee: mingleizhang > End-to-end test: Quickstarts > > >

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423819#comment-16423819 ] ASF GitHub Bot commented on FLINK-8961: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5804: [hotfix] [docs] fix typo in table streaming docs

GitHub user mayyamus opened a pull request: https://github.com/apache/flink/pull/5804 [hotfix] [docs] fix typo in table streaming docs ## Brief change log fix typo in table streaming docs ## Verifying this change This change is a trivial rework / code

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423860#comment-16423860 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178790018 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178789878 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178790003 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178789937 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/NopTaskLocalStateStoreImpl.java --- @@ -0,0 +1,71 @@ +/* + * Licensed

[GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5798 cc @tillrohrmann ---

[jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423882#comment-16423882 ] ASF GitHub Bot commented on FLINK-7917: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5799: [FLINK-7775] Remove unreferenced method PermanentBlobCach...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5799 cc @tillrohrmann ---

[jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423881#comment-16423881 ] ASF GitHub Bot commented on FLINK-7775: --- Github user yanghua commented on the issue:

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423983#comment-16423983 ] ASF GitHub Bot commented on FLINK-5480: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8205) Multi key get

[ https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423677#comment-16423677 ] Aljoscha Krettek commented on FLINK-8205: - [~sihuazhou] Sounds good! > Multi key get >

[jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6

[ https://issues.apache.org/jira/browse/FLINK-8966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423674#comment-16423674 ] ASF GitHub Bot commented on FLINK-8966: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423675#comment-16423675 ] ASF GitHub Bot commented on FLINK-8704: --- Github user zentol commented on the issue:

[GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5697#discussion_r178754924 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/LegacyScheduleOrUpdateConsumersTest.java --- @@ -0,0 +1,168 @@ +/* + *

[jira] [Commented] (FLINK-9107) Document timer coalescing for ProcessFunctions

[ https://issues.apache.org/jira/browse/FLINK-9107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423682#comment-16423682 ] ASF GitHub Bot commented on FLINK-9107: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423717#comment-16423717 ] Amit Jain commented on FLINK-2685: -- [~uce] [~StephanEwen] We are also facing the same issue on version

[jira] [Comment Edited] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423732#comment-16423732 ] dhiraj prajapati edited comment on FLINK-9120 at 4/3/18 9:29 AM: - Hi

[jira] [Commented] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423782#comment-16423782 ] ASF GitHub Bot commented on FLINK-8973: --- Github user twalthr commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423778#comment-16423778 ] ASF GitHub Bot commented on FLINK-8703: --- Github user zentol commented on the issue:

[GitHub] flink issue #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMachineEx...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5750 Thank you @kl0u. I found a little bug that I will fix. Merging... ---

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423780#comment-16423780 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5797: [FLINK-9104][doc]Re-generate REST API documentatio...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5797#discussion_r178773735 --- Diff: flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java --- @@ -258,6 +265,37 @@ private static String

[jira] [Commented] (FLINK-9104) Re-generate REST API documentation for FLIP-6

[ https://issues.apache.org/jira/browse/FLINK-9104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423803#comment-16423803 ] ASF GitHub Bot commented on FLINK-9104: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423855#comment-16423855 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423867#comment-16423867 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423866#comment-16423866 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178790036 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423865#comment-16423865 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423862#comment-16423862 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423863#comment-16423863 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423919#comment-16423919 ] Chesnay Schepler commented on FLINK-8835: - [~mingleizhang] How far along are you with this issue?

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

[ https://issues.apache.org/jira/browse/FLINK-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423933#comment-16423933 ] ASF GitHub Bot commented on FLINK-8872: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6

[ https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423932#comment-16423932 ] ASF GitHub Bot commented on FLINK-8961: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Updated] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-8835: Description: Many new config keys in the TaskManager don't follow the proper naming scheme. We

[GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure...

GitHub user florianschmidt1994 opened a pull request: https://github.com/apache/flink/pull/5807 [FLINK-8982][E2E Tests] Add test for known failure of queryable state ## What is the purpose of the change Add an end-to-end test to verify that the changes that @kl0u introduced in

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423662#comment-16423662 ] Sihua Zhou commented on FLINK-9120: --- Hmm...It looks like the JobManager still try to deploy the job to

[jira] [Reopened] (FLINK-8891) RestServerEndpoint can bind on local address only

[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8891: - Reopen to change fix version   > RestServerEndpoint can bind on local address only >

[jira] [Updated] (FLINK-8891) RestServerEndpoint can bind on local address only

[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8891: Fix Version/s: 1.5.0 > RestServerEndpoint can bind on local address only >

[jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource

[ https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423685#comment-16423685 ] ASF GitHub Bot commented on FLINK-8704: --- Github user zentol commented on a diff in the pull request:

[jira] [Closed] (FLINK-8891) RestServerEndpoint can bind on local address only

[ https://issues.apache.org/jira/browse/FLINK-8891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8891. --- Resolution: Fixed > RestServerEndpoint can bind on local address only >

[jira] [Commented] (FLINK-9094) AccumulatorLiveITCase unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-9094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423755#comment-16423755 ] ASF GitHub Bot commented on FLINK-9094: --- Github user zentol commented on the issue:

[GitHub] flink issue #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5771 whoops, that last comment was for the wrong PR... ---

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423753#comment-16423753 ] dhiraj prajapati commented on FLINK-9120: - Hi [~till.rohrmann], with MemoryStateBackend, the state

[GitHub] flink issue #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsTest

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5782 I've run the test 10k+ times on my machine without a failure, +1 from my side. ---

[jira] [Commented] (FLINK-9094) AccumulatorLiveITCase unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-9094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423757#comment-16423757 ] ASF GitHub Bot commented on FLINK-9094: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI

[ https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423758#comment-16423758 ] ASF GitHub Bot commented on FLINK-6567: --- Github user zentol commented on the issue:

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178771947 --- Diff: flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java --- @@ -0,0 +1,451 @@

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423799#comment-16423799 ] ASF GitHub Bot commented on FLINK-8910: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178788150 --- Diff: flink-end-to-end-tests/test-scripts/test_local_recovery_and_scheduling.sh --- @@ -0,0 +1,111 @@ +#!/usr/bin/env bash +

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423931#comment-16423931 ] ASF GitHub Bot commented on FLINK-8910: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r178804348 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/NopTaskLocalStateStoreImpl.java --- @@ -0,0 +1,71 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423930#comment-16423930 ] ASF GitHub Bot commented on FLINK-8910: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5730#discussion_r178804508 --- Diff: flink-tests/src/test/java/org/apache/flink/test/example/client/JobRetrievalITCase.java --- @@ -21,54 +21,69 @@ import

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

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5672#discussion_r178804566 --- Diff: flink-yarn/pom.xml --- @@ -326,6 +334,62 @@ under the License.

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423948#comment-16423948 ] ASF GitHub Bot commented on FLINK-5480: --- Github user ShashwatRastogi-Reflektion commented on the

  1   2   3   >