[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699254#comment-14699254
]
Sachin Goel commented on FLINK-2448:
I'm not sure what you mean by running multiple
[
https://issues.apache.org/jira/browse/FLINK-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699268#comment-14699268
]
Aljoscha Krettek commented on FLINK-2530:
-
Can this issue be closed then?
[
https://issues.apache.org/jira/browse/FLINK-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699270#comment-14699270
]
Aljoscha Krettek commented on FLINK-2531:
-
Can this be closed again then?
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699283#comment-14699283
]
ASF GitHub Bot commented on FLINK-2527:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699295#comment-14699295
]
Sachin Goel commented on FLINK-2448:
Aha. It makes sense. The `TestEnvironment`
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699336#comment-14699336
]
Márton Balassi commented on FLINK-2491:
---
That should be good enough. I was testing
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699335#comment-14699335
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user StephanEwen commented on a diff
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-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699353#comment-14699353
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699242#comment-14699242
]
Aljoscha Krettek commented on FLINK-2514:
-
I have a fix for this as part of
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1026#issuecomment-131767636
Looks mostly good.
The `TaskRuntimeInfo` is now a bit strange. It contains some runtime info
for tasks (attempt number) but not all (subtasks, etc). The
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699349#comment-14699349
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on the
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
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
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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:
```
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
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699252#comment-14699252
]
Márton Balassi commented on FLINK-2514:
---
Cool, thanks.
Local and Remote
Huang Wei created FLINK-2536:
Summary: Add a retry for SocketClientSink
Key: FLINK-2536
URL: https://issues.apache.org/jira/browse/FLINK-2536
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2514:
--
Assignee: Aljoscha Krettek (was: Márton Balassi)
Local and Remote environment behave
[
https://issues.apache.org/jira/browse/FLINK-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-2530.
Resolution: Won't Fix
optimize equal() of AcknowledgeCheckpoint
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699295#comment-14699295
]
Sachin Goel edited comment on FLINK-2448 at 8/17/15 9:56 AM:
-
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1029#issuecomment-131759047
This seems correct, will 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
[
https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699298#comment-14699298
]
ASF GitHub Bot commented on FLINK-2534:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699314#comment-14699314
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699315#comment-14699315
]
Robert Metzger commented on FLINK-2491:
---
I quickly talked with [~StephanEwen] about
[
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-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-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699220#comment-14699220
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699292#comment-14699292
]
Robert Metzger commented on FLINK-2491:
---
I suspect FLINK-2519 resolves this bug.
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2491:
--
Comment: was deleted
(was: Yes, it fixes it - that is why I removed my previous comment that
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1026#discussion_r37173822
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
---
@@ -93,6 +93,15 @@ public int
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
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
--
[
https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699374#comment-14699374
]
Stephan Ewen commented on FLINK-2415:
-
The plan is currently created from the
[
https://issues.apache.org/jira/browse/FLINK-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-2531.
Resolution: Won't Fix
combining the if branch to improve the performance
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1019#issuecomment-131756217
I merged this in 3c1b5f0e7f28d18868e941712d2ca42b140ef3a0 , but forgot the
closing message.
Can you manually close this pull request?
Thank you!
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1018#issuecomment-131756341
Will 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 not have
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1031
[FLINK-2448]Clear cache file list in ExecutionEnvironment after program
plan creation
You can merge this pull request into a Git repository by running:
$ git pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1026#discussion_r37173778
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java
---
@@ -120,7 +125,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699318#comment-14699318
]
ASF GitHub Bot commented on FLINK-2448:
---
GitHub user sachingoel0101 opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699319#comment-14699319
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699321#comment-14699321
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user sachingoel0101 commented on a
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699333#comment-14699333
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699351#comment-14699351
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699324#comment-14699324
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user sachingoel0101 commented on a
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1026#discussion_r37173958
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java
---
@@ -120,7 +125,7 @@ public
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-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-855.
--
Web interface: flow vs stack layout
---
Key: FLINK-855
[
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
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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/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
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
[
https://issues.apache.org/jira/browse/FLINK-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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/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
[
https://issues.apache.org/jira/browse/FLINK-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699440#comment-14699440
]
ASF GitHub Bot commented on FLINK-2534:
---
Github user asfgit closed the pull request
[
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
[
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-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699218#comment-14699218
]
ASF GitHub Bot commented on FLINK-2462:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1017#discussion_r37168797
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java
---
@@ -39,61
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1027#issuecomment-131753704
Looks good, will 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-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699299#comment-14699299
]
Robert Metzger commented on FLINK-2491:
---
The issue still persists
{code}
1750
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-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699342#comment-14699342
]
ASF GitHub Bot commented on FLINK-2488:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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 @@
[
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-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
[
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
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1017#issuecomment-131735854
This looks like a very nice continuation of the cleanup work. I'd suggest
to merge it rather sooner than later.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-2491:
--
Comment: was deleted
(was: Here is the root cause. [1]
[1]
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1026#discussion_r37173574
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java
---
@@ -93,6 +93,15 @@ public int
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
[
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
[
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 reopened FLINK-1321:
-
New web interface, contains parts from WebInfoServer and WebClient
[
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
GitHub user HuangWHWHW opened a pull request:
https://github.com/apache/flink/pull/1030
[FLINK-2536][streaming]add a re-connect for socket sink
add a re-connect in function invoke() when it throws exception.
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699265#comment-14699265
]
ASF GitHub Bot commented on FLINK-2536:
---
GitHub user HuangWHWHW opened a pull
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699275#comment-14699275
]
Chesnay Schepler commented on FLINK-2448:
-
yep that's what i mean. the environment
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699345#comment-14699345
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user zentol commented on the pull
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
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
[
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 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-tabpanelfocusedCommentId=14699503#comment-14699503
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699594#comment-14699594
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699493#comment-14699493
]
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_r37184472
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/executor/FlinkExecutor.scala
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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 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
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699507#comment-14699507
]
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_r37185622
--- Diff:
flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/SchedulerUtils.scala
---
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699605#comment-14699605
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user StephanEwen commented on the
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
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699581#comment-14699581
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user rmetzger commented on a diff in
1 - 100 of 161 matches
Mail list logo
