[jira] [Created] (FLINK-34654) Add "Special Thanks" Page on the Flink Website

Jark Wu created FLINK-34654: --- Summary: Add "Special Thanks" Page on the Flink Website Key: FLINK-34654 URL: https://issues.apache.org/jira/browse/FLINK-34654 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33600) Print cost time for batch queries in SQL Client

Jark Wu created FLINK-33600: --- Summary: Print cost time for batch queries in SQL Client Key: FLINK-33600 URL: https://issues.apache.org/jira/browse/FLINK-33600 Project: Flink Issue Type: New

[jira] [Created] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

Jark Wu created FLINK-32444: --- Summary: Enable object reuse for Flink SQL jobs by default Key: FLINK-32444 URL: https://issues.apache.org/jira/browse/FLINK-32444 Project: Flink Issue Type: New

[jira] [Created] (FLINK-31598) Cleanup usage of deprecated TableEnvironment#registerTable

Jark Wu created FLINK-31598: --- Summary: Cleanup usage of deprecated TableEnvironment#registerTable Key: FLINK-31598 URL: https://issues.apache.org/jira/browse/FLINK-31598 Project: Flink Issue Type:

[jira] [Created] (FLINK-31597) Cleanup usage of deprecated TableEnvironment#registerFunction

Jark Wu created FLINK-31597: --- Summary: Cleanup usage of deprecated TableEnvironment#registerFunction Key: FLINK-31597 URL: https://issues.apache.org/jira/browse/FLINK-31597 Project: Flink Issue

[jira] [Created] (FLINK-31596) Cleanup usage of deprecated methods in TableEnvironment

Jark Wu created FLINK-31596: --- Summary: Cleanup usage of deprecated methods in TableEnvironment Key: FLINK-31596 URL: https://issues.apache.org/jira/browse/FLINK-31596 Project: Flink Issue Type:

[jira] [Created] (FLINK-31576) Add JavaDoc that SqlNodeConverter.getCatalogManager is discouraged to use

Jark Wu created FLINK-31576: --- Summary: Add JavaDoc that SqlNodeConverter.getCatalogManager is discouraged to use Key: FLINK-31576 URL: https://issues.apache.org/jira/browse/FLINK-31576 Project: Flink

[jira] [Created] (FLINK-31550) Replace deprecated TableSchema with Schema in OperationConverterUtils

Jark Wu created FLINK-31550: --- Summary: Replace deprecated TableSchema with Schema in OperationConverterUtils Key: FLINK-31550 URL: https://issues.apache.org/jira/browse/FLINK-31550 Project: Flink

[jira] [Created] (FLINK-31517) Move execution logic of AddJarOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31517: --- Summary: Move execution logic of AddJarOperation out from TableEnvironmentImpl Key: FLINK-31517 URL: https://issues.apache.org/jira/browse/FLINK-31517 Project: Flink

[jira] [Created] (FLINK-31516) Move execution logic of LoadModule and UnloadModule operations out from TableEnvironmentImpl

Jark Wu created FLINK-31516: --- Summary: Move execution logic of LoadModule and UnloadModule operations out from TableEnvironmentImpl Key: FLINK-31516 URL: https://issues.apache.org/jira/browse/FLINK-31516

[jira] [Created] (FLINK-31515) Move execution logic of AnalyzeTableOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31515: --- Summary: Move execution logic of AnalyzeTableOperation out from TableEnvironmentImpl Key: FLINK-31515 URL: https://issues.apache.org/jira/browse/FLINK-31515 Project: Flink

[jira] [Created] (FLINK-31514) Move query SqlNode conversion logic to SqlQueryConverter

Jark Wu created FLINK-31514: --- Summary: Move query SqlNode conversion logic to SqlQueryConverter Key: FLINK-31514 URL: https://issues.apache.org/jira/browse/FLINK-31514 Project: Flink Issue Type:

[jira] [Created] (FLINK-31512) Move SqlAlterView conversion logic to SqlAlterViewConverter

