[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: 1.20.0 > ClosureCleaner rejects ExecutionConfig as not be Serializable due to > Te

[jira] [Updated] (FLINK-28726) CompileException: BoundedOverAggregateHelper must implement method AggsHandeFunction.setWindowSize(int)

[ https://issues.apache.org/jira/browse/FLINK-28726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28726: Fix Version/s: 1.20.0 > CompileException: BoundedOverAggregateHelper must implement method > Aggs

[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()

[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15740: Fix Version/s: 1.20.0 > Remove Deadline#timeLeft() > -- > >

[jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

[ https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21179: Fix Version/s: 1.20.0 > Make sure that the open/close methods of the Python DataStream Function ar

[jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29330: Fix Version/s: 1.20.0 > Provide better logs of MiniCluster shutdown procedure > --

[jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28909: Fix Version/s: 1.20.0 > Add ribbon filter policy option in RocksDBConfiguredOptions >

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27237: Fix Version/s: 1.20.0 > Partitioned table statement enhancement >

[jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

[ https://issues.apache.org/jira/browse/FLINK-32699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32699: Fix Version/s: 1.20.0 > select typeof(proctime()); throw exception in sql-client > ---

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

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

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19659: Fix Version/s: 1.20.0 > Array type supports equals and not_equals operator when element types are

[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: 1.20.0 > Support schema evolution for Hive tables > ---

[jira] [Updated] (FLINK-23752) Add document for using HiveSource API

[ https://issues.apache.org/jira/browse/FLINK-23752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23752: Fix Version/s: 1.20.0 > Add document for using HiveSource API > --

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14500: Fix Version/s: 1.20.0 > Support Flink Python User-Defined Stateless Function for Table - Phase 2 >

[jira] [Updated] (FLINK-33597) Can not use a nested column for a join condition

[ https://issues.apache.org/jira/browse/FLINK-33597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33597: Fix Version/s: 1.20.0 > Can not use a nested column for a join condition > ---

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22334: Fix Version/s: 1.20.0 > Fail to translate the hive-sql in STREAMING mode > ---

[jira] [Updated] (FLINK-29240) Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29240: Fix Version/s: 1.20.0 > Unify the ClassLoader in StreamExecutionEnvironment and TableEnvironment >

[jira] [Updated] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method

[ https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33951: Fix Version/s: 1.20.0 > should use aggCallNeedRetractions instead of needRetraction to check retra

[jira] [Updated] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase

[ https://issues.apache.org/jira/browse/FLINK-27455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27455: Fix Version/s: 1.20.0 > [JUnit5 Migration] SnapshotMigrationTestBase > ---

[jira] [Updated] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29339: Fix Version/s: 1.20.0 > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager

[jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18564: Fix Version/s: 1.20.0 > Add Support for Azure Event Hub DataStream Connector > ---

[jira] [Updated] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic

[ https://issues.apache.org/jira/browse/FLINK-28737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28737: Fix Version/s: 1.20.0 > FlinkRelMdUpsertKeys should consider the case when the condition of a calc

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14122: Fix Version/s: 1.20.0 > Extend State Processor API to read ListCheckpointed operator state > -

[jira] [Updated] (FLINK-24169) Flaky local YARN tests relying on log files

[ https://issues.apache.org/jira/browse/FLINK-24169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24169: Fix Version/s: 1.20.0 > Flaky local YARN tests relying on log files >

[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: 1.20.0 > Query hints in RexSubQuery could not be printed >

[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: 1.20.0 > Supports configure heap memory of sql-client to avoid OOM > --

[jira] [Updated] (FLINK-28109) Delete useful code in the row emitter.

[ https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28109: Fix Version/s: 1.20.0 > Delete useful code in the row emitter. > -

[jira] [Updated] (FLINK-29001) Migrate datadog reporter to v2 metric submission API

[ https://issues.apache.org/jira/browse/FLINK-29001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29001: Fix Version/s: 1.20.0 > Migrate datadog reporter to v2 metric submission API > ---

[jira] [Updated] (FLINK-28929) Add built-in datediff function.

[ https://issues.apache.org/jira/browse/FLINK-28929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28929: Fix Version/s: 1.20.0 > Add built-in datediff function. > --- > >

[jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-28893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28893: Fix Version/s: 1.20.0 > Add conv function supported in SQL & Table API > -

[jira] [Updated] (FLINK-14934) Remove error log statement in ES connector

[ https://issues.apache.org/jira/browse/FLINK-14934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14934: Fix Version/s: 1.20.0 > Remove error log statement in ES connector > -

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14383: Fix Version/s: 1.20.0 > Support python UDFs with constant value of time interval types > -

[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: 1.20.0 > Look into enabling parallel compilation on CI > --

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18592: Fix Version/s: 1.20.0 > StreamingFileSink fails due to truncating HDFS file failure >

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

[ https://issues.apache.org/jira/browse/FLINK-21765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21765: Fix Version/s: 1.20.0 > Remove implementation-specific MetricGroup parents > -

[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs

[ https://issues.apache.org/jira/browse/FLINK-19263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19263: Fix Version/s: 1.20.0 > Enforce alphabetical order in configuration option docs >

[jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause

[ https://issues.apache.org/jira/browse/FLINK-29003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29003: Fix Version/s: 1.20.0 > sqlServerDialect should support limit clause > ---

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-13015: Fix Version/s: 1.20.0 > Create validators, strategies and transformations required for porting >

[jira] [Updated] (FLINK-32577) Avoid memory fragmentation when running CI for flink-table-planner module

[ https://issues.apache.org/jira/browse/FLINK-32577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32577: Fix Version/s: 1.20.0 > Avoid memory fragmentation when running CI for flink-table-planner module

[jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23403: Fix Version/s: 1.20.0 > Decrease default values for heartbeat timeout and interval > -

[jira] [Updated] (FLINK-29172) Add built-in string_split function.

[ https://issues.apache.org/jira/browse/FLINK-29172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29172: Fix Version/s: 1.20.0 > Add built-in string_split function. > ---

[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: 1.20.0 > Add ARRAY_SIZE supported in SQL & Table API >

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20788: Fix Version/s: 1.20.0 > It doesn't support to use cube/rollup/grouping sets in the Table API > ---

[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: 1.20.0 > Add support to do clean in history server > --

[jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector

[ https://issues.apache.org/jira/browse/FLINK-21184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21184: Fix Version/s: 1.20.0 > Support temporary table/function for hive connector >

[jira] [Updated] (FLINK-29699) Json format parsing supports converting strings at the end with Z and numbers to timestamp

[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29699: Fix Version/s: 1.20.0 > Json format parsing supports converting strings at the end with Z and >

[jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes

[ https://issues.apache.org/jira/browse/FLINK-32537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32537: Fix Version/s: 1.20.0 > Add compatibility annotation for REST API classes > --

[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: 1.20.0 > Add ARRAY_INTERSECT supported in SQL & Table API > ---

[jira] [Updated] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE

[ https://issues.apache.org/jira/browse/FLINK-28538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28538: Fix Version/s: 1.20.0 > Eagerly emit a watermark the first time we exceed Long.MIN_VALUE > ---

[jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment

[ https://issues.apache.org/jira/browse/FLINK-14707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14707: Fix Version/s: 1.20.0 > Refactor checkpoint related methods within Environment > -

[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: 1.20.0 > DefaultResourceAllocationStrategy need more log info to troubleshoot > ---

[jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar

[ https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31006: Fix Version/s: 1.20.0 > job is not finished when using pipeline mode to run bounded source like >

[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: 1.20.0 > develop PostgresCatalog to connect Flink with Postgres tables and ecosyste

[jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down

[ https://issues.apache.org/jira/browse/FLINK-19819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19819: Fix Version/s: 1.20.0 > SourceReaderBase supports limit push down > --

[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: 1.20.0 > show statistics details for DESCRIBE EXTENDED > --

[jira] [Updated] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26760: Fix Version/s: 1.20.0 > The new CSV source (file system source + CSV format) does not support read

[jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18563: Fix Version/s: 1.20.0 > Add Support for Azure Cosmos DB DataStream Connector > ---

[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: 1.20.0 > Improving adaptive hash join by using sort merge join strategy per partiti

[jira] [Updated] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33626: Fix Version/s: 1.20.0 > Wrong style in flink ui > --- > > Key:

[jira] [Updated] (FLINK-26477) Finalize the window support in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-26477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26477: Fix Version/s: 1.20.0 > Finalize the window support in Python DataStream API > ---

[jira] [Updated] (FLINK-31336) interval type process has problem in table api and sql

[ https://issues.apache.org/jira/browse/FLINK-31336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31336: Fix Version/s: 1.20.0 > interval type process has problem in table api and sql > -

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24237: Fix Version/s: 1.20.0 > Consider disabling or lowering DNS caching timeout in docker image > -

[jira] [Updated] (FLINK-28042) Create an extension for resetting HiveConf

[ https://issues.apache.org/jira/browse/FLINK-28042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28042: Fix Version/s: 1.20.0 > Create an extension for resetting HiveConf > -

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

[ https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20572: Fix Version/s: 1.20.0 > HiveCatalog should be a standalone module > --

[jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18566: Fix Version/s: 1.20.0 > Add Support for Azure Cognitive Search DataStream Connector >

[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log

[ https://issues.apache.org/jira/browse/FLINK-19846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19846: Fix Version/s: 1.20.0 > Grammar mistakes in annotations and log >

[jira] [Updated] (FLINK-20787) Improve the Table API to solve user friction

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20787: Fix Version/s: 1.20.0 > Improve the Table API to solve user friction > ---

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16548: Fix Version/s: 1.20.0 > Expose consistent environment variable to identify the component name and

[jira] [Updated] (FLINK-29060) can not set rewriteBatchedStatements parameter for JDBC catalog for MySQL

[ https://issues.apache.org/jira/browse/FLINK-29060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29060: Fix Version/s: 1.20.0 > can not set rewriteBatchedStatements parameter for JDBC catalog for MySQL

[jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck

[ https://issues.apache.org/jira/browse/FLINK-34559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34559: Fix Version/s: 1.20.0 > TVF Window Aggregations might get stuck >

[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: 1.20.0 > Improve docs re state compression > - > >

[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: 1.20.0 > Transfer external connectors's CI result to Flink Slack #builds channel >

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12273: Fix Version/s: 1.20.0 > The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE

[jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners

[ https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19499: Fix Version/s: 1.20.0 > Expose Metric Groups to Split Assigners >

[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: 1.20.0 > Print JVM flags on AZP > -- > > Key: F

[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: 1.20.0 > Improve the plan for TPC-DS queries > ---

[jira] [Updated] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28399: Fix Version/s: 1.20.0 > Refactor CheckedThread to accept runnable via constructor > --

[jira] [Updated] (FLINK-28061) create new tech blog for connector development based on Source API

[ https://issues.apache.org/jira/browse/FLINK-28061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28061: Fix Version/s: 1.20.0 > create new tech blog for connector development based on Source API > -

[jira] [Updated] (FLINK-31666) Add ARRAY_OVERLAP supported in SQL & Table API

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

[jira] [Updated] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node

[ https://issues.apache.org/jira/browse/FLINK-33895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33895: Fix Version/s: 1.20.0 > Implement restore tests for PythonGroupWindowAggregate node >

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27191: Fix Version/s: 1.20.0 > Support multi kerberos-enabled Hive clusters > --

[jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24951: Fix Version/s: 1.20.0 > Allow watch bookmarks to mitigate frequent watcher rebuilding > --

[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: 1.20.0 > Enhance the ITCase for FLIP-147 > --- > >

[jira] [Updated] (FLINK-25353) Add tests to ensure API graduation process is honoured

[ https://issues.apache.org/jira/browse/FLINK-25353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25353: Fix Version/s: 1.20.0 > Add tests to ensure API graduation process is honoured > -

[jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs

[ https://issues.apache.org/jira/browse/FLINK-21409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21409: Fix Version/s: 1.20.0 > Add Avro to DataTypes & Serialization docs > -

[jira] [Updated] (FLINK-25354) Document API graduation process

[ https://issues.apache.org/jira/browse/FLINK-25354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25354: Fix Version/s: 1.20.0 > Document API graduation process > --- > >

[jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21578: Fix Version/s: 1.20.0 > Closeable Sink Committer/GlobalCommitter were created to function in onest

[jira] [Updated] (FLINK-28401) Remove snapshot repo from quickstarts for released versions

[ https://issues.apache.org/jira/browse/FLINK-28401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28401: Fix Version/s: 1.20.0 > Remove snapshot repo from quickstarts for released versions >

[jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26003: Fix Version/s: 1.20.0 > Use Jackson serialization for persisting TaskExecutor state to working >

[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: 1.20.0 > SavepointFormatITCase did NOT fail with changelog.enabled randomized > --

[jira] [Updated] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials

[ https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29530: Fix Version/s: 1.20.0 > CommittableMessageTypeInfo#toString may force client to have S3 credential

[jira] [Updated] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting

[ https://issues.apache.org/jira/browse/FLINK-30289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30289: Fix Version/s: 1.20.0 > RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting > -

[jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14879: Fix Version/s: 1.20.0 > Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client

[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: 1.20.0 > Upgrade the SnakeYaml Maven dependency > -

[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: 1.20.0 > Write doc for change log disorder by special operators > -

[jira] [Updated] (FLINK-29912) jdbc scan.partition.column can specify any type of field

[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29912: Fix Version/s: 1.20.0 > jdbc scan.partition.column can specify any type of field > ---

[jira] [Updated] (FLINK-32263) Add ELT support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32263: Fix Version/s: 1.20.0 > Add ELT support in SQL & Table API > -- >

[jira] [Updated] (FLINK-24258) Connection timed out or very slowly when visiting Flink website

[ https://issues.apache.org/jira/browse/FLINK-24258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24258: Fix Version/s: 1.20.0 > Connection timed out or very slowly when visiting Flink website >

[jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods

[ https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32682: Fix Version/s: 1.20.0 > Introduce option for choosing time function evaluation methods > -

[jira] [Updated] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer

[ https://issues.apache.org/jira/browse/FLINK-22960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22960: Fix Version/s: 1.20.0 > Temporal join TTL should use enableTimeToLive of state instead of timer >

[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: 1.20.0 > HA e2e check for empty .out files does not print specific error >

<    1   2   3   4   5   6   7   8   9   10   >