[jira] [Updated] (FLINK-23860) Conversion to relational algebra failed to preserve datatypes

[ https://issues.apache.org/jira/browse/FLINK-23860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23860: Fix Version/s: (was: 1.19.0) > Conversion to relational algebra failed to preserve datatypes >

[jira] [Updated] (FLINK-34338) An exception is thrown when some named params change order when using window tvf

[ https://issues.apache.org/jira/browse/FLINK-34338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34338: Fix Version/s: (was: 1.19.0) > An exception is thrown when some named params change order when

[jira] [Updated] (FLINK-30399) Enable connectors to use config docs generator

[ https://issues.apache.org/jira/browse/FLINK-30399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30399: Fix Version/s: (was: 1.19.0) > Enable connectors to use config docs generator > --

[jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider

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

[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: (was: 1.19.0) > Grammar mistakes in annotations and log > -

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19881: Fix Version/s: (was: 1.19.0) > Optimize temporal join with upsert-Source(upsert-kafka) > -

[jira] [Updated] (FLINK-28919) Add built-in generate_series function.

[ https://issues.apache.org/jira/browse/FLINK-28919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28919: Fix Version/s: (was: 1.19.0) > Add built-in generate_series function. > --

[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: (was: 1.19.0) > Delete useful code in the row emitter. > --

[jira] [Updated] (FLINK-33162) seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint

[ https://issues.apache.org/jira/browse/FLINK-33162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33162: Fix Version/s: (was: 1.19.0) > seperate the executor in DefaultDispatcherResourceManagerCompon

[jira] [Updated] (FLINK-28022) Support Google Cloud PubSub connector in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-28022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28022: Fix Version/s: (was: 1.19.0) > Support Google Cloud PubSub connector in Python DataStream API

[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: (was: 1.19.0) > Add built-in string_split function. > -

[jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24376: Fix Version/s: (was: 1.19.0) > Operator name in OperatorCoordinator should not use chained nam

[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: (was: 1.19.0) > It doesn't support to use cube/rollup/grouping sets in the Tabl

[jira] [Updated] (FLINK-32264) Add FIELD support in SQL & Table API

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

[jira] [Updated] (FLINK-15003) Improve hive test performance

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

[jira] [Updated] (FLINK-32745) Add a flag to skip InputSelectable preValidate step

[ https://issues.apache.org/jira/browse/FLINK-32745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32745: Fix Version/s: (was: 1.19.0) > Add a flag to skip InputSelectable preValidate step > -

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20687: Fix Version/s: (was: 1.19.0) > Missing 'yarn-application' target in CLI help message > ---

[jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

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

[jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result

[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16466: Fix Version/s: (was: 1.19.0) > Group by on event time should produce insert only result >

[jira] [Updated] (FLINK-6810) Add a set of built-in functions to Table API & SQL

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

[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: (was: 1.19.0) > Connection timed out or very slowly when visiting Flink website

[jira] [Updated] (FLINK-34397) Resource wait timeout can't be disabled

[ https://issues.apache.org/jira/browse/FLINK-34397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34397: Fix Version/s: (was: 1.19.0) > Resource wait timeout can't be disabled > -

[jira] [Updated] (FLINK-29717) Supports hive udaf such as sum/count by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29717: Fix Version/s: (was: 1.19.0) > Supports hive udaf such as sum/count by native implementation

[jira] [Updated] (FLINK-26129) Using fail method instead of kill method when yarn application deployment error occures

[ https://issues.apache.org/jira/browse/FLINK-26129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26129: Fix Version/s: (was: 1.19.0) > Using fail method instead of kill method when yarn application

[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: (was: 1.19.0) > [JUnit5 Migration] SnapshotMigrationTestBase >

[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: (was: 1.19.0) > Fail to translate the hive-sql in STREAMING mode >

[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: (was: 1.19.0) > Json format parsing supports converting strings at the end wit

[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: (was: 1.19.0) > Remove error log statement in ES connector > --

[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: (was: 1.19.0) > JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromReso

[jira] [Updated] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog

[ https://issues.apache.org/jira/browse/FLINK-29776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29776: Fix Version/s: (was: 1.19.0) > [JUnit5 Migration] Module: flink-statebackend-changelog > -

[jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25291: Fix Version/s: (was: 1.19.0) > Add failure cases in DataStream source and sink suite of connec

[jira] [Updated] (FLINK-28516) UI is misleading when source doesn't emit watermark due to misconfigured idleness

[ https://issues.apache.org/jira/browse/FLINK-28516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28516: Fix Version/s: (was: 1.19.0) > UI is misleading when source doesn't emit watermark due to misc

[jira] [Updated] (FLINK-32603) Avoid consuming twice when two pipelines have the same table source

[ https://issues.apache.org/jira/browse/FLINK-32603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32603: Fix Version/s: (was: 1.19.0) > Avoid consuming twice when two pipelines have the same table so

[jira] [Updated] (FLINK-25725) Agile configurable modules in web ui

[ https://issues.apache.org/jira/browse/FLINK-25725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25725: Fix Version/s: (was: 1.19.0) > Agile configurable modules in web ui >

[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21613: Fix Version/s: (was: 1.19.0) > Parse Compute Column with `IN` expression throws NPE >

[jira] [Updated] (FLINK-34264) Prometheuspushgateway's hosturl can use basicAuth certification login

[ https://issues.apache.org/jira/browse/FLINK-34264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34264: Fix Version/s: (was: 1.19.0) > Prometheuspushgateway's hosturl can use basicAuth certification

[jira] [Updated] (FLINK-26951) Add HASH supported in SQL & Table API

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

[jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-15860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15860: Fix Version/s: (was: 1.19.0) > Store temporary functions as CatalogFunctions in FunctionCatalo

[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: (was: 1.19.0) > HiveCatalog should be a standalone module > ---

[jira] [Updated] (FLINK-24683) Add Support for Azure Synapse Analytics

[ https://issues.apache.org/jira/browse/FLINK-24683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24683: Fix Version/s: (was: 1.19.0) > Add Support for Azure Synapse Analytics > -

[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: (was: 1.19.0) > TVF Window Aggregations might get stuck > -

[jira] [Updated] (FLINK-21053) Prevent potential RejectedExecutionExceptions in CheckpointCoordinator failing JM

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

[jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format

[ https://issues.apache.org/jira/browse/FLINK-20952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20952: Fix Version/s: (was: 1.19.0) > Changelog json formats should support inherit options from JSON

[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: (was: 1.19.0) > SourceReaderBase supports limit push down > ---

[jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API

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

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30524: Fix Version/s: (was: 1.19.0) > Support full screen viewing on the Logs/Stdout/Thread Dump page

[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: (was: 1.19.0) > Refactor checkpoint related methods within Environment > --

[jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19482: Fix Version/s: (was: 1.19.0) > OrcRowInputFormat does not define serialVersionUID > --

[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: (was: 1.19.0) > Enforce alphabetical order in configuration option docs > -

[jira] [Updated] (FLINK-32852) [JUnit5 Migration] The scheduler package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32852: Fix Version/s: (was: 1.19.0) > [JUnit5 Migration] The scheduler package of flink-runtime modul

[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: (was: 1.19.0) > Add Support for Azure Cosmos DB DataStream Connector >

[jira] [Updated] (FLINK-32641) json format supports pojo type

[ https://issues.apache.org/jira/browse/FLINK-32641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32641: Fix Version/s: (was: 1.19.0) > json format supports pojo type > --

[jira] [Updated] (FLINK-23545) Use new schema in SqlCreateTableConverter

[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23545: Fix Version/s: (was: 1.19.0) > Use new schema in SqlCreateTableConverter > ---

[jira] [Updated] (FLINK-27632) Improve connector testing framework to support more cases

[ https://issues.apache.org/jira/browse/FLINK-27632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27632: Fix Version/s: (was: 1.19.0) > Improve connector testing framework to support more cases > ---

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20110: Fix Version/s: (was: 1.19.0) > Support 'merge' method for first_value and last_value UDAF > --

[jira] [Updated] (FLINK-22371) Chinese grammatical error

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

[jira] [Updated] (FLINK-31161) upgrade MojoHaus Versions Maven Plugin to 2.14.2

[ https://issues.apache.org/jira/browse/FLINK-31161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31161: Fix Version/s: (was: 1.19.0) > upgrade MojoHaus Versions Maven Plugin to 2.14.2 >

[jira] [Updated] (FLINK-25290) Add table source and sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25290: Fix Version/s: (was: 1.19.0) > Add table source and sink test suite in connector testing frame

[jira] [Updated] (FLINK-30284) Make datadog reporter url configurable

[ https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30284: Fix Version/s: (was: 1.19.0) > Make datadog reporter url configurable > --

[jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24757: Fix Version/s: (was: 1.19.0) > Yarn application is not terminated after the job finishes when

[jira] [Updated] (FLINK-28813) new stach builtinfunction validateClassForRuntime it not correct

[ https://issues.apache.org/jira/browse/FLINK-28813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28813: Fix Version/s: (was: 1.19.0) > new stach builtinfunction validateClassForRuntime it not corre

[jira] [Updated] (FLINK-25283) End-to-end application modules create oversized jars

[ https://issues.apache.org/jira/browse/FLINK-25283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25283: Fix Version/s: (was: 1.19.0) > End-to-end application modules create oversized jars >

[jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14690: Fix Version/s: (was: 1.19.0) > Support 'DESCRIBE CATALOG catalogName' statement in TableEnviro

[jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager

[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22594: Fix Version/s: (was: 1.19.0) > Report oom killed pod in k8s resource manager > ---

[jira] [Updated] (FLINK-34315) Temporarily force disabling window join, window rank and window deduplicate optimization when using session window tvf

[ https://issues.apache.org/jira/browse/FLINK-34315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34315: Fix Version/s: (was: 1.19.0) > Temporarily force disabling window join, window rank and window

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12692: Fix Version/s: (was: 1.19.0) > Support disk spilling in HeapKeyedStateBackend > --

[jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32738: Fix Version/s: (was: 1.19.0) > PROTOBUF format supports projection push down > ---

Re: [PR] [FLINK-23545] Use new schema in SqlCreateTableConverter [flink]

hackergin closed pull request #16721: [FLINK-23545] Use new schema in SqlCreateTableConverter URL: https://github.com/apache/flink/pull/16721 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18627: Fix Version/s: (was: 1.19.0) > Get unmatch filter method records to side output >

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

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

[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: (was: 1.19.0) > Support python UDFs with constant value of time interval types

[jira] [Updated] (FLINK-29559) Disable Join Reorder and Hash join for these tables whose statistics are unavailable in batch mode

[ https://issues.apache.org/jira/browse/FLINK-29559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29559: Fix Version/s: (was: 1.19.0) > Disable Join Reorder and Hash join for these tables whose stati

[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: (was: 1.19.0) > Decrease default values for heartbeat timeout and interval > --

[jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[]

[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20578: Fix Version/s: (was: 1.19.0) > Cannot create empty array using ARRAY[] > -

[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: (was: 1.19.0) > Improve the Table API to solve user friction >

[jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector

[ https://issues.apache.org/jira/browse/FLINK-18567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18567: Fix Version/s: (was: 1.19.0) > Add Support for Azure Cognitive Search Table & SQL Connector >

[jira] [Updated] (FLINK-24306) group by index throw SqlValidatorException

[ https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24306: Fix Version/s: (was: 1.19.0) > group by index throw SqlValidatorException > --

[jira] [Updated] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28901: Fix Version/s: (was: 1.19.0) > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with

[jira] [Updated] (FLINK-29150) TIMESTAMPDIFF microsecond unit for table api

[ https://issues.apache.org/jira/browse/FLINK-29150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29150: Fix Version/s: (was: 1.19.0) > TIMESTAMPDIFF microsecond unit for table api > ---

[jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23216: Fix Version/s: (was: 1.19.0) > RM keeps allocating and freeing slots after a TM lost until its

[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: (was: 1.19.0) > RateLimitedSourceReader uses wrong signal for checkpoint rate-l

[jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

[ https://issues.apache.org/jira/browse/FLINK-19425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19425: Fix Version/s: (was: 1.19.0) > Correct the usage of BulkWriter#flush and BulkWriter#finish > -

[jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

[ https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15183: Fix Version/s: (was: 1.19.0) > Use SQL-CLI to TPC-DS E2E test > --

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27858: Fix Version/s: (was: 1.19.0) > Hive source support filter push down for parquet format > -

[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: (was: 1.19.0) > Add ARRAY_OVERLAP supported in SQL & Table API > --

[jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26761: Fix Version/s: (was: 1.19.0) > Fix the cast exception thrown by PreValidateReWriter when inser

[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: (was: 1.19.0) > Add built-in datediff function. > -

[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: (was: 1.19.0) > Implement restore tests for PythonGroupWindowAggregate node > -

[jira] [Updated] (FLINK-30738) Disable verbose mode

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

[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: (was: 1.19.0) > Use Jackson serialization for persisting TaskExecutor state to

[jira] [Updated] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce

[ https://issues.apache.org/jira/browse/FLINK-31841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31841: Fix Version/s: (was: 1.19.0) > Redundant local variables in AllWindowedStream#reduce > ---

[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: (was: 1.19.0) > Remove Deadline#timeLeft() > -- > >

[jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-15859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15859: Fix Version/s: (was: 1.19.0) > Unify identifiers in the interface methods of CatalogManager >

[jira] [Updated] (FLINK-32530) array_position semantic should align with array_contains instead of spark

[ https://issues.apache.org/jira/browse/FLINK-32530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32530: Fix Version/s: (was: 1.19.0) > array_position semantic should align with array_contains instea

[jira] [Commented] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825301#comment-17825301 ] lincoln lee commented on FLINK-33696: - [~pnowojski] Since there's still some work to

[jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector

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

[jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16143: Fix Version/s: (was: 1.19.0) > Turn on more date time functions of blink planner > ---

[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: (was: 1.19.0) > Create validators, strategies and transformations required for

[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: (was: 1.19.0) > CompileException: BoundedOverAggregateHelper must implement met

[jira] [Updated] (FLINK-29027) Fix HiveTableSink failed to report statistic to hive metastore in stream mode

[ https://issues.apache.org/jira/browse/FLINK-29027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29027: Fix Version/s: (was: 1.19.0) > Fix HiveTableSink failed to report statistic to hive metastore

<    4   5   6   7   8   9   10   11   >