Jark Wu created FLINK-31512: --- Summary: Move SqlAlterView conversion logic to SqlAlterViewConverter Key: FLINK-31512 URL: https://issues.apache.org/jira/browse/FLINK-31512 Project: Flink Issue

[jira] [Created] (FLINK-31507) Move execution logic of ShowOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31507: --- Summary: Move execution logic of ShowOperation out from TableEnvironmentImpl Key: FLINK-31507 URL: https://issues.apache.org/jira/browse/FLINK-31507 Project: Flink

[jira] [Created] (FLINK-31505) Move execution logic of DropOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31505: --- Summary: Move execution logic of DropOperation out from TableEnvironmentImpl Key: FLINK-31505 URL: https://issues.apache.org/jira/browse/FLINK-31505 Project: Flink

[jira] [Created] (FLINK-31506) Move execution logic of AlterOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31506: --- Summary: Move execution logic of AlterOperation out from TableEnvironmentImpl Key: FLINK-31506 URL: https://issues.apache.org/jira/browse/FLINK-31506 Project: Flink

[jira] [Created] (FLINK-31504) Move execution logic of CreateOperation out from TableEnvironmentImpl

Jark Wu created FLINK-31504: --- Summary: Move execution logic of CreateOperation out from TableEnvironmentImpl Key: FLINK-31504 URL: https://issues.apache.org/jira/browse/FLINK-31504 Project: Flink

[jira] [Created] (FLINK-31501) Move SqlCreateView conversion logic to SqlCreateViewConverter

Jark Wu created FLINK-31501: --- Summary: Move SqlCreateView conversion logic to SqlCreateViewConverter Key: FLINK-31501 URL: https://issues.apache.org/jira/browse/FLINK-31501 Project: Flink Issue

[jira] [Created] (FLINK-31500) Move SqlAlterTableSchema conversion logic to AlterTableSchemaConverter

Jark Wu created FLINK-31500: --- Summary: Move SqlAlterTableSchema conversion logic to AlterTableSchemaConverter Key: FLINK-31500 URL: https://issues.apache.org/jira/browse/FLINK-31500 Project: Flink

[jira] [Created] (FLINK-31499) Move SqlCreateTable conversion logic to SqlCreateTableConverter

Jark Wu created FLINK-31499: --- Summary: Move SqlCreateTable conversion logic to SqlCreateTableConverter Key: FLINK-31499 URL: https://issues.apache.org/jira/browse/FLINK-31499 Project: Flink Issue

[jira] [Created] (FLINK-31450) Introduce ExecutableOperation for operations to execute

Jark Wu created FLINK-31450: --- Summary: Introduce ExecutableOperation for operations to execute Key: FLINK-31450 URL: https://issues.apache.org/jira/browse/FLINK-31450 Project: Flink Issue Type:

[jira] [Created] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

Jark Wu created FLINK-31368: --- Summary: Move operation execution logic out from TableEnvironmentImpl Key: FLINK-31368 URL: https://issues.apache.org/jira/browse/FLINK-31368 Project: Flink Issue

[jira] [Created] (FLINK-30129) Push projection through ChangelogNormalize

Jark Wu created FLINK-30129: --- Summary: Push projection through ChangelogNormalize Key: FLINK-30129 URL: https://issues.apache.org/jira/browse/FLINK-30129 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29942) Improve average performance for TPC-DS

Jark Wu created FLINK-29942: --- Summary: Improve average performance for TPC-DS Key: FLINK-29942 URL: https://issues.apache.org/jira/browse/FLINK-29942 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29941) Support SQL Client connects to SQL Gateway

Jark Wu created FLINK-29941: --- Summary: Support SQL Client connects to SQL Gateway Key: FLINK-29941 URL: https://issues.apache.org/jira/browse/FLINK-29941 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

Jark Wu created FLINK-29370: --- Summary: Protobuf in flink-sql-protobuf is not shaded Key: FLINK-29370 URL: https://issues.apache.org/jira/browse/FLINK-29370 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29121) SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed

Jark Wu created FLINK-29121: --- Summary: SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed Key: FLINK-29121 URL: https://issues.apache.org/jira/browse/FLINK-29121 Project: Flink

[jira] [Created] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

