[
https://issues.apache.org/jira/browse/FLINK-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620642#comment-14620642
]
ASF GitHub Bot commented on FLINK-2329:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-119988165
Did we find a solution for the random port problem?
---
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-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620568#comment-14620568
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620625#comment-14620625
]
Stephan Ewen commented on FLINK-2339:
-
I have a patch coming up, currently testing on
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-119996182
In HA mode, JobManagers start with a random free port. That is fine,
because no one connects to them based on a config value, but only based on
ZooKeeper entries.
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620572#comment-14620572
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-12744
The web interface is, modulo some object which are not serializable,
already independent of the JobManager. It should not be a big problem to
only have one
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120029960
Looks like this change breaks the YARN integration. The YARN WordCount no
longer works.
---
If your project is set up for it, you can reply to this email and have
Github user shghatge commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-120036933
Hello @vasia
I would like to work on both versions of Adamic Adar. As the JIRA did not
ask for an approximate version, it was suggested that I create another JIRA
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34268803
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java
---
@@ -212,19 +218,19 @@ public InputGate
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620697#comment-14620697
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/859#issuecomment-119987554
1/4 of the physical memory seems sensible and indeed returns almost the
same memory size as the maximum memory setting on my machine. I've adapted the
pull request.
---
If
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620613#comment-14620613
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user rmetzger commented on a diff in
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/895#discussion_r34262141
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamCheckpointingITCase.java
---
@@ -53,6 +62,8 @@
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620610#comment-14620610
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620609#comment-14620609
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user StephanEwen commented on a diff
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/895#discussion_r34262145
--- 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-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620611#comment-14620611
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620634#comment-14620634
]
ASF GitHub Bot commented on FLINK-2288:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620654#comment-14620654
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34266800
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
---
@@ -60,6 +60,7 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620538#comment-14620538
]
ASF GitHub Bot commented on FLINK-2235:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-12117
Yes that makes sense. So the user will always have to connect to the web
interface of the leading job manager, right? We could only circumvent that by
separating the web
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/895#discussion_r34262472
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/Utils.java
Maximilian Michels created FLINK-2340:
-
Summary: Provide standalone mode for web interface of the
JobManager
Key: FLINK-2340
URL: https://issues.apache.org/jira/browse/FLINK-2340
Project: Flink
Stephan Ewen created FLINK-2341:
---
Summary: Deadlock in SpilledSubpartitionViewAsyncIO
Key: FLINK-2341
URL: https://issues.apache.org/jira/browse/FLINK-2341
Project: Flink
Issue Type: Bug
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/895#discussion_r34261966
--- Diff: docs/apis/streaming_guide.md ---
@@ -1300,6 +1300,9 @@ Another way of exposing user defined operator state
for the Flink runtime for ch
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/895#discussion_r34262084
--- 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-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620608#comment-14620608
]
ASF GitHub Bot commented on FLINK-2008:
---
Github user StephanEwen commented on a diff
Github user shghatge commented on the pull request:
https://github.com/apache/flink/pull/892#issuecomment-120033517
Hello @vasia
I would like to work on both versions of Adamic Adar. As the JIRA did not
ask for an approximate version, it was suggested that I create another JIRA
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34269026
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -237,12 +246,13 @@ public Task(TaskDeploymentDescriptor tdd,
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620708#comment-14620708
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620707#comment-14620707
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620750#comment-14620750
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120054333
The is a potential modification conflict: Drawing a snapshot for
serialization and registering a new accumulator can lead to a
ConcurrentModificationException in the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34273441
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -601,6 +636,11 @@ void markFinished() {
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620786#comment-14620786
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620776#comment-14620776
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34274318
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -172,13 +173,20 @@
/** The library cache, from
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620768#comment-14620768
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620801#comment-14620801
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620810#comment-14620810
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34274983
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/895#issuecomment-120065921
Except for the issue mentioned by Gyula (the double commit of the head),
this looks good. I would like to merge this later today or tomorrow. Could
address Gyula's
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620724#comment-14620724
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34270017
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/StreamingAbstractRecordReader.java
---
[
https://issues.apache.org/jira/browse/FLINK-2340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620767#comment-14620767
]
Ufuk Celebi commented on FLINK-2340:
+1 I think separation is the way to go.
Provide
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/896#issuecomment-120058469
The naming of the accumulators refers sometimes to flink vs.
user-defined, and sometimes to internal vs. external. Can we make this
consistent? I actually like the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34271710
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
---
@@ -60,6 +60,7 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620782#comment-14620782
]
Ufuk Celebi commented on FLINK-2341:
Thanks for the stacktrace. I will look into it
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620780#comment-14620780
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620756#comment-14620756
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34272101
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -306,99 +308,100 @@ extends Actor with
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620773#comment-14620773
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34273000
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -131,6 +133,35 @@
private
[
https://issues.apache.org/jira/browse/FLINK-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620081#comment-14620081
]
ASF GitHub Bot commented on FLINK-2280:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620119#comment-14620119
]
ASF GitHub Bot commented on FLINK-2240:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/888#issuecomment-119873635
Nice, thank you.
I will try to take a look soon...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620123#comment-14620123
]
Andra Lungu commented on FLINK-2293:
I should not have tried anything yesterday... I
[
https://issues.apache.org/jira/browse/FLINK-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620130#comment-14620130
]
ASF GitHub Bot commented on FLINK-2280:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1239.
-
Resolution: Not A Problem
Fix iteration example getting stuck with large input
[
https://issues.apache.org/jira/browse/FLINK-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-2261.
-
Resolution: Fixed
Remove reduce/aggregation from DataStream
-
David Heller created FLINK-2334:
---
Summary: IOException: Channel to path could not be opened
Key: FLINK-2334
URL: https://issues.apache.org/jira/browse/FLINK-2334
Project: Flink
Issue Type: Bug
Gyula Fora created FLINK-2335:
-
Summary: Rework iteration construction in StreamGraph
Key: FLINK-2335
URL: https://issues.apache.org/jira/browse/FLINK-2335
Project: Flink
Issue Type: Improvement
William Saar created FLINK-2336:
---
Summary: ArrayIndexOufOBoundsException in TypeExtractor when
mapping
Key: FLINK-2336
URL: https://issues.apache.org/jira/browse/FLINK-2336
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620345#comment-14620345
]
William Saar commented on FLINK-2336:
-
When replacing the lambda with a MapFunction
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/894#issuecomment-119865296
Good catch!
+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
Stephan Ewen created FLINK-2333:
---
Summary: Stream Data Sink that periodically rolls files
Key: FLINK-2333
URL: https://issues.apache.org/jira/browse/FLINK-2333
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620116#comment-14620116
]
Stephan Ewen commented on FLINK-2293:
-
[~andralungu] The line numbers in your stack
[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620117#comment-14620117
]
Stephan Ewen commented on FLINK-2293:
-
You can look at the beginning of the log, it
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/894
---
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-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1421.
---
Resolution: Done
Implement a SAMOA Adapter for Flink Streaming
[
https://issues.apache.org/jira/browse/FLINK-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-2328:
-
Assignee: Gyula Fora
Applying more than one transformation on an IterativeDataStream fails
[
https://issues.apache.org/jira/browse/FLINK-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-2328:
--
Component/s: Streaming
Applying more than one transformation on an IterativeDataStream fails
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620163#comment-14620163
]
ASF GitHub Bot commented on FLINK-2235:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/859#issuecomment-119883278
Typically, programs can allocate as much memory as they like. We only take
a fraction of the free physical memory for the manged memory. We could also
take only half of the
[
https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620102#comment-14620102
]
ASF GitHub Bot commented on FLINK-2305:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/884#issuecomment-119870990
Let's make it a separate issue.
If there is a followup on these two issues, we can merge this, in my
opinion.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620135#comment-14620135
]
ASF GitHub Bot commented on FLINK-2280:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2280.
Resolution: Fixed
Fixed with 590c6d0644e59d0bc3b5b6f4869f91bc38864232
[
https://issues.apache.org/jira/browse/FLINK-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2338:
---
Summary: Shut down Storm Topologies cleanly (was: Shut down Storm
Topologies clenaly)
Shut
[
https://issues.apache.org/jira/browse/FLINK-2162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-2162:
-
Assignee: Ventura Del Monte
Implement adaptive learning rate strategies for SGD
[
https://issues.apache.org/jira/browse/FLINK-2162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620427#comment-14620427
]
Till Rohrmann commented on FLINK-2162:
--
Great to hear [~ventura] :-) I've assigned
Matthias J. Sax created FLINK-2337:
--
Summary: Multiple SLF4J bindings using Storm compatibility layer
Key: FLINK-2337
URL: https://issues.apache.org/jira/browse/FLINK-2337
Project: Flink
Matthias J. Sax created FLINK-2338:
--
Summary: Shut down Storm Topologies clenaly
Key: FLINK-2338
URL: https://issues.apache.org/jira/browse/FLINK-2338
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620418#comment-14620418
]
ASF GitHub Bot commented on FLINK-2305:
---
Github user mjsax commented on the pull
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/884#issuecomment-119943363
I just created two JIRAs:
- SLF4J: https://issues.apache.org/jira/browse/FLINK-2337
- JobExecutionException: https://issues.apache.org/jira/browse/FLINK-2338
[
https://issues.apache.org/jira/browse/FLINK-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620389#comment-14620389
]
Stephan Ewen commented on FLINK-2336:
-
Can you post a simpifies data type that
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/859#issuecomment-119891011
Okay, from skimming over some Oracle docs, it seems the default max heap is
1/4 of the physical memory. Let's use that.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620197#comment-14620197
]
ASF GitHub Bot commented on FLINK-2235:
---
Github user StephanEwen commented on the
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/895
[FLINK-2008][FLINK-2296] Fix checkpoint committing KafkaITCase [wip]
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink2008
[
https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620459#comment-14620459
]
ASF GitHub Bot commented on FLINK-2008:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620523#comment-14620523
]
ASF GitHub Bot commented on FLINK-2292:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/896
[FLINK-2292][FLINK-1573] add live per-task accumulators
This refactors the accumulators to accumulate per task execution. The
accumulators are reported from the task managers periodically to the job
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34272308
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1017,6 +1040,9 @@ object TaskManager {
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620762#comment-14620762
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/896#discussion_r34273136
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -601,6 +636,11 @@ void markFinished() {
[
https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620819#comment-14620819
]
ASF GitHub Bot commented on FLINK-2292:
---
Github user StephanEwen commented on the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/886#issuecomment-120015233
Alright, I've opened a JIRA for this:
https://issues.apache.org/jira/browse/FLINK-2340
---
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-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14620638#comment-14620638
]
ASF GitHub Bot commented on FLINK-2329:
---
Github user mxm commented on a diff in the
1 - 100 of 101 matches
Mail list logo
