[
https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410823#comment-16410823
]
Sihua Zhou commented on FLINK-9058:
---
Shall we also relax the {{MapState.putAll()}} to take {{Iterable}},
[
https://issues.apache.org/jira/browse/FLINK-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410799#comment-16410799
]
yinhua.dai commented on FLINK-6473:
---
[~fhueske]
Wondering before this feature is implemented, how could
[
https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-8988:
-
Assignee: Shuyi Chen
> End-to-end test: Cassandra connector
>
[
https://issues.apache.org/jira/browse/FLINK-8988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410784#comment-16410784
]
Shuyi Chen commented on FLINK-8988:
---
[~till.rohrmann] that sounds a good idea. I can help with it.
>
[
https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410766#comment-16410766
]
ASF GitHub Bot commented on FLINK-8970:
---
Github user walterddr commented on the issue:
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/5750
Based on the umbrella task link FLINK-8970, it seems like this e2e test
should be attached to FLINK-8973 instead?
---
[
https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410755#comment-16410755
]
ASF GitHub Bot commented on FLINK-9060:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5751
CC: @aljoscha @StefanRRichter
---
[
https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410753#comment-16410753
]
ASF GitHub Bot commented on FLINK-9060:
---
GitHub user sihuazhou opened a pull request:
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5751
[FLINK-9060][state] Deleting state using KeyedStateBackend.getKeys() throws
Exception
## What is the purpose of the change
This PR fixes the problem when deleting state using
[
https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-7775:
---
Assignee: vinoyang
> Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs
>
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410688#comment-16410688
]
ASF GitHub Bot commented on FLINK-9057:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/5747
Thanks for fixing this problem. The `notifyReaderCreated` should be called
after both views are created correctly, otherwise it will cause inconsistent.
LGTM ð
---
[
https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410669#comment-16410669
]
Sihua Zhou commented on FLINK-9060:
---
1. For {{MemoryStateBackendTest}} this is because a concurrency
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5580
@zentol What do you think we still need now? I think this makes things
easier for users. And we also need this for work on the Beam Flink Runner.
---
[
https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410665#comment-16410665
]
ASF GitHub Bot commented on FLINK-8620:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410660#comment-16410660
]
vinoyang commented on FLINK-8946:
-
[~till.rohrmann] yes, I will try to fix it.
> TaskManager stop sending
[
https://issues.apache.org/jira/browse/FLINK-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9060:
-
Assignee: Sihua Zhou
> Deleting state using KeyedStateBackend.getKeys() throws Exception
>
Jamie Grier created FLINK-9061:
--
Summary: S3 checkpoint data not partitioned well -- causes errors
and poor performance
Key: FLINK-9061
URL: https://issues.apache.org/jira/browse/FLINK-9061
Project:
Aljoscha Krettek created FLINK-9060:
---
Summary: Deleting state using KeyedStateBackend.getKeys() throws
Exception
Key: FLINK-9060
URL: https://issues.apache.org/jira/browse/FLINK-9060
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7775:
--
Description:
{code}
public int getNumberOfCachedJobs() {
return jobRefCounters.size();
}
{code}
The
[
https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410237#comment-16410237
]
Shuyi Chen commented on FLINK-9049:
---
Good point, [~fhueske]. Just created a JIRA for this and will get
Shuyi Chen created FLINK-9059:
-
Summary: Add support for unified table source and sink declaration
in environment file
Key: FLINK-9059
URL: https://issues.apache.org/jira/browse/FLINK-9059
Project: Flink
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/5750
[FLINK-8970] [E2E] HA end-to-end test with StateMachineExample.
Adds an end-to-end test that runs the StateMachineExample on a local
cluster with HA enabled. There is a single JM which gets killed and
[
https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410172#comment-16410172
]
ASF GitHub Bot commented on FLINK-8970:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410031#comment-16410031
]
Aljoscha Krettek commented on FLINK-9058:
-
We could do but I would be more hesitant to change
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410027#comment-16410027
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9054:
Priority: Blocker (was: Critical)
> IllegalStateException: Buffer pool is destroyed
>
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9054:
Fix Version/s: 1.5.0
> IllegalStateException: Buffer pool is destroyed
>
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5732
@StephanEwen Yes, I think this should go into 1.5.0 because it fixes
potential (and real) problems. And yes, I wasn't suggesting to remove
`initializeSerializerUnlessSet(ExecutionConfig)` now, but
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410004#comment-16410004
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410009#comment-16410009
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410010#comment-16410010
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410005#comment-16410005
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410007#comment-16410007
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410011#comment-16410011
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410008#comment-16410008
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410013#comment-16410013
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410006#comment-16410006
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16410012#comment-16410012
]
ASF GitHub Bot commented on FLINK-8721:
---
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/5737#discussion_r176515090
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176517944
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/client/SerializedJobExecutionResultTest.java
---
@@ -21,83 +21,98 @@
import
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176515453
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176515734
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176515638
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176518316
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorErrorITCase.java
---
@@ -45,84 +47,87 @@
* b) are not
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176516910
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176517725
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java
---
@@ -50,13 +51,13 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176517187
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java
---
@@ -48,8 +49,9 @@
* @param
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176514312
--- Diff:
flink-core/src/main/java/org/apache/flink/util/OptionalFailure.java ---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1640#comment-1640
]
Ken Krugler commented on FLINK-9058:
Would it make sense to file a related enhancement issue, for the
[
https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409985#comment-16409985
]
ASF GitHub Bot commented on FLINK-9058:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/5749
[FLINK-9058] Relax ListState.addAll() and ListState.update() to take
Iterable
If we do this, we should do it before 1.5.0 because we are introducing the
methods for the first time there.
[
https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409966#comment-16409966
]
Aljoscha Krettek commented on FLINK-9058:
-
And I would like to fix this before we release those
Aljoscha Krettek created FLINK-9058:
---
Summary: Relax ListState.addAll() and ListState.update() to take
Iterable
Key: FLINK-9058
URL: https://issues.apache.org/jira/browse/FLINK-9058
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8562.
--
Resolution: Fixed
Fixed via
master:
37a114875afb9352e6f7b10e2729a94d0eeb72ee
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409949#comment-16409949
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5416
---
[
https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409918#comment-16409918
]
ASF GitHub Bot commented on FLINK-8919:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5680#discussion_r176499309
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/operators/KeyedProcessFunctionWithCleanupStateTest.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409913#comment-16409913
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5746
Thanks for your reply ;)
---
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409907#comment-16409907
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409908#comment-16409908
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5746
Yes @sihuazhou. In such a case the JM will terminate in order to let
another JM try to recover the jobs.
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5746
please just ignore my question...
---
[
https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409899#comment-16409899
]
ASF GitHub Bot commented on FLINK-9031:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5742
Updated the PR.
Tests are passing (mod an unrelated failure).
---
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409888#comment-16409888
]
ASF GitHub Bot commented on FLINK-8943:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5746
Hi @tillrohrmann there is one question I want ask about this PR, is it
means that in HA mode we can't tolerant jobs partial broken?
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5624
@StephanEwen unfortunately not, for example:
`org.apache.flink.runtime.fs.hdfs.HadoopFileSystem#create()` ->
`org.apache.hadoop.fs.FileSystem#create()` ->
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409887#comment-16409887
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409866#comment-16409866
]
ASF GitHub Bot commented on FLINK-8402:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5624#discussion_r176492623
--- Diff:
flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/PrestoS3FileSystemITCase.java
---
@@ -143,7 +157,20 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409841#comment-16409841
]
ASF GitHub Bot commented on FLINK-8964:
---
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/5727#discussion_r176489375
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/example/failing/JobSubmissionFailsITCase.java
---
@@ -105,90 +85,51 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409832#comment-16409832
]
ASF GitHub Bot commented on FLINK-8964:
---
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/5727#discussion_r176487399
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/example/failing/JobSubmissionFailsITCase.java
---
@@ -105,90 +85,51 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409833#comment-16409833
]
ASF GitHub Bot commented on FLINK-8964:
---
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/5727#discussion_r176487184
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/example/failing/JobSubmissionFailsITCase.java
---
@@ -105,90 +85,51 @@ public
Github user sihuazhou closed the pull request at:
https://github.com/apache/flink/pull/5696
---
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409803#comment-16409803
]
ASF GitHub Bot commented on FLINK-9053:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5748
[FLINK-9053][runtime] only release outputs under the checkpoint lock
## What is the purpose of the change
Releasing an operator chain's outputs will call
`RecordWriter#clearBuffers()` and
[
https://issues.apache.org/jira/browse/FLINK-8957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409800#comment-16409800
]
ASF GitHub Bot commented on FLINK-8957:
---
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/5720#discussion_r176482195
--- Diff:
flink-metrics/flink-metrics-jmx/src/test/java/org/apache/flink/runtime/jobmanager/JMXJobManagerMetricTest.java
---
@@ -92,28 +101,26 @@
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-9053:
--
Assignee: Nico Kruber
> Exception in RecordWriter during cleanup of StreamTask with the
[
https://issues.apache.org/jira/browse/FLINK-9057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409786#comment-16409786
]
ASF GitHub Bot commented on FLINK-9057:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5747
[FLINK-9057][network] fix an NPE when cleaning up before requesting a
subpartition view
## What is the purpose of the change
In `PartitionRequestServerHandler`, the view reader is created
[
https://issues.apache.org/jira/browse/FLINK-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409777#comment-16409777
]
ASF GitHub Bot commented on FLINK-8959:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5719
Good work @zentol. I guess only a rebase is missing. +1 for merging then.
---
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9053:
---
Summary: Exception in RecordWriter during cleanup of StreamTask with the
checkpoint trigger running
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9053:
---
Affects Version/s: 1.6.0
> RescalingITCase failed on travis
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9053:
---
Component/s: (was: Tests)
> RescalingITCase failed on travis
>
>
[
https://issues.apache.org/jira/browse/FLINK-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9053:
---
Labels: (was: test-stability)
> RescalingITCase failed on travis
>
Nico Kruber created FLINK-9057:
--
Summary: NPE in CreditBasedSequenceNumberingViewReader when
cancelling before initilization was complete
Key: FLINK-9057
URL: https://issues.apache.org/jira/browse/FLINK-9057
[
https://issues.apache.org/jira/browse/FLINK-8956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409766#comment-16409766
]
ASF GitHub Bot commented on FLINK-8956:
---
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/5715#discussion_r176475682
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
---
@@ -528,54 +454,44 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9055:
-
Assignee: Sihua Zhou
> WebUI shows job as Running although not enough resources are available
>
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409738#comment-16409738
]
Till Rohrmann edited comment on FLINK-8887 at 3/22/18 3:41 PM:
---
When did you
[
https://issues.apache.org/jira/browse/FLINK-8887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409738#comment-16409738
]
Till Rohrmann commented on FLINK-8887:
--
When did you observe the problem [~gjy]? I think this problem
1 - 100 of 177 matches
Mail list logo
