[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-31 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-177429493 Yes, i think we should do that, my Skype is chengxiang.li...@gmail.com. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125253#comment-15125253 ] ASF GitHub Bot commented on FLINK-3225: --- Github user ChengXiangLi commented on the p

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-31 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1556#issuecomment-177517981 @ChengXiangLi The code generation will be similar to the old Table API. The main difference is that the code generation already happens at the client side. The generated

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-31 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-177520097 Yes, good idea. My Skype name is `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 proje

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

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

[jira] [Commented] (FLINK-3128) Add Isotonic Regression To ML Library

2016-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125387#comment-15125387 ] ASF GitHub Bot commented on FLINK-3128: --- GitHub user f-sander opened a pull request:

[GitHub] flink pull request: [FLINK-3128] [flink-ml] Add Isotonic Regressio...

2016-01-31 Thread f-sander
GitHub user f-sander opened a pull request: https://github.com/apache/flink/pull/1565 [FLINK-3128] [flink-ml] Add Isotonic Regression To ML Library Adds isotonic regression to the ml library. It's a port of the implementation in Apache Spark. You can merge this pull request into

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-31 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1556#issuecomment-177541447 I got it, as most of the work is done by code generation, current DataSetProjectRule/DataSetFilterRule/DataSetCalRule implementation should be ready. Most part of `

[jira] [Commented] (FLINK-2803) Add test case for Flink's memory allocation

2016-01-31 Thread Lokesh Ravindranathan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125404#comment-15125404 ] Lokesh Ravindranathan commented on FLINK-2803: -- Hi, I would like to work on

[jira] [Commented] (FLINK-2803) Add test case for Flink's memory allocation

2016-01-31 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125474#comment-15125474 ] Stephan Ewen commented on FLINK-2803: - Nice to hear to you want to contribute! Flink

[GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato...

2016-01-31 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1564#issuecomment-177597755 Could you describe what exactly the change looks like, share a few screenshots of the parts that changed? --- If your project is set up for it, you can reply to thi

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

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

[GitHub] flink pull request: [FLINK-3109]Join two streams with two differen...

2016-01-31 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1527#issuecomment-177599020 Concerning the data management: @aljoscha and me are currently heavily reworking that. All window operations need to go onto the "state" interfaces. Before we me

[jira] [Commented] (FLINK-3109) Join two streams with two different buffer time

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

[GitHub] flink pull request: Enhance Partitioned State and use it in Window...

2016-01-31 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1562#issuecomment-177611308 Hey, First of all, great work I am looking forward to having this is :) I think it would be good if we added default implementations of the List, Reducing sta

[GitHub] flink pull request: Enhance Partitioned State and use it in Window...

2016-01-31 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1562#issuecomment-177611887 This would also remove a lot of code duplication for the DbStateBackend and would probably also make the RocksDb backend a little cleaner :) --- If your project is set u

[GitHub] flink pull request: [FLINK-3208] [gelly] rename vertex-centric ite...

2016-01-31 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1514#issuecomment-177612285 +1 to 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

[jira] [Commented] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather

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

[jira] [Commented] (FLINK-3216) Define pattern specification

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

[GitHub] flink pull request: [FLINK-3216] [FLINK-3217] [cep] Initial versio...

2016-01-31 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1557#issuecomment-177622750 Super nice! Has documentation, tests, JavaDocs. Very good all in all! The builds fail on Scala 2.11 build profiles in different maven projects. Errors lo

[GitHub] flink pull request: [FLINK-2678]DataSet API does not support multi...

2016-01-31 Thread sbcd90
GitHub user sbcd90 opened a pull request: https://github.com/apache/flink/pull/1566 [FLINK-2678]DataSet API does not support multi-dimensional arrays as keys Hello, @tillrohrmann I have added support for multi-dimensional arrays as keys in Dataset api. Please review & merge

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15125642#comment-15125642 ] ASF GitHub Bot commented on FLINK-2678: --- GitHub user sbcd90 opened a pull request:

[GitHub] flink pull request: [Flink-3226] Translate logical plan into physi...

2016-01-31 Thread ChengXiangLi
GitHub user ChengXiangLi opened a pull request: https://github.com/apache/flink/pull/1567 [Flink-3226] Translate logical plan into physical plan This PR includes: * `DataSetAggregateRule` and `DataSetJoinRule` implementation. * Several common SQL aggregate function implementa

[GitHub] flink pull request: [Flink-3226] Translate logical plan into physi...

2016-01-31 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1567#issuecomment-177831170 @twalthr and @fhueske , please help to review. For other rules, `DataSetScanRule` and `DataSetUnionRule` should be ready yet, and the missed Flink UDF in `Data