[jira] [Commented] (FLINK-703) Use complete element as join key.

[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14480902#comment-14480902 ] ASF GitHub Bot commented on FLINK-703: -- Github user hsaputra commented on a diff in th

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

Github user hsaputra commented on a diff in the pull request: https://github.com/apache/flink/pull/572#discussion_r27784222 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/functions/BasicKeySelector.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-703) Use complete element as join key.

[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14407480#comment-14407480 ] ASF GitHub Bot commented on FLINK-703: -- GitHub user chiwanpark opened a pull request:

[GitHub] flink pull request: [FLINK-703] Use complete element as join key

GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/572 [FLINK-703] Use complete element as join key Hello. I open a pull request about FLINK-703. You can find more detail description in [JIRA](https://issues.apache.org/jira/browse/FLINK-703). This PR

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396386#comment-14396386 ] ASF GitHub Bot commented on FLINK-951: -- Github user markus-h commented on the pull req

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-89849730 Thanks for your comments! I will try to revert my formattings. I am used to doing STRG+F while programming that probably changed the formatting. I also got ri

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396384#comment-14396384 ] ASF GitHub Bot commented on FLINK-1792: --- Github user bhatsachin commented on the pul

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

Github user bhatsachin commented on the pull request: https://github.com/apache/flink/pull/553#issuecomment-89848884 Hey Robert, The required changes have been made and are working fine for Java 7 onwards. Using this method, it is not possible to fetch CPU load in Java 6 si

[GitHub] flink pull request: [FLINK-951] Reworking of Iteration Synchroniza...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/570#issuecomment-89823498 Nice to see that you picked this up again. :-) I know from experience that it can be tricky to port the old RPC calls to Akka msgs, so kudos. ;-) - I actually agree wi

[jira] [Commented] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396350#comment-14396350 ] ASF GitHub Bot commented on FLINK-951: -- Github user uce commented on the pull request:

[jira] [Closed] (FLINK-1825) Fix the constructor comments with correct parameter in DefaultMemoryManager

[ https://issues.apache.org/jira/browse/FLINK-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1825. - Resolution: Fixed Fix Version/s: (was: master) 0.9 Fixed via 909cee2

[jira] [Closed] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

[ https://issues.apache.org/jira/browse/FLINK-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1808. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 1da4b64 > Omit sending checkpoi

[jira] [Closed] (FLINK-1824) Allow missing types for DataStreams

[ https://issues.apache.org/jira/browse/FLINK-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1824. - Resolution: Implemented Fix Version/s: 0.9 Implemented via 1cf49e9 > Allow missing types f

[jira] [Commented] (FLINK-1824) Allow missing types for DataStreams

[ https://issues.apache.org/jira/browse/FLINK-1824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396155#comment-14396155 ] ASF GitHub Bot commented on FLINK-1824: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1808] Send barrier requests only when t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/551 --- 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 enabl

[jira] [Commented] (FLINK-1825) Fix the constructor comments with correct parameter in DefaultMemoryManager

[ https://issues.apache.org/jira/browse/FLINK-1825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396154#comment-14396154 ] ASF GitHub Bot commented on FLINK-1825: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1824] [streaming] Support added for mis...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/567 --- 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 enabl

[GitHub] flink pull request: [FLINK-1825]Fix the constructor comments with ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/568 --- 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 enabl

[jira] [Commented] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

[ https://issues.apache.org/jira/browse/FLINK-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14396156#comment-14396156 ] ASF GitHub Bot commented on FLINK-1808: --- Github user asfgit closed the pull request