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
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 Feature
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 Featu
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:
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 Ty
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: Tec
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
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
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
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
Pr
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
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: Su
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 Type
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
Is
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
Is
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
I
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
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 Ty
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
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
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: Sub
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 Typ
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
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
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
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
Jark Wu created FLINK-29121:
---
Summary:
SqlGatewayRestAPIStabilityTest.testSqlGatewayRestAPIStability is failed
Key: FLINK-29121
URL: https://issues.apache.org/jira/browse/FLINK-29121
Project: Flink
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
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: B
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
I
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
Co
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
Component
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:
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
Issu
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
Is
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
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
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: Bu
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
Issue
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: Imp
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
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 Typ
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 Fea
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: Sub-task
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: Fl
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
Components
Jark Wu created FLINK-22365:
---
Summary: Images are not displayed in "Data Sources" documentation
page
Key: FLINK-22365
URL: https://issues.apache.org/jira/browse/FLINK-22365
Project: Flink
Issue Ty
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
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:
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
Proj
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
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: Sub-ta
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: Sub-ta
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
Iss
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 Type
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
I
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
Issu
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
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
Is
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
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
Co
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
C
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: S
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
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
Is
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
Components:
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
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
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
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: Sub-tas
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
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
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
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
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: Su
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:
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
Iss
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
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
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 Typ
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
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
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 Ty
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
Com
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: I
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: I
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: I
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: I
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
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 Typ
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 Ty
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:
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
Compone
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
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
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
Jark Wu created FLINK-21265:
---
Summary: SQLClientSchemaRegistryITCase.testReading failed with
DockerClientException unauthorized
Key: FLINK-21265
URL: https://issues.apache.org/jira/browse/FLINK-21265
Projec
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
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
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
1 - 100 of 583 matches
Mail list logo