Jark Wu created FLINK-28844: --- Summary: YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator Key: FLINK-28844 URL: https://issues.apache.org/jira/browse/FLINK-28844 Project: Flink

[jira] [Created] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

Jark Wu created FLINK-28620: --- Summary: SQL Client doesn't properly print values of INTERVAL type Key: FLINK-28620 URL: https://issues.apache.org/jira/browse/FLINK-28620 Project: Flink Issue Type:

[jira] [Created] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

Jark Wu created FLINK-27369: --- Summary: COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch Key: FLINK-27369 URL: https://issues.apache.org/jira/browse/FLINK-27369 Project: Flink

[jira] [Created] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

Jark Wu created FLINK-27368: --- Summary: CAST(' 1 ' as BIGINT) reutrns wrong result Key: FLINK-27368 URL: https://issues.apache.org/jira/browse/FLINK-27368 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27367) CAST between INT and DATE is broken

Jark Wu created FLINK-27367: --- Summary: CAST between INT and DATE is broken Key: FLINK-27367 URL: https://issues.apache.org/jira/browse/FLINK-27367 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27301) KafkaSourceE2ECase#restartFromSavepoint is failed on Azure

Jark Wu created FLINK-27301: --- Summary: KafkaSourceE2ECase#restartFromSavepoint is failed on Azure Key: FLINK-27301 URL: https://issues.apache.org/jira/browse/FLINK-27301 Project: Flink Issue Type:

[jira] [Created] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

Jark Wu created FLINK-26541: --- Summary: SQL Client should support submitting SQL jobs in application mode Key: FLINK-26541 URL: https://issues.apache.org/jira/browse/FLINK-26541 Project: Flink

[jira] [Created] (FLINK-26077) Support operators send request to Coordinator and return a response

Jark Wu created FLINK-26077: --- Summary: Support operators send request to Coordinator and return a response Key: FLINK-26077 URL: https://issues.apache.org/jira/browse/FLINK-26077 Project: Flink

[jira] [Created] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

Jark Wu created FLINK-24607: --- Summary: SourceCoordinator may miss to close SplitEnumerator when failover frequently Key: FLINK-24607 URL: https://issues.apache.org/jira/browse/FLINK-24607 Project: Flink

[jira] [Created] (FLINK-24512) Allow metadata columns can also be part of primary key

Jark Wu created FLINK-24512: --- Summary: Allow metadata columns can also be part of primary key Key: FLINK-24512 URL: https://issues.apache.org/jira/browse/FLINK-24512 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24511) "sink.parallelism" doesn't work for upsert "values" sink

Jark Wu created FLINK-24511: --- Summary: "sink.parallelism" doesn't work for upsert "values" sink Key: FLINK-24511 URL: https://issues.apache.org/jira/browse/FLINK-24511 Project: Flink Issue Type:

[jira] [Created] (FLINK-24204) Failed to insert nested types using value constructed functions

Jark Wu created FLINK-24204: --- Summary: Failed to insert nested types using value constructed functions Key: FLINK-24204 URL: https://issues.apache.org/jira/browse/FLINK-24204 Project: Flink

[jira] [Created] (FLINK-24026) Fix FLIP-XXX link can't be recognized correctly by IDEA

Jark Wu created FLINK-24026: --- Summary: Fix FLIP-XXX link can't be recognized correctly by IDEA Key: FLINK-24026 URL: https://issues.apache.org/jira/browse/FLINK-24026 Project: Flink Issue Type:

[jira] [Created] (FLINK-23848) PulsarSourceITCase is failed on Azure

Jark Wu created FLINK-23848: --- Summary: PulsarSourceITCase is failed on Azure Key: FLINK-23848 URL: https://issues.apache.org/jira/browse/FLINK-23848 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

Jark Wu created FLINK-23012: --- Summary: Add v1.13 docs link in "Pick Docs Version" for master branch Key: FLINK-23012 URL: https://issues.apache.org/jira/browse/FLINK-23012 Project: Flink Issue

[jira] [Created] (FLINK-22936) Support column comment in Schema and ResolvedSchema

