[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209299#comment-16209299 ] Fabian Hueske commented on FLINK-7548: -- Thanks for the comment [~ykt836]. I think the projection

[jira] [Commented] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209189#comment-16209189 ] Fabian Hueske commented on FLINK-7755: -- I think we should treat this kind of bugs as blockers. If

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209059#comment-16209059 ] Fabian Hueske commented on FLINK-6584: -- Without this feature the use of streamed joins and aggregates

[jira] [Commented] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208992#comment-16208992 ] Fabian Hueske commented on FLINK-7755: -- We compute wrong results. This is qualifies as a blocker,

[jira] [Updated] (FLINK-7548) Support watermark generation for TableSource

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7548: - Issue Type: Improvement (was: Bug) > Support watermark generation for TableSource >

[jira] [Assigned] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6173: Assignee: Timo Walther (was: Fabian Hueske) > flink-table not pack-in

[jira] [Assigned] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6173: Assignee: Fabian Hueske (was: Timo Walther) > flink-table not pack-in

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208976#comment-16208976 ] Fabian Hueske commented on FLINK-7853: -- And the answer is also the same as for FLINK-7854. > Reject

[jira] [Commented] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208973#comment-16208973 ] Fabian Hueske commented on FLINK-7854: -- IMO, this is a blocker. We are silently computing wrong

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208238#comment-16208238 ] Fabian Hueske commented on FLINK-7548: -- Thanks for the comments [~twalthr] and [~xccui]. @ Timo: I

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207628#comment-16207628 ] Fabian Hueske commented on FLINK-7548: -- Hi [~jark], [~wheat9], [~twalthr], [~xccui], [~ykt836],I'd

[jira] [Assigned] (FLINK-7848) Allow time attributes for atomic types

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7848: Assignee: Fabian Hueske > Allow time attributes for atomic types >

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

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-5498: Assignee: Fabian Hueske (was: lincoln.lee) > Add support for left/right outer joins with

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

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207579#comment-16207579 ] Fabian Hueske commented on FLINK-5498: -- Hi [~lincoln.86xy], I'll fix this issue as this has the same

[jira] [Commented] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207153#comment-16207153 ] Fabian Hueske commented on FLINK-7373: -- OK, thanks for the reply [~walterddr] :-) > Using

[jira] [Closed] (FLINK-7852) An input of GenericTypeInfo cannot be converted to Table

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7852. Resolution: Invalid Not a bug report or feature request. > An input of GenericTypeInfo cannot be

[jira] [Commented] (FLINK-7852) An input of GenericTypeInfo cannot be converted to Table

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207110#comment-16207110 ] Fabian Hueske commented on FLINK-7852: -- Hi Han, as the error message says, you need to specify a

[jira] [Updated] (FLINK-7852) An input of GenericTypeInfo cannot be converted to Table

2017-10-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7852: - Description: Dear All: I'm starting to learn about Flink,and I have a question about Table API

[jira] [Closed] (FLINK-7798) Add support for windowed joins to Table API

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7798. Resolution: Implemented Implemented for 1.4.0 with e79cedf23b42a67f28c23c558a4b0be2179aba2d > Add

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206150#comment-16206150 ] Fabian Hueske commented on FLINK-7730: -- The pressing issue that needs to be fixed before the next

[jira] [Commented] (FLINK-7848) Allow time attributes for atomic types

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205890#comment-16205890 ] Fabian Hueske commented on FLINK-7848: -- This would be supported with the refactoring I proposed for

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205591#comment-16205591 ] Fabian Hueske commented on FLINK-7051: -- Thanks [~wheat9], that would be great! > Bump up Calcite

[jira] [Updated] (FLINK-7759) Fix Bug that fieldName with Boolean prefix can't be parsed by ExpressionParser.

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7759: - Priority: Critical (was: Major) > Fix Bug that fieldName with Boolean prefix can't be parsed by

[jira] [Updated] (FLINK-7759) Fix Bug that fieldName with Boolean prefix can't be parsed by ExpressionParser.

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7759: - Fix Version/s: 1.4.0 > Fix Bug that fieldName with Boolean prefix can't be parsed by >

[jira] [Assigned] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7755: Assignee: Fabian Hueske > Null values are not correctly handled by batch inner and outer

[jira] [Updated] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6584: - Fix Version/s: 1.4.0 > Support multiple consecutive windows in SQL >

[jira] [Updated] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7051: - Fix Version/s: 1.4.0 > Bump up Calcite version to 1.14 > --- > >

[jira] [Updated] (FLINK-7548) Support watermark generation for TableSource

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7548: - Fix Version/s: 1.4.0 > Support watermark generation for TableSource >

[jira] [Updated] (FLINK-6697) Add batch multi-window support

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6697: - Fix Version/s: 1.4.0 > Add batch multi-window support > -- > >

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7802: - Fix Version/s: 1.3.3 1.4.0 > Exception occur when empty field collection was

[jira] [Updated] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6173: - Fix Version/s: 1.4.0 > flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 >

[jira] [Updated] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7657: - Fix Version/s: 1.4.0 > SQL Timestamps Converted To Wrong Type By Optimizer Causing

[jira] [Updated] (FLINK-7426) Table API does not support null values in keys

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7426: - Fix Version/s: 1.3.3 1.4.0 > Table API does not support null values in keys >

[jira] [Updated] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7371: - Fix Version/s: 1.4.0 > user defined aggregator assumes nr of arguments smaller or equal than

[jira] [Resolved] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-7763. -- Resolution: Fixed Fixed for 1.3.3 with 80c23de709a56f9ea3b5ecd04876d95a1df7db96 Fixed for 1.4.0

[jira] [Updated] (FLINK-7548) Support watermark generation for TableSource

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7548: - Priority: Blocker (was: Major) > Support watermark generation for TableSource >

[jira] [Commented] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205559#comment-16205559 ] Fabian Hueske commented on FLINK-7373: -- Hi [~walterddr], did you find some time to look into this

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205556#comment-16205556 ] Fabian Hueske commented on FLINK-7730: -- Yes, the idea would be to forbid all predicates except

[jira] [Assigned] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7802: Assignee: Fabian Hueske (was: godfrey he) > Exception occur when empty field collection

[jira] [Assigned] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7802: Assignee: godfrey he (was: Fabian Hueske) > Exception occur when empty field collection

[jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7371: Assignee: Timo Walther (was: Fabian Hueske) > user defined aggregator assumes nr of

[jira] [Assigned] (FLINK-7426) Table API does not support null values in keys

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7426: Assignee: Timo Walther (was: Fabian Hueske) > Table API does not support null values in

[jira] [Assigned] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6584: Assignee: Timo Walther (was: Fabian Hueske) > Support multiple consecutive windows in SQL

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7798: Assignee: Xingcan Cui (was: Fabian Hueske) > Add support for windowed joins to Table API

[jira] [Updated] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7730: - Priority: Critical (was: Major) > TableFunction LEFT OUTER joins with ON predicates are broken >

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205157#comment-16205157 ] Fabian Hueske commented on FLINK-7730: -- This is mainly problem in Calcite (see [this thread on the

[jira] [Updated] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7371: - Priority: Blocker (was: Major) > user defined aggregator assumes nr of arguments smaller or

[jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7371: Assignee: Fabian Hueske (was: Timo Walther) > user defined aggregator assumes nr of

[jira] [Updated] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7051: - Priority: Critical (was: Major) > Bump up Calcite version to 1.14 >

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7802: - Priority: Critical (was: Major) > Exception occur when empty field collection was pushed into

[jira] [Assigned] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6584: Assignee: Fabian Hueske (was: Timo Walther) > Support multiple consecutive windows in SQL

[jira] [Assigned] (FLINK-7426) Table API does not support null values in keys

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7426: Assignee: Fabian Hueske (was: Timo Walther) > Table API does not support null values in

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7798: Assignee: Fabian Hueske (was: Xingcan Cui) > Add support for windowed joins to Table API

[jira] [Commented] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled

2017-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203440#comment-16203440 ] Fabian Hueske commented on FLINK-7763: -- Fixed for 1.4.0 with 57333c62271253248bf3699be31ae7224e97de75

[jira] [Commented] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled

2017-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16203297#comment-16203297 ] Fabian Hueske commented on FLINK-7763: -- The problem is caused by a test sink that simply collects

[jira] [Assigned] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled

2017-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7763: Assignee: Fabian Hueske > TableSinkITCase fails with "object reuse" enabled >

[jira] [Closed] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode

2017-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7833. Resolution: Duplicate Thanks for reporting the bug! This is a duplicate of FLINK-7657. > Flink's

[jira] [Updated] (FLINK-7798) Add support for windowed joins to Table API

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7798: - Priority: Blocker (was: Critical) > Add support for windowed joins to Table API >

[jira] [Updated] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6584: - Priority: Blocker (was: Major) > Support multiple consecutive windows in SQL >

[jira] [Closed] (FLINK-5905) Add user-defined aggregation functions to documentation.

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5905. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.x with

[jira] [Updated] (FLINK-7426) Table API does not support null values in keys

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7426: - Priority: Blocker (was: Major) > Table API does not support null values in keys >

[jira] [Closed] (FLINK-5564) Add User Defined Aggregates in Table API

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5564. Resolution: Implemented Fix Version/s: 1.3.0 UDAGGs were added with Flink 1.3.0 > Add User

[jira] [Updated] (FLINK-6697) Add batch multi-window support

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6697: - Priority: Blocker (was: Major) > Add batch multi-window support > --

[jira] [Updated] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6173: - Priority: Blocker (was: Major) > flink-table not pack-in com.fasterxml.jackson.* in after

[jira] [Updated] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7342: - Issue Type: New Feature (was: Bug) > Add support for Regular Expression Operators (RLIKE) >

[jira] [Updated] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7821: - Description: The Table API method limit() exists in two variants: - {{limit(offset)}} returns

[jira] [Updated] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7821: - Description: The Table API method limit() exists in two variants: - {{limit(offset)}} returns

[jira] [Created] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-12 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7821: Summary: Replace Table.limit() by Table.fetch() and Table.offset() Key: FLINK-7821 URL: https://issues.apache.org/jira/browse/FLINK-7821 Project: Flink

[jira] [Created] (FLINK-7814) Add BETWEEN expression to Table API

2017-10-11 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7814: Summary: Add BETWEEN expression to Table API Key: FLINK-7814 URL: https://issues.apache.org/jira/browse/FLINK-7814 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16200344#comment-16200344 ] Fabian Hueske commented on FLINK-7798: -- Yes, it's a bit of effort to get all the pieces that we would

[jira] [Updated] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-10-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7657: - Affects Version/s: 1.4.0 > SQL Timestamps Converted To Wrong Type By Optimizer Causing

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199876#comment-16199876 ] Fabian Hueske commented on FLINK-7798: -- And we need to adjust the Table API docs, i.e., copy the

[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

2017-10-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199854#comment-16199854 ] Fabian Hueske commented on FLINK-7798: -- Thanks for looking into this [~xccui]. Yes, I think it would

[jira] [Created] (FLINK-7800) Enable window joins without equi-join predicates

2017-10-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7800: Summary: Enable window joins without equi-join predicates Key: FLINK-7800 URL: https://issues.apache.org/jira/browse/FLINK-7800 Project: Flink Issue Type:

[jira] [Created] (FLINK-7799) Improve performance of windowed joins

2017-10-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7799: Summary: Improve performance of windowed joins Key: FLINK-7799 URL: https://issues.apache.org/jira/browse/FLINK-7799 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7798) Add support for windowed joins to Table API

2017-10-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7798: Summary: Add support for windowed joins to Table API Key: FLINK-7798 URL: https://issues.apache.org/jira/browse/FLINK-7798 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5725) Support windowed JOIN between two streaming tables

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5725: - Summary: Support windowed JOIN between two streaming tables (was: Support windowed JOIN between

[jira] [Created] (FLINK-7797) Add support for windowed outer joins for streaming tables

2017-10-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7797: Summary: Add support for windowed outer joins for streaming tables Key: FLINK-7797 URL: https://issues.apache.org/jira/browse/FLINK-7797 Project: Flink

[jira] [Updated] (FLINK-5725) Support windowed JOIN between two streams in the SQL API

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5725: - Summary: Support windowed JOIN between two streams in the SQL API (was: Support JOIN between two

[jira] [Closed] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7410. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7491. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-7776) do not emit duplicated records in group aggregation

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7776. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-10-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6233. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197673#comment-16197673 ] Fabian Hueske commented on FLINK-7548: -- I've created a proposal for a reworked TableSource API that

[jira] [Commented] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197278#comment-16197278 ] Fabian Hueske commented on FLINK-6219: -- Thanks [~phoenixjiangnan], I updated the linked issue.

[jira] [Updated] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6219: - Summary: Add a sorted state primitive (was: Add a state backend which supports sorting) > Add a

[jira] [Updated] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6219: - Description: When we implement the OVER window of

[jira] [Commented] (FLINK-6219) Add a state backend which supports sorting

2017-10-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196579#comment-16196579 ] Fabian Hueske commented on FLINK-6219: -- Hi [~phoenixjiangnan], I think this feature would be very

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

2017-10-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196030#comment-16196030 ] Fabian Hueske commented on FLINK-3655: -- I don't think there's a particular reason why the PR hasn't

[jira] [Commented] (FLINK-2973) Add flink-benchmark with compliant licenses again

2017-10-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194801#comment-16194801 ] Fabian Hueske commented on FLINK-2973: -- Not sure. [This

[jira] [Assigned] (FLINK-7548) Support watermark generation for TableSource

2017-10-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7548: Assignee: Fabian Hueske > Support watermark generation for TableSource >

[jira] [Created] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

2017-10-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7764: Summary: FlinkKafkaProducer010 does not accept name, uid, or parallelism Key: FLINK-7764 URL: https://issues.apache.org/jira/browse/FLINK-7764 Project: Flink

[jira] [Closed] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

2017-10-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7446. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191086#comment-16191086 ] Fabian Hueske commented on FLINK-7730: -- Thanks for looking into this [~xccui]! This looks like a

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191017#comment-16191017 ] Fabian Hueske commented on FLINK-7388: -- [~xccui] is right. This issue is about the timestamp that is

[jira] [Created] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

2017-10-02 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7755: Summary: Null values are not correctly handled by batch inner and outer joins Key: FLINK-7755 URL: https://issues.apache.org/jira/browse/FLINK-7755 Project: Flink

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16188254#comment-16188254 ] Fabian Hueske commented on FLINK-7051: -- The vote for Calcite 1.14 has passed and it will be released

[jira] [Commented] (FLINK-7731) Trigger on GlobalWindow does not clean state completely

2017-09-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184580#comment-16184580 ] Fabian Hueske commented on FLINK-7731: -- [~aljoscha], might this issue be related to FLINK-7700? >

[jira] [Created] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-09-28 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7730: Summary: TableFunction LEFT OUTER joins with ON predicates are broken Key: FLINK-7730 URL: https://issues.apache.org/jira/browse/FLINK-7730 Project: Flink

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-09-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181234#comment-16181234 ] Fabian Hueske commented on FLINK-7548: -- I think there might be a misunderstanding of the

  1   2   3   4   5   6   7   8   9   10   >