[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-03-06 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182594#comment-15182594 ] ramkrishna.s.vasudevan commented on FLINK-3179: --- [~fhueske], [~fhue...@gmail.com] I have

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

2016-03-06 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

2016-03-06 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182331#comment-15182331 ] Subhobrata Dey commented on FLINK-3387: --- Hello [~StephanEwen], Thanks for replying. I need some

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-03-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182268#comment-15182268 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ggevay commented on the pull request:

[GitHub] flink pull request: [FLINK-3322] MemoryManager creates too much GC...

2016-03-06 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1769#issuecomment-192962635 > I would be curious about the soft reference implementation as in DetaIteration cases I think it is a valid situation that the job needs less and less memory.

[jira] [Commented] (FLINK-3573) Implement more String functions for Table API

2016-03-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182261#comment-15182261 ] ASF GitHub Bot commented on FLINK-3573: --- Github user mbalassi commented on the pull request:

[GitHub] flink pull request: [FLINK-3573] [table] Implement more String fun...

2016-03-06 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1766#issuecomment-192954747 Do not forget to add the licence header to `NotCallGenerator` when merging. :) --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-03-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182260#comment-15182260 ] ASF GitHub Bot commented on FLINK-3322: --- Github user mbalassi commented on the pull request:

[GitHub] flink pull request: [FLINK-3322] MemoryManager creates too much GC...

2016-03-06 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/1769#issuecomment-192954621 I would be curious about the soft reference implementation as in DetaIteration cases I think it is a valid situation that the job needs less and less memory. Please

[jira] [Updated] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution

2016-03-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-3533: - Fix Version/s: 1.0.1 1.1.0 > Update the Gelly docs wrt examples and cluster

[jira] [Assigned] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution

2016-03-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri reassigned FLINK-3533: Assignee: Vasia Kalavri > Update the Gelly docs wrt examples and cluster execution >

[jira] [Resolved] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution

2016-03-06 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3533. -- Resolution: Fixed - master: cf9a0ae46537273801cd974ce997a52960b95dbe - release-1.0:

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-03-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182076#comment-15182076 ] ASF GitHub Bot commented on FLINK-3322: --- GitHub user Xazax-hun opened a pull request:

[GitHub] flink pull request: [FLINK-3322] MemoryManager creates too much GC...

2016-03-06 Thread Xazax-hun
GitHub user Xazax-hun opened a pull request: https://github.com/apache/flink/pull/1769 [FLINK-3322] MemoryManager creates too much GC pressure with iterative jobs. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Xazax-hun/flink

[jira] [Commented] (FLINK-3474) Partial aggregate interface design and sort-based implementation

2016-03-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182043#comment-15182043 ] ASF GitHub Bot commented on FLINK-3474: --- Github user ChengXiangLi commented on the pull request:

[GitHub] flink pull request: [FLINK-3474] support partial aggregate

2016-03-06 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1746#issuecomment-192826952 Add null value handling in aggregate functions, some code refactor. Besides, i found the previous Double/Float average function does not work in partial