[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15065213#comment-15065213 ] ASF GitHub Bot commented on FLINK-1994: --- Github user rawkintrevo commented on the pu

[GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati...

2015-12-18 Thread rawkintrevo
Github user rawkintrevo commented on the pull request: https://github.com/apache/flink/pull/1397#issuecomment-165941576 I think I really screwed this up... I was just trying to undo the changes to flink-staging/flink-ml/pom.xml --- If your project is set up for it, you can reply to t

[jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064765#comment-15064765 ] ASF GitHub Bot commented on FLINK-3118: --- GitHub user s1ck opened a pull request:

[GitHub] flink pull request: [FLINK-3118] [Gelly] Consider ResultTypeQuerya...

2015-12-18 Thread s1ck
GitHub user s1ck opened a pull request: https://github.com/apache/flink/pull/1471 [FLINK-3118] [Gelly] Consider ResultTypeQueryable in Message and GatherFunction You can merge this pull request into a Git repository by running: $ git pull https://github.com/s1ck/flink FLINK-3

[GitHub] flink pull request: Introduce RestartStrategy to decouple restarti...

2015-12-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1470 Introduce RestartStrategy to decouple restarting behaviour from ExecutionGraph Disclaimer: This PR is based on PR #1468. ## Description This PR decouples the restart behaviour

[jira] [Updated] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-18 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-3188: Attachment: kafka-deletions.patch Patch to LegacyFetcher to pass deletions on to Deserializa

[jira] [Created] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-18 Thread Sebastian Klemke (JIRA)
Sebastian Klemke created FLINK-3188: --- Summary: Deletes in Kafka source should be passed on to KeyedDeserializationSchema Key: FLINK-3188 URL: https://issues.apache.org/jira/browse/FLINK-3188 Project

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1428#issuecomment-165848516 Do we want to make the IOFormats Public as well? Most of them are hidden by helper methods of the `ExecutionEnvironment`. However, they can also be used as regular in

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064289#comment-15064289 ] ASF GitHub Bot commented on FLINK-3093: --- Github user fhueske commented on the pull r

[jira] [Created] (FLINK-3187) Decouple restart strategy from ExecutionGraph

2015-12-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3187: Summary: Decouple restart strategy from ExecutionGraph Key: FLINK-3187 URL: https://issues.apache.org/jira/browse/FLINK-3187 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064280#comment-15064280 ] ASF GitHub Bot commented on FLINK-3093: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1428#issuecomment-165847905 Created a PR for `flink-java`. **Summary** Changed to Experimental: - DataSink.sortLocalOutput (should be deprecated, IMO. See FLINK-3186) - Dat

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064148#comment-15064148 ] ASF GitHub Bot commented on FLINK-3140: --- Github user twalthr commented on the pull r

[GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser...

2015-12-18 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1465#issuecomment-165819420 I now use lazy vals for that. --- 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 ha

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15064128#comment-15064128 ] ASF GitHub Bot commented on FLINK-3140: --- Github user twalthr commented on the pull r

[GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser...

2015-12-18 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1465#issuecomment-165813593 I implemented your feedback. But I don't know if we should use `Option` for the `deserializedKeyFields`, because we then need to add checks for each serialized compariso

[jira] [Created] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods

2015-12-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3186: Summary: Deprecate DataSink.sortLocalOutput() methods Key: FLINK-3186 URL: https://issues.apache.org/jira/browse/FLINK-3186 Project: Flink Issue Type: Task

[GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser...

2015-12-18 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1465#discussion_r48026706 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RowComparator.scala --- @@ -0,0 +1,468 @@ +/* + * License

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063976#comment-15063976 ] ASF GitHub Bot commented on FLINK-3140: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063961#comment-15063961 ] ASF GitHub Bot commented on FLINK-3140: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser...

2015-12-18 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1465#discussion_r48025862 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RowComparator.scala --- @@ -0,0 +1,468 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063948#comment-15063948 ] ASF GitHub Bot commented on FLINK-3184: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165780008 Ahhh sorry for my stupid comment. The actual config values didn't change. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165779642 I've created https://docs.google.com/document/d/1987ydc2rez79Pph7qBbcXwu6XzMU2Hm-nX8kORLoZBM/edit?usp=sharing and added the config renaming as an API breaking change. I will

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063947#comment-15063947 ] ASF GitHub Bot commented on FLINK-3184: --- Github user uce commented on the pull reque

[jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

2015-12-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063920#comment-15063920 ] Stephan Ewen commented on FLINK-2315: - I think this is pretty easy to fix. The {{Writ

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2015-12-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063899#comment-15063899 ] Stephan Ewen commented on FLINK-3160: - I can of like that it shows all tasks when you

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063857#comment-15063857 ] ASF GitHub Bot commented on FLINK-2978: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063855#comment-15063855 ] ASF GitHub Bot commented on FLINK-3184: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165754886 The idea is to decouple the restart logic from the `JobManager` and to make it configurable on a per job basis. Different strategies are conceivable. For instance,

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

2015-12-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-165754941 Olrite. :) --- 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 feat

[jira] [Commented] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063854#comment-15063854 ] ASF GitHub Bot commented on FLINK-3166: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-3166] [runtime] The first program in Ob...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1464#discussion_r48017305 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ObjectReuseITCase.java --- @@ -124,26 +125,30 @@ public static String runProgr

[jira] [Commented] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063853#comment-15063853 ] ASF GitHub Bot commented on FLINK-3166: --- Github user StephanEwen commented on the pu

[jira] [Updated] (FLINK-3110) Add support for partition-centric iterations

2015-12-18 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-3110: - Labels: requires-design-doc (was: ) > Add support for partition-centric iterations >

[GitHub] flink pull request: [FLINK-3166] [runtime] The first program in Ob...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1464#issuecomment-165753852 Good catch. I think all of these changes look actually good. Minor comment in-line, otherwise +1 --- If your project is set up for it, you can reply to this

[jira] [Created] (FLINK-3185) Silent failure during job graph recovery

2015-12-18 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3185: -- Summary: Silent failure during job graph recovery Key: FLINK-3185 URL: https://issues.apache.org/jira/browse/FLINK-3185 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063847#comment-15063847 ] ASF GitHub Bot commented on FLINK-2978: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-165752988 I'll merge this PR in the next days. If I find a minor issue on the way, would fix it on the fly. Thanks for the good work, @sachingoel0101 --- If your pr

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063843#comment-15063843 ] ASF GitHub Bot commented on FLINK-3184: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063844#comment-15063844 ] ASF GitHub Bot commented on FLINK-3184: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165752782 What is the `RestartStrategy` about? --- 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] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165752725 With upcoming Mesos integration (and some YARN refactoring), we can probably drop the heartbeats between master and worker as well from Akka. --- If your project is

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063839#comment-15063839 ] ASF GitHub Bot commented on FLINK-3184: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165752514 This is true. Might be a bit anticipated but I plan to remove them completely with my next PR. I want to introduce a `RestartStrategy` which can be set on a job bas

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063840#comment-15063840 ] ASF GitHub Bot commented on FLINK-3184: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165752418 I like having lower ask timeouts. +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

[jira] [Updated] (FLINK-3182) TaskManagersHandler can block web frontend

2015-12-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3182: --- Priority: Minor (was: Major) > TaskManagersHandler can block web frontend > -

[jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063832#comment-15063832 ] ASF GitHub Bot commented on FLINK-3184: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts

2015-12-18 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1468#issuecomment-165750742 Good changes. I like the configuration key changes, but we have to keep in mind that they are API breaking. With 1.0 approaching, I think it's good to do the changes

[jira] [Commented] (FLINK-3182) TaskManagersHandler can block web frontend

2015-12-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063827#comment-15063827 ] Stephan Ewen commented on FLINK-3182: - I think this is a minor issue right now. Fixing

[GitHub] flink pull request: Set current class loader to user-class loader ...

2015-12-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1457 --- 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 enab

[jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063810#comment-15063810 ] ASF GitHub Bot commented on FLINK-2978: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra...

2015-12-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1338#issuecomment-165744791 @StephanEwen can you have a look at this again? Apologies for being hasty, but I've already addressed all concerns; this should be mergeable now. --- If your pro

[GitHub] flink pull request: Set current class loader to user-class loader ...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1457#discussion_r48012762 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java --- @@ -574,8 +574,11 @@ private static String getEntryPointC

[jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063797#comment-15063797 ] ASF GitHub Bot commented on FLINK-2716: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2716] [gelly java scala] New checksum m...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1462#discussion_r48012505 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -394,6 +396,21 @@ public long count() throws Exception {

[GitHub] flink pull request: [FLINK-3180] [runtime] Log direct memory usage...

2015-12-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1466#issuecomment-165741781 Nice addition. +1 --- 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

[jira] [Commented] (FLINK-3180) MemoryLogger does not log direct memory

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063795#comment-15063795 ] ASF GitHub Bot commented on FLINK-3180: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063792#comment-15063792 ] ASF GitHub Bot commented on FLINK-2871: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2871] support outer join for hash join ...

2015-12-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1469#issuecomment-165740727 Thanks for the PR! I will shepherd 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 do

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063769#comment-15063769 ] ASF GitHub Bot commented on FLINK-7: Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner.

2015-12-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1255#issuecomment-165732606 Range partitioning serves two purposes: 1. producing fully sorted results. 2. evenly balancing the load in case of skewed key distributions. Producin

[jira] [Commented] (FLINK-3180) MemoryLogger does not log direct memory

2015-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063754#comment-15063754 ] ASF GitHub Bot commented on FLINK-3180: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-3180] [runtime] Log direct memory usage...

2015-12-18 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1466#issuecomment-165726928 @uce Sure. We can do that. --- 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

[jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey

2015-12-18 Thread Martin Junghanns (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063684#comment-15063684 ] Martin Junghanns commented on FLINK-2315: - Hi, is this hard to fix? I wanted to ap