Jark Wu created FLINK-22936: --- Summary: Support column comment in Schema and ResolvedSchema Key: FLINK-22936 URL: https://issues.apache.org/jira/browse/FLINK-22936 Project: Flink Issue Type: New

[jira] [Created] (FLINK-22540) Remove YAML environment file support in SQL Client

Jark Wu created FLINK-22540: --- Summary: Remove YAML environment file support in SQL Client Key: FLINK-22540 URL: https://issues.apache.org/jira/browse/FLINK-22540 Project: Flink Issue Type:

[jira] [Created] (FLINK-22523) TUMBLE TVF should throw helpful exception when specifying second interval parameter

Jark Wu created FLINK-22523: --- Summary: TUMBLE TVF should throw helpful exception when specifying second interval parameter Key: FLINK-22523 URL: https://issues.apache.org/jira/browse/FLINK-22523 Project:

[jira] [Created] (FLINK-22522) BytesHashMap has many verbose logs

Jark Wu created FLINK-22522: --- Summary: BytesHashMap has many verbose logs Key: FLINK-22522 URL: https://issues.apache.org/jira/browse/FLINK-22522 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

Jark Wu created FLINK-22356: --- Summary: Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type Key: FLINK-22356 URL: https://issues.apache.org/jira/browse/FLINK-22356

[jira] [Created] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

Jark Wu created FLINK-22354: --- Summary: Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP Key: FLINK-22354 URL: https://issues.apache.org/jira/browse/FLINK-22354 Project:

[jira] [Created] (FLINK-22349) LOCALTIMESTAMP doesn't return correct result when setting session time zone to 'UTC-09:00'

Jark Wu created FLINK-22349: --- Summary: LOCALTIMESTAMP doesn't return correct result when setting session time zone to 'UTC-09:00' Key: FLINK-22349 URL: https://issues.apache.org/jira/browse/FLINK-22349

[jira] [Created] (FLINK-22346) sql-client-defaults.yaml should be removed from dist

Jark Wu created FLINK-22346: --- Summary: sql-client-defaults.yaml should be removed from dist Key: FLINK-22346 URL: https://issues.apache.org/jira/browse/FLINK-22346 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

Jark Wu created FLINK-22318: --- Summary: Support RENAME column name for ALTER TABLE statement Key: FLINK-22318 URL: https://issues.apache.org/jira/browse/FLINK-22318 Project: Flink Issue Type:

[jira] [Created] (FLINK-22319) Support RESET table option for ALTER TABLE statement

Jark Wu created FLINK-22319: --- Summary: Support RESET table option for ALTER TABLE statement Key: FLINK-22319 URL: https://issues.apache.org/jira/browse/FLINK-22319 Project: Flink Issue Type:

[jira] [Created] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

Jark Wu created FLINK-22317: --- Summary: Support DROP column/constraint/watermark for ALTER TABLE statement Key: FLINK-22317 URL: https://issues.apache.org/jira/browse/FLINK-22317 Project: Flink

[jira] [Created] (FLINK-22320) Add documentation for new introduced ALTER TABLE statements

Jark Wu created FLINK-22320: --- Summary: Add documentation for new introduced ALTER TABLE statements Key: FLINK-22320 URL: https://issues.apache.org/jira/browse/FLINK-22320 Project: Flink Issue

[jira] [Created] (FLINK-22316) Support MODIFY column/constraint/watermark for ALTER TABLE statement

Jark Wu created FLINK-22316: --- Summary: Support MODIFY column/constraint/watermark for ALTER TABLE statement Key: FLINK-22316 URL: https://issues.apache.org/jira/browse/FLINK-22316 Project: Flink

[jira] [Created] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

Jark Wu created FLINK-22315: --- Summary: Support ADD column/constraint/watermark for ALTER TABLE statement Key: FLINK-22315 URL: https://issues.apache.org/jira/browse/FLINK-22315 Project: Flink

[jira] [Created] (FLINK-22314) AggRecordsCombiner should combine buffered records first instead of accumulate on state directly

