[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)

[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=15825602#comment-15825602 ] Fabian Hueske commented on FLINK-5498: -- Fair enough, those are valid concerns. Then let's split this

[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

[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

[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:

[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=15825599#comment-15825599 ] Anton Mushin commented on FLINK-5256: - Hi, I update PR, but it is incorrect yet. I have some problem

[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=15825594#comment-15825594 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the pull request:

[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=15825591#comment-15825591 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the pull request:

[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

[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=15825588#comment-15825588 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 commented on a diff in the pull request:

[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

[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,

[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=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

[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=15825551#comment-15825551 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Trying your suggestions bq.Since the code

[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=15825546#comment-15825546 ] sunjincheng commented on FLINK-5386: Hi [~fhueske] [~shaoxuan] thanks for the reply . [~fhueske] You

[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=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:12 AM: --- We also meet

[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=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:11 AM: --- We also meet

[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=15824927#comment-15824927 ] Syinchwun Leo edited comment on FLINK-4266 at 1/17/17 4:09 AM: --- We also meet

[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=15824927#comment-15824927 ] Syinchwun Leo commented on FLINK-4266: -- We also meet this problem,and plan to using incremental

[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=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=15824885#comment-15824885 ] Syinchwun Leo commented on FLINK-5372: -- When I run RocksDBStateBackend's test alone, it is OK. But

[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=15824844#comment-15824844 ] Shaoxuan Wang commented on FLINK-5386: -- [~sunjincheng121], thanks for the updates. Hi [~fhueske],

[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=15824818#comment-15824818 ] ASF GitHub Bot commented on FLINK-3475: --- Github user KurtYoung commented on a diff in the pull

[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=15824565#comment-15824565 ] ASF GitHub Bot commented on FLINK-5447: --- Github user fhueske commented on a diff in the pull

[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=15824566#comment-15824566 ] ASF GitHub Bot commented on FLINK-5447: --- Github user fhueske commented on a diff in the pull

[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 > --- > >

[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=15824554#comment-15824554 ] Stephan Ewen commented on FLINK-3617: - Improved the null check in - 1.2.0 via

[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

[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=15824552#comment-15824552 ] Stephan Ewen commented on FLINK-5345: - [~tonycox] Sorry for the confusion in this issue. > IOManager

[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

[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

[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:

[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

[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

[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

[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=15824537#comment-15824537 ] ASF GitHub Bot commented on FLINK-5448: --- Github user asfgit closed the pull request at:

[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=15824536#comment-15824536 ] ASF GitHub Bot commented on FLINK-5438: --- Github user asfgit closed the pull request at:

[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

[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

[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=15824538#comment-15824538 ] ASF GitHub Bot commented on FLINK-5485: --- Github user asfgit closed the pull request at:

[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

[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

[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=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

[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) >

[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}

[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}

[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=15824451#comment-15824451 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in the pull request:

[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

[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=15824449#comment-15824449 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in the pull request:

[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

[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=15824450#comment-15824450 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in the pull request:

[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

[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=15824436#comment-15824436 ] ASF GitHub Bot commented on FLINK-5423: --- Github user Fokko commented on a diff in the pull request:

[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=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

[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=15824325#comment-15824325 ] ASF GitHub Bot commented on FLINK-4988: --- Github user rmetzger commented on a diff in the pull

[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=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

[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=15824291#comment-15824291 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- bq.However, I think we would need a custom

[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=15824230#comment-15824230 ] ASF GitHub Bot commented on FLINK-4988: --- Github user fpompermaier commented on a diff in the pull

[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;

[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;

[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=15824194#comment-15824194 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on the issue:

[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

[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

[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

[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:

[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;

[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=15824176#comment-15824176 ] ASF GitHub Bot commented on FLINK-5303: --- Github user asfgit closed the pull request at:

[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

[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=15824170#comment-15824170 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on the issue:

[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

[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

[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=15824168#comment-15824168 ] ASF GitHub Bot commented on FLINK-1293: --- Github user tonycox commented on the issue:

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

2017-01-16 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2976 Thanks for the update @chermenin. I will have a final look over the code and merge it. I will also add a follow-up issue for efficiency. --- If your project is set up for it, you can reply to this

[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=15824169#comment-15824169 ] ASF GitHub Bot commented on FLINK-5303: --- Github user twalthr commented on the issue:

[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=15824160#comment-15824160 ] ASF GitHub Bot commented on FLINK-1293: --- Github user fhueske commented on the issue:

[GitHub] flink issue #243: [FLINK-1293] Add support for out-of-place aggregations

2017-01-16 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/243 Thanks for the ping @tonycox. I think this PR can be closed. The functionality it adds is available in the Table API. --- If your project is set up for it, you can reply to this email and have

  1   2   3   >