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

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

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

[ 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

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16203440#comment-16203440 ] Fabian Hueske commented on FLINK-7763: -- Fixed for 1.4.0 with 57333c62271253248bf3699b

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

[ https://issues.apache.org/jira/browse/FLINK-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16203297#comment-16203297 ] Fabian Hueske commented on FLINK-7763: -- The problem is caused by a test sink that sim

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

[ 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

[ 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

[ 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

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

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

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

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

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

[ 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] [Updated] (FLINK-6697) Add batch multi-window support

[ 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

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

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

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

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

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

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

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

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 Issue

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

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

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16200344#comment-16200344 ] Fabian Hueske commented on FLINK-7798: -- Yes, it's a bit of effort to get all the piec

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199854#comment-16199854 ] Fabian Hueske commented on FLINK-7798: -- Thanks for looking into this [~xccui]. Yes, I

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

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

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

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

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: Sub-tas

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

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

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

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 Issue

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

[ 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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197673#comment-16197673 ] Fabian Hueske commented on FLINK-7548: -- I've created a proposal for a reworked TableS

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

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197278#comment-16197278 ] Fabian Hueske commented on FLINK-6219: -- Thanks [~phoenixjiangnan], I updated the link

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

[ 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

[ 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 [FLIP11|https://cwiki.apache.org/confluence/dis

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

[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196579#comment-16196579 ] Fabian Hueske commented on FLINK-6219: -- Hi [~phoenixjiangnan], I think this feature w

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

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196030#comment-16196030 ] Fabian Hueske commented on FLINK-3655: -- I don't think there's a particular reason why

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

[ https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16194801#comment-16194801 ] Fabian Hueske commented on FLINK-2973: -- Not sure. [This page|http://www.apache.org/l

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191086#comment-16191086 ] Fabian Hueske commented on FLINK-7730: -- Thanks for looking into this [~xccui]! This

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

[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191017#comment-16191017 ] Fabian Hueske commented on FLINK-7388: -- [~xccui] is right. This issue is about the ti

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

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

[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16188254#comment-16188254 ] Fabian Hueske commented on FLINK-7051: -- The vote for Calcite 1.14 has passed and it w

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

[ https://issues.apache.org/jira/browse/FLINK-7731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184580#comment-16184580 ] Fabian Hueske commented on FLINK-7731: -- [~aljoscha], might this issue be related to F

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

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 I

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

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16181234#comment-16181234 ] Fabian Hueske commented on FLINK-7548: -- I think there might be a misunderstanding of

[jira] [Created] (FLINK-7696) Add projection push-down support for TableSources with time attributes

Fabian Hueske created FLINK-7696: Summary: Add projection push-down support for TableSources with time attributes Key: FLINK-7696 URL: https://issues.apache.org/jira/browse/FLINK-7696 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16179870#comment-16179870 ] Fabian Hueske commented on FLINK-7657: -- Hi [~kmurra], thanks for looking into this. I

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

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16179836#comment-16179836 ] Fabian Hueske commented on FLINK-7548: -- Thanks for your thoughts [~xccui]. I added a

[jira] [Closed] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster

[ https://issues.apache.org/jira/browse/FLINK-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7656. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with 9a8b515c

[jira] [Commented] (FLINK-7672) Publish Kinesis connector to Maven Central?

[ https://issues.apache.org/jira/browse/FLINK-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177215#comment-16177215 ] Fabian Hueske commented on FLINK-7672: -- AFAIK, calling the API might be considered as

[jira] [Resolved] (FLINK-7672) Publish Kinesis connector to Maven Central?

[ https://issues.apache.org/jira/browse/FLINK-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-7672. -- Resolution: Unresolved Unfortunately, Amazon Software License is Cat X (https://www.apache.org/

[jira] [Commented] (FLINK-7672) Publish Kinesis connector to Maven Central?

[ https://issues.apache.org/jira/browse/FLINK-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177172#comment-16177172 ] Fabian Hueske commented on FLINK-7672: -- The Kinesis connector is not published to Mav

[jira] [Closed] (FLINK-7571) Execution of TableSources with Time Indicators fails

[ https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7571. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for 1.4.0 with 2a4ac66009f276c157fd35710006b2eba

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

[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174682#comment-16174682 ] Fabian Hueske commented on FLINK-6173: -- Yes, [~kmurra]. The shaded dependencies are m

[jira] [Closed] (FLINK-7644) Line the extra semicolon in the source code

[ https://issues.apache.org/jira/browse/FLINK-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7644. Resolution: Fixed Fix Version/s: (was: 1.3.3) Fixed for 1.4.0 with 6c315be0928a0ffc214e60

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

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174581#comment-16174581 ] Fabian Hueske commented on FLINK-7548: -- Thanks for the feedback [~jark]! bq. Regardi

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

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173442#comment-16173442 ] Fabian Hueske commented on FLINK-7657: -- Thanks for reporting this bug and investigati

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

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7657: Assignee: Kent Murra > SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCas

[jira] [Closed] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7357. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Release Note: Fixed for

[jira] [Created] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster

Fabian Hueske created FLINK-7656: Summary: Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster Key: FLINK-7656 URL: https://issues.apache.org/jira/browse/FLINK-7656 Project: F

[jira] [Closed] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL

[ https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6442. Resolution: Implemented Fix Version/s: 1.4.0 Release Note: Implemented for 1.4.0 with 2c

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

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16171469#comment-16171469 ] Fabian Hueske commented on FLINK-7548: -- At the moment, we expect a {{TableSource}} to

[jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable

[ https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169757#comment-16169757 ] Fabian Hueske commented on FLINK-7627: -- I don't have concerns that {{SingleElementIte

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

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7446: Assignee: Fabian Hueske > Support to define an existing field as the rowtime field for Tabl

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

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16158910#comment-16158910 ] Fabian Hueske commented on FLINK-7446: -- Hi [~jark], did you start to work on this iss

[jira] [Commented] (FLINK-7594) Add a SQL CLI client

[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16156647#comment-16156647 ] Fabian Hueske commented on FLINK-7594: -- [~twalthr] and I have been working on a proto

[jira] [Updated] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

[ https://issues.apache.org/jira/browse/FLINK-7596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7596: - Description: If two inputs with Any(GenericRelDataType), when they comes to Set Operation({{UNION

[jira] [Commented] (FLINK-7593) Generated plan does not create correct groups

[ https://issues.apache.org/jira/browse/FLINK-7593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16155275#comment-16155275 ] Fabian Hueske commented on FLINK-7593: -- Thanks for reporting the bug! I could reprodu

[jira] [Closed] (FLINK-7564) Fix Watermark semantics in Table API

[ https://issues.apache.org/jira/browse/FLINK-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7564. Resolution: Fixed Fixed for 1.3.3 with 7f4a58d4fe004d603e8bf2a9b3d19e443b104662 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-7404) Table API batch join code-gen's equi-join conditions

[ https://issues.apache.org/jira/browse/FLINK-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7404. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with 50f6c752

[jira] [Closed] (FLINK-6751) Table API / SQL Docs: UDFs Page

[ https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6751. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with 3211e8af

[jira] [Closed] (FLINK-7572) Improve TableSchema ValidationException message.

[ https://issues.apache.org/jira/browse/FLINK-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7572. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with 0e2e9cb5

[jira] [Closed] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource

[ https://issues.apache.org/jira/browse/FLINK-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7227. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with ab55a436

[jira] [Commented] (FLINK-6563) Expose time indicator attributes in the KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152674#comment-16152674 ] Fabian Hueske commented on FLINK-6563: -- Hi [~wheat9], I addressed this issue but did

[jira] [Created] (FLINK-7571) Execution of TableSources with Time Indicators fails

Fabian Hueske created FLINK-7571: Summary: Execution of TableSources with Time Indicators fails Key: FLINK-7571 URL: https://issues.apache.org/jira/browse/FLINK-7571 Project: Flink Issue Type

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

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16147172#comment-16147172 ] Fabian Hueske commented on FLINK-6233: -- Thanks for the excellent document [~xccui]. I

[jira] [Closed] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code

[ https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7309. Resolution: Fixed Fix Version/s: 1.3.3 1.4.0 Fixed for 1.3.3 with eec261e9

[jira] [Closed] (FLINK-7398) Table API operators/UDFs must not store Logger

[ https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7398. Resolution: Fixed Fixed for 1.3.3 with 3167f72d95719ee551e798196fd26b9503e2dfd9 Fixed for 1.4.0 with

[jira] [Closed] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7245. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with 68fdaa57e35b8ee30a262

[jira] [Closed] (FLINK-7206) Implementation of DataView to support state access for UDAGG

[ https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7206. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with 1fc0b6413c74eff0ace25

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143673#comment-16143673 ] Fabian Hueske commented on FLINK-7465: -- HyperLogLog does not support retraction, i.e.

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137425#comment-16137425 ] Fabian Hueske edited comment on FLINK-7465 at 8/28/17 10:20 AM:

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137425#comment-16137425 ] Fabian Hueske edited comment on FLINK-7465 at 8/28/17 10:20 AM:

[jira] [Commented] (FLINK-7509) Refactorings to AggregateCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143526#comment-16143526 ] Fabian Hueske commented on FLINK-7509: -- Yes, with more special cases being added it m

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

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143522#comment-16143522 ] Fabian Hueske commented on FLINK-6233: -- Thanks [~xccui], that would be great! :-) >

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

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143517#comment-16143517 ] Fabian Hueske commented on FLINK-7446: -- I think that's a good plan [~jark]. However,

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137425#comment-16137425 ] Fabian Hueske commented on FLINK-7465: -- I'm sorry, I confused count-min sketches (for

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

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137358#comment-16137358 ] Fabian Hueske commented on FLINK-7446: -- I agree that the watermark generation for Tab

[jira] [Commented] (FLINK-7471) Improve bounded OVER support non-retract method AGG

[ https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137343#comment-16137343 ] Fabian Hueske commented on FLINK-7471: -- I understand the motivation for this issue an

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

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131805#comment-16131805 ] Fabian Hueske commented on FLINK-7446: -- That's in fact a good question. In principle

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

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131364#comment-16131364 ] Fabian Hueske commented on FLINK-6233: -- Hi [~xccui], sorry for the late reply. You a

[jira] [Commented] (FLINK-7471) Improve bounded OVER support non-retract method AGG

[ https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131336#comment-16131336 ] Fabian Hueske commented on FLINK-7471: -- Are you proposing to compute all aggregates f

issues@flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131296#comment-16131296 ] Fabian Hueske commented on FLINK-7465: -- I think an approximate count distinct would b

[jira] [Commented] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16131275#comment-16131275 ] Fabian Hueske commented on FLINK-7447: -- I would be fine with adding time zone informa

<    5   6   7   8   9   10   11   12   13   14   >