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
[
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:
[
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
[
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 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-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
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 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
[
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
[
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:
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 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-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
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
[
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:
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
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
[
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.
---
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:
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
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:
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-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611908#comment-15611908
]
ASF GitHub Bot commented on FLINK-4943:
---
GitHub user Makman2 opened a pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2689
---
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
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-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:
[
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:
[
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:
[
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:
[
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 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-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 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
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
[
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 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-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.
[
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:
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-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 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-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-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-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 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-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 thvasilo commented on the issue:
https://github.com/apache/flink/pull/2684
One last thing, could you change this PR's title to `[FLINK-4865] [ml] Add
EvaluateDataSet operation for LabeledVector`
This is the standard naming for PRs, issue number, followed by
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85334057
--- Diff: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java
---
@@ -55,6 +60,40 @@
private static final String
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85334345
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/AbstractCloseableRegistry.java
---
@@ -16,29 +16,29 @@
* limitations under the
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611881#comment-15611881
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611885#comment-15611885
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611880#comment-15611880
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611883#comment-15611883
]
ASF GitHub Bot commented on FLINK-4910:
---
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/2691#discussion_r85335033
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java
---
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85330867
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetWrapperFileSystem.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611882#comment-15611882
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611879#comment-15611879
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611886#comment-15611886
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611884#comment-15611884
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StephanEwen commented on a diff in the pull
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
[
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 thvasilo commented on the issue:
https://github.com/apache/flink/pull/2684
> We don't need to care about Jenkins/Travis fails, do we ?
Normally we should, but there many unstable tests and issues with Travis
that it's hard to follow now.
You should generally
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85332853
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java
---
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85331518
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java
---
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85330501
--- Diff: flink-core/src/main/java/org/apache/flink/util/IOUtils.java ---
@@ -213,6 +214,16 @@ public static void closeSocket(final Socket sock) {
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2691#discussion_r85329878
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -446,6 +447,8 @@ public void startTaskThread() {
GitHub user Makman2 opened a pull request:
https://github.com/apache/flink/pull/2703
[FLINK-4900] flink-master: Allow to deploy TM with container
Allows via a setting to deploy a base image on that a task manager runs.
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-4903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4903.
Resolution: Fixed
Added via 1e1e4dc701d3606bdcaa291d2d85460fdfbb0dc7
> Introduce non async future
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
GitHub user Makman2 opened a pull request:
https://github.com/apache/flink/pull/2704
[FLINK-4943] ConfigConstants: YYARN -> YARN
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Makman2/flink Makman2/dcos4
Alternatively you can
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2704
I'd recommend collecting typographical and grammatical errors within
comments into a larger ticket and pull request.
---
If your project is set up for it, you can reply to this email and have
[
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:
Mischa Krüger created FLINK-4943:
Summary: flink-mesos/ConfigConstants: Typo: YYARN -> YARN
Key: FLINK-4943
URL: https://issues.apache.org/jira/browse/FLINK-4943
Project: Flink
Issue Type:
[
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-4865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611809#comment-15611809
]
ASF GitHub Bot commented on FLINK-4865:
---
Github user thvasilo commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611900#comment-15611900
]
ASF GitHub Bot commented on FLINK-4900:
---
GitHub user Makman2 opened a pull request:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2689
That is true. I'll increase the timeouts to 10s just to be sure. The
failing test case is unrelated. Will merge the PR then. Thanks for the review
@uce and @StephanEwen.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611919#comment-15611919
]
ASF GitHub Bot commented on FLINK-4903:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611934#comment-15611934
]
ASF GitHub Bot commented on FLINK-4903:
---
Github user asfgit closed the pull request at:
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(
//
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
[
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
[
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
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-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
> -
>
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-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:
101 - 200 of 203 matches
Mail list logo
