Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52575628
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
+ * L
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1607#issuecomment-182773179
Hi @ndimiduk, the ASF bot only closes PRs which are merged into master.
Can you manually close this one? Thanks
---
If your project is set up for it, you can reply t
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142441#comment-15142441
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142443#comment-15142443
]
ASF GitHub Bot commented on FLINK-3372:
---
Github user fhueske commented on the pull r
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1606#issuecomment-182776315
Some of the internal sinks sources, such as File* Socket are Internal while
others are PublicEvolving. Is there a reason behind this?
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142446#comment-15142446
]
ASF GitHub Bot commented on FLINK-3367:
---
Github user aljoscha commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1606#issuecomment-182778295
The motivation for this was to to make those Internal which can be added
via the ExecutionEnvironment. Sources that offer configuration parameters which
are not accessib
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1606#issuecomment-182778504
I see. Might seem inconsistent, though. :smile: So maybe we should make all
of them PublicEvolving.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142454#comment-15142454
]
ASF GitHub Bot commented on FLINK-3367:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142456#comment-15142456
]
ASF GitHub Bot commented on FLINK-3367:
---
Github user aljoscha commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1533#issuecomment-182779503
I think Robert has a good point.
The examples should follow the implementations of the other examples after
the rework in PR #1581.
---
If your project is set up f
[
https://issues.apache.org/jira/browse/FLINK-3270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142460#comment-15142460
]
ASF GitHub Bot commented on FLINK-3270:
---
Github user fhueske commented on the pull r
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1621
[FLINK-3369] [runtime] Make RemoteTransportException instance of
CancelTaskException
Problem: RemoteTransportException (RTE) is thrown on data transfer failures
when the remote data producer fails. Bec
[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142554#comment-15142554
]
ASF GitHub Bot commented on FLINK-3369:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142569#comment-15142569
]
Ufuk Celebi commented on FLINK-3369:
Yes, for example if the connection is lost, I agr
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1609#issuecomment-182809855
We also have `CommonTestUtils`, which you can use to create the temporary
directory.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-3377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142574#comment-15142574
]
ASF GitHub Bot commented on FLINK-3377:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142576#comment-15142576
]
Ufuk Celebi commented on FLINK-2824:
Is this really a blocker? In my opinion, the stre
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1564#discussion_r52588212
--- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.jade
---
@@ -22,7 +22,10 @@
nav.navbar.navbar-default.navbar-secondary-additional
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142597#comment-15142597
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1564#discussion_r52588713
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
---
@@ -203,6 +204,27 @@ public JobVertexID getJobVertexId(
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142601#comment-15142601
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user uce commented on a diff in the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1564#issuecomment-182814031
Changes and screenshots look very good!
I have a minor inline comment regarding the added method. After addressing
it, I think that this is good to merge.
---
If y
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142604#comment-15142604
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user uce commented on the pull reque
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1621#issuecomment-182813990
Do the exceptions still have information about which connection failed? I
see that the network address parameter is removed from the exceptions and also
not included
[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142603#comment-15142603
]
ASF GitHub Bot commented on FLINK-3369:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142605#comment-15142605
]
Gyula Fora commented on FLINK-2824:
---
You are probably right this should not block the re
[
https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-2824:
--
Priority: Major (was: Blocker)
> Iteration feedback partitioning does not work as expected
> --
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142610#comment-15142610
]
Stefano Baghino commented on FLINK-2609:
[~rmetzger] can you elaborate on this iss
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142610#comment-15142610
]
Stefano Baghino edited comment on FLINK-2609 at 2/11/16 11:28 AM:
--
Gyula Fora created FLINK-3386:
-
Summary: Kafka consumers should not necessarily fail on expiring
data
Key: FLINK-3386
URL: https://issues.apache.org/jira/browse/FLINK-3386
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3386:
--
Component/s: ps://issues.apache.org/jira/browse/FLINK-3386
> Kafka consumers should not necessar
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3386:
--
Component/s: Kafka Connector
> Kafka consumers should not necessarily fail on expiring data
> --
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3386:
--
Component/s: (was: ps://issues.apache.org/jira/browse/FLINK-3386)
> Kafka consumers should n
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142614#comment-15142614
]
Robert Metzger commented on FLINK-3386:
---
I think this issue is basically a duplicate
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142615#comment-15142615
]
Gyula Fora commented on FLINK-3386:
---
You are right, I am closing this...
> Kafka consum
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142617#comment-15142617
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1524#issuecomment-182817638
Thanks @rmetzger for the comment. Will fix it!
---
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 proje
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182817751
Looks pretty good. Can you check the `@Ignore` annotations?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-3386.
-
Resolution: Duplicate
Duplicate of: FLINK-3264
> Kafka consumers should not necessarily fail on expiring
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142618#comment-15142618
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user fhueske commented on the pull r
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1571
---
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 StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1571#issuecomment-182818412
Manually merged
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142621#comment-15142621
]
ASF GitHub Bot commented on FLINK-3312:
---
Github user StephanEwen closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142620#comment-15142620
]
ASF GitHub Bot commented on FLINK-3312:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-182821560
Adjusting 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 no
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1619#issuecomment-182821639
Changes look good. Do we have another way of deploying the snapshots then?
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142625#comment-15142625
]
ASF GitHub Bot commented on FLINK-3383:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1619#discussion_r52590661
--- Diff: .travis.yml ---
@@ -17,9 +17,9 @@ language: java
matrix:
include:
- jdk: "oraclejdk8"
- env: PROFILE="-Dhadoop.version=2.7.
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142626#comment-15142626
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142627#comment-15142627
]
ASF GitHub Bot commented on FLINK-3383:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142628#comment-15142628
]
Dongwon Kim commented on FLINK-1502:
[~mxm] Could you elaborate more on the above expl
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142631#comment-15142631
]
Ufuk Celebi commented on FLINK-3299:
I think you raise valid points. But as long as we
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1554#issuecomment-182824952
I think this breaks the code. The `setOutEdges()` method is actually used
(even though the call site can probably be removes as well, given that they are
not read an
[
https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142634#comment-15142634
]
ASF GitHub Bot commented on FLINK-2428:
---
Github user StephanEwen commented on the pu
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1621#issuecomment-182825136
Thanks for looking into it. The remote address is actually part of all the
messages, but I've readded it as an explicit argument. For the local variant,
the address is known
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1619#discussion_r52591570
--- Diff: .travis.yml ---
@@ -17,9 +17,9 @@ language: java
matrix:
include:
- jdk: "oraclejdk8"
- env: PROFILE="-Dhadoop.version=2.7.
[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142635#comment-15142635
]
ASF GitHub Bot commented on FLINK-3369:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142637#comment-15142637
]
ASF GitHub Bot commented on FLINK-3383:
---
Github user mxm commented on a diff in the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1619#issuecomment-182825715
Thanks for the comment. Yes, as stated above, I would like to migrate
snapshot deployment to the a nightly Buildbot job at Apache's infrastructure
(like we also do for the d
[
https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142638#comment-15142638
]
ASF GitHub Bot commented on FLINK-3383:
---
Github user mxm commented on the pull reque
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52597099
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142668#comment-15142668
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52597604
--- Diff: docs/apis/cli.md ---
@@ -248,6 +252,16 @@ Action "cancel" cancels a running program.
configuration.
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142675#comment-15142675
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598106
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/StoppableTask.java
---
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142681#comment-15142681
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598306
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142684#comment-15142684
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Stephan Ewen created FLINK-3387:
---
Summary: Replace all ByteArrayOutputStream and DataOutputStream
use in State Backends by DataOutputSerializer
Key: FLINK-3387
URL: https://issues.apache.org/jira/browse/FLINK-3387
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598511
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -417,6 +417,28 @@ class TaskManager(
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142688#comment-15142688
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598636
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142691#comment-15142691
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598649
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142690#comment-15142690
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598725
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598713
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52598719
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -464,6 +464,33 @@ class JobManager(
)
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142694#comment-15142694
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142692#comment-15142692
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142693#comment-15142693
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142700#comment-15142700
]
ASF GitHub Bot commented on FLINK-2991:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1605#discussion_r52599200
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java
---
@@ -148,6 +150,18 @@ public void dispose() {
a
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-182859453
Really good work @mjsax.
I had a couple of minor inline comments with respect to the latest commit
and some with respect to the overall changes (especially c
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142704#comment-15142704
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142710#comment-15142710
]
Maximilian Michels commented on FLINK-1502:
---
[~eastcirclek] Yes, I was working o
[
https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3170.
-
Resolution: Duplicate
> Expose task manager metrics via JMX
>
Maximilian Michels created FLINK-3388:
-
Summary: Expose task accumulators via JMX
Key: FLINK-3388
URL: https://issues.apache.org/jira/browse/FLINK-3388
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142727#comment-15142727
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/750#discussion_r52601121
--- Diff: flink-runtime-web/web-dashboard/web/css/vendor.css ---
@@ -7704,6 +7704,7 @@ button.close {
.modal-header {
padding: 15px;
bor
[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3369.
--
Resolution: Fixed
Fixed in cf3ae88.
> RemoteTransportException should be instance of CancelTaskExceptio
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1621
---
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-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142735#comment-15142735
]
ASF GitHub Bot commented on FLINK-3369:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142745#comment-15142745
]
Ufuk Celebi commented on FLINK-3283:
Do you think we can close this issue?
> Failed
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-182872207
I'm thinking about partitioning, but again, I'm finding it too difficult to
imagine how this algorithm behaves, when we emit/rebuild only some part of the
table at a time
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142753#comment-15142753
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182872698
@fhueske I fixed the aggregation hashCode and enables the ignored tests.
Let me know if it's OK now!
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142754#comment-15142754
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on the pull req
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1622
[FLINK-3364] [runtime, yarn] Move SavepointStore initialization out of
JobManager constructor
Initializing the `SavepointStore` can fail. Doing this in the `JobManager`
constructor is bad, because it i
1 - 100 of 254 matches
Mail list logo
