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

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1746#issuecomment-193636206 merging this PR --- 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 f

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

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

[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&focusedCommentId=15184556#comment-15184556 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ggevay commented on the pull re

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

Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1769#issuecomment-193635557 The Memory tab in Java Mission Control can probably help with investigating this. --- If your project is set up for it, you can reply to this email and have your reply a

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

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

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

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1746#issuecomment-193631851 FLINK-3586 is created to track Long AVG issue. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[jira] [Created] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

Chengxiang Li created FLINK-3586: Summary: Risk of data overflow while use sum/count to calculate AVG value Key: FLINK-3586 URL: https://issues.apache.org/jira/browse/FLINK-3586 Project: Flink

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-193595361 @fhueske I was looking into the comments and the refactoring I can avoid by creating a new patch altogether. But saying the last comment I think I can hold this o

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

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

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-193580086 Hi @danielblazevski, thanks for update and sorry for late reply. I tried to test your implementation and have found few things to do before merging this. Firs

[jira] [Commented] (FLINK-3584) WebInterface: Broken graphical display in Chrome

[ https://issues.apache.org/jira/browse/FLINK-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15183787#comment-15183787 ] Stephan Ewen commented on FLINK-3584: - Can you check the 1.0.0 version? We fixed a sim

[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&focusedCommentId=15183674#comment-15183674 ] ASF GitHub Bot commented on FLINK-3322: --- Github user Xazax-hun commented on the pull

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

Github user Xazax-hun commented on the pull request: https://github.com/apache/flink/pull/1769#issuecomment-193443590 > 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

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

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1766#issuecomment-193375514 @mbalassi Thanks, I added the header. Good to merge if build succeeds. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

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

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

[jira] [Closed] (FLINK-3383) Separate Maven deployment from CI testing

[ https://issues.apache.org/jira/browse/FLINK-3383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3383. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in c413b23b8c8dd3323d4a3d82feed0abab2b

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1619#issuecomment-193355435 Snapshots are now deployed nightly using the ASF Jenkins installation: https://builds.apache.org/job/flink-snapshot-deployment/ --- If your project is set up for it, you c

[jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing

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

[GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1619 --- 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-3383) Separate Maven deployment from CI testing

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

[jira] [Closed] (FLINK-3585) Deploy scripts don't support spaces in paths

[ https://issues.apache.org/jira/browse/FLINK-3585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3585. - Resolution: Fixed Fixed in master with d3808c7bc060e8837b5a35d6f1f305bd4c446384. > Deploy

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

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

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

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

[GitHub] flink pull request: [FLINK-3332] Add Exactly-Once Cassandra connec...

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

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/1771 [FLINK-3311/FLINK-3332] Add Cassandra connector This PR is a combination of #1640 and #1660, essentially providing a mid-merge view of both PR's. As they reside in the same module and expose similar

[jira] [Created] (FLINK-3585) Deploy scripts don't support spaces in paths

Maximilian Michels created FLINK-3585: - Summary: Deploy scripts don't support spaces in paths Key: FLINK-3585 URL: https://issues.apache.org/jira/browse/FLINK-3585 Project: Flink Issue Ty

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

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

[GitHub] flink pull request: FLINK-3327: ExecutionConfig to JobGraph.

Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1583#issuecomment-193338674 Thanks a lot @zentol --- 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 fea

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1662#issuecomment-193338524 @tillrohrmann @aljoscha @StephanEwen I just rebased on the current master. It passes on my travis. This PR is rebased on top of https://github.com/apache/flink/p

[jira] [Commented] (FLINK-3564) Implement distinct() for Table API

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

[GitHub] flink pull request: FLINK-3327: ExecutionConfig to JobGraph.

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1583#issuecomment-193337830 looks like something went wrong while rebasing, a commit by aljoscha suddenly popped up. but hey, that can be fixed while merging, +1 from me. --- If you

[jira] [Commented] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

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

[jira] [Commented] (FLINK-3567) Rework selection when grouping in Table API

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

[jira] [Commented] (FLINK-3567) Rework selection when grouping in Table API

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

[GitHub] flink pull request: [FLINK-3567] Fix selection on grouping. Only g...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1761#issuecomment-19836 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 enable

[GitHub] flink pull request: [FLINK-3567] Fix selection on grouping. Only g...

Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/1761 --- 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 ena

[jira] [Resolved] (FLINK-3567) Rework selection when grouping in Table API

[ https://issues.apache.org/jira/browse/FLINK-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3567. -- Resolution: Fixed Fix Version/s: 1.1.0 > Rework selection when grouping in Table API > --

[jira] [Resolved] (FLINK-3564) Implement distinct() for Table API

[ https://issues.apache.org/jira/browse/FLINK-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3564. -- Resolution: Implemented Fix Version/s: 1.1.0 > Implement distinct() for Table API > -

[jira] [Commented] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

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

[GitHub] flink pull request: FLINK-3327: ExecutionConfig to JobGraph.

Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/1583#issuecomment-193330011 @StephanEwen , @zentol I just rebased to the latest master. It passes all tests on my Travis (https://travis-ci.org/kl0u/flink/builds/114228524). Please revi

[GitHub] flink pull request: [FLINK-3564] [table] Implement distinct() for ...

Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/1754 --- 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 ena

[jira] [Commented] (FLINK-3564) Implement distinct() for Table API

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

[GitHub] flink pull request: [FLINK-3567] Fix selection on grouping. Only g...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1761#issuecomment-193324103 You can close this @fhueske! --- 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

[jira] [Commented] (FLINK-3567) Rework selection when grouping in Table API

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

[GitHub] flink pull request: [FLINK-3564] [table] Implement distinct() for ...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1754#issuecomment-193324252 You can close this @twalthr! --- 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

[jira] [Commented] (FLINK-2946) Add orderBy() to Table API

[ https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15183076#comment-15183076 ] Fabian Hueske commented on FLINK-2946: -- I think users should configure where to sent

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

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-193272515 Hi Ram, I just realized that the approach taken here might not work. We are modifying the plan while it is enumerated. There might be cases, where this leads to com

[jira] [Commented] (FLINK-3547) Add support for streaming projection, selection, and union

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

[GitHub] flink pull request: [FLINK-3547] add support for streaming filter,...

GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1770 [FLINK-3547] add support for streaming filter, project, and union int he Table API This PR adds: - Java and Scala stream translators - methods to convert a table to a DataStream and vice

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55208348 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

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

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55208210 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

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

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

[jira] [Commented] (FLINK-3567) Rework selection when grouping in Table API

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

[GitHub] flink pull request: [FLINK-3567] Fix selection on grouping. Only g...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1761#issuecomment-193258467 Merging this one, too. --- 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 f

[jira] [Commented] (FLINK-3564) Implement distinct() for Table API

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

[GitHub] flink pull request: [FLINK-3564] [table] Implement distinct() for ...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1754#issuecomment-193258420 Merging this. --- 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 en

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55205009 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

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

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55205422 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55205324 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

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

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

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

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55205361 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55205091 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

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

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

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

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

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

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

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1553#discussion_r55204942 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java --- @@ -126,12 +117,66 @@ public SingleInp

[jira] [Commented] (FLINK-3584) WebInterface: Broken graphical display in Chrome

[ https://issues.apache.org/jira/browse/FLINK-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15182958#comment-15182958 ] Greg Hogan commented on FLINK-3584: --- This sounds similar to FLINK-3483. I am not aware

[jira] [Created] (FLINK-3584) WebInterface: Broken graphical display in Chrome

Niels Basjes created FLINK-3584: --- Summary: WebInterface: Broken graphical display in Chrome Key: FLINK-3584 URL: https://issues.apache.org/jira/browse/FLINK-3584 Project: Flink Issue Type: Bug

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

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1746#issuecomment-193194745 Thanks Chengxiang for the update. I think we can merge the PR now. But we should open a JIRA and improve the LongAvg aggregation. The communication between Mappe

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

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