[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462498#comment-17462498 ] Haohui Mai commented on FLINK-24456: IMO anything on-par with the current table API is sufficient >

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443250#comment-17443250 ] Haohui Mai commented on FLINK-24456: It just needs to be on par with the datastream api. > Support

[jira] [Created] (FLINK-24485) COUNT(DISTINCT) should support binary field

Haohui Mai created FLINK-24485: -- Summary: COUNT(DISTINCT) should support binary field Key: FLINK-24485 URL: https://issues.apache.org/jira/browse/FLINK-24485 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426117#comment-17426117 ] Haohui Mai commented on FLINK-24456: [~MartijnVisser] feel free to take it forward > Support

[jira] [Created] (FLINK-24456) Support bounded offset in the Kafka table connector

Haohui Mai created FLINK-24456: -- Summary: Support bounded offset in the Kafka table connector Key: FLINK-24456 URL: https://issues.apache.org/jira/browse/FLINK-24456 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296435#comment-16296435 ] Haohui Mai commented on FLINK-8240: --- It seems that it is a great use case of layered table sources /

[jira] [Commented] (FLINK-7980) Bump joda-time to 2.9.9

[ https://issues.apache.org/jira/browse/FLINK-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16245232#comment-16245232 ] Haohui Mai commented on FLINK-7980: --- IMO it is a better idea to get rid of joda-time as all APIs in

[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=16215758#comment-16215758 ] Haohui Mai commented on FLINK-7548: --- Sorry for the late response. The APIs should work for our use cases

[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=16205312#comment-16205312 ] Haohui Mai commented on FLINK-7051: --- I plan to work on it this week to make sure it happens before the

[jira] [Closed] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai closed FLINK-6569. - Resolution: Invalid Fix Version/s: (was: 1.4.0) > flink-table KafkaJsonTableSource example

[jira] [Created] (FLINK-7787) Remove guava dependency in the cassandra connector

Haohui Mai created FLINK-7787: - Summary: Remove guava dependency in the cassandra connector Key: FLINK-7787 URL: https://issues.apache.org/jira/browse/FLINK-7787 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7743) Remove the restriction of minimum memory of JM

Haohui Mai created FLINK-7743: - Summary: Remove the restriction of minimum memory of JM Key: FLINK-7743 URL: https://issues.apache.org/jira/browse/FLINK-7743 Project: Flink Issue Type: Bug

[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=16156221#comment-16156221 ] Haohui Mai commented on FLINK-7594: --- We internally has a project (AthenaX) for this requirement and we

[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=16154348#comment-16154348 ] Haohui Mai commented on FLINK-6563: --- Thanks for the PR. I'll take a look at the PR later today. >

[jira] [Commented] (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:comment-tabpanel=16136280#comment-16136280 ] Haohui Mai commented on FLINK-7398: --- +1 on logging trait. I'll submit a PR. Adding a checkstyle rule is

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125856#comment-16125856 ] Haohui Mai commented on FLINK-6692: --- Sounds good. Thanks for the effort! > The flink-dist jar contains

[jira] [Resolved] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-6692. --- Resolution: Fixed > The flink-dist jar contains unshaded netty jar >

[jira] [Commented] (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:comment-tabpanel=16121265#comment-16121265 ] Haohui Mai commented on FLINK-7398: --- Putting in a companion object is an viable option. My worry,

[jira] [Commented] (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:comment-tabpanel=16120536#comment-16120536 ] Haohui Mai commented on FLINK-7398: --- Good catch! I think we can fix it for once but I'm more worried

[jira] [Assigned] (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 ] Haohui Mai reassigned FLINK-7398: - Assignee: Haohui Mai > Table API operators/UDFs must not store Logger >

[jira] [Commented] (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:comment-tabpanel=16120511#comment-16120511 ] Haohui Mai commented on FLINK-7357: --- I haven't started yet. Please go ahead. > HOP_START() HOP_END()

[jira] [Resolved] (FLINK-7159) Semantics of OVERLAPS in Table API diverge from the SQL standard

[ https://issues.apache.org/jira/browse/FLINK-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-7159. --- Resolution: Fixed This has been resolved as a part of FLINK-6429. > Semantics of OVERLAPS in Table

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

[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-7051: - Assignee: Haohui Mai > Bump up Calcite version to 1.14 > --- > >

[jira] [Created] (FLINK-7392) Enable more predicate push-down in joins

Haohui Mai created FLINK-7392: - Summary: Enable more predicate push-down in joins Key: FLINK-7392 URL: https://issues.apache.org/jira/browse/FLINK-7392 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117500#comment-16117500 ] Haohui Mai commented on FLINK-6429: --- bq. In order to change the default behavior of the rule, the only

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117328#comment-16117328 ] Haohui Mai commented on FLINK-6429: --- It's difficult to say this is a pure Calcite bug. Technically SQL

[jira] [Assigned] (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 ] Haohui Mai reassigned FLINK-7357: - Assignee: Haohui Mai > HOP_START() HOP_END() does not work when using HAVING clause with GROUP

[jira] [Created] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API

Haohui Mai created FLINK-7344: - Summary: Migrate usage of joda-time to the Java 8 DateTime API Key: FLINK-7344 URL: https://issues.apache.org/jira/browse/FLINK-7344 Project: Flink Issue Type:

[jira] [Created] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

Haohui Mai created FLINK-7237: - Summary: Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14 Key: FLINK-7237 URL: https://issues.apache.org/jira/browse/FLINK-7237 Project: Flink

[jira] [Created] (FLINK-7236) Bump up the Calcite version to 1.14

Haohui Mai created FLINK-7236: - Summary: Bump up the Calcite version to 1.14 Key: FLINK-7236 URL: https://issues.apache.org/jira/browse/FLINK-7236 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

Haohui Mai created FLINK-7235: - Summary: Backport CALCITE-1884 to the Flink repository before Calcite 1.14 Key: FLINK-7235 URL: https://issues.apache.org/jira/browse/FLINK-7235 Project: Flink

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091283#comment-16091283 ] Haohui Mai commented on FLINK-6429: --- Sorry for the delay. There are several issues that need to be

[jira] [Assigned] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6429: - Assignee: Haohui Mai (was: Timo Walther) > Bump up Calcite version to 1.13 >

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083277#comment-16083277 ] Haohui Mai commented on FLINK-6429: --- [~twalthr] that would be great. I found a few issues and I'm adding

[jira] [Created] (FLINK-7159) Semantics of OVERLAPS in Table API diverge from the SQL standard

Haohui Mai created FLINK-7159: - Summary: Semantics of OVERLAPS in Table API diverge from the SQL standard Key: FLINK-7159 URL: https://issues.apache.org/jira/browse/FLINK-7159 Project: Flink

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081820#comment-16081820 ] Haohui Mai commented on FLINK-6429: --- I have a patch and will upload it shortly. > Bump up Calcite

[jira] [Closed] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai closed FLINK-6568. - Resolution: Duplicate > flink-table doesn't work without flink-streaming-scala dependency >

[jira] [Resolved] (FLINK-6749) Table API / SQL Docs: SQL Page

[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-6749. --- Resolution: Fixed > Table API / SQL Docs: SQL Page > -- > >

[jira] [Updated] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6693: -- Summary: Support DATE_FORMAT function in the Table / SQL API (was: Support DATE_FORMAT function in the

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16037492#comment-16037492 ] Haohui Mai commented on FLINK-6810: --- Thanks for creating these jira. They are quite useful. Is it

[jira] [Assigned] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-5252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-5252: - Assignee: Haohui Mai > Migrate all YARN related configurations to ConfigOptions >

[jira] [Updated] (FLINK-6780) ExternalTableSource should add time attributes in the row type

[ https://issues.apache.org/jira/browse/FLINK-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6780: -- Summary: ExternalTableSource should add time attributes in the row type (was: ExternalTableSource

[jira] [Commented] (FLINK-5354) Split up Table API documentation into multiple pages

[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16030728#comment-16030728 ] Haohui Mai commented on FLINK-5354: --- Thanks [~fhueske]. I will work on the SQL page. > Split up Table

[jira] [Assigned] (FLINK-6749) Table API / SQL Docs: SQL Page

[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6749: - Assignee: Haohui Mai > Table API / SQL Docs: SQL Page > -- > >

[jira] [Created] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

Haohui Mai created FLINK-6780: - Summary: ExternalTableSource fails to add the processing time and the event time attribute in the row type Key: FLINK-6780 URL: https://issues.apache.org/jira/browse/FLINK-6780

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023587#comment-16023587 ] Haohui Mai commented on FLINK-6692: --- The issue also presents in Flink 1.2.0. > The flink-dist jar

[jira] [Created] (FLINK-6693) Support DATE_FORMAT function in the SQL API

Haohui Mai created FLINK-6693: - Summary: Support DATE_FORMAT function in the SQL API Key: FLINK-6693 URL: https://issues.apache.org/jira/browse/FLINK-6693 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-6672) Support CAST(timestamp AS BIGINT)

[ https://issues.apache.org/jira/browse/FLINK-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6672: - Assignee: Haohui Mai > Support CAST(timestamp AS BIGINT) > - > >

[jira] [Updated] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6692: -- Summary: The flink-dist jar contains unshaded netty jar (was: The flink-dist jar contains unshaded

[jira] [Created] (FLINK-6692) The flink-dist jar contains unshaded nettyjar

Haohui Mai created FLINK-6692: - Summary: The flink-dist jar contains unshaded nettyjar Key: FLINK-6692 URL: https://issues.apache.org/jira/browse/FLINK-6692 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6692) The flink-dist jar contains unshaded nettyjar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6692: -- Component/s: Build System > The flink-dist jar contains unshaded nettyjar >

[jira] [Resolved] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-6595. --- Resolution: Duplicate > Nested SQL queries do not expose proctime / rowtime attributes >

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016602#comment-16016602 ] Haohui Mai commented on FLINK-6595: --- This is addressed by FLINK-6483 via exposing the proctime in the

[jira] [Commented] (FLINK-6605) Allow users to specify a default name for processing time

[ https://issues.apache.org/jira/browse/FLINK-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013242#comment-16013242 ] Haohui Mai commented on FLINK-6605: --- Discussed with [~fhueske] offline. The proposed solution is to add

[jira] [Created] (FLINK-6605) Allow users to specify a default name for processing time

Haohui Mai created FLINK-6605: - Summary: Allow users to specify a default name for processing time Key: FLINK-6605 URL: https://issues.apache.org/jira/browse/FLINK-6605 Project: Flink Issue

[jira] [Updated] (FLINK-6605) Allow users to specify a default name for processing time

[ https://issues.apache.org/jira/browse/FLINK-6605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6605: -- Fix Version/s: 1.3.0 Component/s: Table API & SQL > Allow users to specify a default name for

[jira] [Updated] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6595: -- Component/s: Table API & SQL > Nested SQL queries do not expose proctime / rowtime attributes >

[jira] [Created] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

Haohui Mai created FLINK-6595: - Summary: Nested SQL queries do not expose proctime / rowtime attributes Key: FLINK-6595 URL: https://issues.apache.org/jira/browse/FLINK-6595 Project: Flink

[jira] [Updated] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6574: -- Summary: Support nested catalogs in ExternalCatalog (was: External catalog should support a single

[jira] [Updated] (FLINK-6574) External catalog should support a single level catalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6574: -- Priority: Critical (was: Major) > External catalog should support a single level catalog >

[jira] [Commented] (FLINK-6574) External catalog should support a single level catalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011516#comment-16011516 ] Haohui Mai commented on FLINK-6574: --- Raising the priority to critical as it introduces API changes of

[jira] [Commented] (FLINK-6529) Rework the shading model in Flink

[ https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008891#comment-16008891 ] Haohui Mai commented on FLINK-6529: --- Will do. Thanks! > Rework the shading model in Flink >

[jira] [Created] (FLINK-6574) External catalog should support a single level catalog

Haohui Mai created FLINK-6574: - Summary: External catalog should support a single level catalog Key: FLINK-6574 URL: https://issues.apache.org/jira/browse/FLINK-6574 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008821#comment-16008821 ] Haohui Mai commented on FLINK-6568: --- Hit the same issue multiple times when testing out 1.3. Are we good

[jira] [Assigned] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6569: - Assignee: Haohui Mai > flink-table KafkaJsonTableSource example doesn't work >

[jira] [Assigned] (FLINK-6568) flink-table doesn't work without flink-streaming-scala dependency

[ https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6568: - Assignee: Haohui Mai > flink-table doesn't work without flink-streaming-scala dependency >

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

[ https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6563: -- Priority: Critical (was: Major) Component/s: Table API & SQL > Expose time indicator attributes

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

Haohui Mai created FLINK-6563: - Summary: Expose time indicator attributes in the KafkaTableSource Key: FLINK-6563 URL: https://issues.apache.org/jira/browse/FLINK-6563 Project: Flink Issue Type:

[jira] [Created] (FLINK-6562) Support implicit table references for nested fields in SQL

Haohui Mai created FLINK-6562: - Summary: Support implicit table references for nested fields in SQL Key: FLINK-6562 URL: https://issues.apache.org/jira/browse/FLINK-6562 Project: Flink Issue

[jira] [Updated] (FLINK-6562) Support implicit table references for nested fields in SQL

[ https://issues.apache.org/jira/browse/FLINK-6562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6562: -- Component/s: Table API & SQL > Support implicit table references for nested fields in SQL >

[jira] [Commented] (FLINK-6529) Rework the shading model in Flink

[ https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16005350#comment-16005350 ] Haohui Mai commented on FLINK-6529: --- That makes sense as we are being hit by this problem quite hard

[jira] [Assigned] (FLINK-6529) Rework the shading model in Flink

[ https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6529: - Assignee: Haohui Mai > Rework the shading model in Flink > - > >

[jira] [Commented] (FLINK-6335) Parse DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997937#comment-15997937 ] Haohui Mai commented on FLINK-6335: --- No problem -- will do it next time. > Parse DISTINCT over grouped

[jira] [Assigned] (FLINK-6430) Remove Calcite classes for time resolution of auxiliary group functions

[ https://issues.apache.org/jira/browse/FLINK-6430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6430: - Assignee: Haohui Mai > Remove Calcite classes for time resolution of auxiliary group functions >

[jira] [Assigned] (FLINK-6424) Add basic helper functions for map type

[ https://issues.apache.org/jira/browse/FLINK-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6424: - Assignee: Haohui Mai > Add basic helper functions for map type >

[jira] [Created] (FLINK-6377) Support map types in the Table / SQL API

Haohui Mai created FLINK-6377: - Summary: Support map types in the Table / SQL API Key: FLINK-6377 URL: https://issues.apache.org/jira/browse/FLINK-6377 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

Haohui Mai created FLINK-6373: - Summary: Add runtime support for distinct aggregation over grouped windows Key: FLINK-6373 URL: https://issues.apache.org/jira/browse/FLINK-6373 Project: Flink

[jira] [Updated] (FLINK-6335) Parse DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6335: -- Summary: Parse DISTINCT over grouped window in stream SQL (was: Support DISTINCT over grouped window

[jira] [Commented] (FLINK-6335) Support DISTINCT over grouped window in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976845#comment-15976845 ] Haohui Mai commented on FLINK-6335: --- The scope of this jira is about supporting the DISTINCT keyword

[jira] [Created] (FLINK-6335) Support DISTINCT over grouped window in stream SQL

Haohui Mai created FLINK-6335: - Summary: Support DISTINCT over grouped window in stream SQL Key: FLINK-6335 URL: https://issues.apache.org/jira/browse/FLINK-6335 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6281) Create TableSink for JDBC

Haohui Mai created FLINK-6281: - Summary: Create TableSink for JDBC Key: FLINK-6281 URL: https://issues.apache.org/jira/browse/FLINK-6281 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5622) Support tumbling window on batch tables in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai closed FLINK-5622. - Resolution: Duplicate > Support tumbling window on batch tables in the SQL API >

[jira] [Commented] (FLINK-5622) Support tumbling window on batch tables in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961476#comment-15961476 ] Haohui Mai commented on FLINK-5622: --- I think so. Thanks for the reminder. I'll close this jira. >

[jira] [Assigned] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6225: - Assignee: Haohui Mai > Support Row Stream for CassandraSink >

[jira] [Updated] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6012: -- Summary: Support WindowStart / WindowEnd functions in streaming SQL (was: Support WindowStart /

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958592#comment-15958592 ] Haohui Mai commented on FLINK-6012: --- I'm okay with either way, but I think we have a decent chance to

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956510#comment-15956510 ] Haohui Mai commented on FLINK-6261: --- That's even better -- looking forward to the PR :-) > Add support

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956108#comment-15956108 ] Haohui Mai commented on FLINK-6261: --- [~fhueske], I am interested in contributing this feature. If you

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951280#comment-15951280 ] Haohui Mai commented on FLINK-5998: --- All failed tests passed locally. :-| [~rmetzger], is it possible

[jira] [Created] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

Haohui Mai created FLINK-6217: - Summary: ContaineredTaskManagerParameters sets off heap memory size incorrectly Key: FLINK-6217 URL: https://issues.apache.org/jira/browse/FLINK-6217 Project: Flink

[jira] [Commented] (FLINK-5668) passing taskmanager configuration through taskManagerEnv instead of file

[ https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946785#comment-15946785 ] Haohui Mai commented on FLINK-5668: --- Sorry for the delayed response. Our main requirement is to allow

[jira] [Commented] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

[ https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946043#comment-15946043 ] Haohui Mai commented on FLINK-6209: --- We found that FLINK-5808 removes this snippet of code that causes

[jira] [Created] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

Haohui Mai created FLINK-6209: - Summary: StreamPlanEnvironment always has a parallelism of 1 Key: FLINK-6209 URL: https://issues.apache.org/jira/browse/FLINK-6209 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943938#comment-15943938 ] Haohui Mai commented on FLINK-5829: --- Unfortunately it seems that it is infeasible to inherit and forward

[jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available

[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941637#comment-15941637 ] Haohui Mai commented on FLINK-5829: --- I just pushed a PR. The migration process is relatively

[jira] [Commented] (FLINK-5570) Support register external catalog to table environment

[ https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939344#comment-15939344 ] Haohui Mai commented on FLINK-5570: --- I think the APIs of the PR looks good to me overall. One question

[jira] [Commented] (FLINK-6102) Update protobuf to latest version

[ https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934151#comment-15934151 ] Haohui Mai commented on FLINK-6102: --- I would recommend keeping it as is. The problem is that the whole

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934054#comment-15934054 ] Haohui Mai commented on FLINK-5998: --- Sorry for the delay I'm just busy on other issues -- I'll take care

[jira] [Commented] (FLINK-5570) Support register external catalog to table environment

[ https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15928975#comment-15928975 ] Haohui Mai commented on FLINK-5570: --- Thanks for the ping, [~fhueske]. Please allow me for a day or two

[jira] [Commented] (FLINK-6033) Support UNNEST query in the stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922923#comment-15922923 ] Haohui Mai commented on FLINK-6033: --- Discussed offline with [~fhueske] -- the proposed approach is to

  1   2   >