[jira] [Updated] (FLINK-4617) Kafka & Flink duplicate messages on restart

[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Barlocker updated FLINK-4617: - Affects Version/s: 1.0.1 1.0.2 1.0.3 >

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488555#comment-15488555 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], I'm not sure I understand what you mean. Will

[jira] [Created] (FLINK-4617) Kafka & Flink duplicate messages on restart

Matthew Barlocker created FLINK-4617: Summary: Kafka & Flink duplicate messages on restart Key: FLINK-4617 URL: https://issues.apache.org/jira/browse/FLINK-4617 Project: Flink Issue

[jira] [Commented] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488223#comment-15488223 ] ASF GitHub Bot commented on FLINK-4608: --- Github user apivovarov commented on the issue:

[GitHub] flink issue #2489: [FLINK-4608] Use short-circuit AND in Max/Min Aggregation...

Github user apivovarov commented on the issue: https://github.com/apache/flink/pull/2489 @zentol Can you 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 does not have this feature enabled and

[GitHub] flink issue #2488: [FLINK-4607] Close FileInputStream in ParameterTool and o...

Github user apivovarov commented on the issue: https://github.com/apache/flink/pull/2488 @zentol Time to 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 does not have this feature enabled and

[jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator

[ https://issues.apache.org/jira/browse/FLINK-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488221#comment-15488221 ] ASF GitHub Bot commented on FLINK-4609: --- Github user apivovarov commented on a diff in the pull

[jira] [Commented] (FLINK-4607) Close FileInputStream in ParameterTool and other

[ https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15488225#comment-15488225 ] ASF GitHub Bot commented on FLINK-4607: --- Github user apivovarov commented on the issue:

[GitHub] flink pull request #2490: [FLINK-4609] Remove redundant check for null in Cr...

Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2490#discussion_r78631478 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java --- @@ -129,14 +129,11 @@ private String getDefaultName() {

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

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-3322: - Assignee: ramkrishna.s.vasudevan > MemoryManager creates too much GC

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15487509#comment-15487509 ] Dan Bress commented on FLINK-3869: -- I know this is slated for 2.0, but just wanted to drop a comment

[jira] [Created] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

Yuri Makhno created FLINK-4616: -- Summary: Kafka consumer doesn't store last emmited watermarks per partition in state Key: FLINK-4616 URL: https://issues.apache.org/jira/browse/FLINK-4616 Project: Flink

[jira] [Created] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

ramkrishna.s.vasudevan created FLINK-4615: - Summary: Reusing the memory allocated for the drivers and iterators Key: FLINK-4615 URL: https://issues.apache.org/jira/browse/FLINK-4615 Project:

[jira] [Commented] (FLINK-4615) Reusing the memory allocated for the drivers and iterators

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

[GitHub] flink pull request #2496: FLINK-4615 Reusing the memory allocated for the dr...

GitHub user ramkrish86 opened a pull request: https://github.com/apache/flink/pull/2496 FLINK-4615 Reusing the memory allocated for the drivers and iterators Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

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

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan updated FLINK-3322: -- Attachment: FLINK-3322_reusingmemoryfordrivers.docx Attaching a doc with two

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

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15487192#comment-15487192 ] ramkrishna.s.vasudevan commented on FLINK-3322: --- [~ggevay] I think I was able to make the

[GitHub] flink pull request #2495: FLINK-3322 - Make sorters to reuse the memory page...

GitHub user ramkrish86 opened a pull request: https://github.com/apache/flink/pull/2495 FLINK-3322 - Make sorters to reuse the memory pages allocated for iterative tasks Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

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

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