[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: 1.20.0 > Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE > --

[jira] [Updated] (FLINK-26927) Improve FlinkContainers to better support JM restarting

[ https://issues.apache.org/jira/browse/FLINK-26927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26927: Fix Version/s: 1.20.0 > Improve FlinkContainers to better support JM restarting >

[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: 1.20.0 > Support KafkaSerializationSchema in Kafka connector for Python DataStream

[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: 1.20.0 > batch query cannot generate plan when a sorted view into multi sinks > ---

[jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16531: Fix Version/s: 1.20.0 > Add full integration tests for "GROUPING SETS" for streaming mode > --

[jira] [Updated] (FLINK-24517) Streamline Flink releases

[ https://issues.apache.org/jira/browse/FLINK-24517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24517: Fix Version/s: 1.20.0 > Streamline Flink releases > - > >

[jira] [Updated] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5

[ https://issues.apache.org/jira/browse/FLINK-25900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25900: Fix Version/s: 1.20.0 > Create view example does not assign alias to functions resulting in genera

[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: 1.20.0 > Add Support for Azure Synapse Analytics >

[jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34066: Fix Version/s: 1.20.0 > LagFunction throw NPE when input argument are not null > -

[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: 1.20.0 > End to end test produce excessive amount of logs > ---

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21637: Fix Version/s: 1.20.0 > Wrong results when filtering by timestamp type > -

[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: 1.20.0 > Jdbc reading supports setting multiple queryTemplates > --

[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: 1.20.0 > enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processi

[jira] [Updated] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API

[ https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29192: Fix Version/s: 1.20.0 > Add completeness test for built-in functions between Java and Python Table

[jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause

[ https://issues.apache.org/jira/browse/FLINK-24849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24849: Fix Version/s: 1.20.0 > Only return stacktrace if RestHandlerException has a cause > -

[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: 1.20.0 > Improve table examples to reflect latest status >

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22059: Fix Version/s: 1.20.0 > add a new option is rocksdb statebackend to enable job threads setting > -

[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: 1.20.0 > Translate "Operator/Process Function" into Chinese > -

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17337: Fix Version/s: 1.20.0 > Send UPDATE messages instead of INSERT and DELETE in streaming join operat

[jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

[ https://issues.apache.org/jira/browse/FLINK-23737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23737: Fix Version/s: 1.20.0 > Ensure publish-to-dockerhub.sh only publish specific flink versions >

[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: 1.20.0 > Support Google Cloud PubSub connector in Python DataStream API > -

[jira] [Updated] (FLINK-30285) Inline checkstyle config into pom

[ https://issues.apache.org/jira/browse/FLINK-30285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30285: Fix Version/s: 1.20.0 > Inline checkstyle config into pom > - > >

[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: 1.20.0 > Add Support for Azure Event Grid DataStream Connector > --

[jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node

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

[jira] [Updated] (FLINK-33498) Do not allow manually triggering incremental checkpoints with full checkpoint configured

[ https://issues.apache.org/jira/browse/FLINK-33498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33498: Fix Version/s: 1.20.0 > Do not allow manually triggering incremental checkpoints with full checkpo

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16023: Fix Version/s: 1.20.0 > jdbc connector's 'connector.table' property should be optional rather than

[jira] [Updated] (FLINK-31829) Conversion to relational algebra failed to preserve datatypes' nullabilities

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

[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: 1.20.0 > Implement restore tests for PythonCorrelate node > ---

[jira] [Updated] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

[ https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24900: Fix Version/s: 1.20.0 > Support to run multiple shuffle plugins in one session cluster > -

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20457: Fix Version/s: 1.20.0 > Fix the handling of timestamp in DataStream.from_collection >

[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: 1.20.0 > Examples use deprecated AscendingTimestampExtractor >

[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: 1.20.0 > TIMESTAMPDIFF microsecond unit for table api > --

[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: 1.20.0 > Correct the usage of BulkWriter#flush and BulkWriter#finish >

[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: 1.20.0 > planner dependencies won't be necessary for JDBC connector > -

[jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks

[ https://issues.apache.org/jira/browse/FLINK-24680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24680: Fix Version/s: 1.20.0 > Expose UserCodeClassLoader in OperatorCoordinator.Context for registering

[jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

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

[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: 1.20.0 > Move creation of SplitEnumerator to the SourceCoordinator thread > ---

[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: 1.20.0 > Optimize temporal join with upsert-Source(upsert-kafka) >

[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: 1.20.0 > Python UDF should only be created once regardless of how many times it is

[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: 1.20.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: 1.20.0 > Use new schema in SqlCreateTableConverter > --

[jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

[ https://issues.apache.org/jira/browse/FLINK-22299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22299: Fix Version/s: 1.20.0 > should remind users to ignoreParseErrors option when parser failed > -

[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: 1.20.0 > sql-gateway-api is bundled twice in the distribution > ---

[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: 1.20.0 > RM keeps allocating and freeing slots after a TM lost until its heartbeat

[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: 1.20.0 > UI is misleading when source doesn't emit watermark due to misconfigured

[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: 1.20.0 > submit flink sql job error when flink HA on yarn is configured > -

[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: 1.20.0 > FLIP-416: Deprecate and remove the RestoreMode#LEGACY > --

[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: 1.20.0 > flink sql where condition is not supported != writing > -

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21022: Fix Version/s: 1.20.0 > flink-connector-es add onSuccess handler after bulk process for sync succe

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12590: Fix Version/s: 1.20.0 > Replace http links in documentation > ---

[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: 1.20.0 > Turn on more date time functions of blink planner > --

[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: 1.20.0 > Materialization Files are not cleaned up if no checkpoint is using it > --

[jira] [Updated] (FLINK-30050) [Umbrella] Externalize Flink connectors

[ https://issues.apache.org/jira/browse/FLINK-30050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30050: Fix Version/s: 1.20.0 > [Umbrella] Externalize Flink connectors >

[jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split

[ https://issues.apache.org/jira/browse/FLINK-22926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22926: Fix Version/s: 1.20.0 > IDLE FLIP-27 source should go ACTIVE when registering a new split > --

[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: 1.20.0 > [JUnit5 Migration] The scheduler package of flink-runtime module > ---

[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: 1.20.0 > Improve hive temporal table exception > -

[jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

[ https://issues.apache.org/jira/browse/FLINK-25887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25887: Fix Version/s: 1.20.0 > FLIP-193: Snapshots ownership follow ups > ---

[jira] [Updated] (FLINK-24547) A function named row_kind() can get row_kind

[ https://issues.apache.org/jira/browse/FLINK-24547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24547: Fix Version/s: 1.20.0 > A function named row_kind() can get row_kind > ---

[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: 1.20.0 > Improve connector testing framework to support more cases > --

[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: 1.20.0 > Improve the error message when input invalid command in the sql client > -

[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: 1.20.0 > upgrade MojoHaus Versions Maven Plugin to 2.14.2 > ---

[jira] [Updated] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26559: Fix Version/s: 1.20.0 > Support Customized Kubernetes Schedulers for Flink Kubernetes > --

[jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-27809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27809: Fix Version/s: 1.20.0 > Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode

[jira] [Updated] (FLINK-25346) FLIP-197: API stability graduation process

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

[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: 1.20.0 > Disable Join Reorder and Hash join for these tables whose statistics are

[jira] [Updated] (FLINK-31706) The default source parallelism should be the same as execution's default parallelism under adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-31706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31706: Fix Version/s: 1.20.0 > The default source parallelism should be the same as execution's default

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19722: Fix Version/s: 1.20.0 > Pushdown Watermark to SourceProvider (new Source) > --

[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: 1.20.0 > Document stability concerns of flamegraphs for heavier jobs >

[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: 1.20.0 > Avoid consuming twice when two pipelines have the same table source >

[jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34380: Fix Version/s: 1.20.0 > Strange RowKind and records about intermediate output when using minibatch

[jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column

[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-15553: Fix Version/s: 1.20.0 > Create table ddl support comment after computed column >

[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source

[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18578: Fix Version/s: 1.20.0 > Add rejecting checkpoint logic in source > ---

[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: 1.20.0 > Prevent potential RejectedExecutionExceptions in CheckpointCoordinator >

[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: 1.20.0 > Support setting env.java.opts.all & env.java.opts.cli configs via dynamic

[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: 1.20.0 > Report oom killed pod in k8s resource manager > --

[jira] [Updated] (FLINK-25244) Deprecate Java 8 support

[ https://issues.apache.org/jira/browse/FLINK-25244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25244: Fix Version/s: 1.20.0 > Deprecate Java 8 support > > > Ke

[jira] [Updated] (FLINK-28732) Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API

[ https://issues.apache.org/jira/browse/FLINK-28732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28732: Fix Version/s: 1.20.0 > Deprecate ambiguous StateTTLConfig#cleanFullSnapshot API > ---

[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: 1.20.0 > Add a set of built-in functions to Table API & SQL >

[jira] [Updated] (FLINK-31608) Re-evaluate 'min-parallelism-increase' option

[ https://issues.apache.org/jira/browse/FLINK-31608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31608: Fix Version/s: 1.20.0 > Re-evaluate 'min-parallelism-increase' option > --

[jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

[ https://issues.apache.org/jira/browse/FLINK-24688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24688: Fix Version/s: 1.20.0 > yarn.application-attempt-failures-validity-interval link url is invalid >

[jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs

[ https://issues.apache.org/jira/browse/FLINK-23942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23942: Fix Version/s: 1.20.0 > Python documentation redirects to shared pages should activate python tabs

[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: 1.20.0 > Incorrect documentation for directory path separators of CoreOptions.TMP_D

[jira] [Updated] (FLINK-27079) Setup cron jobs

[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27079: Fix Version/s: 1.20.0 > Setup cron jobs > --- > > Key: FLINK-27079 >

[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: 1.20.0 > Fix the cast exception thrown by PreValidateReWriter when insert > into/o

[jira] [Updated] (FLINK-34094) Document new AsyncScalarFunction

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

[jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

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

[jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26692: Fix Version/s: 1.20.0 > migrate TpcdsTestProgram.java to new source >

[jira] [Updated] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23147: Fix Version/s: 1.20.0 > ThreadPools can be poisoned by context class loaders > ---

[jira] [Updated] (FLINK-27077) Setup per-commit builds

[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27077: Fix Version/s: 1.20.0 > Setup per-commit builds > --- > > Key:

[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: 1.20.0 > Improve the accuracy of estimating the row count of LocalHashAgg to make m

[jira] [Updated] (FLINK-29547) Select a[1] which is array type for parquet complex type throw ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-29547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29547: Fix Version/s: 1.20.0 > Select a[1] which is array type for parquet complex type throw > ClassCa

[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: 1.20.0 > IteratorSourceReaderBase should report END_OF_INPUT sooner > -

[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: 1.20.0 > Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and S

[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: 1.20.0 > Example in the Elasticsearch doc of fault tolerance section is missing > -

[jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28777: Fix Version/s: 1.20.0 > Add configure session API for sql gateway rest endpoint >

[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: 1.20.0 > Enable connectors to use config docs generator > -

[jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable

[ https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23564: Fix Version/s: 1.20.0 > Make taskmanager.out and taskmanager.err rollable > --

[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: 1.20.0 > An exception is thrown when some named params change order when using wind

[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: 1.20.0 > Fall back to lastest supported HiveShim when user use a higher hive versio

[jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception

[ https://issues.apache.org/jira/browse/FLINK-19254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19254: Fix Version/s: 1.20.0 > Invalid UTF-8 start byte exception > ---

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