[
https://issues.apache.org/jira/browse/FLINK-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639545#comment-14639545
]
Fabian Hueske commented on FLINK-2394:
--
Hadoop handles {{OutputCommitters}}
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639621#comment-14639621
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35379501
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java
---
@@ -0,0 +1,189 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35379539
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java
---
@@ -0,0 +1,189 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639596#comment-14639596
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639598#comment-14639598
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35379150
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java
---
@@ -0,0 +1,189 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35381702
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeOuterJoinIteratorITCase.java
---
@@ -0,0 +1,593 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639681#comment-14639681
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/907#issuecomment-124270766
Very nice work! :+1: I had just a few minor style regards.
It would be nice if you could check the overhead of having all outer join
cases handled by the same
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35378409
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java
---
@@ -0,0 +1,189 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639605#comment-14639605
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639617#comment-14639617
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35377999
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java
---
@@ -0,0 +1,189 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639640#comment-14639640
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/907#discussion_r35384117
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeOuterJoinIteratorITCase.java
---
@@ -0,0 +1,587 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639677#comment-14639677
]
ASF GitHub Bot commented on FLINK-2105:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639686#comment-14639686
]
Fabian Hueske commented on FLINK-2106:
--
Hi [~jkovacs] and [~r-pogalz], I had a look
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/933#issuecomment-124086584
Any reservation against this?
(The one failed build profile is due to a Travis hiccup)
---
If your project is set up for it, you can reply to this email and
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/933#issuecomment-124088349
Nope. +1 from my side.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638766#comment-14638766
]
ASF GitHub Bot commented on FLINK-2385:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johannes Günther reopened FLINK-2152:
-
When Using zip with index in a longer running job the following error occurs:
Gyula Fora created FLINK-2403:
-
Summary: Rework partitioned state checkpointing logic
Key: FLINK-2403
URL: https://issues.apache.org/jira/browse/FLINK-2403
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638815#comment-14638815
]
ASF GitHub Bot commented on FLINK-2205:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638891#comment-14638891
]
Gyula Fora commented on FLINK-2398:
---
I suggest we design the API in a way that it will
[
https://issues.apache.org/jira/browse/FLINK-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638913#comment-14638913
]
Stephan Ewen commented on FLINK-2400:
-
Would that error be triggered on timeout?
The
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/927#issuecomment-124109471
I think you can actually add the code to the current UI. It is not going to
disappear in the near future, it will probably stay as a fallback variant for
one more
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638935#comment-14638935
]
Aljoscha Krettek commented on FLINK-2398:
-
Yes, I think this is a prerequisite for
Ufuk Celebi created FLINK-2399:
--
Summary: Fail when actor versions don't match
Key: FLINK-2399
URL: https://issues.apache.org/jira/browse/FLINK-2399
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2397.
-
Resolution: Fixed
Fixed via c52e753a8d3fc15ed48df7bfa24a327a90df9a0f
Unify two backend servers
[
https://issues.apache.org/jira/browse/FLINK-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2397.
---
Unify two backend servers to one server
---
Key:
Ufuk Celebi created FLINK-2400:
--
Summary: TaskTest.testExecutionFailesAfterCanceling fails
Key: FLINK-2400
URL: https://issues.apache.org/jira/browse/FLINK-2400
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-2400.
Resolution: Later
Changed the error message via fa78be6. We have to check whether this occurs
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638272#comment-14638272
]
Chengxiang Li commented on FLINK-1901:
--
Thanks,[~till.rohrmann], i got it now. This
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2332.
Resolution: Fixed
Added via 45428518d0e1b843947a6184b4a803a78ad5
Assign session IDs to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/917
---
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-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639028#comment-14639028
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/933
---
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-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638985#comment-14638985
]
Till Rohrmann commented on FLINK-2392:
--
The same happened to me:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-124143378
Tests pass on Travis. Will merge 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
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2385.
-
Resolution: Fixed
Fixed via 5d475f88784f796e054d7cff2492b9989d3f47d6
Scala DataSet.distinct
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2385.
---
Scala DataSet.distinct should have parenthesis
--
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639018#comment-14639018
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639041#comment-14639041
]
ASF GitHub Bot commented on FLINK-2385:
---
Github user asfgit closed the pull request
Aljoscha Krettek created FLINK-2398:
---
Summary: Decouple StreamGraph Building from the API
Key: FLINK-2398
URL: https://issues.apache.org/jira/browse/FLINK-2398
Project: Flink
Issue Type:
Stephan Ewen created FLINK-2402:
---
Summary: Add a non-blocking BarrierTracker
Key: FLINK-2402
URL: https://issues.apache.org/jira/browse/FLINK-2402
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2389.
---
Add dashboard frontend architecture amd build infrastructue
[
https://issues.apache.org/jira/browse/FLINK-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638757#comment-14638757
]
ASF GitHub Bot commented on FLINK-2385:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639389#comment-14639389
]
ASF GitHub Bot commented on FLINK-2391:
---
Github user mjsax commented on the pull
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/932#issuecomment-124218025
Your second commit reverted your first commit. I don't see any changes.
File changed 0.
---
If your project is set up for it, you can reply to this email and have your
Stephan Ewen created FLINK-2397:
---
Summary: Unify two backend servers to one server
Key: FLINK-2397
URL: https://issues.apache.org/jira/browse/FLINK-2397
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639094#comment-14639094
]
Stephan Ewen commented on FLINK-2398:
-
What would be great down the line is the
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14639107#comment-14639107
]
Aljoscha Krettek commented on FLINK-2398:
-
But what would go into
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638429#comment-14638429
]
Till Rohrmann commented on FLINK-1901:
--
That's a good idea to break down the task. Do
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638448#comment-14638448
]
Till Rohrmann commented on FLINK-1901:
--
Currently, whats happening to decide whether
[
https://issues.apache.org/jira/browse/FLINK-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638589#comment-14638589
]
ASF GitHub Bot commented on FLINK-2332:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/917#issuecomment-124038143
Will rebase and then merge this PR.
---
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-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638603#comment-14638603
]
Ufuk Celebi commented on FLINK-2395:
Interesting link. Thanks for sharing!
Check
[
https://issues.apache.org/jira/browse/FLINK-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1863.
Resolution: Cannot Reproduce
RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2213:
---
Assignee: (was: Ufuk Celebi)
Configure number of vcores
--
[
https://issues.apache.org/jira/browse/FLINK-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638608#comment-14638608
]
Stephan Ewen commented on FLINK-2395:
-
At some points, catch {{Throwable}} is probably
Chengxiang Li created FLINK-2396:
Summary: Review the datasets of dynamic path and static path in
iteration.
Key: FLINK-2396
URL: https://issues.apache.org/jira/browse/FLINK-2396
Project: Flink
Till Rohrmann created FLINK-2395:
Summary: Check Scala catch blocks for Throwable
Key: FLINK-2395
URL: https://issues.apache.org/jira/browse/FLINK-2395
Project: Flink
Issue Type: Improvement
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/927#issuecomment-124019229
@ebautistabar you're the only one who can close the PR. But maybe the new
web interface needs the same fixes as you've proposed for the old UI.
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638458#comment-14638458
]
ASF GitHub Bot commented on FLINK-2205:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638525#comment-14638525
]
Andreas Kunft commented on FLINK-2373:
--
I will
Add configuration parameter to
[
https://issues.apache.org/jira/browse/FLINK-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638613#comment-14638613
]
Ufuk Celebi commented on FLINK-2341:
I think this is an issue with the test.
In
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638617#comment-14638617
]
Chengxiang Li commented on FLINK-1901:
--
Thanks for the analysis,
68 matches
Mail list logo
