[jira] [Updated] (FLINK-30467) Improve the accuracy of estimating the row count of LocalHashAgg to make more two-phase HashAgg operators effective

[ https://issues.apache.org/jira/browse/FLINK-30467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30467: Fix Version/s: (was: 1.19.0) > Improve the accuracy of estimating the row count of LocalHashAg

[jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15460: Fix Version/s: (was: 1.19.0) > planner dependencies won't be necessary for JDBC connector > --

[jira] [Updated] (FLINK-25345) FLIP-196: Source API stability guarantees

[ https://issues.apache.org/jira/browse/FLINK-25345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25345: Fix Version/s: (was: 1.19.0) > FLIP-196: Source API stability guarantees > ---

[jira] [Updated] (FLINK-31664) Add ARRAY_INTERSECT supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31664: Fix Version/s: (was: 1.19.0) > Add ARRAY_INTERSECT supported in SQL & Table API >

[jira] [Updated] (FLINK-26144) SavepointFormatITCase did NOT fail with changelog.enabled randomized

[ https://issues.apache.org/jira/browse/FLINK-26144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26144: Fix Version/s: (was: 1.19.0) > SavepointFormatITCase did NOT fail with changelog.enabled rando

[jira] [Updated] (FLINK-32983) Support setting env.java.opts.all & env.java.opts.cli configs via dynamic properties on the CLI side

[ https://issues.apache.org/jira/browse/FLINK-32983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32983: Fix Version/s: (was: 1.19.0) > Support setting env.java.opts.all & env.java.opts.cli configs v

[jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs

[ https://issues.apache.org/jira/browse/FLINK-20818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20818: Fix Version/s: (was: 1.19.0) > End to end test produce excessive amount of logs >

[jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value

[ https://issues.apache.org/jira/browse/FLINK-29058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29058: Fix Version/s: (was: 1.19.0) > Analyze table xxx For columns will thrown error while encounter

[jira] [Updated] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement

[ https://issues.apache.org/jira/browse/FLINK-29343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29343: Fix Version/s: (was: 1.19.0) > Fix fail to execute ddl in HiveDialect when use specifc catalog

[jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username

[ https://issues.apache.org/jira/browse/FLINK-19562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19562: Fix Version/s: (was: 1.19.0) > the /flink/docs/docker/run.sh cause an error with numeric usern

[jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax

[ https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29368: Fix Version/s: (was: 1.19.0) > Modify DESCRIBE statement docs for new syntax > ---

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17784: Fix Version/s: (was: 1.19.0) > Better detection for parquet and orc in hive >

[jira] [Updated] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26764: Fix Version/s: (was: 1.19.0) > Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE > ---

[jira] [Updated] (FLINK-30112) Improve docs re state compression

[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30112: Fix Version/s: (was: 1.19.0) > Improve docs re state compression > ---

[jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked

[ https://issues.apache.org/jira/browse/FLINK-22605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22605: Fix Version/s: (was: 1.19.0) > Python UDF should only be created once regardless of how many t

[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

[ https://issues.apache.org/jira/browse/FLINK-19007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19007: Fix Version/s: (was: 1.19.0) > Automatically set presto staging directory to io.tmp.dirs > ---

[jira] [Updated] (FLINK-28422) Fall back to lastest supported HiveShim when user use a higher hive version

[ https://issues.apache.org/jira/browse/FLINK-28422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28422: Fix Version/s: (was: 1.19.0) > Fall back to lastest supported HiveShim when user use a higher

[jira] [Updated] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure

[ https://issues.apache.org/jira/browse/FLINK-24343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24343: Fix Version/s: (was: 1.19.0) > Revisit Scheduler and Coordinator Startup Procedure > -

[jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code

[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29040: Fix Version/s: (was: 1.19.0) > When using the JDBC Catalog, the custom cannot be applied becau

[jira] [Updated] (FLINK-26840) [minor refactor] Add a general TopNBufferCacheRemovalListener for topN function

[ https://issues.apache.org/jira/browse/FLINK-26840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26840: Fix Version/s: (was: 1.19.0) > [minor refactor] Add a general TopNBufferCacheRemovalListener f

[jira] [Updated] (FLINK-25419) Support the metadata column to generate dynamic index

[ https://issues.apache.org/jira/browse/FLINK-25419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25419: Fix Version/s: (was: 1.19.0) > Support the metadata column to generate dynamic index > --

[jira] [Updated] (FLINK-34241) Transfer external connectors's CI result to Flink Slack #builds channel

[ https://issues.apache.org/jira/browse/FLINK-34241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34241: Fix Version/s: (was: 1.19.0) > Transfer external connectors's CI result to Flink Slack #builds

[jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM

[ https://issues.apache.org/jira/browse/FLINK-19935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19935: Fix Version/s: (was: 1.19.0) > Supports configure heap memory of sql-client to avoid OOM > ---

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24094: Fix Version/s: (was: 1.19.0) > Support DROP PARTITION by partial partition specification > ---

[jira] [Updated] (FLINK-26732) DefaultResourceAllocationStrategy need more log info to troubleshoot

[ https://issues.apache.org/jira/browse/FLINK-26732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26732: Fix Version/s: (was: 1.19.0) > DefaultResourceAllocationStrategy need more log info to trouble

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29863: Fix Version/s: (was: 1.19.0) > Properly handle NaN/Infinity in OpenAPI spec >

[jira] [Updated] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30959: Fix Version/s: (was: 1.19.0) > Improve the documentation of UNIX_TIMESTAMP for different argum

[jira] [Updated] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33528: Fix Version/s: (was: 1.19.0) > Externalize Python connector code > ---

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17785: Fix Version/s: (was: 1.19.0) > Refactor orc shim to create a OrcShimFactory in hive >

[jira] [Updated] (FLINK-30290) IteratorSourceReaderBase should report END_OF_INPUT sooner

[ https://issues.apache.org/jira/browse/FLINK-30290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30290: Fix Version/s: (was: 1.19.0) > IteratorSourceReaderBase should report END_OF_INPUT sooner > --

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22282: Fix Version/s: (was: 1.19.0) > Move creation of SplitEnumerator to the SourceCoordinator threa

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31249: Fix Version/s: (was: 1.19.0) > Checkpoint timeout mechanism fails when finalizeCheckpoint is s

[jira] [Updated] (FLINK-32753) Print JVM flags on AZP

[ https://issues.apache.org/jira/browse/FLINK-32753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32753: Fix Version/s: (was: 1.19.0) > Print JVM flags on AZP > -- > >

[jira] [Updated] (FLINK-31617) Upgrade the SnakeYaml Maven dependency

[ https://issues.apache.org/jira/browse/FLINK-31617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31617: Fix Version/s: (was: 1.19.0) > Upgrade the SnakeYaml Maven dependency > --

[jira] [Updated] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions

[ https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29551: Fix Version/s: (was: 1.19.0) > Improving adaptive hash join by using sort merge join strategy

[jira] [Updated] (FLINK-34335) Query hints in RexSubQuery could not be printed

[ https://issues.apache.org/jira/browse/FLINK-34335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34335: Fix Version/s: (was: 1.19.0) > Query hints in RexSubQuery could not be printed > -

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-3: Fix Version/s: (was: 1.19.0) > Explicitly configure rest.address in distribution config >

[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client

[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22065: Fix Version/s: (was: 1.19.0) > Improve the error message when input invalid command in the sql

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27954: Fix Version/s: (was: 1.19.0) > JobVertexFlameGraphHandler does not work on standby Dispatcher

[jira] [Updated] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table

[ https://issues.apache.org/jira/browse/FLINK-33085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33085: Fix Version/s: (was: 1.19.0) > Improve the error message when the invalidate lookupTableSource

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14340: Fix Version/s: (was: 1.19.0) > Specify an unique DFSClient name for Hadoop FileSystem > --

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20484: Fix Version/s: (was: 1.19.0) > Improve hive temporal table exception > --

[jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15351: Fix Version/s: (was: 1.19.0) > develop PostgresCatalog to connect Flink with Postgres tables a

[jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16323: Fix Version/s: (was: 1.19.0) > Support to join a static table in streaming mode >

[jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate

[ https://issues.apache.org/jira/browse/FLINK-20305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20305: Fix Version/s: (was: 1.19.0) > Iterative job with maxWaitTimeMillis does not terminate > -

[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16776: Fix Version/s: (was: 1.19.0) > Support schema evolution for Hive tables >

[jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution

[ https://issues.apache.org/jira/browse/FLINK-21408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21408: Fix Version/s: (was: 1.19.0) > Clarify which DataStream sources support Batch execution >

[jira] [Updated] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32427: Fix Version/s: (was: 1.19.0) > FLIP-295: Support lazy initialization of catalogs and persisten

[jira] [Updated] (FLINK-31682) map_from_arrays should take whether allow duplicate keys and null key into consideration

[ https://issues.apache.org/jira/browse/FLINK-31682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31682: Fix Version/s: (was: 1.19.0) > map_from_arrays should take whether allow duplicate keys and nu

[jira] [Updated] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite

[ https://issues.apache.org/jira/browse/FLINK-24192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24192: Fix Version/s: (was: 1.19.0) > Sql get plan failed. All the inputs have relevant nodes, howeve

[jira] [Updated] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16155: Fix Version/s: (was: 1.19.0) > Translate "Operator/Process Function" into Chinese > --

[jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files

[ https://issues.apache.org/jira/browse/FLINK-22897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22897: Fix Version/s: (was: 1.19.0) > FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to

[jira] [Updated] (FLINK-31098) Add ARRAY_SIZE supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31098: Fix Version/s: (was: 1.19.0) > Add ARRAY_SIZE supported in SQL & Table API > -

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15532: Fix Version/s: (was: 1.19.0) > Enable strict capacity limit for memory usage for RocksDB > ---

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22607: Fix Version/s: (was: 1.19.0) > Examples use deprecated AscendingTimestampExtractor > -

[jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28120: Fix Version/s: (was: 1.19.0) > Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has low

[jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18734: Fix Version/s: (was: 1.19.0) > Add documentation for DynamoStreams Consumer CDC >

[jira] [Updated] (FLINK-28097) Remove bundling of formats-common in json/csv format

[ https://issues.apache.org/jira/browse/FLINK-28097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28097: Fix Version/s: (was: 1.19.0) > Remove bundling of formats-common in json/csv format >

[jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured

[ https://issues.apache.org/jira/browse/FLINK-23955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23955: Fix Version/s: (was: 1.19.0) > submit flink sql job error when flink HA on yarn is configured

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17362: Fix Version/s: (was: 1.19.0) > Improve table examples to reflect latest status > -

[jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

[ https://issues.apache.org/jira/browse/FLINK-22235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22235: Fix Version/s: (was: 1.19.0) > Document stability concerns of flamegraphs for heavier jobs > -

[jira] [Updated] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

[ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28428: Fix Version/s: (was: 1.19.0) > Example in the Elasticsearch doc of fault tolerance section is

[jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister

[ https://issues.apache.org/jira/browse/FLINK-25862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25862: Fix Version/s: (was: 1.19.0) > Refactor SharedStateRegistry to not limit StreamStateHandle to

[jira] [Updated] (FLINK-29858) Jdbc reading supports setting multiple queryTemplates

[ https://issues.apache.org/jira/browse/FLINK-29858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29858: Fix Version/s: (was: 1.19.0) > Jdbc reading supports setting multiple queryTemplates > ---

[jira] [Updated] (FLINK-26253) Speed up detection of dropped message in MessageSerializationTest

[ https://issues.apache.org/jira/browse/FLINK-26253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26253: Fix Version/s: (was: 1.19.0) > Speed up detection of dropped message in MessageSerializationTe

[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17826: Fix Version/s: (was: 1.19.0) > Add missing custom query support on new jdbc connector > --

[jira] [Updated] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25068: Fix Version/s: (was: 1.19.0) > Show the maximum parallelism (number of key groups) of a job in

[jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20865: Fix Version/s: (was: 1.19.0) > Prevent potential resource deadlock in fine-grained resource ma

[jira] [Updated] (FLINK-30087) sql-gateway-api is bundled twice in the distribution

[ https://issues.apache.org/jira/browse/FLINK-30087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30087: Fix Version/s: (was: 1.19.0) > sql-gateway-api is bundled twice in the distribution >

[jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

[ https://issues.apache.org/jira/browse/FLINK-17589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17589: Fix Version/s: (was: 1.19.0) > Extend StreamingFileSink to Support Streaming Hive Connector >

[jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references

[ https://issues.apache.org/jira/browse/FLINK-23555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23555: Fix Version/s: (was: 1.19.0) > Improve common subexpression elimination by using local referen

[jira] [Updated] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey

[ https://issues.apache.org/jira/browse/FLINK-29967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29967: Fix Version/s: (was: 1.19.0) > Optimize determinism requirements from sink node with consideri

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23350: Fix Version/s: (was: 1.19.0) > Write doc for change log disorder by special operators > --

[jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-20853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20853: Fix Version/s: (was: 1.19.0) > Add reader schema null check for AvroDeserializationSchema when

[jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

[ https://issues.apache.org/jira/browse/FLINK-32535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32535: Fix Version/s: (was: 1.19.0) > CheckpointingStatisticsHandler periodically returns NullArgumen

[jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page

[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14684: Fix Version/s: (was: 1.19.0) > Add Pinterest to Chinese Powered By page >

[jira] [Updated] (FLINK-33893) Implement restore tests for PythonCorrelate node

[ https://issues.apache.org/jira/browse/FLINK-33893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33893: Fix Version/s: (was: 1.19.0) > Implement restore tests for PythonCorrelate node >

[jira] [Updated] (FLINK-25512) Materialization Files are not cleaned up if no checkpoint is using it

[ https://issues.apache.org/jira/browse/FLINK-25512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25512: Fix Version/s: (was: 1.19.0) > Materialization Files are not cleaned up if no checkpoint is us

[jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24666: Fix Version/s: (was: 1.19.0) > Add job level "table.exec.state-stale.error-handling" option an

[jira] [Updated] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25447: Fix Version/s: (was: 1.19.0) > batch query cannot generate plan when a sorted view into multi

[jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18199: Fix Version/s: (was: 1.19.0) > Translate "Filesystem SQL Connector" page into Chinese > --

[jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing

[ https://issues.apache.org/jira/browse/FLINK-15645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15645: Fix Version/s: (was: 1.19.0) > enable COPY TO/FROM in Postgres JDBC source/sink for faster bat

[jira] [Updated] (FLINK-34189) FLIP-416: Deprecate and remove the RestoreMode#LEGACY

[ https://issues.apache.org/jira/browse/FLINK-34189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34189: Fix Version/s: (was: 1.19.0) > FLIP-416: Deprecate and remove the RestoreMode#LEGACY > ---

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16799: Fix Version/s: (was: 1.19.0) > add hive partition limit when read from hive >

[jira] [Updated] (FLINK-24140) Enhance the ITCase for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-24140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24140: Fix Version/s: (was: 1.19.0) > Enhance the ITCase for FLIP-147 > -

[jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED

[ https://issues.apache.org/jira/browse/FLINK-28074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28074: Fix Version/s: (was: 1.19.0) > show statistics details for DESCRIBE EXTENDED > ---

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24048: Fix Version/s: (was: 1.19.0) > Move changeLog inference out of optimizing phase >

[jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function

[ https://issues.apache.org/jira/browse/FLINK-23997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23997: Fix Version/s: (was: 1.19.0) > Improvement for SQL windowing table-valued function > -

[jira] [Updated] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25444: Fix Version/s: (was: 1.19.0) > ClosureCleaner rejects ExecutionConfig as not be Serializable d

[jira] [Updated] (FLINK-31654) DataStreamUtils.reinterpretAsKeyedStream() should not override the user specified chaining strategy.

[ https://issues.apache.org/jira/browse/FLINK-31654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31654: Fix Version/s: (was: 1.19.0) > DataStreamUtils.reinterpretAsKeyedStream() should not override

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15471: Fix Version/s: (was: 1.19.0) > HA e2e check for empty .out files does not print specific error

[jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators

[ https://issues.apache.org/jira/browse/FLINK-23445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23445: Fix Version/s: (was: 1.19.0) > Separate data and timer connection into different channels for

[jira] [Updated] (FLINK-30380) Look into enabling parallel compilation on CI

[ https://issues.apache.org/jira/browse/FLINK-30380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30380: Fix Version/s: (was: 1.19.0) > Look into enabling parallel compilation on CI > ---

[jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12491: Fix Version/s: (was: 1.19.0) > Incorrect documentation for directory path separators of CoreOp

[jira] [Updated] (FLINK-27583) Improve the plan for TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-27583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27583: Fix Version/s: (was: 1.19.0) > Improve the plan for TPC-DS queries > -

[jira] [Updated] (FLINK-22975) Specify port or range for k8s service

[ https://issues.apache.org/jira/browse/FLINK-22975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22975: Fix Version/s: (was: 1.19.0) > Specify port or range for k8s service > ---

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24536: Fix Version/s: (was: 1.19.0) > flink sql where condition is not supported != writing > --

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24122: Fix Version/s: (was: 1.19.0) > Add support to do clean in history server > ---

[jira] [Updated] (FLINK-23412) Improve sourceSink description

[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23412: Fix Version/s: (was: 1.19.0) > Improve sourceSink description > --

[jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16073: Fix Version/s: (was: 1.19.0) > Translate "State & Fault Tolerance" pages into Chinese > --

<    3   4   5   6   7   8   9   10   11   >