[
https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637045#comment-14637045
]
ASF GitHub Bot commented on FLINK-2097:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/858#issuecomment-123755792
It should just add more nodes to the ExecutionGraph. Existing ones should
not be modified. For batch, I think the assumption is that it needs to be
finished. For streaming,
Stephan Ewen created FLINK-2393:
---
Summary: Add a stateless at-least-once mode for streaming
Key: FLINK-2393
URL: https://issues.apache.org/jira/browse/FLINK-2393
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637038#comment-14637038
]
ASF GitHub Bot commented on FLINK-2097:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/858#issuecomment-123754538
I think right now, it pretty much behaves as if someone started a new job,
with the grown execution graph.
---
If your project is set up for it, you can reply to
Stefano Bortoli created FLINK-2394:
--
Summary: HadoopOutFormat OutputCommitter is default to
FileOutputCommiter
Key: FLINK-2394
URL: https://issues.apache.org/jira/browse/FLINK-2394
Project: Flink
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/933
[FLINK-2385] [scala api] Add parenthesis to Scala 'distinct' transformation.
The operation is not side-effect free. It does not mutate the original
DataSet, but defines distributed computation.
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-123755971
Addressed the following comments: Corrected order of visibility and
abstract modifiers. Removed the lazy log field from `FlinkActor`. Now all
implementing
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637059#comment-14637059
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637083#comment-14637083
]
Aljoscha Krettek commented on FLINK-2393:
-
I guess you meant no state backup for
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-123752371
Hi @mxm. Thanks a lot!
I don't have your email unfortunately.
Could you somehow send it to me?
---
If your project is set up for it, you can reply to this email
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-123751721
Do you mean `JobManager.getJobManagerGateway`? This is only a temporary
solution to obtain an `ActorGateway` for the JobManager for which you have to
know the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-123756678
@kl0u Sure, I've sent you an email.
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-123757309
Looks good. +1 to merge 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
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637064#comment-14637064
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637068#comment-14637068
]
ASF GitHub Bot commented on FLINK-2385:
---
GitHub user StephanEwen opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637031#comment-14637031
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user tillrohrmann commented on the
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/887#issuecomment-123756855
Thanks a lot!
---
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
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/642#discussion_r35240445
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -421,6 +426,50 @@ public JobSubmissionResult run(JobGraph jobGraph,
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637250#comment-14637250
]
ASF GitHub Bot commented on FLINK-1818:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/642#discussion_r35240432
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -421,6 +426,50 @@ public JobSubmissionResult run(JobGraph jobGraph,
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637248#comment-14637248
]
ASF GitHub Bot commented on FLINK-1818:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637249#comment-14637249
]
ASF GitHub Bot commented on FLINK-1818:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637329#comment-14637329
]
Stephan Ewen commented on FLINK-2373:
-
That is definitely a good idea. Would you be up
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637385#comment-14637385
]
niraj rai commented on FLINK-1818:
--
Thanks Max for mentoring me.. Really appreciate your
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/642#issuecomment-123815171
@rainiraj Thanks for your contribution!
---
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
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/642#issuecomment-123802868
Thanks @rainiraj. I think we can merge your changes with some small
adjustments.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/642#discussion_r35240453
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -421,6 +426,50 @@ public JobSubmissionResult run(JobGraph jobGraph,
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637251#comment-14637251
]
ASF GitHub Bot commented on FLINK-1818:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/642#discussion_r35240436
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/Client.java ---
@@ -421,6 +426,50 @@ public JobSubmissionResult run(JobGraph jobGraph,
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-2388.
-
Resolution: Fixed
Thanks for your help, [~ebautistabar]!
JobManager should try
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/930
---
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-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637274#comment-14637274
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14637347#comment-14637347
]
ASF GitHub Bot commented on FLINK-1818:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636427#comment-14636427
]
ASF GitHub Bot commented on FLINK-2304:
---
Github user gyfora commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/878#issuecomment-123589583
Thanks I will merge it later today! :)
---
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-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636520#comment-14636520
]
ASF GitHub Bot commented on FLINK-1658:
---
Github user uce commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/929#issuecomment-123620462
No, +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 have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636531#comment-14636531
]
Maximilian Michels commented on FLINK-2388:
---
Hi [~ebautistabar], thanks for
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636533#comment-14636533
]
ASF GitHub Bot commented on FLINK-2388:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/930
[FLINK-2388] return AccumulatorResultsNotFound until archive is checked
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636549#comment-14636549
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636551#comment-14636551
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35193782
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -707,33 +706,33 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636431#comment-14636431
]
ASF GitHub Bot commented on FLINK-2363:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/913#issuecomment-123590116
@fhueske Naa, I just want to see it finished. So I'll probably have to
write some other parts myself but it would be cool if you could contribute this
part.
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636451#comment-14636451
]
Till Rohrmann commented on FLINK-1901:
--
If you use the sampling operator this way, it
[
https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636497#comment-14636497
]
Aljoscha Krettek commented on FLINK-2390:
-
Yes, this could be a good idea.
How
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/931
[FLINK-1927][py] Operator distribution rework
Python operators are no longer serialized and shipped across the
cluster. Instead the plan file is executed on each node, followed by
usage of the
[
https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-2173:
---
Assignee: Chesnay Schepler
Python uses different tmp file than Flink
[
https://issues.apache.org/jira/browse/FLINK-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636537#comment-14636537
]
ASF GitHub Bot commented on FLINK-1927:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-2346.
-
Resolution: Duplicate
I'm closing this issue, its a duplicate of FLINK-1984.
Mesos clustering
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35193777
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -688,16 +688,15 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636575#comment-14636575
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/885#discussion_r35194868
--- Diff:
flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/assembly/word-count-storm.xml
---
@@ -36,7 +36,7 @@ under the
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636627#comment-14636627
]
ASF GitHub Bot commented on FLINK-2218:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/904#issuecomment-123648113
This only occurs with your changes, right? Then let's first fix the issue
of the failing tests before merging.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636740#comment-14636740
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user ebautistabar commented on a
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636601#comment-14636601
]
Maximilian Michels commented on FLINK-2388:
---
[~ebautistabar] Can you take a look
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636598#comment-14636598
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-123643760
No need to hurry .. I needed 10 days to look at it .. so a few hours don't
matter ;)
I tried to install the artifacts to my local repository, but the _2.11
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636606#comment-14636606
]
ASF GitHub Bot commented on FLINK-2218:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/904#issuecomment-123645039
+1 for merging 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 project does not have this feature
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/930#issuecomment-123649614
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636741#comment-14636741
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user ebautistabar commented on a
Github user ebautistabar commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35202994
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -580,6 +581,34 @@ public ExecutionContext
Github user ebautistabar commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35202991
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -687,61 +687,23 @@ class JobManager(
message
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636591#comment-14636591
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35195856
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -688,16 +688,15 @@ class JobManager(
case
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636603#comment-14636603
]
ASF GitHub Bot commented on FLINK-2391:
---
GitHub user ffbin opened a pull request:
GitHub user ffbin opened a pull request:
https://github.com/apache/flink/pull/932
[FLINK-2391]Fix Storm-compatibility FlinkTopologyBuilder.createTopology bug
1.Error Scene:
Error happend in program like this:
builder.setSpout(source0, new Generator(pt),
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/904#issuecomment-123646720
You are right. I just updated it.
What about the failing YARN test. Is there already a JIRA for it?
https://travis-ci.org/apache/flink/builds/72019686
---
If your
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/929#issuecomment-123646781
+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 have this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636621#comment-14636621
]
ASF GitHub Bot commented on FLINK-1658:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636620#comment-14636620
]
ASF GitHub Bot commented on FLINK-2218:
---
Github user mjsax commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636727#comment-14636727
]
Enrique Bautista Barahona edited comment on FLINK-2388 at 7/22/15 11:10 AM:
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636727#comment-14636727
]
Enrique Bautista Barahona commented on FLINK-2388:
--
Sure [~mxm], I'll
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/904#issuecomment-123674841
I don't know exactly. My changes should not influence YARN component (as
fas as I can tell). YARN test have been instable a lot -- I would guess, it is
a general issue.
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636578#comment-14636578
]
Robert Metzger commented on FLINK-2200:
---
[~pgoetze], can you check if Chiwan's pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35195608
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -688,16 +688,15 @@ class JobManager(
case
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-123640287
Sorry for the delay.
I will deploy the artifacts from this branch to the maven snapshot
repository to see if everything works as expected.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636589#comment-14636589
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on the pull
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/885#issuecomment-123642852
Hi, currently this PR is not ready to merge, because this PR doesn't
contain changes for #677. I'll update soon. Unfortunately I'm outside now.
Maybe I can update
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636595#comment-14636595
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user chiwanpark commented on the
[
https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax closed FLINK-2371.
--
Fixed test passed 10 Travis runs for me without failing. Seems to be stable now.
[
https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636714#comment-14636714
]
Stephan Ewen commented on FLINK-685:
So far, we have had the paradigm that any
[
https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636632#comment-14636632
]
Maximilian Michels commented on FLINK-2371:
---
Good to hear :)
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636635#comment-14636635
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636764#comment-14636764
]
ASF GitHub Bot commented on FLINK-2388:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35204559
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -580,6 +581,34 @@ public ExecutionContext
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/930#discussion_r35204984
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -687,61 +687,23 @@ class JobManager(
message match {
[
https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636798#comment-14636798
]
ASF GitHub Bot commented on FLINK-2205:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/927#issuecomment-123700358
The job manager UI is under rework right now, there is a new version coming
up, see here:
https://github.com/apache/flink/tree/master/flink-runtime-web
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/928#issuecomment-123700349
Maybe your vim is set to replace tabs with spaces, but in the files that
you changed there are definitely spaces now.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-2322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636797#comment-14636797
]
ASF GitHub Bot commented on FLINK-2322:
---
Github user aljoscha commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/929
---
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-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636828#comment-14636828
]
ASF GitHub Bot commented on FLINK-1658:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636854#comment-14636854
]
ASF GitHub Bot commented on FLINK-2218:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-2218.
---
Resolution: Fixed
Web client cannot distinguesh between Flink options and program
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-123720593
The mechanism looks good, all in all.
Some comments:
- I think it makes the code more understandable, if the
`decorateMessage()` method would be called
1 - 100 of 157 matches
Mail list logo
