Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2356
@aljoscha i have rebase the newest master branch, and forward port the
changes in rollingsink to bucketsink
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15610584#comment-15610584
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user wenlong88 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15610428#comment-15610428
]
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
sorry,@aljoscha, I have miss the last message in august, I will update the
pr quite soon
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Ted Yu created FLINK-4938:
-
Summary: Unnecessary update() call for Views to be removed in
ViewUpdater#run()
Key: FLINK-4938
URL: https://issues.apache.org/jira/browse/FLINK-4938
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609992#comment-15609992
]
ASF GitHub Bot commented on FLINK-4887:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2699
[FLINK-4887] [execution graph] Introduce TaskManagerGateway to encapsulate
communcation logic
This PR is based on #2689 and #2698.
This PR introduces the `TaskManagerGateway` which is
[
https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609950#comment-15609950
]
ASF GitHub Bot commented on FLINK-4889:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2698
[FLINK-4889] [InstanceManager] Remove ActorRef dependency from
InstanceManager
The `InstanceManager` should not know about the underlying RPC abstraction,
namely Akka.
Therefore, the PR
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609926#comment-15609926
]
ASF GitHub Bot commented on FLINK-4283:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2661
---
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-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4283.
--
Resolution: Fixed
Fixed via b5938b052dfd1b4e9450c430446062852bca8850
>
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609915#comment-15609915
]
ASF GitHub Bot commented on FLINK-3347:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2696
[FLINK-3347] [akka] Add QuarantineMonitor which shuts a quarantined actor
system and JVM down
The QuarantineMonitor subscribes to the actor system's event bus and
listens to
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609883#comment-15609883
]
ASF GitHub Bot commented on FLINK-3347:
---
GitHub user tillrohrmann opened a pull request:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2356
@wenlong88 Are there any updates on 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
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609785#comment-15609785
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4907.
---
Resolution: Fixed
Done in
[
https://issues.apache.org/jira/browse/FLINK-4892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4892.
---
Resolution: Fixed
Done in
[
https://issues.apache.org/jira/browse/FLINK-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4924.
---
> Simplify Operator Test Harness Constructors
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4924.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609732#comment-15609732
]
ASF GitHub Bot commented on FLINK-4924:
---
Github user aljoscha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4937:
-
Description:
Group-window aggregates for streaming tables are currently not done in an
Fabian Hueske created FLINK-4937:
Summary: Add incremental group window aggregation for streaming
Table API
Key: FLINK-4937
URL: https://issues.apache.org/jira/browse/FLINK-4937
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-4691.
Resolution: Implemented
Fix Version/s: 1.2.0
Implemented for 1.2.0 with
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609692#comment-15609692
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2562
---
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-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609680#comment-15609680
]
Pattarawat Chormai commented on FLINK-4917:
---
Yeah, I'm also thinking about that. However, I'm
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609660#comment-15609660
]
Fabian Hueske commented on FLINK-4917:
--
When deprecating interfaces it is good practice to add a
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85218584
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/PowerExpressionTest.scala
---
@@ -0,0 +1,149 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609647#comment-15609647
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609646#comment-15609646
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85217190
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/AggregationsITCase.scala
---
@@ -258,4 +258,22 @@ class
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609614#comment-15609614
]
Pattarawat Chormai commented on FLINK-4917:
---
If I understand correctly, what we have to do here
[
https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609584#comment-15609584
]
Pattarawat Chormai commented on FLINK-4920:
---
Hi [~StephanEwen],
I would like to work on this
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609415#comment-15609415
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2690
This looks very good.
To double check: Do we have tests for the following situations?
- Records larger than buffers
- Records such that they exactly line up with buffer size
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609402#comment-15609402
]
ASF GitHub Bot commented on FLINK-4894:
---
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/2690#discussion_r85199848
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -108,15 +108,25 @@ private void
Greg Hogan created FLINK-4936:
-
Summary: Operator names for Gelly inputs
Key: FLINK-4936
URL: https://issues.apache.org/jira/browse/FLINK-4936
Project: Flink
Issue Type: Improvement
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2541
Okay, this has binary compatibility now.
Few things I would still suggest to do:
- There is still a bug that the `parallelism` and `port` parameter are
mixed up.
- It still does
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609302#comment-15609302
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609290#comment-15609290
]
ASF GitHub Bot commented on FLINK-4579:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2482
Looks good, thanks!
Rebasing and 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 does not have
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609265#comment-15609265
]
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
@chermenin Do you plan to continue with this pull request? Would be great
if you
I would suggest to adjust it in the following way:
- Update the Chill dependency (validate if they
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2625
Looks reasonable to me, Travis tests pass.
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609089#comment-15609089
]
ASF GitHub Bot commented on FLINK-4801:
---
Github user StephanEwen commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r85175840
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -108,6 +111,11 @@
private final Options ALL_OPTIONS;
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15609088#comment-15609088
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
Ufuk Celebi created FLINK-4935:
--
Summary: Submit job with savepoint via REST API
Key: FLINK-4935
URL: https://issues.apache.org/jira/browse/FLINK-4935
Project: Flink
Issue Type: Improvement
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r85167083
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -108,6 +111,11 @@
private final Options
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608966#comment-15608966
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608896#comment-15608896
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
The mailing list conversation only included an indirect reference to
including connectors in this `opt` directory. I was just trying to verify that
we did in fact wish to include these.
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2460
The repackaging is good.
Unfortunately this breaks the Table API tests, because they use one of the
examples.
The Table API IT cases probably need to use their own programs, rather
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608887#comment-15608887
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2452
@liuyuzhong Because we proceed with #2439 , can you close this pull request?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608867#comment-15608867
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2664
What do you mean by "We should also consider allowing jars to be placed in
subdirectories of Flink's lib folder."?
---
If your project is set up for it, you can reply to this email and have
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2431
@rmetzger and @iampeter
What do you think about this pull request? Does this fit with the current
Web UI efforts?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608863#comment-15608863
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608864#comment-15608864
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2664
Connectors are already included, correct?
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2650
I would suggest to not cache the filters and try to catch the "reporter
uses changing filters" case:
- It sounds like pre-mature optimization. Since one can use multiple
reporters,
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608842#comment-15608842
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2445
The approach looks good, but I think it would be good to adjust a few
things:
- We are migrating most of the Scala code in `flink-runtime` to Java (for
example in FLIP-6), so would be good
[
https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608808#comment-15608808
]
ASF GitHub Bot commented on FLINK-4544:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608782#comment-15608782
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608758#comment-15608758
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2418
Looks good, +1 to add this with minor comments.
Two comments inline, and I would suggest to call `getLogicalName()` simply
`getName()` or `getGroupName()`.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608752#comment-15608752
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608751#comment-15608751
]
ASF GitHub Bot commented on FLINK-4245:
---
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/2418#discussion_r85145059
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java
---
@@ -112,6 +116,43 @@ public
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2418#discussion_r85146695
--- Diff:
flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java
---
@@ -206,27 +211,24 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608702#comment-15608702
]
ASF GitHub Bot commented on FLINK-4913:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2692
Thanks for checking out the changes.
Yes, it is handled correctly. Indeed, I started off just thinking about the
user-provided jar but then discovered that the `PackagedProgram` extracts
nested
[
https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608662#comment-15608662
]
ASF GitHub Bot commented on FLINK-4497:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2633
Look pretty good.
I think it would be good to try to make the Cassandra Module to the user
Scala independent. That way, we don't introduce a hard requirement for Scala
versioning and
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2661
Changes look good to me ð Thanks for your contribution
@AlexanderShoshin :-)
The failing tests are unrelated. Will merge this PR with the next batch.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608632#comment-15608632
]
ASF GitHub Bot commented on FLINK-4283:
---
Github user tillrohrmann commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2664
I think this is a good idea.
However, having all the individual dependency jar files in the folder makes
it very hard to use. To actually use the libs (from an IDE without maven) it is
very
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608623#comment-15608623
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the issue:
Greg Hogan created FLINK-4934:
-
Summary: Triadic Census
Key: FLINK-4934
URL: https://issues.apache.org/jira/browse/FLINK-4934
Project: Flink
Issue Type: New Feature
Components: Gelly
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608314#comment-15608314
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2680
I added a new way to define configuration options (see below). It is a much
more maintainable way of defining configuration options.
Would be great if we used that for all new options
Till Rohrmann created FLINK-4933:
Summary: ExecutionGraph.scheduleOrUpdateConsumers can fail the
ExecutionGraph
Key: FLINK-4933
URL: https://issues.apache.org/jira/browse/FLINK-4933
Project: Flink
Till Rohrmann created FLINK-4932:
Summary: Don't let ExecutionGraph fail when in state Restarting
Key: FLINK-4932
URL: https://issues.apache.org/jira/browse/FLINK-4932
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3347:
Assignee: Till Rohrmann
> TaskManager (or its ActorSystem) need to restart in case they
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4928:
Summary: Implement FLIP-6 YARN Application Master Runner (was: Implement
YARN Application Master
[
https://issues.apache.org/jira/browse/FLINK-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4929:
Summary: Implement FLIP-6 YARN TaskManager Runner (was: Implement YARN
TaskManager Runner)
>
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4927:
Summary: Implement FLI-6 YARN Resource Manager (was: Implement YARN
Resource Manager)
> Implement
Stephan Ewen created FLINK-4930:
---
Summary: Implement FLIP-6 YARN client
Key: FLINK-4930
URL: https://issues.apache.org/jira/browse/FLINK-4930
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4931.
---
Resolution: Duplicate
Duplicate of FLINK-4930
> Implement FLIP-6 YARN client
>
Stephan Ewen created FLINK-4931:
---
Summary: Implement FLIP-6 YARN client
Key: FLINK-4931
URL: https://issues.apache.org/jira/browse/FLINK-4931
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4911:
Assignee: Zhijiang Wang
> Non-disruptive JobManager Failures via Reconciliation
>
Stephan Ewen created FLINK-4929:
---
Summary: Implement YARN TaskManager Runner
Key: FLINK-4929
URL: https://issues.apache.org/jira/browse/FLINK-4929
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15608180#comment-15608180
]
ASF GitHub Bot commented on FLINK-4924:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2695
[FLINK-4924] Simplify Operator Test Harness Constructors
R: @StefanRRichter for review, please.
You can merge this pull request into a Git repository by running:
$ git pull
Stephan Ewen created FLINK-4928:
---
Summary: Implement YARN Application Master Runner
Key: FLINK-4928
URL: https://issues.apache.org/jira/browse/FLINK-4928
Project: Flink
Issue Type: Sub-task
1 - 100 of 141 matches
Mail list logo
