[GitHub] flink pull request: [FLINK-3583] User configuration visible in web...

2016-03-04 Thread fijolekProjects
GitHub user fijolekProjects opened a pull request: https://github.com/apache/flink/pull/1768 [FLINK-3583] User configuration visible in webdashboard when job is running Before:

[jira] [Commented] (FLINK-3583) Configuration not visible in gui when job is running

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

[jira] [Closed] (FLINK-3552) Change socket WordCount to be properly windowed

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3552. --- > Change socket WordCount to be properly windowed > --- > >

[jira] [Resolved] (FLINK-3550) Rework stream join example

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3550. - Resolution: Fixed Fix Version/s: (was: 1.0.1) 1.1.0 Fixed via

[jira] [Resolved] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3578. - Resolution: Fixed Fixed in - 1.0.1 via 91587892b527e7d56661b14bfe4f425a7ba403a4 - 1.1.0 via

[jira] [Closed] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3578. --- > Scala DataStream API does not support Rich Window Functions >

[jira] [Resolved] (FLINK-3575) Update Working With State Section in Doc

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3575. - Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Fixed in - 1.0.1 via

[jira] [Closed] (FLINK-3575) Update Working With State Section in Doc

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3575. --- > Update Working With State Section in Doc > > >

[jira] [Closed] (FLINK-3495) RocksDB Tests can't run on Windows

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3495. --- > RocksDB Tests can't run on Windows > -- > > Key:

[GitHub] flink pull request: [docs] fix the active tab caption is not displ...

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1763 --- 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

[GitHub] flink pull request: [FLINK-3491] Prevent failure of HDFSCopyUtilit...

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1703 --- 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

[GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W...

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1765 --- 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

[GitHub] flink pull request: [FLINK-3575] Update Working With State Section...

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1760 --- 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

[GitHub] flink pull request: [FLINK-3495] Disable RocksDB tests on Windows

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1711 --- 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

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

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

[GitHub] flink pull request: [FLINK-3566] [FLINK-3563] Input type validatio...

2016-03-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1759 --- 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

[jira] [Resolved] (FLINK-3495) RocksDB Tests can't run on Windows

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3495. - Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Fixed in - 1.0.1 via

[jira] [Closed] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3491. --- > HDFSCopyUtilitiesTest fails on Windows > -- > >

[jira] [Resolved] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3491. - Resolution: Fixed Fix Version/s: (was: 1.0.0) 1.0.1

[jira] [Resolved] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3566. - Resolution: Fixed Fix Version/s: 1.0.1 1.1.0 Fixed in - 1.0.1 via

[jira] [Commented] (FLINK-3495) RocksDB Tests can't run on Windows

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

[jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

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

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Fix Version/s: (was: 1.0.1) > Configuration not visible in gui when job is running >

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

2016-03-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1766#issuecomment-192480019 Good to merge --- 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-3573) Implement more String functions for Table API

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

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Description: Hello. I can see that configuration is not visible in frontend when job is

[jira] [Updated] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michał Fijołek updated FLINK-3583: -- Attachment: no-configuration-when-job-running.png

[jira] [Created] (FLINK-3583) Configuration not visible in gui when job is running

2016-03-04 Thread JIRA
Michał Fijołek created FLINK-3583: - Summary: Configuration not visible in gui when job is running Key: FLINK-3583 URL: https://issues.apache.org/jira/browse/FLINK-3583 Project: Flink Issue

[jira] [Commented] (FLINK-3560) Examples shouldn't always print usage statement

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

[GitHub] flink pull request: [FLINK-3560] [examples] Remove unchecked outpu...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1752#issuecomment-192406987 I remember a discussion from a while back that we actually wanted to drop `ProgramDescription`. It comes from the days when programs had to implement

[jira] [Commented] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows

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

[GitHub] flink pull request: [FLINK-3491] Prevent failure of HDFSCopyUtilit...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1703#issuecomment-192363616 Will merge 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

[GitHub] flink pull request: [FLINK-3550] [FLINK-3552] Rework WindowJoin an...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1745#issuecomment-192363417 Will adjust the example to use the parameter tool and merge this... --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3495) RocksDB Tests can't run on Windows

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

[jira] [Commented] (FLINK-3550) Rework stream join example

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

[GitHub] flink pull request: [FLINK-3495] Disable RocksDB tests on Windows

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1711#issuecomment-192363521 Will merge 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

[GitHub] flink pull request: [docs] fix javascript exception caused by disq...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1756#issuecomment-192362732 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

[jira] [Commented] (FLINK-3566) Input type validation often fails on custom TypeInfo implementations

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

[jira] [Commented] (FLINK-3575) Update Working With State Section in Doc

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

[jira] [Commented] (FLINK-3575) Update Working With State Section in Doc

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

[GitHub] flink pull request: [FLINK-3566] [FLINK-3563] Input type validatio...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1759#issuecomment-192362699 Will merge 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

[GitHub] flink pull request: [FLINK-3575] Update Working With State Section...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1760#issuecomment-192362650 Will merge this also into the 1.0 minor releases branch... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-3575] Update Working With State Section...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1760#issuecomment-192362560 Good update, +1 Will merge 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

[GitHub] flink pull request: [FLINK-3577] [docs] Display anchor links when ...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1762#issuecomment-192362409 Looks good to me, +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 have

[jira] [Commented] (FLINK-3577) Display anchor links when hovering over headers.

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

[GitHub] flink pull request: [docs] fix the active tab caption is not displ...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1763#issuecomment-192362294 Looks good, thanks for the contribution! Will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

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

[GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1765#issuecomment-192361719 Tests have been added for RichWindowFunctions, plus for combinations with Reduce and Fold for pre-aggregation. Merging this... --- If your project is set

[jira] [Commented] (FLINK-3569) Test cases fail due to Maven Shade plugin

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

[GitHub] flink pull request: [FLINK-3569] fix test cases that expect a diff...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1767#issuecomment-192361294 Looks good, 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

[GitHub] flink pull request: [FLINK-3569] fix test cases that expect a diff...

2016-03-04 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1767#issuecomment-192338586 I think it is fixed now. The YARN test run in test scope and are not shaded... --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3569) Test cases fail due to Maven Shade plugin

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

[jira] [Created] (FLINK-3582) Add Iterator over State for All Keys in Partitioned State

2016-03-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3582: --- Summary: Add Iterator over State for All Keys in Partitioned State Key: FLINK-3582 URL: https://issues.apache.org/jira/browse/FLINK-3582 Project: Flink

[jira] [Created] (FLINK-3581) Add Non-Keyed Window Trigger

2016-03-04 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-3581: --- Summary: Add Non-Keyed Window Trigger Key: FLINK-3581 URL: https://issues.apache.org/jira/browse/FLINK-3581 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3569) Test cases fail due to Maven Shade plugin

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

[GitHub] flink pull request: [FLINK-3569] fix test cases that expect a diff...

2016-03-04 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1767 [FLINK-3569] fix test cases that expect a different working directory All the IT cases executed after shading now have the target directory as working directory. You can merge this pull request into a

[GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W...

2016-03-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1765#issuecomment-192270494 Yes, have started in tests already... --- 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

[jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

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

[jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

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

[GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W...

2016-03-04 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1765#issuecomment-192269684 One thing is that we should maybe have tests/ITCases that verify that rich functions actually work. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

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

[jira] [Created] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

2016-03-04 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3580: --- Summary: Reintroduce Date/Time and implement scalar functions for it Key: FLINK-3580 URL: https://issues.apache.org/jira/browse/FLINK-3580 Project: Flink

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

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

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

2016-03-04 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1761#issuecomment-192259728 Looks good to merge (besides a small comment). --- 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

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

2016-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179818#comment-15179818 ] ASF GitHub Bot commented on FLINK-3567: --- Github user twalthr commented on a diff in the pull

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

2016-03-04 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1761#discussion_r55023665 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala --- @@ -385,16 +387,23 @@ class GroupedTable(

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

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

[GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no...

2016-03-04 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1704#issuecomment-192259307 @tillrohrmann Yes, I've already fixed them locally, thanks for the notice and for pinging me. I'm working on the documentation, sorry if it's taking me a little

[jira] [Created] (FLINK-3579) Improve String concatenation

2016-03-04 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3579: --- Summary: Improve String concatenation Key: FLINK-3579 URL: https://issues.apache.org/jira/browse/FLINK-3579 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3574) Implement math functions for Table API

2016-03-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179788#comment-15179788 ] Timo Walther commented on FLINK-3574: - You can have a look at my PR, which is pretty similar to this:

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

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

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

2016-03-04 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1766 [FLINK-3573] [table] Implement more String functions for Table API This PR implements the remaining string functions: CHARACTER_LENGTH CONCAT UPPER LOWER INITCAP LIKE

[GitHub] flink pull request: [FLINK-3578] Support RichFunctions for Scala W...

2016-03-04 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1765 [FLINK-3578] Support RichFunctions for Scala Window Function and AllWindowFunction This adds support RichFunctions for Scala Window Function and AllWindowFunction. RichFunction method

[jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor

2016-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179767#comment-15179767 ] ASF GitHub Bot commented on FLINK-3428: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma...

2016-03-04 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1764#discussion_r55019932 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala --- @@ -750,6 +750,34 @@ class DataStream[T](stream:

[jira] [Created] (FLINK-3578) Scala DataStream API does not support Rich Window Functions

2016-03-04 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3578: --- Summary: Scala DataStream API does not support Rich Window Functions Key: FLINK-3578 URL: https://issues.apache.org/jira/browse/FLINK-3578 Project: Flink

[jira] [Commented] (FLINK-3554) Bounded sources should emit a Max Watermark when they are done

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

[GitHub] flink pull request: [FLINK-3554] [streaming] Emit a MAX Watermark ...

2016-03-04 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1750#issuecomment-192241682 Yes, that's a problem. Could you maybe open an issue for that here: https://issues.apache.org/jira/browse/FLINK In the meantime, I have a workaround for you.

[jira] [Commented] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor

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

[GitHub] flink pull request: FLINK-3428: Adds a fixed time trailing waterma...

2016-03-04 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/1764 FLINK-3428: Adds a fixed time trailing watermark timestamp extractor. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink flink-3428

[jira] [Commented] (FLINK-3577) Display anchor links when hovering over headers.

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

[GitHub] flink pull request: [docs] fix the active tab caption is not displ...

2016-03-04 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/1763 [docs] fix the active tab caption is not displaying blue and a very very minor typo fix

[GitHub] flink pull request: [FLINK-3577] [docs] Display anchor links when ...

2016-03-04 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/1762 [FLINK-3577] [docs] Display anchor links when hovering over headers. This is useful to share the document url if display anchor links when hovering over headers. Currently we must scroll up to the

[jira] [Commented] (FLINK-3568) Hadoop's Bzip decompression is not thread safe

2016-03-04 Thread Moritz Schubotz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179739#comment-15179739 ] Moritz Schubotz commented on FLINK-3568: http://flink.apache.org/downloads.html suggests that one

[jira] [Commented] (FLINK-3568) Hadoop's Bzip decompression is not thread safe

2016-03-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179725#comment-15179725 ] Stephan Ewen commented on FLINK-3568: - You can download Flink for a variety or Hadoop versions. If

[jira] [Commented] (FLINK-3568) Hadoop's Bzip decompression is not thread safe

2016-03-04 Thread Moritz Schubotz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179722#comment-15179722 ] Moritz Schubotz commented on FLINK-3568: i.e. do you mean changing this line

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

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

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

2016-03-04 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1754#issuecomment-192228765 I changed 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

[jira] [Commented] (FLINK-3568) Hadoop's Bzip decompression is not thread safe

2016-03-04 Thread Moritz Schubotz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179712#comment-15179712 ] Moritz Schubotz commented on FLINK-3568: What exactly do you mean by "removing the 'shaded-hadoop'

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

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

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

2016-03-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1746#discussion_r55014256 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AvgAggregate.scala --- @@ -17,115 +17,144 @@ */

[jira] [Commented] (FLINK-3554) Bounded sources should emit a Max Watermark when they are done

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

[GitHub] flink pull request: [FLINK-3554] [streaming] Emit a MAX Watermark ...

2016-03-04 Thread wenlonglwl
Github user wenlonglwl commented on the pull request: https://github.com/apache/flink/pull/1750#issuecomment-192224050 In our production environment, window is used to make a small batch, for some operator that should be done in batch to improve the throughput, such as writing data

[GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast...

2016-03-04 Thread HungUnicorn
Github user HungUnicorn commented on a diff in the pull request: https://github.com/apache/flink/pull/1040#discussion_r55013666 --- Diff:

[jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch

2016-03-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179686#comment-15179686 ] ASF GitHub Bot commented on FLINK-2558: --- Github user HungUnicorn commented on a diff in the pull

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

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

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

2016-03-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1746#discussion_r55013155 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -0,0 +1,329 @@ +/* + *

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

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

  1   2   >