Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76189450
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -36,27 +82,617 @@
*/
public class
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436376#comment-15436376
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436373#comment-15436373
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76189334
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -94,12 +729,11 @@ public void notifyOfNewRes
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2410
@tillrohrmann , I modify the code based on your advice.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not ha
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436366#comment-15436366
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436334#comment-15436334
]
ramkrishna.s.vasudevan commented on FLINK-4367:
---
So it is better to remove t
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436242#comment-15436242
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2410#discussion_r76176826
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/heartbeat/HeartbeatScheduler.java
---
@@ -0,0 +1,286 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436237#comment-15436237
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2410#discussion_r76176673
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerHATest.java
---
@@ -0,0 +1,102 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436225#comment-15436225
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2410#discussion_r76176210
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/heartbeat/HeartbeatSchedulerTest.java
---
@@ -0,0 +1,248 @@
+/*
+ * Licensed to
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2410#discussion_r76176200
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerHATest.java
---
@@ -0,0 +1,102 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436226#comment-15436226
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436212#comment-15436212
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
I can work on this and come
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2416
Hi @smarthi,
Thank you for picking this up. The changes LGTM :) Also tested the 2.3.5 ES
version bump.
Good catches on the Guava and broken example also!
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436175#comment-15436175
]
ASF GitHub Bot commented on FLINK-4480:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-4339:
-
Assignee: Kurt Young
> Implement Slot Pool Core
>
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4339:
--
Description:
Impements the core slot structures and behavior of the {{SlotPool}}:
- pool of available
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436167#comment-15436167
]
zhangjing commented on FLINK-4478:
--
[~till.rohrmann]. I agree we should define how should
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436164#comment-15436164
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on the iss
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2410
Hi, till. Thanks for reviewing and good advices so much. I agree we should
define how should it look like first. And I try to give my opinions for your
question.
1. exponential backoff strat
[
https://issues.apache.org/jira/browse/FLINK-4449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436094#comment-15436094
]
ASF GitHub Bot commented on FLINK-4449:
---
Github user beyond1920 commented on a diff
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2410#discussion_r76168206
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/heartbeat/HeartbeatSchedulerTest.java
---
@@ -0,0 +1,248 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435930#comment-15435930
]
Pavel Fadeev commented on FLINK-4483:
-
Team,
can you please help with this ticket assi
Pavel Fadeev created FLINK-4483:
---
Summary: Complete test coverage integration
Key: FLINK-4483
URL: https://issues.apache.org/jira/browse/FLINK-4483
Project: Flink
Issue Type: Improvement
Ted Yu created FLINK-4482:
-
Summary: numUnsuccessfulCheckpointsTriggers is accessed without
holding triggerLock
Key: FLINK-4482
URL: https://issues.apache.org/jira/browse/FLINK-4482
Project: Flink
I
Github user rehevkor5 commented on the issue:
https://github.com/apache/flink/pull/2383
@StephanEwen do you want me to take a look & see what straightforward
refactoring I can make, and squeeze that into this PR? I can't tell if that was
a hint or not :)
---
If your project is set u
[
https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435824#comment-15435824
]
ASF GitHub Bot commented on FLINK-4418:
---
Github user rehevkor5 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435814#comment-15435814
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435813#comment-15435813
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@mxm Thank you for the review. I've updated PR accordingly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r76148927
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/GlobFilePathFilterTest.java
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435810#comment-15435810
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r76148802
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/FileInputFormatTest.java
---
@@ -314,43 +299,95 @@ public void testIgnoredUnderscoreFiles
Github user smarthi commented on the issue:
https://github.com/apache/flink/pull/2416
1. Changed the ES2 version to 2.3.5
2. Fixed broken ElasticsearchExample.java
3. Removed use of Guava API.
---
If your project is set up for it, you can reply to this email and have your
repl
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435807#comment-15435807
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435808#comment-15435808
]
ASF GitHub Bot commented on FLINK-4480:
---
Github user smarthi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435804#comment-15435804
]
ASF GitHub Bot commented on FLINK-4480:
---
GitHub user smarthi opened a pull request:
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r76148725
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/DefaultFilterTest.java
---
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Softwa
GitHub user smarthi opened a pull request:
https://github.com/apache/flink/pull/2416
FLINK-4480: Incorrect link to elastic.co in documentation
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4453.
---
> Scala code example in Window documentation shows Java
>
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4453.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 42f65e4b93ef7f71b6252bc9c664bee727fd4278
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4437.
---
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
>
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4437.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 4da40bcb9ea01cb0c5e6fd0d7472dc09397f648e
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435730#comment-15435730
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2409
@tedyu No problem, happens to everyone.
I actually took your code and extended it a bit. Merged in
4da40bcb9ea01cb0c5e6fd0d7472dc09397f648e
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4417.
---
> Checkpoints should be subsumed by CheckpointID not, by timestamp
> -
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4417.
-
Resolution: Fixed
Fixed via 4e9d1775b5514c87981c78d55323cc2b17361867
Thank you for the contributi
[
https://issues.apache.org/jira/browse/FLINK-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi reassigned FLINK-4480:
Assignee: Suneel Marthi
> Incorrect link to elastic.co in documentation
> -
[
https://issues.apache.org/jira/browse/FLINK-4457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4457.
---
> Make the ExecutionGraph independent of Akka
> ---
>
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2411
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435701#comment-15435701
]
ASF GitHub Bot commented on FLINK-4417:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4457.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 635c869326cc77e4199e4d8ee597aed69ed16cd2
[
https://issues.apache.org/jira/browse/FLINK-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435702#comment-15435702
]
ASF GitHub Bot commented on FLINK-4453:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2407
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435668#comment-15435668
]
Fabian Hueske commented on FLINK-3850:
--
Sorry for the very long delay [~ram_krish]. I
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435630#comment-15435630
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Thank you for your review @fhueske. I've updated it. Could you please take
a look at it?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Greg Hogan created FLINK-4481:
-
Summary: Maximum results for pairwise algorithms
Key: FLINK-4481
URL: https://issues.apache.org/jira/browse/FLINK-4481
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435522#comment-15435522
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on th
Github user danielblazevski commented on the issue:
https://github.com/apache/flink/pull/2368
Pushed the Scala example
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user mtanski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r76121574
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/InflaterInputStreamFactory.java
---
@@ -23,13 +23,12 @@
import java.io.IOE
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435489#comment-15435489
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on a
Github user danielblazevski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r76120063
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435452#comment-15435452
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r76115561
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
the
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-3999:
---
Assignee: Neelesh Srinivas Salian
> Rename the `running` flag in the drivers to `canceled`
> -
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435446#comment-15435446
]
Gabor Gevay commented on FLINK-3999:
Yes, thank you for working on it!
> Rename the `
[
https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435357#comment-15435357
]
ASF GitHub Bot commented on FLINK-4407:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2415
[FLINK-4407] Implement the trigger DSL
This PR implements the Trigger DSL as presented in
[FLIP-9](https://cwiki.apache.org/confluence/display/FLINK/FLIP-9%3A+Trigger+DSL)
with the addition of
th
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
>
It seems like the privileged port issues can be circumvented by setting
conf.getBoolean("dfs.datanode.require.secure.ports", false)?
It is not supported yet https://github.com/apach
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435356#comment-15435356
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435353#comment-15435353
]
ASF GitHub Bot commented on FLINK-3899:
---
Github user danielblazevski commented on a
Github user danielblazevski commented on a diff in the pull request:
https://github.com/apache/flink/pull/2368#discussion_r76102678
--- Diff: docs/apis/streaming/windows.md ---
@@ -459,42 +459,106 @@ ready for processing. This allows to get the benefit
of incremental window compu
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2414
[FLINK-4341] Let idle consumer subtasks emit max value watermarks and fail
on resharding
This is a short-term fix, until the min-watermark service for the
JobManager described in the JIRA discussi
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435319#comment-15435319
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/2409
I ran test suite which patch which failed here:
```
Tests run: 2, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 201.106 sec
<<< FAILURE! - in
org.apache.flink.runtime.jobmanager.TaskManager
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435309#comment-15435309
]
ASF GitHub Bot commented on FLINK-4341:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435284#comment-15435284
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user eliaslevy commented on the issu
Github user eliaslevy commented on the issue:
https://github.com/apache/flink/pull/2369
@rmetzger that's the one. NP. I realize breaking it up makes things
easier. I just thought I'd mention it.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435172#comment-15435172
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user tedyu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435171#comment-15435171
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/2409
```
Executing Maven: -B -f
/home/jenkins/jenkins-slave/workspace/flink-github-ci/pom.xml
-Dmaven.repo.local=/home/jenkins/jenkins-slave/maven-repositories/1 clean
install -Dflink.forkCount=1C
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2400
Thank you @wangzhijiang999 for the changes. I've made a couple of more
requests after which we can merge the PR.
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435164#comment-15435164
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435163#comment-15435163
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76085144
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -94,12 +729,11 @@ public void notifyOfNewResourceManager
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76085101
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -94,12 +729,11 @@ public void notifyOfNewResourceManager
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76084947
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -36,27 +82,617 @@
*/
public class TaskExecuto
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435161#comment-15435161
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435159#comment-15435159
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76084797
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -36,27 +82,617 @@
*/
public class TaskExecuto
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435158#comment-15435158
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76084721
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -36,27 +82,617 @@
*/
public class TaskExecuto
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435153#comment-15435153
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76084398
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -36,27 +82,617 @@
*/
public class TaskExecuto
Fabian Hueske created FLINK-4480:
Summary: Incorrect link to elastic.co in documentation
Key: FLINK-4480
URL: https://issues.apache.org/jira/browse/FLINK-4480
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435082#comment-15435082
]
ASF GitHub Bot commented on FLINK-4451:
---
Github user tillrohrmann closed the pull re
1 - 100 of 387 matches
Mail list logo
