[jira] [Updated] (FLINK-5498) Add support for outer joins with non-equality predicates (and 1+ equality predicates)

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Summary: Add support for outer joins with non-equality predicates (and 1+ equality predicates) (w

[jira] [Commented] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825602#comment-15825602 ] Fabian Hueske commented on FLINK-5498: -- Fair enough, those are valid concerns. Then l

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Issue Type: New Feature (was: Bug) > OuterJoins with non-equality predicates compute wrong result

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Affects Version/s: (was: 1.1.4) (was: 1.2.0) > OuterJoins with non-

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Priority: Minor (was: Critical) > OuterJoins with non-equality predicates compute wrong results >

[jira] [Created] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-16 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5520: Summary: Disable outer joins with non-equality predicates Key: FLINK-5520 URL: https://issues.apache.org/jira/browse/FLINK-5520 Project: Flink Issue Type: Bu

[jira] [Comment Edited] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-01-16 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin edited comment on FLINK-5256 at 1/17/17 7:51 AM: --

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-01-16 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825599#comment-15825599 ] Anton Mushin commented on FLINK-5256: - Hi, I update PR, but it is incorrect yet. I hav

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825594#comment-15825594 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-01-16 Thread ex00
Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r96356761 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/JoinITCase.scala --- @@ -372,9 +372,163 @@ class JoinITCase(

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825591#comment-15825591 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-01-16 Thread ex00
Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r96356416 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetJoinRule.scala --- @@ -43,7 +43,7 @@ class DataSetJoinRule

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825588#comment-15825588 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-01-16 Thread ex00
Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r96356194 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -144,21 +150,46 @@ class DataSe

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee updated FLINK-5498: --- Description: I found the expected result of a unit test case incorrect compare to that in a RDMBS, s

[jira] [Commented] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

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

[GitHub] flink pull request #3132: [FLINK-5519] [build] scala-maven-plugin version al...

2017-01-16 Thread shijinkui
GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/3132 [FLINK-5519] [build] scala-maven-plugin version all change to 3.2.2 1. scala-maven-plugin version all change to 3.2.2 in all module 2. parent pom version change to apache-18 from apache-14

[jira] [Created] (FLINK-5519) scala-maven-plugin version all change to 3.2.2

2017-01-16 Thread shijinkui (JIRA)
shijinkui created FLINK-5519: Summary: scala-maven-plugin version all change to 3.2.2 Key: FLINK-5519 URL: https://issues.apache.org/jira/browse/FLINK-5519 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

2017-01-16 Thread Jakub Havlik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Havlik updated FLINK-5518: Description: When developing a simple Flink applications reading ORC files it crashes with NullPoin

[jira] [Created] (FLINK-5518) HadoopInputFormat throws NPE when close() is called before open()

2017-01-16 Thread Jakub Havlik (JIRA)
Jakub Havlik created FLINK-5518: --- Summary: HadoopInputFormat throws NPE when close() is called before open() Key: FLINK-5518 URL: https://issues.apache.org/jira/browse/FLINK-5518 Project: Flink

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-01-16 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825551#comment-15825551 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Trying your suggestions bq.

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825546#comment-15825546 ] sunjincheng commented on FLINK-5386: Hi [~fhueske] [~shaoxuan] thanks for the reply .

[jira] [Comment Edited] (FLINK-4266) Remote Database Statebackend

2017-01-16 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:12 AM: -

[jira] [Comment Edited] (FLINK-4266) Remote Database Statebackend

2017-01-16 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:11 AM: -

[jira] [Comment Edited] (FLINK-4266) Remote Database Statebackend

2017-01-16 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:09 AM: -

[jira] [Commented] (FLINK-4266) Remote Database Statebackend

2017-01-16 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824927#comment-15824927 ] Syinchwun Leo commented on FLINK-4266: -- We also meet this problem,and plan to using i

[jira] [Comment Edited] (FLINK-5386) Refactoring Window Clause

2017-01-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824844#comment-15824844 ] Shaoxuan Wang edited comment on FLINK-5386 at 1/17/17 3:37 AM: -

[jira] [Commented] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2017-01-16 Thread Syinchwun Leo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824885#comment-15824885 ] Syinchwun Leo commented on FLINK-5372: -- When I run RocksDBStateBackend's test alone,

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824844#comment-15824844 ] Shaoxuan Wang commented on FLINK-5386: -- [~sunjincheng121], thanks for the updates. H

[jira] [Created] (FLINK-5517) Upgrade hbase version to 1.3.0

2017-01-16 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5517: - Summary: Upgrade hbase version to 1.3.0 Key: FLINK-5517 URL: https://issues.apache.org/jira/browse/FLINK-5517 Project: Flink Issue Type: Improvement Reporter:

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-01-16 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3111#discussion_r96329552 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala --- @@ -96,6 +96,13 @@ object FlinkRuleSets {

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824818#comment-15824818 ] ASF GitHub Bot commented on FLINK-3475: --- Github user KurtYoung commented on a diff i

[jira] [Updated] (FLINK-4266) Remote Database Statebackend

2017-01-16 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-4266: Affects Version/s: (was: 1.0.3) > Remote Database Statebackend > > >

[jira] [Commented] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824565#comment-15824565 ] ASF GitHub Bot commented on FLINK-5447: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824566#comment-15824566 ] ASF GitHub Bot commented on FLINK-5447: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #3126: [FLINK-5447] [table] Sync documentation of built-i...

2017-01-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3126#discussion_r96254835 --- Diff: docs/dev/table_api.md --- @@ -1508,522 +1508,601 @@ Both the Table API and SQL come with a set of built-in functions for data transf

[GitHub] flink pull request #3126: [FLINK-5447] [table] Sync documentation of built-i...

2017-01-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3126#discussion_r96255434 --- Diff: docs/dev/table_api.md --- @@ -1508,522 +1508,601 @@ Both the Table API and SQL come with a set of built-in functions for data transf

[jira] [Closed] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4959. --- > Write Documentation for ProcessFunction > --- > > Ke

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824554#comment-15824554 ] Stephan Ewen commented on FLINK-3617: - Improved the null check in - 1.2.0 via 27c11e

[jira] [Resolved] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4959. - Resolution: Fixed Fixed in - 1.2.0 via 2eb926f2bed5723f160620b94f3b67e5dc418387 - 1.3.0 via 7a

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824552#comment-15824552 ] Stephan Ewen commented on FLINK-5345: - [~tonycox] Sorry for the confusion in this issu

[jira] [Resolved] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5345. - Resolution: Fixed Fixed in - 1.2.0 via d1b86aab09061627d8b8c8f99b4277cc60e3dc28 - 1.3.0 via c4

[jira] [Closed] (FLINK-5345) IOManager failed to properly clean up temp file directory

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5345. --- > IOManager failed to properly clean up temp file directory >

[jira] [Closed] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5485. --- > Mark compiled web frontend files as binary when processed by git diff >

[jira] [Resolved] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5485. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in - 1.2.0 via 6b3c683450eb7aee1c9c65be75a0f

[jira] [Closed] (FLINK-5438) Typo in JobGraph generator Exception

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5438. --- > Typo in JobGraph generator Exception > - > > Key: F

[jira] [Resolved] (FLINK-5438) Typo in JobGraph generator Exception

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5438. - Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in - 1.2.0 via 30b4

[jira] [Closed] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5448. --- > Fix typo in StateAssignmentOperation Exception > -- > >

[jira] [Resolved] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5448. - Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in - 1.2.0 via 119d

[jira] [Resolved] (FLINK-4450) update storm version to 1.0.0

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4450. - Resolution: Fixed Fix Version/s: (was: 2.0.0) 1.3.0 Fixed via 475c0b

[jira] [Commented] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824537#comment-15824537 ] ASF GitHub Bot commented on FLINK-5448: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5438) Typo in JobGraph generator Exception

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824536#comment-15824536 ] ASF GitHub Bot commented on FLINK-5438: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3097: [FLINK-5448] Fix typo in StateAssignmentOperation ...

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3097 --- 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 #3037: Flink-4450 update storm version to 1.0

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3037 --- 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-5485) Mark compiled web frontend files as binary when processed by git diff

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824538#comment-15824538 ] ASF GitHub Bot commented on FLINK-5485: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3122: [FLINK-5485] [webfrontend] Mark compiled web front...

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3122 --- 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 #3098: [FLINK-5438] Typo in JobGraph generator Exception

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3098 --- 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 issue #3068: [FLINK-5380] Fix task metrics reuse for single-operator c...

2017-01-16 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3068 Mh, I just realized that the streaming APIs multichaining is leading to some ugly side effects. In below screenshot, you see that the number of outgoing records is reported as 247. These re

[jira] [Commented] (FLINK-5380) Number of outgoing records not reported in web interface

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824522#comment-15824522 ] ASF GitHub Bot commented on FLINK-5380: --- Github user rmetzger commented on the issue

[jira] [Updated] (FLINK-5516) Hardcoded paths in flink-python/.../PythonPlanBinder.java

2017-01-16 Thread Felix seibert (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix seibert updated FLINK-5516: - Summary: Hardcoded paths in flink-python/.../PythonPlanBinder.java (was: Hardcoded paths in flink

[jira] [Updated] (FLINK-5516) Hardcoded paths in flink-python/.../

2017-01-16 Thread Felix seibert (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix seibert updated FLINK-5516: - Summary: Hardcoded paths in flink-python/.../ (was: Hardcoded paths in flink-python) > Hardcoded

[jira] [Updated] (FLINK-5516) Hardcoded paths in flink-python

2017-01-16 Thread Felix seibert (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix seibert updated FLINK-5516: - Description: The PythonPlanBinder.java contains three hardcoded filesystem paths: {code:java} pub

[jira] [Updated] (FLINK-5516) Hardcoded paths in flink-python

2017-01-16 Thread Felix seibert (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix seibert updated FLINK-5516: - Description: The PythonPlanBinder.java contains two hardcoded filesystem paths: {code:java} publi

[jira] [Created] (FLINK-5516) Hardcoded paths in flink-python

2017-01-16 Thread Felix seibert (JIRA)
Felix seibert created FLINK-5516: Summary: Hardcoded paths in flink-python Key: FLINK-5516 URL: https://issues.apache.org/jira/browse/FLINK-5516 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4959: --- Assignee: Stephan Ewen > Write Documentation for ProcessFunction > --

[jira] [Updated] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4959: Fix Version/s: 1.3.0 > Write Documentation for ProcessFunction > ---

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824451#comment-15824451 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in th

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread Fokko
Github user Fokko commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96290365 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824449#comment-15824449 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in th

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread Fokko
Github user Fokko commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96290218 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824450#comment-15824450 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in th

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread Fokko
Github user Fokko commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96290195 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed t

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread Fokko
Github user Fokko commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96289143 --- Diff: flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/outlier/StochasticOutlierSelectionITSuite.scala --- @@ -0,0 +1,240 @@ +/* + * Lic

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824436#comment-15824436 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in th

[jira] [Commented] (FLINK-5515) fix unused kvState.getSerializedValue call in KvStateServerHandler

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

[GitHub] flink pull request #3131: [FLINK-5515] remove unused kvState.getSerializedVa...

2017-01-16 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3131 [FLINK-5515] remove unused kvState.getSerializedValue call in KvStateServerHandler this seems like a simple left-over from a merge that is doing unnecessary extra work You can merge this pull reques

[jira] [Created] (FLINK-5515) fix unused kvState.getSerializedValue call in KvStateServerHandler

2017-01-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5515: -- Summary: fix unused kvState.getSerializedValue call in KvStateServerHandler Key: FLINK-5515 URL: https://issues.apache.org/jira/browse/FLINK-5515 Project: Flink

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824325#comment-15824325 ] ASF GitHub Bot commented on FLINK-4988: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-16 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/3112#discussion_r96274454 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java ---

[jira] [Commented] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824320#comment-15824320 ] ASF GitHub Bot commented on FLINK-5394: --- Github user twalthr commented on the issue:

[GitHub] flink issue #3058: [FLINK-5394] [Table API & SQL]the estimateRowCount method...

2017-01-16 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3058 I will also look at it tomorrow. --- 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-2168) Add HBaseTableSource

2017-01-16 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824291#comment-15824291 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- bq.However, I think we woul

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824230#comment-15824230 ] ASF GitHub Bot commented on FLINK-4988: --- Github user fpompermaier commented on a dif

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-16 Thread fpompermaier
Github user fpompermaier commented on a diff in the pull request: https://github.com/apache/flink/pull/3112#discussion_r96265039 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java -

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere; FLI

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere; FLI

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824194#comment-15824194 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on th

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

2017-01-16 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3071 Surely not :) --- 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,

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824187#comment-15824187 ] ASF GitHub Bot commented on FLINK-5417: --- Github user zentol commented on the issue:

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

2017-01-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3580. - Resolution: Fixed Fix Version/s: 1.2.0 All functions mentioned in this issue have been impl

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

2017-01-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3071 Could be; it's a bit frightening to see how much the results differ based on which application one uses :/ Anyway, I will add this to my batch of commits to merge. However, the massive diff d

[jira] [Created] (FLINK-5514) Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS

2017-01-16 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5514: --- Summary: Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS Key: FLINK-5514 URL: https://issues.apache.org/jira/browse/FLINK-5514 Project: Flink

[jira] [Resolved] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5303. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0: ef8cdfe5930201f79c78f34cc9f462b4e88b

[jira] [Updated] (FLINK-5384) clean up jira issues

2017-01-16 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: h4. must be closed: FLINK-37 -> from stratosphere; FLINK-87 -> from stratosphere; FLI

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824176#comment-15824176 ] ASF GitHub Bot commented on FLINK-5303: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS...

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2976 --- 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-5417) Fix the wrong config file name

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824170#comment-15824170 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on th

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

2017-01-16 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3071 I guess it is probably that the illustrator added sth. --- 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 issue #243: [FLINK-1293] Add support for out-of-place aggregations

2017-01-16 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/243 Ok, cool. I can go through abandoned PRs and add them to https://issues.apache.org/jira/browse/FLINK-5384. Wouldn't you mind @fhueske ? --- If your project is set up for it, you can reply to this ema

[jira] [Commented] (FLINK-1293) Add support for out-of-place aggregations

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824168#comment-15824168 ] ASF GitHub Bot commented on FLINK-1293: --- Github user tonycox commented on the issue:

  1   2   3   4   >