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 ap
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15610584#comment-15610584
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user wenlong88 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15610428#comment-15610428
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user wenlong88 commented on the issu
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
Issue
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609992#comment-15609992
]
ASF GitHub Bot commented on FLINK-4887:
---
GitHub user tillrohrmann opened a pull requ
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&focusedCommentId=15609950#comment-15609950
]
ASF GitHub Bot commented on FLINK-4889:
---
GitHub user tillrohrmann opened a pull requ
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 re
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609926#comment-15609926
]
ASF GitHub Bot commented on FLINK-4283:
---
Github user asfgit closed the pull request
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 enab
[
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
> ExecutionGraphRestartTes
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609915#comment-15609915
]
ASF GitHub Bot commented on FLINK-3347:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2697
[backport] [FLINK-3347] [akka] Add QuarantineMonitor which shuts a
quarantined actor system and JVM down
This is a back port for release 1.1.
The QuarantineMonitor subscribes to the ac
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
AssociationErr
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609883#comment-15609883
]
ASF GitHub Bot commented on FLINK-3347:
---
GitHub user tillrohrmann opened a pull requ
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
e
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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://github.com/apache/flink/commit/fa664e5b9527ec82dae1f18746f7
[
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://github.com/apache/flink/commit/c0192ecad161ce85c07e44853702
[
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://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-4924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609732#comment-15609732
]
ASF GitHub Bot commented on FLINK-4924:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2695
---
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 en
[
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
incrementa
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 44f3977e7fee44a3601b6
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609692#comment-15609692
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user asfgit closed the pull request
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609680#comment-15609680
]
Pattarawat Chormai commented on FLINK-4917:
---
Yeah, I'm also thinking about that.
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609660#comment-15609660
]
Fabian Hueske commented on FLINK-4917:
--
When deprecating interfaces it is good practi
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 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609647#comment-15609647
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609646#comment-15609646
]
ASF GitHub Bot commented on FLINK-4743:
---
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/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 Aggregation
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609614#comment-15609614
]
Pattarawat Chormai commented on FLINK-4917:
---
If I understand correctly, what we
[
https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609584#comment-15609584
]
Pattarawat Chormai commented on FLINK-4920:
---
Hi [~StephanEwen],
I would like to
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609415#comment-15609415
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user StephanEwen commented on the is
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 (f
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609402#comment-15609402
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user StephanEwen commented on a diff
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 sendToTarge
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
Com
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 no
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609302#comment-15609302
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609290#comment-15609290
]
ASF GitHub Bot commented on FLINK-4579:
---
Github user StephanEwen commented on the is
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&focusedCommentId=15609265#comment-15609265
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the is
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 c
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 hav
[
https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609089#comment-15609089
]
ASF GitHub Bot commented on FLINK-4801:
---
Github user StephanEwen commented on the is
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&focusedCommentId=15609088#comment-15609088
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the
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 ALL_OPTI
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608966#comment-15608966
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608896#comment-15608896
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
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.
I'
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 th
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608887#comment-15608887
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user StephanEwen commented on the is
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 you
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608867#comment-15608867
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user StephanEwen commented on the is
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 your
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&focusedCommentId=15608863#comment-15608863
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608864#comment-15608864
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the is
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 featur
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, why
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608842#comment-15608842
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user StephanEwen commented on the is
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&focusedCommentId=15608808#comment-15608808
]
ASF GitHub Bot commented on FLINK-4544:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608782#comment-15608782
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
@StephanEwen thanks for looking at this.
In this first cut I included all the build artifacts. Should connectors be
included?
We should also consider allowing jars to be placed in
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608758#comment-15608758
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
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 u
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608752#comment-15608752
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608751#comment-15608751
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on a diff
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 AbstractMetricGrou
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 notifyOfRemov
[
https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15608662#comment-15608662
]
ASF GitHub Bot commented on FLINK-4497:
---
Github user StephanEwen commented on the is
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 mak
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&focusedCommentId=15608632#comment-15608632
]
ASF GitHub Bot commented on FLINK-4283:
---
Github user tillrohrmann commented on the i
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 h
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15608623#comment-15608623
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the is
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&focusedCommentId=15608314#comment-15608314
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user StephanEwen commented on the is
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 tha
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 Ty
[
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 not
[
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 Ru
[
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)
> Imple
[
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
[
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-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
Compo
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
Compo
[
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
1 - 100 of 142 matches
Mail list logo