Jark Wu created FLINK-22314: --- Summary: AggRecordsCombiner should combine buffered records first instead of accumulate on state directly Key: FLINK-22314 URL: https://issues.apache.org/jira/browse/FLINK-22314

[jira] [Created] (FLINK-22302) Restructure SQL "Queries" documentation into one page per operation

Jark Wu created FLINK-22302: --- Summary: Restructure SQL "Queries" documentation into one page per operation Key: FLINK-22302 URL: https://issues.apache.org/jira/browse/FLINK-22302 Project: Flink

[jira] [Created] (FLINK-22261) Python StreamingModeDataStreamTests is failed on Azure

Jark Wu created FLINK-22261: --- Summary: Python StreamingModeDataStreamTests is failed on Azure Key: FLINK-22261 URL: https://issues.apache.org/jira/browse/FLINK-22261 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22161) 'Run Mesos WordCount test' failed on Azure

Jark Wu created FLINK-22161: --- Summary: 'Run Mesos WordCount test' failed on Azure Key: FLINK-22161 URL: https://issues.apache.org/jira/browse/FLINK-22161 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22160) Test Window TVF based aggregation and TopN

Jark Wu created FLINK-22160: --- Summary: Test Window TVF based aggregation and TopN Key: FLINK-22160 URL: https://issues.apache.org/jira/browse/FLINK-22160 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-22159) Add documentation for the new window TVF based operations

Jark Wu created FLINK-22159: --- Summary: Add documentation for the new window TVF based operations Key: FLINK-22159 URL: https://issues.apache.org/jira/browse/FLINK-22159 Project: Flink Issue Type:

[jira] [Created] (FLINK-22080) Refactor SqlClient for better testing

Jark Wu created FLINK-22080: --- Summary: Refactor SqlClient for better testing Key: FLINK-22080 URL: https://issues.apache.org/jira/browse/FLINK-22080 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22011) Support local global optimization for window aggregation in runtime

Jark Wu created FLINK-22011: --- Summary: Support local global optimization for window aggregation in runtime Key: FLINK-22011 URL: https://issues.apache.org/jira/browse/FLINK-22011 Project: Flink

[jira] [Created] (FLINK-21997) Add back missing jdbc.md zh docs

Jark Wu created FLINK-21997: --- Summary: Add back missing jdbc.md zh docs Key: FLINK-21997 URL: https://issues.apache.org/jira/browse/FLINK-21997 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-21909) Unify API and implementation for Hive and Filesystem source connector

Jark Wu created FLINK-21909: --- Summary: Unify API and implementation for Hive and Filesystem source connector Key: FLINK-21909 URL: https://issues.apache.org/jira/browse/FLINK-21909 Project: Flink

[jira] [Created] (FLINK-21908) Support HiveSource to emit watermarks which is extract from partition values

Jark Wu created FLINK-21908: --- Summary: Support HiveSource to emit watermarks which is extract from partition values Key: FLINK-21908 URL: https://issues.apache.org/jira/browse/FLINK-21908 Project: Flink

[jira] [Created] (FLINK-21907) Support watermark syntax for Hive DDL dialect

Jark Wu created FLINK-21907: --- Summary: Support watermark syntax for Hive DDL dialect Key: FLINK-21907 URL: https://issues.apache.org/jira/browse/FLINK-21907 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21906) Support computed column syntax for Hive DDL dialect

Jark Wu created FLINK-21906: --- Summary: Support computed column syntax for Hive DDL dialect Key: FLINK-21906 URL: https://issues.apache.org/jira/browse/FLINK-21906 Project: Flink Issue Type:

[jira] [Created] (FLINK-21905) Hive streaming source should use FIFO FileSplitAssigner instead of LIFO

Jark Wu created FLINK-21905: --- Summary: Hive streaming source should use FIFO FileSplitAssigner instead of LIFO Key: FLINK-21905 URL: https://issues.apache.org/jira/browse/FLINK-21905 Project: Flink

[jira] [Created] (FLINK-21899) Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source

Jark Wu created FLINK-21899: --- Summary: Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source Key: FLINK-21899 URL: https://issues.apache.org/jira/browse/FLINK-21899 Project: Flink

