[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700776#comment-14700776
]
Suminda Dharmasena commented on FLINK-2366:
---
Can you consider something more sim
Ted Yu created FLINK-2538:
-
Summary: Potential resource leak in
ClassLoaderUtil#getUserCodeClassLoaderInfo()
Key: FLINK-2538
URL: https://issues.apache.org/jira/browse/FLINK-2538
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fangfengbin closed FLINK-2526.
--
Resolution: Fixed
> Add catch{} for task when it stop running
> ---
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1010#issuecomment-132005060
Thanks all, will do
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700013#comment-14700013
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700023#comment-14700023
]
chenliang commented on FLINK-2367:
--
ok, how about adding some note like this: "log file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Assignee: chenliang
> “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected
> after
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700016#comment-14700016
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700018#comment-14700018
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2367:
-
Comment: was deleted
(was: ok, your explanation looks reasonable. how about adding some note: "log
file d
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700015#comment-14700015
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700017#comment-14700017
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700012#comment-14700012
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
[
https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14700014#comment-14700014
]
chenliang commented on FLINK-2367:
--
ok, your explanation looks reasonable. how about addi
chenliang created FLINK-2537:
Summary: Add scala examples.jar to build-target/examples
Key: FLINK-2537
URL: https://issues.apache.org/jira/browse/FLINK-2537
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2537:
-
Labels: maven (was: )
> Add scala examples.jar to build-target/examples
> ---
[
https://issues.apache.org/jira/browse/FLINK-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenliang updated FLINK-2537:
-
Description:
Currently Scala as functional programming language has been acknowledged by
more and more d
Github user chenliang613 commented on the pull request:
https://github.com/apache/flink/pull/1019#issuecomment-131911333
ok, done!
---
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 chenliang613 closed the pull request at:
https://github.com/apache/flink/pull/1019
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699891#comment-14699891
]
Aljoscha Krettek commented on FLINK-2398:
-
It works because the output type is not
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699848#comment-14699848
]
Stephan Ewen commented on FLINK-2398:
-
What does the runtime do in the end, when it do
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699841#comment-14699841
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-131892889
I changed it to execute dangling operators now. There is, however, a
strange "feature". This code works on master:
https://gist.github.com/aljoscha/bbe74309a31a16ca8413.
[
https://issues.apache.org/jira/browse/FLINK-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-1028.
---
Resolution: Cannot Reproduce
> Certain exceptions are not visibly reported to the user
> -
[
https://issues.apache.org/jira/browse/FLINK-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699782#comment-14699782
]
Aljoscha Krettek commented on FLINK-1028:
-
I don't think it is relevant anymore. I
[
https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699672#comment-14699672
]
Aljoscha Krettek commented on FLINK-2508:
-
I think this is a manifestation of the
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699623#comment-14699623
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1026#issuecomment-131853677
I have implemented a `TaskRuntimeInfo` which holds descriptive information
about the task, such as name, index, parallelism, etc. Also renamed the
`TaskManagerRun
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-131847425
I like this idea a lot. The backported code is not very stable anyways...
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699605#comment-14699605
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699594#comment-14699594
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1028#issuecomment-131843222
How about dropping the backported Kafka code and relying completely on our
own implementation against the SimpleConsumer API?
We would need to implement the `KafkaCo
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699585#comment-14699585
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-131840098
+1 for merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this featur
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699581#comment-14699581
]
ASF GitHub Bot commented on FLINK-1297:
---
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/605#discussion_r37192039
--- Diff: flink-contrib/flink-operator-stats/pom.xml ---
@@ -0,0 +1,67 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://
[
https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699567#comment-14699567
]
ASF GitHub Bot commented on FLINK-2521:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2517:
--
Assignee: Nezih Yigitbasi
> Wrong KafkaSink arguments in streaming guide
> -
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1015#issuecomment-131829785
Very useful change. +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 no
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/948#discussion_r37185622
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/SchedulerUtils.scala
---
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699507#comment-14699507
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-131812796
It seems that you are ignoring methods such as `error(driver:
SchedulerDriver, message: String)` or `frameworkMessage()`.
Are they application specific (e.g. send by
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699503#comment-14699503
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/948#discussion_r37184472
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/executor/FlinkExecutor.scala
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699493#comment-14699493
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699483#comment-14699483
]
ASF GitHub Bot commented on FLINK-1984:
---
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/948#discussion_r37183905
--- Diff: flink-mesos/pom.xml ---
@@ -0,0 +1,188 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XML
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699476#comment-14699476
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-131803783
For the tests: For HDFS, Kafka and YARN, we are using "MiniClusters" which
start all needed services in one JVM.
I don't think we can do something similar with Mesos
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699464#comment-14699464
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-131800322
Failing KafkaConnector test. This in unrelated. Failing run is green on
personal Travis ((https://travis-ci.org/mjsax/flink/builds/75910791).
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2527.
-
Resolution: Fixed
Fixed
- 0.10 in 0ea0bc12b3f8a8a82b6fca563340af547c0a02ab
- 0.9.1 in e8802f90
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2527.
---
> If a VertexUpdateFunction calls setNewVertexValue more than once, the
> MessagingFunction will only see
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2462.
---
> Wrong exception reporting in streaming jobs
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2534.
---
> Improve execution code in CompactingHashTable.java
> --
[
https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2534.
-
Resolution: Fixed
Fixed via 63ee34c5b894e2795e74a3c2aa3d5dc9ac2d5b88
Thank you for the contributi
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2462.
-
Resolution: Fixed
Fixed via 92b1e471d4762545637817c74f9396765984b39a
> Wrong exception reporting
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699441#comment-14699441
]
ASF GitHub Bot commented on FLINK-2527:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1018
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1029
---
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-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699439#comment-14699439
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1027
---
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-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699440#comment-14699440
]
ASF GitHub Bot commented on FLINK-2534:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1017
---
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-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699437#comment-14699437
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-131796852
Hi @ankurcha,
I've started a Mesos cluster on Google Compute Engine to try out your pull
request.
I've used this configuration:
```
flink.mesos.maste
[
https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699374#comment-14699374
]
Stephan Ewen commented on FLINK-2415:
-
The plan is currently created from the Optimize
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699373#comment-14699373
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-2415:
---
Assignee: Stephan Ewen
> Link nodes in plan to vertices
> --
>
>
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-131781343
Should there be a unit test to verify this functionality?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2415:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-2357
> Link nodes in plan to vertices
[
https://issues.apache.org/jira/browse/FLINK-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2365.
-
Resolution: Fixed
Fixed as part of 1f917e3b40fc74431e06834826cc556e4e78c48b
> Review of How to co
[
https://issues.apache.org/jira/browse/FLINK-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2365.
---
> Review of How to contribute page
>
>
> Key: FLINK-2365
[
https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1321.
---
Resolution: Fixed
> New web interface, contains parts from WebInfoServer and WebClient
> -
[
https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1321.
-
Resolution: Incomplete
Fix Version/s: (was: 0.7.0-incubating)
No progress on that issue
[
https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reopened FLINK-1321:
-
> New web interface, contains parts from WebInfoServer and WebClient
> ---
[
https://issues.apache.org/jira/browse/FLINK-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-855.
Resolution: Won't Fix
Will be subsumed by the new web dashboard
> Web interface: flow vs stack layou
[
https://issues.apache.org/jira/browse/FLINK-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-855.
--
> Web interface: flow vs stack layout
> ---
>
> Key: FLINK-85
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699353#comment-14699353
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-131772983
Ah yes. You're right. Lemme see if I can write a workaround to this.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699351#comment-14699351
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1017#issuecomment-131772364
Allright, if there are no further comments, I'll merge this...
---
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-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699349#comment-14699349
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1026#issuecomment-131771732
Yes, let's have a `TaskRuntimeInfo` and a `TaskManagerContext`. Both are
available in the `RuntimeEnvironment` and passed to the `RuntimeContext`.
The `TaskR
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1010#issuecomment-131770992
+1 for adding a rule (otherwise, I will not learn it ;) )
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-131769530
Does this work properly with collect() calls? as in, would the following
plan still work?
`env = ..
env.registerCacheFile()
...
someSet.collect()
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699345#comment-14699345
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699342#comment-14699342
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1026#issuecomment-131768999
Yes. Minimizing the arguments being passed to `RuntimeContext` was the
motivation. I thought about putting every task specific field into the TaskInfo
object but
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699340#comment-14699340
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1017#discussion_r37174684
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/Output.java
---
@@ -33,9 +33,8 @@
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1017#discussion_r37174502
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -27,11
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699336#comment-14699336
]
Márton Balassi commented on FLINK-2491:
---
That should be good enough. I was testing w
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699335#comment-14699335
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699333#comment-14699333
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on the pu
1 - 100 of 161 matches
Mail list logo
