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

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

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

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

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

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

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

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

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

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

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

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

[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] [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] [Created] (FLINK-6033) Support UNNEST query in the stream SQL api

Haohui Mai created FLINK-6033: - Summary: Support UNNEST query in the stream SQL api Key: FLINK-6033 URL: https://issues.apache.org/jira/browse/FLINK-6033 Project: Flink Issue Type: Improvement

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

Haohui Mai created FLINK-6012: - Summary: Support WindowStart / WindowEnd functions in stream SQL Key: FLINK-6012 URL: https://issues.apache.org/jira/browse/FLINK-6012 Project: Flink Issue Type: S

[jira] [Created] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

Haohui Mai created FLINK-6011: - Summary: Support TUMBLE, HOP, SESSION window in streaming SQL Key: FLINK-6011 URL: https://issues.apache.org/jira/browse/FLINK-6011 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-5954) Always assign names to the window in the Stream SQL APi

Haohui Mai created FLINK-5954: - Summary: Always assign names to the window in the Stream SQL APi Key: FLINK-5954 URL: https://issues.apache.org/jira/browse/FLINK-5954 Project: Flink Issue Type: I

[jira] [Created] (FLINK-5931) Make Flink highly available even if defaultFS is unavailable

Haohui Mai created FLINK-5931: - Summary: Make Flink highly available even if defaultFS is unavailable Key: FLINK-5931 URL: https://issues.apache.org/jira/browse/FLINK-5931 Project: Flink Issue T

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

Haohui Mai created FLINK-5725: - Summary: Support JOIN between two streams in the SQL API Key: FLINK-5725 URL: https://issues.apache.org/jira/browse/FLINK-5725 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-5631) [yarn] Support downloading additional jars from non-HDFS paths

Haohui Mai created FLINK-5631: - Summary: [yarn] Support downloading additional jars from non-HDFS paths Key: FLINK-5631 URL: https://issues.apache.org/jira/browse/FLINK-5631 Project: Flink Issue

[jira] [Created] (FLINK-5583) Support flexible error handling in the Kafka consumer

Haohui Mai created FLINK-5583: - Summary: Support flexible error handling in the Kafka consumer Key: FLINK-5583 URL: https://issues.apache.org/jira/browse/FLINK-5583 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml

Haohui Mai created FLINK-5489: - Summary: maven release:prepare fails due to invalid JDOM comments in pom.xml Key: FLINK-5489 URL: https://issues.apache.org/jira/browse/FLINK-5489 Project: Flink