[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-4928:
---
Assignee: shuai.xu
> Implement FLIP-6 YARN Application Master Runner
>
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-4927:
---
Assignee: shuai.xu
> Implement FLI-6 YARN Resource Manager
> -
>
Manu Zhang created FLINK-4952:
-
Summary: Add Scala API for KeyedStream.flatMap
Key: FLINK-4952
URL: https://issues.apache.org/jira/browse/FLINK-4952
Project: Flink
Issue Type: Improvement
Manu Zhang created FLINK-4951:
-
Summary: Better Javadocs for KeyedStream.flatMap
Key: FLINK-4951
URL: https://issues.apache.org/jira/browse/FLINK-4951
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15614076#comment-15614076
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user wenlong88 commented on the issue:
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2356
all of the test in travis have passed. thanks for merging this. ^_^
---
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
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15614058#comment-15614058
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zhuhaifengleon commented on a diff in the pull
Github user zhuhaifengleon commented on a diff in the pull request:
https://github.com/apache/flink/pull/2693#discussion_r85463825
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -347,6 +348,12 @@ public Task(
//
Vijay Srinivasaraghavan created FLINK-4950:
--
Summary: Add support to include multiple Yarn application entries
in Yarn properties file
Key: FLINK-4950
URL:
Greg Hogan created FLINK-4949:
-
Summary: Refactor Gelly driver inputs
Key: FLINK-4949
URL: https://issues.apache.org/jira/browse/FLINK-4949
Project: Flink
Issue Type: Improvement
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2708
[FLINK-4946] [scripts] Load jar files from subdirectories of lib
The Flink classpath is a concatenation of jar files in lib/. This commit
includes files from subdirectories of lib/ in the
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15613223#comment-15613223
]
ASF GitHub Bot commented on FLINK-4946:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15613064#comment-15613064
]
Jamie Grier commented on FLINK-4948:
Makes sense. Maybe a scheme where we can verify that the
[
https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612892#comment-15612892
]
Gyula Fora commented on FLINK-4948:
---
I think in general this would be very nice but what about tools
Jamie Grier created FLINK-4948:
--
Summary: Consider using checksums or similar to detect bad
checkpoints
Key: FLINK-4948
URL: https://issues.apache.org/jira/browse/FLINK-4948
Project: Flink
Jamie Grier created FLINK-4947:
--
Summary: Make all configuration possible via flink-conf.yaml and
CLI.
Key: FLINK-4947
URL: https://issues.apache.org/jira/browse/FLINK-4947
Project: Flink
Greg Hogan created FLINK-4946:
-
Summary: Load jar files from subdirectories of lib
Key: FLINK-4946
URL: https://issues.apache.org/jira/browse/FLINK-4946
Project: Flink
Issue Type: Improvement
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
@StephanEwen latest commit assembles connectors into separate directories.
I'll create a ticket for loading jar files from subdirectories of`lib`.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612777#comment-15612777
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issue:
Github user Makman2 commented on the issue:
https://github.com/apache/flink/pull/2704
Feel free to cherry-pick my commit into your branch and close this PR :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612697#comment-15612697
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user Makman2 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612673#comment-15612673
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612675#comment-15612675
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612690#comment-15612690
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2704
I keep an `_minutiae` branch and push that every few months, typically
after a release. There are fixed costs at each level of Flink's ticketing /
pull request / verify / commit process.
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85392726
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTrace.java
---
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85390985
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTraceSampleResponse.java
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612672#comment-15612672
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85383836
--- Diff: flink-tests/src/test/resources/log4j-test.properties ---
@@ -18,7 +18,7 @@
# Set root logger level to OFF to not flood build logs
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612674#comment-15612674
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff in the pull
Github user Makman2 commented on the issue:
https://github.com/apache/flink/pull/2704
Though I wouldn't fix more than this one (except I stumble over some typos
again) :3
Is there already a larger ticket? @greghogan
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612618#comment-15612618
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user Makman2 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612488#comment-15612488
]
ASF GitHub Bot commented on FLINK-4939:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2707
[FLINK-4939] GenericWriteAheadSink: Decouple the creating from the
committing subtask for a pending checkpoint
So far the GenericWriteAheadSink expected that the subtask that wrote a
temporary buffer
[
https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612480#comment-15612480
]
ASF GitHub Bot commented on FLINK-4889:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2698
---
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
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612477#comment-15612477
]
ASF GitHub Bot commented on FLINK-4945:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2706
R @rmetzger
---
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,
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4939:
--
Summary: GenericWriteAheadSink: Decouple the creating from the committing
subtask for a pending
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612472#comment-15612472
]
ASF GitHub Bot commented on FLINK-4945:
---
GitHub user StefanRRichter opened a pull request:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2706
[FLINK-4945] KafkaConsumer logs wrong warning about confirmation for â¦
This PR fixes an unjustified warning about unknown checkpoints in
FlinkKafkaConsumerBase.
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4939:
--
Summary: GenericWriteAheadSink: Decouple the subtask creating a pending
checkpoint from the one
[
https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612467#comment-15612467
]
Greg Hogan commented on FLINK-4823:
---
How are you creating your {{Graph}}? Each vertex represented in the
[
https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612452#comment-15612452
]
ASF GitHub Bot commented on FLINK-4889:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2698
Looks good
+1 to merge this
---
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
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4945:
-
Assignee: Stefan Richter
> KafkaConsumer logs wrong warning about confirmation for
Stefan Richter created FLINK-4945:
-
Summary: KafkaConsumer logs wrong warning about confirmation for
unknown checkpoint
Key: FLINK-4945
URL: https://issues.apache.org/jira/browse/FLINK-4945
Project:
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612315#comment-15612315
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user chermenin commented on a diff in the pull
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2623#discussion_r85369265
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -710,7 +712,103 @@ public String toString()
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612306#comment-15612306
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
I like this approach. One minor question, otherwise +1 to go here
---
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
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612301#comment-15612301
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2623#discussion_r85368023
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -710,7 +712,103 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612284#comment-15612284
]
ASF GitHub Bot commented on FLINK-4733:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2616
I tested the change locally, it works. +1 to merge.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612219#comment-15612219
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2690
---
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
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612217#comment-15612217
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612273#comment-15612273
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2652
---
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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4715.
--
Resolution: Fixed
Fix Version/s: 1.1.4
Fixed in cc6655b (release-1.1), 27fd249 (master).
>
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612253#comment-15612253
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4894.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in 529534f (release-1.1),
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-4510:
> Always create CheckpointCoordinator
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612226#comment-15612226
]
Ufuk Celebi commented on FLINK-4510:
Fixed in {{b420750}} (release-1.1).
> Always create
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4510.
--
Resolution: Fixed
Fix Version/s: 1.1.4
> Always create CheckpointCoordinator
>
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1561#comment-1561
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612221#comment-15612221
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612215#comment-15612215
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360067
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeSessionWindowsWindowsTest.java
---
@@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85361303
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java
---
@@ -0,0 +1,369 @@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360454
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeTriggerTest.java
---
@@ -0,0 +1,153 @@
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612218#comment-15612218
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85359630
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java
---
@@ -0,0 +1,123 @@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85361208
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java
---
@@ -0,0 +1,369 @@
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612216#comment-15612216
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85359406
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java
---
@@ -0,0 +1,123 @@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360968
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/PurgingTriggerTest.java
---
@@ -0,0 +1,149 @@
[
https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612172#comment-15612172
]
ASF GitHub Bot commented on FLINK-4733:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2616
Thank you for rebasing.
This run:
had the following error:
https://s3.amazonaws.com/archive.travis-ci.org/jobs/170428661/log.txt
```
Failed tests:
[
https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruwen Moos resolved FLINK-4756.
---
Resolution: Not A Bug
Version of flink for the cluster and in the maven project were to far apart.
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2694
+1 to merge.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612162#comment-15612162
]
ASF GitHub Bot commented on FLINK-4925:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612146#comment-15612146
]
ASF GitHub Bot commented on FLINK-2597:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2705
[FLINK-2597][FLINK-4050] Add wrappers for Kafka serializers, test for
partitioner and documentation
This pull requests addresses the following JIRAs:
- [FLINK-2597
Add a test for
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612123#comment-15612123
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user chermenin commented on the issue:
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/2623
I exclude Kryo as a dependency from Chill and add simple test to check Java
collections. Tests added to `flink-tests` because it is depends on
`flink-runtime` (where used Chill).
---
If your
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2696
Thanks for the review @StephanEwen. Yes let's do it as you've proposed.
I've opened an [issue](https://issues.apache.org/jira/browse/FLINK-4944) for
replacing Akka's death watch with our own
[
https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4037.
---
Resolution: Fixed
Fix Version/s: 1.2.0
> Introduce ArchivedExecutionGraph without any
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2697
---
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
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612084#comment-15612084
]
ASF GitHub Bot commented on FLINK-3347:
---
Github user tillrohrmann commented on the issue:
Till Rohrmann created FLINK-4944:
Summary: Replace Akka's deatch watch with own heartbeat on the TM
side
Key: FLINK-4944
URL: https://issues.apache.org/jira/browse/FLINK-4944
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612066#comment-15612066
]
ASF GitHub Bot commented on FLINK-3347:
---
Github user tillrohrmann closed the pull request at:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2691
Thanks for the reviews @StephanEwen and @aljoscha ! I addressed your
comments in my last commit.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611984#comment-15611984
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611981#comment-15611981
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user attachmentgenie commented on the issue:
Github user attachmentgenie commented on the issue:
https://github.com/apache/flink/pull/2680
@StephanEwen seems reasonable thing to do, i updated the code to use the
new ConfigOption method
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611940#comment-15611940
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611963#comment-15611963
]
ASF GitHub Bot commented on FLINK-3347:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2697
Thanks for the review @StephanEwen. I will change the configuration name
and then merge the PR into the release-1.1 branch.
Travis passed locally and the failing test cases are
1 - 100 of 203 matches
Mail list logo