Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169620794
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -319,6 +321,9 @@ pri
Stephan Ewen created FLINK-8727:
---
Summary: Test instability in
SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager
Key: FLINK-8727
URL: https://issues.apache.org/jira/browse/FLINK-8727
Projec
Till Rohrmann created FLINK-8728:
Summary: Fail new worker requests immediately in Standalone mode
Key: FLINK-8728
URL: https://issues.apache.org/jira/browse/FLINK-8728
Project: Flink
Issue T
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5528#discussion_r169622022
--- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.bat ---
@@ -0,0 +1,77 @@
+::
[
https://issues.apache.org/jira/browse/FLINK-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371322#comment-16371322
]
ASF GitHub Bot commented on FLINK-6489:
---
Github user zentol commented on a diff in t
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5541
[FLINK-8728] [flip6] Fail new worker requests immediately in standalone mode
## What is the purpose of the change
Let the StandaloneResourceManager throw a ResourceManagerException in c
[
https://issues.apache.org/jira/browse/FLINK-8728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371326#comment-16371326
]
ASF GitHub Bot commented on FLINK-8728:
---
GitHub user tillrohrmann opened a pull requ
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5535
will merge this, as is, once travis gives a green light. The commits have
the rather nice property that they don't require changes to other classes (like
the MiniClusterResource); wouldn't want to des
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371333#comment-16371333
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5542#discussion_r169623190
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BigUserProgramJobSubmitITCase.java
---
@@ -43,40 +40,27 @@
/**
* Integ
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5542
[FLINK-8703][tests] Migrate tests from LocalFlinkMiniCluster to
MiniClusterResource
## What is the purpose of the change
This PR contains the second batch of test ports from
`LocalFlinkMini
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371336#comment-16371336
]
ASF GitHub Bot commented on FLINK-8703:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371338#comment-16371338
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on a diff in t
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5465
Thanks for your comment for the `AutoCloseable` proposal, I agreed that the
disadvantages are more than advantages
---
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371340#comment-16371340
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user sihuazhou commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8727.
Resolution: Duplicate
> Test instability in
> SlotPoolRpcTest.testCancelSlotAllocationWithoutResour
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5542
Together with #5535 this should cover all usages of `LocalFlinkMiniCluster`
that we can port in isolation.
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5465
I have addressed all the comments. One thing that I am not 100 sure: I
change the size of the `cacheEntries` to the fixed value `CACHE_SIZE_LIMIT`
(128). @StefanRRichter Could you please have a loo
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371344#comment-16371344
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371345#comment-16371345
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user sihuazhou commented on the issu
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5534
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371346#comment-16371346
]
ASF GitHub Bot commented on FLINK-8713:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Affects Version/s: (was: 1.4.0)
1.5.0
> Introduce PartitionedBloomFilter for
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Affects Version/s: (was: 1.4.0)
1.5.0
> Accelerate recover from failover when
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5497#discussion_r169626782
--- Diff: docs/dev/migration.md ---
@@ -145,16 +145,16 @@ public class BufferingSink implements
SinkFunction>,
bufferedElements.add(value);
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5497
It's fine, I'll merge it and add the spaces back while doing so.
---
[
https://issues.apache.org/jira/browse/FLINK-8726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371362#comment-16371362
]
ASF GitHub Bot commented on FLINK-8726:
---
Github user zentol commented on a diff in t
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5518
I have addressed all the comments, could you please have a look again? cc
@StefanRRichter @aljoscha
---
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371366#comment-16371366
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user sihuazhou commented on the issu
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169627770
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371367#comment-16371367
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5465
While `128` is maybe already up to 128x better, a scientific approach for
finding the constant would be to try out for very small entries from which
point you have diminishing returns for high
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371379#comment-16371379
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user StefanRRichter commented on the
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169631205
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +527,7
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371388#comment-16371388
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8715:
Priority: Blocker (was: Major)
> RocksDB does not propagate reconfiguration of serializer to the st
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371392#comment-16371392
]
Stephan Ewen commented on FLINK-8715:
-
[~aljoscha] and [~srichter] and [~tzulitai] - w
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8707:
Description:
The job manager has less FDs than the task manager.
Hi
A support alert indicated t
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8707:
Component/s: (was: JobManager)
TaskManager
> Excessive amount of files opened b
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5543
[FLINK-8596][CLI] Also catch NoClassDefFoundErrors
## What is the purpose of the change
This PR modifies the CliFrontend to also catch `NoClassDefFoundErrors` when
loading the YARN CLI, as o
[
https://issues.apache.org/jira/browse/FLINK-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371396#comment-16371396
]
ASF GitHub Bot commented on FLINK-8596:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8721:
Priority: Blocker (was: Major)
> Client blocks indefinitely if job archiving fails
> --
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5465
Aha, for now I would like to leave it to 128 ... Even I can't find a best
value, but this value is not a bad value and is also a safety value.. If I
found any another value that is better than it
[
https://issues.apache.org/jira/browse/FLINK-8639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371399#comment-16371399
]
ASF GitHub Bot commented on FLINK-8639:
---
Github user sihuazhou commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371401#comment-16371401
]
Stephan Ewen commented on FLINK-8707:
-
If I understand this correctly, the FDs should
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371403#comment-16371403
]
chris snow commented on FLINK-8543:
---
Sorry for the delay. I've added the debug statement
Stephan Ewen created FLINK-8729:
---
Summary: Migrate JSONGenerator from Slink to Jackson
Key: FLINK-8729
URL: https://issues.apache.org/jira/browse/FLINK-8729
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371405#comment-16371405
]
chris snow commented on FLINK-8543:
---
[~aljoscha] The failures seem to be happening for a
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371403#comment-16371403
]
chris snow edited comment on FLINK-8543 at 2/21/18 1:33 PM:
So
[
https://issues.apache.org/jira/browse/FLINK-8645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8645:
---
Assignee: Chesnay Schepler
> Support convenient extension of parent-first ClassLoader
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5543
+1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371420#comment-16371420
]
ASF GitHub Bot commented on FLINK-8596:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371427#comment-16371427
]
Aljoscha Krettek commented on FLINK-8715:
-
I think it is an issue but I don't see
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5544
[FLINK-8645][configuration] Split classloader.parent-first-patterns into
"base" and "append
## What is the purpose of the change
This PR splits the `classloader.parent-first-patterns` optio
[
https://issues.apache.org/jira/browse/FLINK-8645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371441#comment-16371441
]
ASF GitHub Bot commented on FLINK-8645:
---
GitHub user zentol opened a pull request:
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169638326
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -336,1697 +
[
https://issues.apache.org/jira/browse/FLINK-8720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371442#comment-16371442
]
Stephan Ewen commented on FLINK-8720:
-
That looks like a classloading / class duplicat
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371445#comment-16371445
]
Aljoscha Krettek commented on FLINK-8543:
-
Ok, this confirms my suspicion. The pro
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5540
---
[
https://issues.apache.org/jira/browse/FLINK-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371451#comment-16371451
]
ASF GitHub Bot commented on FLINK-8723:
---
Github user asfgit closed the pull request
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5542#discussion_r169647902
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BigUserProgramJobSubmitITCase.java
---
@@ -43,40 +40,27 @@
/**
* Int
[
https://issues.apache.org/jira/browse/FLINK-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371454#comment-16371454
]
Kostas Kloudas commented on FLINK-8723:
---
Merged at 2fa8a158640ab9a46c2bfb6610766e245
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371455#comment-16371455
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8723.
-
Resolution: Fixed
Merged at 2fa8a158640ab9a46c2bfb6610766e2458ebe7a2
> Remove existing BroadcastS
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5542#discussion_r169648970
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BigUserProgramJobSubmitITCase.java
---
@@ -43,40 +40,27 @@
/**
* Int
[
https://issues.apache.org/jira/browse/FLINK-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371461#comment-16371461
]
ASF GitHub Bot commented on FLINK-8703:
---
Github user aljoscha commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169649287
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -336,1
Gary Yao created FLINK-8730:
---
Summary: Make SerializedThrowable deserialized from JSON
re-throwable
Key: FLINK-8730
URL: https://issues.apache.org/jira/browse/FLINK-8730
Project: Flink
Issue Type:
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169651017
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -336,1697 +
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8718:
Component/s: (was: Core)
> Non-parallel DataStreamSource does not set max parallelism
>
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8718:
Component/s: DataStream API
> Non-parallel DataStreamSource does not set max parallelism
> -
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8718:
Component/s: Streaming
> Non-parallel DataStreamSource does not set max parallelism
> --
[
https://issues.apache.org/jira/browse/FLINK-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8729:
---
Assignee: Chesnay Schepler
> Migrate JSONGenerator from Sling to Jackson
> --
[
https://issues.apache.org/jira/browse/FLINK-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8729:
Summary: Migrate JSONGenerator from Sling to Jackson (was: Migrate
JSONGenerator from Slink
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8704:
---
Assignee: mingleizhang
> Migrate tests from TestingCluster to MiniClusterResource
> -
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371477#comment-16371477
]
ASF GitHub Bot commented on FLINK-8718:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5545
[FLINK-8718][DataStream] Set maxParallelism on non-parallel DataStreamSource
## What is the purpose of the change
*Set maxParallelism to 1 on
`org.apache.flink.streaming.api.datastream.DataStre
[
https://issues.apache.org/jira/browse/FLINK-8730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8730:
---
Assignee: Gary Yao
> Make SerializedThrowable deserialized from JSON re-throwable
> -
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371485#comment-16371485
]
chris snow commented on FLINK-8543:
---
Unfortunately, commenting out the call to super.clo
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5544
Good change in principle, but I think "base" and "append" are not a great
choice of names for the parameters. Probably not very intuitive for users.
How about calling them `default` and `
[
https://issues.apache.org/jira/browse/FLINK-8645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371503#comment-16371503
]
ASF GitHub Bot commented on FLINK-8645:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5544#discussion_r169660742
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java ---
@@ -86,11 +86,42 @@
*
*/
public static
[
https://issues.apache.org/jira/browse/FLINK-8645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371505#comment-16371505
]
ASF GitHub Bot commented on FLINK-8645:
---
Github user StephanEwen commented on a diff
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5546
[FLINK-8730][REST] JSON serialize entire SerializedThrowable
## What is the purpose of the change
*For the JSON representation, do not only serialize the serialized
exception but the entire Ser
[
https://issues.apache.org/jira/browse/FLINK-8730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371522#comment-16371522
]
ASF GitHub Bot commented on FLINK-8730:
---
GitHub user GJL opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5547
[FLINK-8704] [tests] Port AccumulatorLiveITCase to MiniClusterResource
## What is the purpose of the change
This PR contains the first batch of test ports from ```TestingCluster``` to
```Mi
[
https://issues.apache.org/jira/browse/FLINK-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371530#comment-16371530
]
ASF GitHub Bot commented on FLINK-8704:
---
GitHub user zhangminglei opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371539#comment-16371539
]
Ken Krugler commented on FLINK-8717:
Hi [~rrevol] - sadly the iteration improvements (
[
https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371542#comment-16371542
]
Romain Revol commented on FLINK-8717:
-
Hi, sadly indeed. Did you finally find a workar
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371570#comment-16371570
]
Aljoscha Krettek commented on FLINK-8543:
-
Regarding IBM COS S3: Yes, that sounds
Chesnay Schepler created FLINK-8731:
---
Summary: TwoInputStreamTaskTest flaky on travis
Key: FLINK-8731
URL: https://issues.apache.org/jira/browse/FLINK-8731
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8731:
Labels: test-stability (was: )
> TwoInputStreamTaskTest flaky on travis
> -
[
https://issues.apache.org/jira/browse/FLINK-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8732:
-
Labels: flip-6 (was: )
> Cancel scheduling operation when cancelling the ExecutionGraph
> ---
Till Rohrmann created FLINK-8732:
Summary: Cancel scheduling operation when cancelling the
ExecutionGraph
Key: FLINK-8732
URL: https://issues.apache.org/jira/browse/FLINK-8732
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8732:
Assignee: Till Rohrmann
> Cancel scheduling operation when cancelling the ExecutionGraph
>
[
https://issues.apache.org/jira/browse/FLINK-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8732:
-
Description:
With the Flip-6 changes and the support for queued scheduling, the
{{ExecutionGraph}
[
https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8731:
Priority: Blocker (was: Major)
> TwoInputStreamTaskTest flaky on travis
> -
[
https://issues.apache.org/jira/browse/FLINK-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8731:
Fix Version/s: 1.5.0
> TwoInputStreamTaskTest flaky on travis
>
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5548
[FLINK-8732] [flip6] Cancel ongoing scheduling operation
## What is the purpose of the change
Keeps track of ongoing scheduling operations in the ExecutionGraph and
cancels
them in
[
https://issues.apache.org/jira/browse/FLINK-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16371597#comment-16371597
]
ASF GitHub Bot commented on FLINK-8732:
---
GitHub user tillrohrmann opened a pull requ
101 - 200 of 387 matches
Mail list logo
