[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park reassigned FLINK-703:
-
Assignee: Chiwan Park
> Use complete element as join key.
> -
>
>
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-73434977
Great, thanks ^^
---
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
e
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311584#comment-14311584
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user vasia commented on the pull req
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-73434866
@vasia yes, just submitted mine
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311583#comment-14311583
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user balidani commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311581#comment-14311581
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-73434636
@rmetzger does this mean I need to do the history filtering magic again and
open a new pr?
@andralungu thanks a lot!
@balidani have you submitted yours?
---
If your
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/375
Add support for strictly local input splits
This adds the possibility to make input split assignment strictly local,
with pre-assignment from splits to tasks on the JobManager.
You can merge thi
[
https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311465#comment-14311465
]
Matthias J. Sax commented on FLINK-1493:
Hi,
I had a look into this. From my point
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311383#comment-14311383
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-73417227
Sounds good to me!
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311342#comment-14311342
]
Timo Walther commented on FLINK-1388:
-
Hey Adnan,
for testing purposes you can create
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311329#comment-14311329
]
Adnan Khan commented on FLINK-1388:
---
Hey Fabian,
I've been digging through those two c
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311318#comment-14311318
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-73410628
Good idea. So we would print `$taskId > $outputValue` if the user did not
supply a string and `$string:$taskId > $outputValue` otherwise. If the
parallelization degree is 1, w
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/374#issuecomment-73410413
@tillrohrmann Thanks for your advice. I will fix 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
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311316#comment-14311316
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311304#comment-14311304
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/374#issuecomment-73409662
Hi Chiwan, thanks for your work. It looks really good. I had some just some
minor remarks.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311302#comment-14311302
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/374#discussion_r24298309
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -300,6 +300,16 @@ import scala.collection.JavaConver
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/374#discussion_r24298303
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -349,6 +349,11 @@ Actor with ActorLogMessages with Act
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311301#comment-14311301
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311258#comment-14311258
]
ASF GitHub Bot commented on FLINK-785:
--
Github user zentol commented on the pull reque
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/370#issuecomment-73404704
there's something funky going on with the tests here.
i got 2 failing tests in ObjectReuseITCase:
```
ObjectReuseITCase>JavaProgramTestBase.testJobWithoutOb
25 matches
Mail list logo
