[
https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314326#comment-14314326
]
Fabian Hueske commented on FLINK-1343:
--
After looking into the execution plan of
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314232#comment-14314232
]
ASF GitHub Bot commented on FLINK-1489:
---
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/378#discussion_r24415175
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -416,13 +426,26 @@ boolean
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/376
---
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 mxm commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73726322
With the current version of the pull request, I get the following when
executing
/pyflink2.sh ../resources/python/flink/example/WordCount.py
Job
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73731632
if you don't mind, try the example again and let it run. both processes
should timeout after 5 minutes throwing exceptions, hopefully pointing to the
origin of the lock.
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314428#comment-14314428
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73736669
Now I'm getting:
02/10/2015 17:47:06 Job execution switched to status RUNNING.
02/10/2015 17:47:06 DataSource (ValueSource)(1/1) switched to
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-73749137
Thanks @balidani.
And travis tests now pass :tada:
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/380
[FLINK-1496] [distributed runtime] Fix loss of events at unitialized input
channels
Related
[
https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14313849#comment-14313849
]
ASF GitHub Bot commented on FLINK-1496:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14313869#comment-14313869
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/376#issuecomment-73667317
Looks good.
---
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
Ufuk Celebi created FLINK-1506:
--
Summary: Add buffer/event wrapper for runtime results
Key: FLINK-1506
URL: https://issues.apache.org/jira/browse/FLINK-1506
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-1507:
--
Summary: Allow to configure produced intermediate result type via
ExecutionConfig
Key: FLINK-1507
URL: https://issues.apache.org/jira/browse/FLINK-1507
Project: Flink
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/236#discussion_r24402955
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -169,4 +186,113 @@ public ExecutionConfig disableObjectReuse() {
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/236#discussion_r24402907
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
---
@@ -82,29 +75,15 @@
//
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/236#discussion_r24403182
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -169,4 +186,113 @@ public ExecutionConfig disableObjectReuse() {
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314010#comment-14314010
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14313973#comment-14313973
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/376#discussion_r24402830
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---
@@ -196,23 +199,28 @@ public void run() {
*/
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/376#issuecomment-73678581
LGTM except for my single question.
---
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
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/236#discussion_r24403132
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -169,4 +186,113 @@ public ExecutionConfig disableObjectReuse() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/376#discussion_r24403795
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---
@@ -196,23 +199,28 @@ public void run() {
*/
@Override
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314072#comment-14314072
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user zentol commented on the pull
Till Rohrmann created FLINK-1508:
Summary: Remove AkkaUtils.ask to encourage explicit future handling
Key: FLINK-1508
URL: https://issues.apache.org/jira/browse/FLINK-1508
Project: Flink
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/376#issuecomment-73699625
OK, thanks. Just a reminder: we need to include this in 0.8.1 as well.
---
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-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314343#comment-14314343
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314348#comment-14314348
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314238#comment-14314238
]
Robert Metzger commented on FLINK-1492:
---
Resolved for master in
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73708514
Looks good to me. +1
We chatted about batching update task calls. Did you realize a problem with
it or can we open an improvement issue for it?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314262#comment-14314262
]
Robert Metzger commented on FLINK-1502:
---
No. This task depends on FLINK-1501.
But I
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314116#comment-14314116
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314080#comment-14314080
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/376#discussion_r24407836
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java ---
@@ -196,23 +199,28 @@ public void run() {
*/
[
https://issues.apache.org/jira/browse/FLINK-1508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314086#comment-14314086
]
Ufuk Celebi commented on FLINK-1508:
I agree.
I was actually misusing it earlier.
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73693561
Very nice. I will have a detailed look later.
@zentol Can you also test it with the Python API? I think you initially
noticed the problem.
---
If your project is
37 matches
Mail list logo
