Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5479
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407874#comment-16407874
]
ASF GitHub Bot commented on FLINK-8649:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407877#comment-16407877
]
Stephan Ewen commented on FLINK-9031:
-
Hmmm, looking at the execution plans you shared
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407884#comment-16407884
]
Stephan Ewen commented on FLINK-9043:
-
When a Flink job starts, you can tell it explic
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407886#comment-16407886
]
vinoyang commented on FLINK-8946:
-
Yes, for TaskExector we could close it. But for TaskMan
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4809
@razvan100 I've merged the PR, could you close it?
---
[
https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407887#comment-16407887
]
ASF GitHub Bot commented on FLINK-7803:
---
Github user zentol commented on the issue:
Herbert Koelman created FLINK-9044:
--
Summary: Fork a new stream in a stream
Key: FLINK-9044
URL: https://issues.apache.org/jira/browse/FLINK-9044
Project: Flink
Issue Type: Wish
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5736
[FLINK-9042][tests] Port ResumeCheckpointManuallyITCase to flip6
## What is the purpose of the change
Ports the `ResumeCheckpointManuallyITCase` to use `MiniClusterResource`.
This po
[
https://issues.apache.org/jira/browse/FLINK-9042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407908#comment-16407908
]
ASF GitHub Bot commented on FLINK-9042:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9040:
Summary: JobVertex#setMaxParallelism does not validate argument (was:
JobVertex#setMaxParal
[
https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407920#comment-16407920
]
Sihua Zhou commented on FLINK-9040:
---
Hi [~Zentol] there's one thing I want to confirm wi
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5734
CC: @zentol I've addressed your comments and Travis given green light,
could you please have a look again?
---
[
https://issues.apache.org/jira/browse/FLINK-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407926#comment-16407926
]
ASF GitHub Bot commented on FLINK-9026:
---
Github user sihuazhou commented on the issu
Stephan Ewen created FLINK-9045:
---
Summary: LocalEnvironment with web UI does not work with flip-6
Key: FLINK-9045
URL: https://issues.apache.org/jira/browse/FLINK-9045
Project: Flink
Issue Type
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5737
[FLINK-8721][flip6] Handle archiving failures for accumulators
During archivization, wrap errors thrown by users' Accumulators into a
FailedAccumulator and do not fail the job because of that.
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407950#comment-16407950
]
ASF GitHub Bot commented on FLINK-8721:
---
GitHub user pnowojski opened a pull request
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5738
[FLINK-8925][tests] Enable flip6 on travis
Minimal version of #5714.
## What is the purpose of the change
This PR enables Flip6 for half of our travis profiles.
You can merge this
[
https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407952#comment-16407952
]
ASF GitHub Bot commented on FLINK-8925:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407955#comment-16407955
]
ASF GitHub Bot commented on FLINK-8771:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5702
cc @zentol
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5573
---
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8756.
--
Resolution: Fixed
Fixed via
master: e0bc37bef69f5376d03214578e9b95816add661b
1.5.0: 9f2b3c33272f
[
https://issues.apache.org/jira/browse/FLINK-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407965#comment-16407965
]
ASF GitHub Bot commented on FLINK-8756:
---
Github user asfgit closed the pull request
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5580
@aljoscha In the end I've implemented uploading directories as zip
archives, as @zentol suggested. End-to-end python tests passes. Let me know
what you both think.
---
[
https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407980#comment-16407980
]
ASF GitHub Bot commented on FLINK-8620:
---
Github user dawidwys commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9045:
---
Assignee: Chesnay Schepler
> LocalEnvironment with web UI does not work with flip-6
>
Kostas Kloudas created FLINK-9046:
-
Summary: Improve error messages when receiving unexpected messages.
Key: FLINK-9046
URL: https://issues.apache.org/jira/browse/FLINK-9046
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-9046:
--
Fix Version/s: 1.5.0
> Improve error messages when receiving unexpected messages.
>
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-9046:
--
Description:
Currently, in many cases, when a Rest Handler received an unexpected messages,
e.g
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5735#discussion_r176099489
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/FoldingStateDescriptor.java
---
@@ -55,7 +55,7 @@
* @param typeClass The typ
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5735#discussion_r176099684
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/FoldingStateDescriptor.java
---
@@ -89,7 +89,7 @@ public FoldingStateDescriptor(Strin
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5735#discussion_r176099599
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/FoldingStateDescriptor.java
---
@@ -72,7 +72,7 @@ public FoldingStateDescriptor(Strin
[
https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407998#comment-16407998
]
ASF GitHub Bot commented on FLINK-9036:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407997#comment-16407997
]
ASF GitHub Bot commented on FLINK-9036:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16407996#comment-16407996
]
ASF GitHub Bot commented on FLINK-9036:
---
Github user sihuazhou commented on a diff i
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5729
Thanks!
---
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5718
Thanks!
---
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5708
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408007#comment-16408007
]
Chesnay Schepler commented on FLINK-9045:
-
Can't reproduce the issue, it even work
[
https://issues.apache.org/jira/browse/FLINK-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408007#comment-16408007
]
Chesnay Schepler edited comment on FLINK-9045 at 3/21/18 2:36 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408009#comment-16408009
]
ASF GitHub Bot commented on FLINK-8073:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408010#comment-16408010
]
ASF GitHub Bot commented on FLINK-7343:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408011#comment-16408011
]
ASF GitHub Bot commented on FLINK-8984:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408007#comment-16408007
]
Chesnay Schepler edited comment on FLINK-9045 at 3/21/18 2:37 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408007#comment-16408007
]
Chesnay Schepler edited comment on FLINK-9045 at 3/21/18 2:37 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8707:
-
Assignee: Piotr Nowojski
> Excessive amount of files opened by flink task manager
> -
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408049#comment-16408049
]
yinhua.dai commented on FLINK-6595:
---
I am having a similar issue in Flink 1.4
SELECT
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408067#comment-16408067
]
Piotr Nowojski commented on FLINK-8707:
---
[~imogard] could you provide us the steps t
[
https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408069#comment-16408069
]
ASF GitHub Bot commented on FLINK-8623:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5449
Hi, @tillrohrmann I push a new version of code based on your suggestions.
Could you please take a look when available ? Thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8989:
---
Assignee: mingleizhang
> End-to-end test: ElasticSearch connector
> -
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408089#comment-16408089
]
Fabian Hueske commented on FLINK-6595:
--
[~yinhua], the inner query does not forward a
[
https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408111#comment-16408111
]
Stephan Ewen commented on FLINK-9031:
-
Fabian and me tracked this to an issue in the {
Till Rohrmann created FLINK-9047:
Summary: SlotPool can fail to release slots
Key: FLINK-9047
URL: https://issues.apache.org/jira/browse/FLINK-9047
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408249#comment-16408249
]
Sihua Zhou commented on FLINK-9047:
---
Hi [~till.rohrmann] have you already work on this?
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5580
I think that's a very good solution in the end that even simplifies things.
What do you think, @zentol ?
---
[
https://issues.apache.org/jira/browse/FLINK-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408258#comment-16408258
]
ASF GitHub Bot commented on FLINK-8620:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8933:
--
Description:
Class#newInstance is deprecated starting in Java 9 -
https://bugs.openjdk.java.net/browse/JDK-6850
[
https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8931:
--
Description:
Noticed the following :
{code}
[WARNING]
/a/flink-1.3.3/flink-mesos/src/main/scala/org/apache/fli
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5739
[FLINK-9047] Fix slot recycling in case of failed release
## What is the purpose of the change
In case that a slot cannot be released it will only recycled/reused if the
owning
Tas
[
https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408322#comment-16408322
]
ASF GitHub Bot commented on FLINK-9047:
---
GitHub user tillrohrmann opened a pull requ
Ted Yu created FLINK-9048:
-
Summary:
LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers
sometimes fails
Key: FLINK-9048
URL: https://issues.apache.org/jira/browse/FLINK-9048
Projec
Github user Bekreth commented on the issue:
https://github.com/apache/flink/pull/5538
I've been looking into this more in depth and I'm uncertain there is going
to be a cleaner solution. The DataStax annotation parser will fail during
runtime if it can't determine the keyspace either
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408449#comment-16408449
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user Bekreth commented on the issue:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209172
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -465,27 +514,23 @@ private static void start(YarnConfiguration conf,
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209223
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -515,28 +514,23 @@ private static void start(YarnConfiguration conf,
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408457#comment-16408457
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408458#comment-16408458
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user suez1224 commented on a diff in
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209369
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -105,7 +105,7 @@ public void testDetachedMode() throws
In
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408459#comment-16408459
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user suez1224 commented on a diff in
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176212439
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -763,48 +764,32 @@ public Executor getFutureEx
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176207009
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResult.java
---
@@ -67,22 +72,29 @@ public String get
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176208188
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorErrorITCase.java
---
@@ -45,84 +47,87 @@
* b) are not compatib
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176207225
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResult.java
---
@@ -67,22 +72,29 @@ public String get
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408470#comment-16408470
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408473#comment-16408473
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408471#comment-16408471
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408472#comment-16408472
]
ASF GitHub Bot commented on FLINK-8721:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176214419
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -106,8 +106,16 @@ public void testDetachedMode() throw
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408479#comment-16408479
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176215020
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -465,27 +514,23 @@ private static void start(YarnConfiguration c
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408480#comment-16408480
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8779:
-
Priority: Critical (was: Blocker)
> ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on
[
https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408481#comment-16408481
]
Till Rohrmann commented on FLINK-8779:
--
Unblocking and setting to critical because it
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408492#comment-16408492
]
Till Rohrmann commented on FLINK-8946:
--
Yes this only applies to the {{TaskExecutor}}
[
https://issues.apache.org/jira/browse/FLINK-9027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9027:
Assignee: Till Rohrmann
> Web UI does not cleanup temporary files
> ---
Shuyi Chen created FLINK-9049:
-
Summary: Create unified interfaces to configure and instatiate
TableSink
Key: FLINK-9049
URL: https://issues.apache.org/jira/browse/FLINK-9049
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-9049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9049:
--
Description:
This is a similar effort to
[FLINK-8240|https://issues.apache.org/jira/browse/FLINK-8240],
[
https://issues.apache.org/jira/browse/FLINK-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8943:
Assignee: Till Rohrmann
> Jobs will not recover if DFS is temporarily unavailable
> ---
[
https://issues.apache.org/jira/browse/FLINK-9047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9047:
---
Assignee: Till Rohrmann
> SlotPool can fail to release slots
> --
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176221943
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java
---
@@ -249,12 +257,13 @@ public boolean isSerializerInitialized(
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176222855
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java
---
@@ -130,6 +135,31 @@ public void
testInitializeSerialize
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176219956
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/AggregatingStateDescriptorTest.java
---
@@ -41,16 +40,11 @@
* Tests that the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176220129
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/ValueStateDescriptorTest.java
---
@@ -149,13 +145,9 @@ public void testVeryLargeDefaul
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176220108
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/ReducingStateDescriptorTest.java
---
@@ -118,17 +115,14 @@ public void testValueStateD
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176220075
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/MapStateDescriptorTest.java
---
@@ -129,23 +125,12 @@ public void testMapStateDescript
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176219997
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/state/ListStateDescriptorTest.java
---
@@ -121,13 +117,9 @@ public void testValueStateDescri
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5732#discussion_r176220974
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java
---
@@ -77,18 +80,22 @@
/** The serializer for the
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408522#comment-16408522
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
101 - 200 of 268 matches
Mail list logo
