[
https://issues.apache.org/jira/browse/FLINK-8300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8300:
---
Assignee: (was: Gary Yao)
Summary: Make JobExecutionResult accessible in per-job cluster
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299644#comment-16299644
]
ASF GitHub Bot commented on FLINK-8226:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/5141
@dawidwys Could you help to take a look at this PR? This is a bug fix and
the issue can be easily reproduced with the test case included in the PR.
Thanks a lot.
---
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/5142
@dawidwys @StephanEwen Sorry for late response. For question 1 and 2, I
have the same thought with @dawidwys and have updated the PR accordingly. For
question 3, I think `int` is enough as we
[
https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299640#comment-16299640
]
ASF GitHub Bot commented on FLINK-8227:
---
Github user dianfu commented on the issue:
Github user casidiablo commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158194237
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299527#comment-16299527
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user casidiablo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299514#comment-16299514
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user casidiablo commented on a diff in the pull
Github user casidiablo commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158192923
--- Diff: docs/monitoring/metrics.md ---
@@ -1293,6 +1293,29 @@ Thus, in order to infer the metric identifier:
+ Kinesis
[
https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8037:
--
Description:
{code}
public Set generateIdsToAbort() {
Set idsToAbort = new HashSet<>();
for (int i =
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299275#comment-16299275
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299274#comment-16299274
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5171#discussion_r158166090
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -30,37 +30,44 @@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5171#discussion_r158164454
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -30,37 +30,44 @@
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299259#comment-16299259
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5171#discussion_r158163793
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -30,37 +30,44 @@
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299238#comment-16299238
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158160866
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299236#comment-16299236
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299240#comment-16299240
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299237#comment-16299237
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158159640
--- Diff: docs/monitoring/metrics.md ---
@@ -1293,6 +1293,29 @@ Thus, in order to infer the metric identifier:
+ Kinesis
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158161267
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r158161564
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
[
https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299208#comment-16299208
]
Ted Yu commented on FLINK-7795:
---
https://github.com/google/error-prone/releases/tag/v2.1.3 was the latest
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299205#comment-16299205
]
Ted Yu commented on FLINK-7525:
---
What should be the next step ?
> Add config option to disable Cancel
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5191
This seems like a mistakenly opened PR.
Can you please close this, @czhxmz? Thanks!
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5187
This seems like a mistake. @laolang113 can you please close this PR? Thanks!
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5195
+1, LGTM
---
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16299058#comment-16299058
]
Tzu-Li (Gordon) Tai commented on FLINK-8283:
I'm suspecting that the Travis infra updates on
[
https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298961#comment-16298961
]
ASF GitHub Bot commented on FLINK-8297:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5185
This might be a great chance to start discussing how ListState APIs should
evolve - specifically, is it time to consider adding `remove()` to ListState?
---
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/5195
[hotfix] [build] Always include Kafka 0.11 connector
Now that Flink only supports builds for Scala 2.11+ we can unconditionally
enable the Kafka 0.11 connector.
You can merge this pull request
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298835#comment-16298835
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5171
You are right. Thank you, Gordon. I updated the PR title
---
[
https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16258309#comment-16258309
]
Ted Yu edited comment on FLINK-7588 at 12/20/17 6:02 PM:
-
bq. Be careful about
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7897:
--
Description:
nio.Files#delete() provides better clue as to why the deletion may fail:
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8295.
-
Resolution: Fixed
Fix Version/s: 1.4.1
1.5.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298771#comment-16298771
]
ASF GitHub Bot commented on FLINK-8295:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5183
---
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298765#comment-16298765
]
ASF GitHub Bot commented on FLINK-8295:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5183
I tested it locally. Will merge this now...
---
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298752#comment-16298752
]
ASF GitHub Bot commented on FLINK-8233:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5194#discussion_r158081176
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobExecutionResultDeserializer.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5194#discussion_r158078273
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobExecutionResultDeserializer.java
---
@@ -0,0 +1,153 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298732#comment-16298732
]
ASF GitHub Bot commented on FLINK-8233:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298723#comment-16298723
]
Timo Walther commented on FLINK-8281:
-
Sorry, I haven't seen that this issue is already resolved.
>
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8234:
Description: In order to serve the {{JobExecutionResults}} we have to cache
them in the {{Dispatcher}}
[
https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298716#comment-16298716
]
Timo Walther commented on FLINK-8281:
-
[~brucewoo] can you tell us a bit more about your environment?
[
https://issues.apache.org/jira/browse/FLINK-8300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8300:
Description: In order to serve the {{JobExecutionResults}} we have to cache
them in the {{JobMaster}} after
Gary Yao created FLINK-8300:
---
Summary: Make JobExecutionResult accessible from JobMaster
Key: FLINK-8300
URL: https://issues.apache.org/jira/browse/FLINK-8300
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298658#comment-16298658
]
ASF GitHub Bot commented on FLINK-8292:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5180
+0
---
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8233:
Description:
Expose {{JobExecutionResult}} from a finished Flink job via HTTP:
* Add a new
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8233:
Summary: Expose JobExecutionResult via HTTP (was: Retrieve ExecutionResult
by REST polling)
> Expose
Gary Yao created FLINK-8299:
---
Summary: Retrieve ExecutionResult by REST polling
Key: FLINK-8299
URL: https://issues.apache.org/jira/browse/FLINK-8299
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298650#comment-16298650
]
ASF GitHub Bot commented on FLINK-8280:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5175#discussion_r158056059
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java ---
@@ -150,8 +150,7 @@ static File initLocalStorageDirectory(String
Piotr Nowojski created FLINK-8298:
-
Summary: Shutdown MockEnvironment
Key: FLINK-8298
URL: https://issues.apache.org/jira/browse/FLINK-8298
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298598#comment-16298598
]
ASF GitHub Bot commented on FLINK-8079:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5156#discussion_r158037581
--- Diff: tools/travis_mvn_watchdog.sh ---
@@ -543,35 +543,45 @@ case $TEST in
printf "Running end-to-end tests\n"
[
https://issues.apache.org/jira/browse/FLINK-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298583#comment-16298583
]
ASF GitHub Bot commented on FLINK-8222:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5136
I'll merge this to 1.5 only.
---
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-5506:
--
Fix Version/s: 1.4.1
1.5.0
> Java 8 - CommunityDetection.java:158 -
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298563#comment-16298563
]
ASF GitHub Bot commented on FLINK-5506:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5126
@StephanEwen thanks for the tip. I'll remove the added `TypeHint` methods
and commit to 1.4 and 1.5.
---
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298531#comment-16298531
]
ASF GitHub Bot commented on FLINK-8233:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5194
[FLINK-8233][flip6] Add JobExecutionResultHandler
## What is the purpose of the change
*Allow retrieval of the JobExecutionResult cached in Dispatcher via HTTP.
This will be needed so that
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8268:
-
Assignee: Piotr Nowojski
> Test instability for 'TwoPhaseCommitSinkFunctionTest'
>
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298389#comment-16298389
]
ASF GitHub Bot commented on FLINK-8268:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5193
[FLINK-8268][tests] Improve tests stability
This is a walk-around an error reported in the issue:
https://issues.apache.org/jira/browse/FLINK-8268 . Instead of writing files to
disk, this PR
[
https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298303#comment-16298303
]
ASF GitHub Bot commented on FLINK-8257:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5192
[FLINK-8257] [conf] Unify the value checks for setParallelism()
## What is the purpose of the change
This PR unifies the value checks for `setParallelism()` methods in
different components.
GitHub user czhxmz opened a pull request:
https://github.com/apache/flink/pull/5191
Release 1.4
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best possible way,
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298177#comment-16298177
]
ASF GitHub Bot commented on FLINK-8289:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5190
[FLINK-8289] [runtime] set the rest.address to the host of the rest server
machine
## What is the purpose of the change
This pull request set the rest.address to the host of the
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298162#comment-16298162
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5171
Ah, I see. The `AmazonKinesisClient` class is not deprecated, but the
constructors are.
Alright, thanks for the clarification. I'll find some time to revisit this
PR tomorrow.
---
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298159#comment-16298159
]
cttestid41 commented on FLINK-8234:
---
Test comment
> Cache JobExecutionResult from finished
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298157#comment-16298157
]
ASF GitHub Bot commented on FLINK-8283:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5181
Also FYI: The stalling tests seems to have been fixed (indirectly?) by
fixing the mocking issue. No failures have occurred anymore over 10 test local
Travis runs.
---
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298155#comment-16298155
]
ASF GitHub Bot commented on FLINK-8283:
---
Github user tzulitai closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298154#comment-16298154
]
ASF GitHub Bot commented on FLINK-8283:
---
Github user tzulitai commented on the issue:
Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/5181
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5181
Making the `AbstractFetcher::commitInternalOffsetsToKafka` non-final just
for the sake of testing using mocks really is not ideal.
I've opened a new PR #5189 that properly solves this by
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298151#comment-16298151
]
ASF GitHub Bot commented on FLINK-8283:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5189
[FLINK-8283] [kafka] Introduce KafkaOffsetCommitter interface
## What is the purpose of the change
This PR is built upon the reworked `FlinkKafkaConsumerBaseTest` in #5188.
The broken
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4559
@NicoK , I have submitted the `hotfix` commit to address above comments.
---
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298149#comment-16298149
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298145#comment-16298145
]
ASF GitHub Bot commented on FLINK-8295:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5183
Thanks for the fix @NicoK. I will have a look at it later today and merge
this.
---
[
https://issues.apache.org/jira/browse/FLINK-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298137#comment-16298137
]
ASF GitHub Bot commented on FLINK-8296:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5188
[FLINK-8296] [kafka] Rework FlinkKafkaConsumerBaseTest to not rely on Java
reflection
## What is the purpose of the change
Prior to this PR, reflection was mainly used to inject mocks
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298135#comment-16298135
]
ASF GitHub Bot commented on FLINK-8295:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5183
true - I adapted the comment accordingly
---
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298092#comment-16298092
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157963387
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -405,22 +407,27 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298081#comment-16298081
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157962431
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -458,7 +465,14 @@ public JobExecutionResult
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16298065#comment-16298065
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on the issue:
1 - 100 of 111 matches
Mail list logo
