[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409136#comment-16409136
]
vinoyang commented on FLINK-9046:
-
[~kkl0u] I think we should keep the whole stack trace a
[
https://issues.apache.org/jira/browse/FLINK-9052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409135#comment-16409135
]
Truong Duc Kien commented on FLINK-9052:
Turn out this issue is due to Java API's
[
https://issues.apache.org/jira/browse/FLINK-9052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-9052:
---
Attachment: TypeInfomationTest.scala
> Flink complains when scala.Option is used inside POJO
>
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409103#comment-16409103
]
Kostas Kloudas commented on FLINK-9046:
---
[~yanghua] I would recommend for all of the
Truong Duc Kien created FLINK-9052:
--
Summary: Flink complains when scala.Option is used inside POJO
Key: FLINK-9052
URL: https://issues.apache.org/jira/browse/FLINK-9052
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408978#comment-16408978
]
vinoyang commented on FLINK-9046:
-
[~kkl0u] I think the first scenario's log message is no
[
https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408972#comment-16408972
]
ASF GitHub Bot commented on FLINK-8931:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5744
cc @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408927#comment-16408927
]
ASF GitHub Bot commented on FLINK-8931:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5744
[FLINK-8931] TASK_KILLING is not covered by match in
TaskMonitor#whenUnhandled
## What is the purpose of the change
*This pull request makes _TASK_KILLING_ covered by match in
`TaskMonito
[
https://issues.apache.org/jira/browse/FLINK-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8931:
---
Assignee: vinoyang
> TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled
>
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-8933:
---
Assignee: vinoyang
> Avoid calling Class#newInstance
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9046:
---
Assignee: vinoyang
> Improve error messages when receiving unexpected messages.
> ---
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408905#comment-16408905
]
yinhua.dai commented on FLINK-6595:
---
Is there anyway I can bypass the step?
> Nested SQ
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408903#comment-16408903
]
yinhua.dai commented on FLINK-6595:
---
[~fhueske]
So that means I need separate to two sq
[
https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408894#comment-16408894
]
ASF GitHub Bot commented on FLINK-8335:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5488
Sup ?
---
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408813#comment-16408813
]
vinoyang commented on FLINK-8946:
-
Could I create a new issue ? It seems that closing mert
[
https://issues.apache.org/jira/browse/FLINK-9051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408725#comment-16408725
]
ASF GitHub Bot commented on FLINK-9051:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5743
[FLINK-9051][build] Invert flip6 profile
## What is the purpose of the change
Invert the `flip6` profile so that flip6 tests are run by default.
You can merge this pull request into a Git re
Chesnay Schepler created FLINK-9051:
---
Summary: Invert flip6 profile
Key: FLINK-9051
URL: https://issues.apache.org/jira/browse/FLINK-9051
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408716#comment-16408716
]
ASF GitHub Bot commented on FLINK-8925:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5738
---
[
https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8925.
---
Resolution: Fixed
master: 893fabf6910b3e2ca55ba2b496f0c9530b35ef28
1.5: f0e6ae6ebfc8eaf1a0a622
[
https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8984.
---
Resolution: Fixed
master: 91707e35d39a1b9c11448f21eafc27f0fd949370
1.5: 23005ee1f653a3fcddac0f
[
https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9020.
---
Resolution: Fixed
Fix Version/s: 1.5.0
master: 129e215961895ef3c759b4fbb919a3be2ce2f1a0
[
https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8649.
---
Resolution: Fixed
master: 7e43f81866d3df8e839c9e01e71d6edca06bc8cd
1.5: 0e2bf7eea9e2b1d694711a
[
https://issues.apache.org/jira/browse/FLINK-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408708#comment-16408708
]
ASF GitHub Bot commented on FLINK-9020:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7343.
---
Resolution: Fixed
master: b87e660ac64bebbd9a0a6aa4334a68736140053f
1.5: 0fa76e50f06e84da876408
[
https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408705#comment-16408705
]
ASF GitHub Bot commented on FLINK-8073:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5717
---
[
https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8984:
Component/s: Configuration
> Disabling credit based flow control deadlocks Flink on checkpoi
[
https://issues.apache.org/jira/browse/FLINK-8984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408707#comment-16408707
]
ASF GitHub Bot commented on FLINK-8984:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408706#comment-16408706
]
ASF GitHub Bot commented on FLINK-7343:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5708
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5718
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5729
---
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/5742
[FLINK-9031] Fix DataSet Union operator translation bug.
## What is the purpose of the change
- Fixes a bug reported in
[FLINK-9031](https://issues.apache.org/jira/browse/FLINK-9031)
-
[
https://issues.apache.org/jira/browse/FLINK-9031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408636#comment-16408636
]
ASF GitHub Bot commented on FLINK-9031:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9050:
Component/s: DataStream API
DataSet API
> Expose operator IO counter metric
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7811:
Fix Version/s: (was: 1.5.0)
1.6.0
> Add support for Scala 2.12
>
Chesnay Schepler created FLINK-9050:
---
Summary: Expose operator IO counter metrics
Key: FLINK-9050
URL: https://issues.apache.org/jira/browse/FLINK-9050
Project: Flink
Issue Type: New Featur
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408626#comment-16408626
]
Aljoscha Krettek commented on FLINK-7811:
-
I'm afraid I don't have any updates but
[
https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8900:
Assignee: Till Rohrmann
> YARN FinalStatus always shows as KILLED with Flip-6
> ---
[
https://issues.apache.org/jira/browse/FLINK-9037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9037:
Fix Version/s: 1.5.0
> Test flake Kafka09ITCase#testCancelingEmptyTopic
> --
[
https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408607#comment-16408607
]
ASF GitHub Bot commented on FLINK-8900:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9043.
---
Resolution: Not A Problem
For more information, you can take a look at:
https://ci.apache.org
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5741
[FLINK-8900] [yarn] Properly unregister application from Yarn RM
## What is the purpose of the change
Unregisters the Flink application from Yarn if the application is shut
down. This
[
https://issues.apache.org/jira/browse/FLINK-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408603#comment-16408603
]
ASF GitHub Bot commented on FLINK-8959:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5719
Looks good now, when travis is green! ð
---
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408599#comment-16408599
]
Aljoscha Krettek commented on FLINK-8707:
-
There is also this ML thread:
https://
[
https://issues.apache.org/jira/browse/FLINK-8925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408589#comment-16408589
]
ASF GitHub Bot commented on FLINK-8925:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5714
---
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408566#comment-16408566
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user suez1224 commented on the issue
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5416
@tillrohrmann addressed your comments. PTAL.
---
[
https://issues.apache.org/jira/browse/FLINK-8562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408556#comment-16408556
]
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_r176231789
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -465,27 +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=16408549#comment-16408549
]
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_r176230467
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -106,8 +106,16 @@ public void testDetachedMode() throws
I
[
https://issues.apache.org/jira/browse/FLINK-9027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408528#comment-16408528
]
ASF GitHub Bot commented on FLINK-9027:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5740
[FLINK-9027] [web] Clean up web UI resources by installing shut down hook
## What is the purpose of the change
The RestServerEndpoint creates temp directories to upload files and store
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408521#comment-16408521
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408520#comment-16408520
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408518#comment-16408518
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408515#comment-16408515
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
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
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408516#comment-16408516
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408517#comment-16408517
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16408519#comment-16408519
]
ASF GitHub Bot commented on FLINK-9034:
---
Github user aljoscha commented on a diff in
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
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_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_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_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_r176221943
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java
---
@@ -249,12 +257,13 @@ public boolean isSerializerInitialized(
[
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
> --
[
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-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],
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-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
> ---
[
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-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-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
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=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_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-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
[
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=16408470#comment-16408470
]
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/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_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_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-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 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=16408458#comment-16408458
]
ASF GitHub Bot commented on FLINK-8562:
---
Github user suez1224 commented on a diff in
1 - 100 of 268 matches
Mail list logo