[jira] [Created] (FLINK-21894) Update type of HiveTablePartition#partitionSpec from Map to Map

Jark Wu created FLINK-21894: --- Summary: Update type of HiveTablePartition#partitionSpec from Map to Map Key: FLINK-21894 URL: https://issues.apache.org/jira/browse/FLINK-21894 Project: Flink Issue

[jira] [Created] (FLINK-21892) Add documentation for the DESC statement syntax

Jark Wu created FLINK-21892: --- Summary: Add documentation for the DESC statement syntax Key: FLINK-21892 URL: https://issues.apache.org/jira/browse/FLINK-21892 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21881) Support local global optimization for window aggregation

Jark Wu created FLINK-21881: --- Summary: Support local global optimization for window aggregation Key: FLINK-21881 URL: https://issues.apache.org/jira/browse/FLINK-21881 Project: Flink Issue Type:

[jira] [Created] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

Jark Wu created FLINK-21871: --- Summary: Support watermark for Hive and Filesystem streaming source Key: FLINK-21871 URL: https://issues.apache.org/jira/browse/FLINK-21871 Project: Flink Issue Type:

[jira] [Created] (FLINK-21774) Do not display column names when retrun set is emtpy in SQL Client

Jark Wu created FLINK-21774: --- Summary: Do not display column names when retrun set is emtpy in SQL Client Key: FLINK-21774 URL: https://issues.apache.org/jira/browse/FLINK-21774 Project: Flink

[jira] [Created] (FLINK-21741) Support SHOW JARS statement in SQL Client

Jark Wu created FLINK-21741: --- Summary: Support SHOW JARS statement in SQL Client Key: FLINK-21741 URL: https://issues.apache.org/jira/browse/FLINK-21741 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21742) Support REMOVE JAR statement in SQL Client

Jark Wu created FLINK-21742: --- Summary: Support REMOVE JAR statement in SQL Client Key: FLINK-21742 URL: https://issues.apache.org/jira/browse/FLINK-21742 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12

Jark Wu created FLINK-21725: --- Summary: DataTypeExtractor extracts wrong fields ordering for Tuple12 Key: FLINK-21725 URL: https://issues.apache.org/jira/browse/FLINK-21725 Project: Flink Issue

[jira] [Created] (FLINK-21669) Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client

Jark Wu created FLINK-21669: --- Summary: Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client Key: FLINK-21669 URL: https://issues.apache.org/jira/browse/FLINK-21669

[jira] [Created] (FLINK-21664) Support STATEMENT SET syntax in TableEnvironment

Jark Wu created FLINK-21664: --- Summary: Support STATEMENT SET syntax in TableEnvironment Key: FLINK-21664 URL: https://issues.apache.org/jira/browse/FLINK-21664 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

Jark Wu created FLINK-21647: --- Summary: 'Run kubernetes session test (default input)' failed on Azure Key: FLINK-21647 URL: https://issues.apache.org/jira/browse/FLINK-21647 Project: Flink Issue

[jira] [Created] (FLINK-21634) ALTER TABLE statement enhancement

Jark Wu created FLINK-21634: --- Summary: ALTER TABLE statement enhancement Key: FLINK-21634 URL: https://issues.apache.org/jira/browse/FLINK-21634 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21618) Introduce a new integration test framework for SQL Client

Jark Wu created FLINK-21618: --- Summary: Introduce a new integration test framework for SQL Client Key: FLINK-21618 URL: https://issues.apache.org/jira/browse/FLINK-21618 Project: Flink Issue Type:

[jira] [Created] (FLINK-21616) Introduce a new integration test framework for SQL Client

Jark Wu created FLINK-21616: --- Summary: Introduce a new integration test framework for SQL Client Key: FLINK-21616 URL: https://issues.apache.org/jira/browse/FLINK-21616 Project: Flink Issue Type:

[jira] [Created] (FLINK-21614) Introduce a new integration test framework for SQL Client

Jark Wu created FLINK-21614: --- Summary: Introduce a new integration test framework for SQL Client Key: FLINK-21614 URL: https://issues.apache.org/jira/browse/FLINK-21614 Project: Flink Issue Type:

