[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan resolved FLINK-4102.
---
Resolution: Cannot Reproduce
> Test failure with checkpoint barriers
>
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3253.
-
Resolution: Unresolved
The code for this part of the system changed completely, so that this
[
https://issues.apache.org/jira/browse/FLINK-3253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3253.
---
> deserializeObject exception on WindowOperator
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569467#comment-15569467
]
Stephan Ewen commented on FLINK-4651:
-
Fixed in 1.2 as part of
[
https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569468#comment-15569468
]
Stephan Ewen commented on FLINK-4651:
-
How will this be resolved?
> Re-register processing time
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2288
@cresny Do you want to continue on this? I think it is a good fix.
---
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-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569490#comment-15569490
]
Stephan Ewen commented on FLINK-4632:
-
Do you have the logs of the JobManager from when the
[
https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4701.
-
Resolution: Not A Problem
Not applicable any more to the latest code, where the cancelables have
[
https://issues.apache.org/jira/browse/FLINK-4701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4701.
---
> Unprotected access to cancelables in StreamTask
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569461#comment-15569461
]
Stephan Ewen commented on FLINK-3154:
-
I would like to close this as "won't fix".
This can only be
Stephan Ewen created FLINK-4815:
---
Summary: Automatic fallback to earlier checkpoints when checkpoint
restore fails
Key: FLINK-4815
URL: https://issues.apache.org/jira/browse/FLINK-4815
Project: Flink
Github user cresny commented on the issue:
https://github.com/apache/flink/pull/2288
I was hoping that when the 1.2-SNAPSHOT dust cleared it would no longer be
necessary. At this point it seems it's only necessary for staging a YARN
session for an S3A configured FileSystem,
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569631#comment-15569631
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569632#comment-15569632
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569630#comment-15569630
]
ASF GitHub Bot commented on FLINK-3888:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83069609
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java
---
@@ -1513,14 +1513,21 @@ private void
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83075316
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/iterative/aggregators/AggregatorConvergenceITCase.java
---
@@ -137,42 +138,51 @@ public void
Stephan Ewen created FLINK-4817:
---
Summary: Checkpoint Coordinator should be called to restore state
with a specific checkpoint ID
Key: FLINK-4817
URL: https://issues.apache.org/jira/browse/FLINK-4817
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2606#discussion_r83071641
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTask.java
---
@@ -56,11 +56,15 @@
Stephan Ewen created FLINK-4818:
---
Summary: RestartStrategy should track how many failed restore
attempts the same checkpoint has and fall back to earlier checkpoints
Key: FLINK-4818
URL:
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4816:
Summary: Executions failed from "DEPLOYING" should retain restored
checkpoint information (was:
Zhenzhong Xu created FLINK-4819:
---
Summary: Checkpoint metadata+data inspection tool (view / update)
Key: FLINK-4819
URL: https://issues.apache.org/jira/browse/FLINK-4819
Project: Flink
Issue
Zhenzhong Xu created FLINK-4820:
---
Summary: Slf4j / log4j version upgrade to support dynamic change
of log levels.
Key: FLINK-4820
URL: https://issues.apache.org/jira/browse/FLINK-4820
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568076#comment-15568076
]
Stephan Ewen commented on FLINK-4803:
-
The task thread is actually interrupted. Immediately, after the
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568256#comment-15568256
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82899030
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/Aggregate.scala
---
@@ -19,6 +19,7 @@ package
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82964364
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/RowIntervalTypeInfo.scala
---
@@ -0,0 +1,108 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568254#comment-15568254
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82901298
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/stream/table/GroupWindowITCase.scala
---
@@ -0,0 +1,873 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568451#comment-15568451
]
ASF GitHub Bot commented on FLINK-4801:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568504#comment-15568504
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568215#comment-15568215
]
Maximilian Michels commented on FLINK-4806:
---
Thank you for your comments [~ykt836]. I agree that
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568299#comment-15568299
]
Chesnay Schepler commented on FLINK-4812:
-
The key issue here is to register the watermark for the
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568325#comment-15568325
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568326#comment-15568326
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568376#comment-15568376
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2609#discussion_r82980824
--- Diff: docs/setup/cli.md ---
@@ -113,6 +113,10 @@ The command line can be used to
./bin/flink cancel
+- Cancel a job with a
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568219#comment-15568219
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568246#comment-15568246
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2620
Thanks for the feedback. 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 this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568279#comment-15568279
]
ASF GitHub Bot commented on FLINK-4799:
---
Github user mxm commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2608
Addressed all comments except Exception narrowing which I would like to
leave open as follow ups as they were not introduced with this PR. Thanks
again! I will wait for Travis and then merge this if
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568366#comment-15568366
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on the issue:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2625
[FLINK-4801] [types] Input type inference is faulty with custom Tuples and
RichFunctions
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check
[
https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568121#comment-15568121
]
ASF GitHub Bot commented on FLINK-4746:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4746.
Resolution: Fixed
Fixed via 64ee1386294cde6c61c8ee15c5e1d1ad018dcc46
> Replace
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568224#comment-15568224
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82971361
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -282,29 +279,71 @@ public boolean isShutdown() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82971228
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -282,29 +279,71 @@ public boolean isShutdown() {
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3706:
--
Component/s: YARN Client
> YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable
>
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3706.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Resolved in
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82976634
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -233,68 +229,90 @@ public int
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2577
thank you for your review @mxm, will merge this now.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568447#comment-15568447
]
ASF GitHub Bot commented on FLINK-4720:
---
Github user zentol commented on the issue:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82989243
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/windows/Session.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568118#comment-15568118
]
ASF GitHub Bot commented on FLINK-4793:
---
Github user asfgit closed the pull request at:
Stephan Ewen created FLINK-4810:
---
Summary: Checkpoint Coordinator should fail ExecutionGraph after
"n" unsuccessful checkpoints
Key: FLINK-4810
URL: https://issues.apache.org/jira/browse/FLINK-4810
Stephan Ewen created FLINK-4809:
---
Summary: Operators should tolerate checkpoint failures
Key: FLINK-4809
URL: https://issues.apache.org/jira/browse/FLINK-4809
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568171#comment-15568171
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2608
Thank you very much for the thorough review. I will address the comments
now and update the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568226#comment-15568226
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568263#comment-15568263
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82886893
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/properties.scala
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82880181
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/windows/Session.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568258#comment-15568258
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82968570
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/TimeIntervalTypeInfo.scala
---
@@ -24,14 +24,14 @@ import
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568257#comment-15568257
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82971688
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/PropertyRead.scala
---
@@ -0,0 +1,33 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82884874
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/aggregations.scala
---
@@ -18,12 +18,15 @@
package
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568262#comment-15568262
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568253#comment-15568253
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568264#comment-15568264
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82899800
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AvgAggregate.scala
---
@@ -23,6 +23,8 @@ import
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82964905
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/RowIntervalTypeInfo.scala
---
@@ -0,0 +1,108 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568259#comment-15568259
]
ASF GitHub Bot commented on FLINK-4691:
---
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/2562#discussion_r82971868
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/PropertyCollector.scala
---
@@ -0,0 +1,42 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82887623
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala
---
@@ -27,48 +27,65 @@ import
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568261#comment-15568261
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568260#comment-15568260
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568255#comment-15568255
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568513#comment-15568513
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15567969#comment-15567969
]
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
@rmetzger If I'm not mistaken Kryo 2.24 and 3.0 versions is compatible each
other at the level of standard IO serialization. And if it possible we will be
able to a little wait for Chill 0.7.5
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2623
Bumping the version of serializers is a sensitive issue in Flink.
If the serialization format changes, savepoints of previous versions can no
longer be used.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568099#comment-15568099
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user fhueske commented on the issue:
Stephan Ewen created FLINK-4811:
---
Summary: Checkpoint Overview should list failed checkpoints
Key: FLINK-4811
URL: https://issues.apache.org/jira/browse/FLINK-4811
Project: Flink
Issue Type:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82971700
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java
---
@@ -18,44 +18,243 @@
package
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4799.
-
Resolution: Fixed
Re-added symlink for Unix systems.
master:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2620
---
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 uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82977296
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
---
@@ -43,24 +125,62 @@
* @return The loaded
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82977266
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
---
@@ -18,23 +18,105 @@
package
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen Actually, I'm not very clear about Clojure Web FrameWork, but
it's web framework are using "ring.ring-core".
import:
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568439#comment-15568439
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user liuyuzhong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-1579:
---
Assignee: Chesnay Schepler
> Create a Flink History Server
>
Stephan Ewen created FLINK-4808:
---
Summary: Allow skipping failed checkpoints
Key: FLINK-4808
URL: https://issues.apache.org/jira/browse/FLINK-4808
Project: Flink
Issue Type: New Feature
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2621
---
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 uce commented on the issue:
https://github.com/apache/flink/pull/2609
Thanks for this review, too. Good catch with the broken
`stopCheckpointScheduler`. I will add your proposed fix as a separate commit.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568233#comment-15568233
]
ASF GitHub Bot commented on FLINK-4516:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2624
[FLINK-4516] update leadership information in ResourceManager
The leadership information remained static for connectedJobMasters. This
updates it to remove stale JobMasters when they lose leadership
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568232#comment-15568232
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
1 - 100 of 224 matches
Mail list logo
