[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8941.
--
Resolution: Fixed
Fixed via
master:
39be1996e461bbeec148bf34a2f92cedeccf59ab
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9057.
--
Resolution: Fixed
Fixed via
master: f486a3fd6ed80b67e8eeed9245ad37b6b0be740b
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dhiraj prajapati updated FLINK-9054:
Fix Version/s: (was: 1.5.0)
> IllegalStateException: Buffer pool is destroyed
>
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416868#comment-16416868
]
ASF GitHub Bot commented on FLINK-8941:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416869#comment-16416869
]
ASF GitHub Bot commented on FLINK-8415:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8415.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
master:
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416867#comment-16416867
]
ASF GitHub Bot commented on FLINK-9057:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5724
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5747
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5709
---
[
https://issues.apache.org/jira/browse/FLINK-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416926#comment-16416926
]
liuzhuo commented on FLINK-9072:
I see underscores are not a allowed in hostnames, But some devops can
[
https://issues.apache.org/jira/browse/FLINK-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liuzhuo closed FLINK-9072.
--
Resolution: Not A Problem
> Host name with "_" causes cluster exception
>
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5778
[FLINK-8979] (part 1) Make Kafka end-to-end tests not embarrassingly
parallel
## What is the purpose of the change
This PR improves the behaviour test coverage of Kafka end-to-end tests
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416907#comment-16416907
]
ASF GitHub Bot commented on FLINK-8979:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9101:
Description:
The test deadlocks on travis.
Chesnay Schepler created FLINK-9101:
---
Summary: HAQueryableStateRocksDBBackendITCase failed on travis
Key: FLINK-9101
URL: https://issues.apache.org/jira/browse/FLINK-9101
Project: Flink
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5676#discussion_r177695881
--- Diff:
flink-end-to-end-tests/src/main/java/org/apache/flink/streaming/tests/StickyAllocationAndLocalRecoveryTestJob.java
---
@@ -0,0 +1,451 @@
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417106#comment-16417106
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417107#comment-16417107
]
ASF GitHub Bot commented on FLINK-8740:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5755#discussion_r177695516
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -165,7 +166,7 @@
private final BlobServer
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417174#comment-16417174
]
yanxiaobin commented on FLINK-8794:
---
Other problems have nothing to do with Flink.
> When using
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417002#comment-16417002
]
ASF GitHub Bot commented on FLINK-8979:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5778
while you are at it, can you also add the savepoint tests to
`run-nightly-tests.sh`?
---
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417032#comment-16417032
]
Stephan Ewen commented on FLINK-9061:
-
One advantage of making the changes in the state backend would
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5779
[FLINK-8990] [test] Extend Kafka end-to-end test to verify partition
discovery
## What is the purpose of the change
This PR is based on #5778.
The changes further extends the
[
https://issues.apache.org/jira/browse/FLINK-8990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417082#comment-16417082
]
ASF GitHub Bot commented on FLINK-8990:
---
GitHub user tzulitai opened a pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177696032
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java
---
@@ -440,28 +439,33 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renjie Liu closed FLINK-9077.
-
Resolution: Not A Problem
It has been proven that this is caused by my mistake. When starting
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417058#comment-16417058
]
Renkai Ge commented on FLINK-2540:
--
[~uce] As far as I can see,there is no reason that the thread can
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417067#comment-16417067
]
ASF GitHub Bot commented on FLINK-8979:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5778
@zentol will do
---
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5755
Thanks for the review @zentol. Addressing your last comment while merging
this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417115#comment-16417115
]
ASF GitHub Bot commented on FLINK-8887:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417116#comment-16417116
]
ASF GitHub Bot commented on FLINK-8887:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177684059
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -645,6 +637,56 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177699910
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -659,7 +660,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417140#comment-16417140
]
Steve Loughran commented on FLINK-8794:
---
bq. Enable consistent-view can cause other problems.
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reopened FLINK-2540:
--
It seems that this issue was not fixed at all.It is closed since some
github/Jira sync bugs occured.
I
[
https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417110#comment-16417110
]
ASF GitHub Bot commented on FLINK-8910:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9040:
-
Assignee: (was: Sihua Zhou)
> JobVertex#setMaxParallelism does not validate argument
>
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417145#comment-16417145
]
Steve Loughran edited comment on FLINK-9061 at 3/28/18 10:33 AM:
-
The s3a
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417145#comment-16417145
]
Steve Loughran commented on FLINK-9061:
---
The s3a connector will have the same issue, though there we
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417168#comment-16417168
]
ASF GitHub Bot commented on FLINK-8704:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5780
[FLINK-8704][tests] Port ClassLoaderITCase to flip6
Partially based on #5766.
## What is the purpose of the change
This PR ports the `ClassLoaderITCase` to flip6.
##
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5760
I would suggest to bump it to 3.2.5 as that's that latest version for which
the shading works properly.
---
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417237#comment-16417237
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417236#comment-16417236
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177722358
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java
---
@@ -19,45 +19,81 @@
package
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417235#comment-16417235
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177723226
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
---
@@ -396,15 +398,22 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177721959
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java
---
@@ -19,45 +19,81 @@
package
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417250#comment-16417250
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5775
Thanks for the review @GJL. Rebasing onto the latest master and merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417263#comment-16417263
]
ASF GitHub Bot commented on FLINK-9102:
---
GitHub user sihuazhou opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417264#comment-16417264
]
ASF GitHub Bot commented on FLINK-9102:
---
Github user sihuazhou commented on the issue:
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5781
[FLINK-9102][FLIP6] disable queued scheduling for JobGraph in
Flip6LocalStreamEnvironment
## What is the purpose of the change
When we start cluster locally with fixed TMS and build
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5781
CC: @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417270#comment-16417270
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177731653
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java
---
@@ -19,45 +19,81 @@
package
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417269#comment-16417269
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417277#comment-16417277
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9102:
--
Description: When we start cluster locally with fixed TMS and we should
disable queued scheduling for
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177734109
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
[
https://issues.apache.org/jira/browse/FLINK-9097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417281#comment-16417281
]
ASF GitHub Bot commented on FLINK-9097:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417286#comment-16417286
]
ASF GitHub Bot commented on FLINK-7897:
---
Github user yuqi1129 commented on a diff in the pull
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5777#discussion_r177736130
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java
---
@@ -100,9 +102,15 @@ public void run() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177739972
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -507,19 +539,21 @@ private TestingDispatcher(
[
https://issues.apache.org/jira/browse/FLINK-9097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417297#comment-16417297
]
ASF GitHub Bot commented on FLINK-9097:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5372:
Comment: was deleted
(was: The instability seems to be caused by a plain race condition in
[
https://issues.apache.org/jira/browse/FLINK-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7958:
Fix Version/s: (was: 1.5.0)
1.6.0
> Allow reporters to override the
[
https://issues.apache.org/jira/browse/FLINK-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8700:
---
Assignee: Chesnay Schepler
> Port tests from FlinkMiniCluster to MiniClusterResource
[
https://issues.apache.org/jira/browse/FLINK-9094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417313#comment-16417313
]
ASF GitHub Bot commented on FLINK-9094:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177746665
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-6567:
Assignee: Till Rohrmann
> ExecutionGraphMetricsTest fails on Windows CI
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5771#discussion_r177751742
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -167,6 +172,9 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-6567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417332#comment-16417332
]
ASF GitHub Bot commented on FLINK-6567:
---
GitHub user tillrohrmann opened a pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177725828
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5746
Thanks for the review @GJL. I've addressed your comments and rebased onto
the soon to be master.
---
[
https://issues.apache.org/jira/browse/FLINK-9102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9102:
--
Summary: Make the JobGraph disable queued scheduling for cluster with fixed
TMs (was: Make the
[
https://issues.apache.org/jira/browse/FLINK-9097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417287#comment-16417287
]
ASF GitHub Bot commented on FLINK-9097:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417294#comment-16417294
]
ASF GitHub Bot commented on FLINK-8704:
---
Github user pnowojski commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417295#comment-16417295
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user GJL commented on a diff in the pull request:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5694
@zentol, why did you have to copy
`LegacySlotCountExceedingParallelismTest`? Shouldn't the new one work as well
for non FLIP6?
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177739371
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java
---
@@ -19,45 +19,81 @@
package
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5372:
---
Assignee: (was: Chesnay Schepler)
> Fix
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417303#comment-16417303
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5746
I had one more comment regarding `Thread.interrupted()`.
---
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5669#discussion_r177742687
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@ -244,7
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5669#discussion_r177747320
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5669#discussion_r177743725
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@ -132,8
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5782
[FLINK-6567] [tests] Harden ExecutionGraphMetricsTest
## What is the purpose of the change
The problem was that in some cases the currentRestartingTime would not
increase
because
[
https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417248#comment-16417248
]
Sihua Zhou commented on FLINK-9055:
---
Hi [~fhueske] shall we fail the job immediately when job
[
https://issues.apache.org/jira/browse/FLINK-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417249#comment-16417249
]
ASF GitHub Bot commented on FLINK-9099:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5775#discussion_r177726389
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSchedulingTest.java
---
@@ -465,6 +464,58 @@ public void
Sihua Zhou created FLINK-9102:
-
Summary: Make the JobGraph disable queued scheduling for
Flip6LocalStreamEnvironment
Key: FLINK-9102
URL: https://issues.apache.org/jira/browse/FLINK-9102
Project: Flink
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177728701
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -645,6 +637,56 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177728773
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java
---
@@ -440,28 +439,33 @@
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417261#comment-16417261
]
ASF GitHub Bot commented on FLINK-8887:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5767
Thanks for the review @GJL. I've addressed your comments and rebased on the
soon to be master and force pushed.
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5746#discussion_r177731740
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
---
@@ -396,15 +398,22 @@ public void
1 - 100 of 262 matches
Mail list logo