[jira] [Created] (FLINK-21615) Introduce a new integration test framework for SQL Client

Jark Wu created FLINK-21615: --- Summary: Introduce a new integration test framework for SQL Client Key: FLINK-21615 URL: https://issues.apache.org/jira/browse/FLINK-21615 Project: Flink Issue Type:

[jira] [Created] (FLINK-21579) Support "SHOW USER FUNCTIONS" statement

Jark Wu created FLINK-21579: --- Summary: Support "SHOW USER FUNCTIONS" statement Key: FLINK-21579 URL: https://issues.apache.org/jira/browse/FLINK-21579 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

Jark Wu created FLINK-21553: --- Summary: WindowDistinctAggregateITCase#testHopWindow_Cube is unstable Key: FLINK-21553 URL: https://issues.apache.org/jira/browse/FLINK-21553 Project: Flink Issue

[jira] [Created] (FLINK-21542) Add documentation for supporting INSERT INTO specific columns

Jark Wu created FLINK-21542: --- Summary: Add documentation for supporting INSERT INTO specific columns Key: FLINK-21542 URL: https://issues.apache.org/jira/browse/FLINK-21542 Project: Flink Issue

[jira] [Created] (FLINK-21456) TableResult#print() should correctly stringify values of TIMESTAMP type in SQL format

Jark Wu created FLINK-21456: --- Summary: TableResult#print() should correctly stringify values of TIMESTAMP type in SQL format Key: FLINK-21456 URL: https://issues.apache.org/jira/browse/FLINK-21456 Project:

[jira] [Created] (FLINK-21327) Support window TVF in batch mode

Jark Wu created FLINK-21327: --- Summary: Support window TVF in batch mode Key: FLINK-21327 URL: https://issues.apache.org/jira/browse/FLINK-21327 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21305) Cumulative window should accumulate late events belonging to the cleaned slice

Jark Wu created FLINK-21305: --- Summary: Cumulative window should accumulate late events belonging to the cleaned slice Key: FLINK-21305 URL: https://issues.apache.org/jira/browse/FLINK-21305 Project: Flink

[jira] [Created] (FLINK-21304) Support split distinct aggregate for window TVF based aggregate

Jark Wu created FLINK-21304: --- Summary: Support split distinct aggregate for window TVF based aggregate Key: FLINK-21304 URL: https://issues.apache.org/jira/browse/FLINK-21304 Project: Flink Issue

[jira] [Created] (FLINK-21290) Support Projection push down for Window TVF

Jark Wu created FLINK-21290: --- Summary: Support Projection push down for Window TVF Key: FLINK-21290 URL: https://issues.apache.org/jira/browse/FLINK-21290 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21265) SQLClientSchemaRegistryITCase.testReading failed with DockerClientException unauthorized

Jark Wu created FLINK-21265: --- Summary: SQLClientSchemaRegistryITCase.testReading failed with DockerClientException unauthorized Key: FLINK-21265 URL: https://issues.apache.org/jira/browse/FLINK-21265

[jira] [Created] (FLINK-21261) Improve digest of physical Expand node

Jark Wu created FLINK-21261: --- Summary: Improve digest of physical Expand node Key: FLINK-21261 URL: https://issues.apache.org/jira/browse/FLINK-21261 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21191) Support reducing buffer for upsert-kafka sink

Jark Wu created FLINK-21191: --- Summary: Support reducing buffer for upsert-kafka sink Key: FLINK-21191 URL: https://issues.apache.org/jira/browse/FLINK-21191 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21176) Translate updates on Confluent Avro Format page

Jark Wu created FLINK-21176: --- Summary: Translate updates on Confluent Avro Format page Key: FLINK-21176 URL: https://issues.apache.org/jira/browse/FLINK-21176 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-21109) Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API

Jark Wu created FLINK-21109: --- Summary: Introduce "retractAccumulators" interface for AggregateFunction in Table/SQL API Key: FLINK-21109 URL: https://issues.apache.org/jira/browse/FLINK-21109 Project:

  1   2   3   4   5   6   >