[jira] [Updated] (FLINK-35654) Add Flink CDC verification guide in docs

[ https://issues.apache.org/jira/browse/FLINK-35654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35654: --- Labels: pull-request-available (was: ) > Add Flink CDC verification guide in docs > ---

[jira] [Updated] (FLINK-35702) Support Parquet Nested Read

[ https://issues.apache.org/jira/browse/FLINK-35702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35702: --- Labels: pull-request-available (was: ) > Support Parquet Nested Read >

[jira] [Updated] (FLINK-35704) ForkJoinPool introduction to NonSplittingRecursiveEnumerator to vastly improve enumeration performance

[ https://issues.apache.org/jira/browse/FLINK-35704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35704: --- Labels: pull-request-available (was: ) > ForkJoinPool introduction to NonSplittingRecursive

[jira] [Updated] (FLINK-35691) Fix the bugs found in releasing testing of Materialized Table

[ https://issues.apache.org/jira/browse/FLINK-35691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35691: --- Labels: pull-request-available (was: ) > Fix the bugs found in releasing testing of Materia

[jira] [Updated] (FLINK-35271) Add doc for syntax `describe job 'xxx'`

[ https://issues.apache.org/jira/browse/FLINK-35271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35271: --- Labels: pull-request-available (was: ) > Add doc for syntax `describe job 'xxx'` >

[jira] [Updated] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY

[ https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35687: --- Labels: pull-request-available (was: ) > JSON_QUERY should return a well formatted nested o

[jira] [Updated] (FLINK-35656) Hive Source has issues setting max parallelism in dynamic inference mode

[ https://issues.apache.org/jira/browse/FLINK-35656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35656: --- Labels: pull-request-available (was: ) > Hive Source has issues setting max parallelism in

[jira] [Updated] (FLINK-35662) Use maven batch mode in k8s-operator CI

[ https://issues.apache.org/jira/browse/FLINK-35662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35662: --- Labels: pull-request-available (was: ) > Use maven batch mode in k8s-operator CI >

[jira] [Updated] (FLINK-35643) Add materialized table statement doc

[ https://issues.apache.org/jira/browse/FLINK-35643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35643: --- Labels: pull-request-available (was: ) > Add materialized table statement doc > ---

[jira] [Updated] (FLINK-35674) MySQL connector cause blocking when searching for binlog timestamps

[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35674: --- Labels: pull-request-available (was: ) > MySQL connector cause blocking when searching for

[jira] [Updated] (FLINK-35673) TestFileSource$TestFileSourceBuilder cannot be cast to class FileSource$FileSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-35673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35673: --- Labels: pull-request-available (was: ) > TestFileSource$TestFileSourceBuilder cannot be cas

[jira] [Updated] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

[ https://issues.apache.org/jira/browse/FLINK-35659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35659: --- Labels: pull-request-available (was: ) > Fix TestFileSystem Connector error setting executi

[jira] [Updated] (FLINK-35649) Bump Flink version to 1.19.1 in k8s-operator

[ https://issues.apache.org/jira/browse/FLINK-35649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35649: --- Labels: pull-request-available (was: ) > Bump Flink version to 1.19.1 in k8s-operator > ---

[jira] [Updated] (FLINK-35648) Pipeline job doesn't support multiple routing

[ https://issues.apache.org/jira/browse/FLINK-35648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35648: --- Labels: pull-request-available (was: ) > Pipeline job doesn't support multiple routing > --

[jira] [Updated] (FLINK-35641) ParquetSchemaConverter should correctly handle field optionality

[ https://issues.apache.org/jira/browse/FLINK-35641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35641: --- Labels: patch-available pull-request-available (was: patch-available) > ParquetSchemaConver

[jira] [Updated] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35639: --- Labels: pull-request-available (was: ) > upgrade to 1.19 with job in HA state with restart

[jira] [Updated] (FLINK-35479) Add end-to-end test for materialized table

[ https://issues.apache.org/jira/browse/FLINK-35479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35479: --- Labels: pull-request-available (was: ) > Add end-to-end test for materialized table > -

[jira] [Updated] (FLINK-35632) The example provided in the kafkaSource/pulsarSource documentation for topic regex subscription is incorrect

[ https://issues.apache.org/jira/browse/FLINK-35632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35632: --- Labels: pull-request-available (was: ) > The example provided in the kafkaSource/pulsarSou

[jira] [Updated] (FLINK-35627) Avoid conflict when pipeline job that used Paimon as sink restart.

[ https://issues.apache.org/jira/browse/FLINK-35627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35627: --- Labels: pull-request-available (was: ) > Avoid conflict when pipeline job that used Paimon

[jira] [Updated] (FLINK-35616) Support upsert into sharded collections for MongoRowDataSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35616: --- Labels: pull-request-available (was: ) > Support upsert into sharded collections for MongoR

[jira] [Updated] (FLINK-35625) FLIP-464: Merge "flink run" and "flink run-application"

[ https://issues.apache.org/jira/browse/FLINK-35625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35625: --- Labels: pull-request-available (was: ) > FLIP-464: Merge "flink run" and "flink run-applica

[jira] [Updated] (FLINK-35601) InitOutputPathTest.testErrorOccursUnSynchronized failed due to NoSuchFieldException

[ https://issues.apache.org/jira/browse/FLINK-35601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35601: --- Labels: pull-request-available (was: ) > InitOutputPathTest.testErrorOccursUnSynchronized f

[jira] [Updated] (FLINK-35623) Bump mongo-driver version from 4.7.2 to 5.1.1 to support MongoDB 7.0

[ https://issues.apache.org/jira/browse/FLINK-35623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35623: --- Labels: pull-request-available (was: ) > Bump mongo-driver version from 4.7.2 to 5.1.1 to s

[jira] [Updated] (FLINK-32229) Implement metrics and logging for Initial implementation

[ https://issues.apache.org/jira/browse/FLINK-32229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32229: --- Labels: pull-request-available (was: ) > Implement metrics and logging for Initial implemen

[jira] [Updated] (FLINK-35619) Window rank query fails with "must call validate first"

[ https://issues.apache.org/jira/browse/FLINK-35619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35619: --- Labels: pull-request-available (was: ) > Window rank query fails with "must call validate f

[jira] [Updated] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

[ https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35600: --- Labels: pull-request-available (was: ) > Data read duplication during the full-to-increment

[jira] [Updated] (FLINK-35593) Apache Kubernetes Operator Docker image does not contain Apache LICENSE

[ https://issues.apache.org/jira/browse/FLINK-35593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35593: --- Labels: pull-request-available (was: ) > Apache Kubernetes Operator Docker image does not c

[jira] [Updated] (FLINK-35598) Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep

[ https://issues.apache.org/jira/browse/FLINK-35598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35598: --- Labels: pull-request-available pull_request_available (was: pull_request_available) > Fix

[jira] [Updated] (FLINK-35598) Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep

[ https://issues.apache.org/jira/browse/FLINK-35598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35598: --- Labels: pull-request-available (was: ) > Fix error comparison type ExtendedSqlRowTypeNameSp

[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35237: --- Labels: pull-request-available (was: ) > Allow Sink to Choose HashFunction in PrePartitionO

[jira] [Updated] (FLINK-35597) Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts

[ https://issues.apache.org/jira/browse/FLINK-35597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35597: --- Labels: pull-request-available (was: ) > Fix unstable > LocatableSplitAssignerTest#testCon

[jira] [Updated] (FLINK-35596) Flink application fails with The implementation of the BlockElement is not serializable

[ https://issues.apache.org/jira/browse/FLINK-35596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35596: --- Labels: pull-request-available (was: ) > Flink application fails with The implementation of

[jira] [Updated] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32086: --- Labels: pull-request-available (was: ) > Cleanup non-reported managed directory on exit of

[jira] [Updated] (FLINK-34918) Introduce comment for CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34918: --- Labels: pull-request-available (was: ) > Introduce comment for CatalogStore > -

[jira] [Updated] (FLINK-35512) ArtifactFetchManagerTest unit tests fail

[ https://issues.apache.org/jira/browse/FLINK-35512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35512: --- Labels: pull-request-available (was: ) > ArtifactFetchManagerTest unit tests fail > ---

[jira] [Updated] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1

[ https://issues.apache.org/jira/browse/FLINK-35586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35586: --- Labels: pull-request-available (was: ) > Detected conflict when using Paimon as pipeline si

[jira] [Updated] (FLINK-35585) Add documentation for distribution

[ https://issues.apache.org/jira/browse/FLINK-35585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35585: --- Labels: pull-request-available (was: ) > Add documentation for distribution > -

[jira] [Updated] (FLINK-35570) Consider PlaceholderStreamStateHandle in checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35570: --- Labels: pull-request-available (was: ) > Consider PlaceholderStreamStateHandle in checkpoin

[jira] [Updated] (FLINK-32091) Add necessary metrics for file-merging

[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32091: --- Labels: pull-request-available (was: ) > Add necessary metrics for file-merging > -

[jira] [Updated] (FLINK-35140) Release flink-connector-opensearch v1.2.0 and v.2.0.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35140: --- Labels: pull-request-available (was: ) > Release flink-connector-opensearch v1.2.0 and v.2.

[jira] [Updated] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35371: --- Labels: SSL pull-request-available (was: SSL) > Allow the keystore and truststore type to c

[jira] [Updated] (FLINK-35559) Shading issue cause class conflict

[ https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35559: --- Labels: pull-request-available (was: ) > Shading issue cause class conflict > -

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3: --- Labels: pull-request-available (was: ) > Serializing List with null values throws NPE > ---

[jira] [Updated] (FLINK-35558) [docs] "Edit This Page" tool does not follow contribution guidelines

[ https://issues.apache.org/jira/browse/FLINK-35558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35558: --- Labels: pull-request-available (was: ) > [docs] "Edit This Page" tool does not follow contr

[jira] [Updated] (FLINK-32562) FileSink Compactor Service should not use FileWriter from Sink for OutputStreamBasedFileCompactor

[ https://issues.apache.org/jira/browse/FLINK-32562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32562: --- Labels: pull-request-available (was: ) > FileSink Compactor Service should not use FileWrit

[jira] [Updated] (FLINK-35548) Add E2E tests for PubSubSinkV2

[ https://issues.apache.org/jira/browse/FLINK-35548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35548: --- Labels: pull-request-available (was: ) > Add E2E tests for PubSubSinkV2 > -

[jira] [Updated] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED

[ https://issues.apache.org/jira/browse/FLINK-35556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35556: --- Labels: pull-request-available (was: ) > Wrong constant in RocksDBSharedResourcesFactory.SL

[jira] [Updated] (FLINK-35553) Integrate newly added trigger interface with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-35553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35553: --- Labels: pull-request-available (was: ) > Integrate newly added trigger interface with check

[jira] [Updated] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint

[ https://issues.apache.org/jira/browse/FLINK-35551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35551: --- Labels: pull-request-available (was: ) > Introduces RescaleManager#onTrigger endpoint > ---

[jira] [Updated] (FLINK-35552) Move CheckpointStatsTracker out of ExecutionGraph into Scheduler

[ https://issues.apache.org/jira/browse/FLINK-35552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35552: --- Labels: pull-request-available (was: ) > Move CheckpointStatsTracker out of ExecutionGraph

[jira] [Updated] (FLINK-35550) Introduce new component RescaleManager

[ https://issues.apache.org/jira/browse/FLINK-35550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35550: --- Labels: pull-request-available (was: ) > Introduce new component RescaleManager > -

[jira] [Updated] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items

[ https://issues.apache.org/jira/browse/FLINK-35546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35546: --- Labels: pull-request-available (was: ) > Elasticsearch 8 connector fails fast for non-retry

[jira] [Updated] (FLINK-35545) Miss 3.0.1 version in snapshot flink-cdc doc version list

[ https://issues.apache.org/jira/browse/FLINK-35545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35545: --- Labels: pull-request-available (was: ) > Miss 3.0.1 version in snapshot flink-cdc doc versi

[jira] [Updated] (FLINK-35544) No description of Flink Operator in the Deployment of  Kubernetes document

[ https://issues.apache.org/jira/browse/FLINK-35544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35544: --- Labels: pull-request-available (was: ) > No description of Flink Operator in the Deployment

[jira] [Updated] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environmen

[ https://issues.apache.org/jira/browse/FLINK-35467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35467: --- Labels: Flink-CDC pull-request-available (was: Flink-CDC) > The flink-cdc.sh script of flin

[jira] [Updated] (FLINK-35528) Skip execution of interruptible mails when yielding

[ https://issues.apache.org/jira/browse/FLINK-35528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35528: --- Labels: pull-request-available (was: ) > Skip execution of interruptible mails when yieldin

[jira] [Updated] (FLINK-35543) Upgrade Hive 2.3 connector to version 2.3.10

[ https://issues.apache.org/jira/browse/FLINK-35543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35543: --- Labels: pull-request-available (was: ) > Upgrade Hive 2.3 connector to version 2.3.10 > ---

[jira] [Updated] (FLINK-35540) flink-cdc-pipeline-connector-mysql lost table which database and table with the same name

[ https://issues.apache.org/jira/browse/FLINK-35540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35540: --- Labels: pull-request-available (was: ) > flink-cdc-pipeline-connector-mysql lost table whic

[jira] [Updated] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35542: --- Labels: pull-request-available (was: ) > ClassNotFoundException when deserializing Checkpoi

[jira] [Updated] (FLINK-35490) [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors

[ https://issues.apache.org/jira/browse/FLINK-35490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35490: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: Flink CDC > flink-cdc-

[jira] [Updated] (FLINK-35537) Error when setting state.backend.rocksdb.compression.per.level

[ https://issues.apache.org/jira/browse/FLINK-35537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35537: --- Labels: pull-request-available (was: ) > Error when setting state.backend.rocksdb.compressi

[jira] [Updated] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo

[ https://issues.apache.org/jira/browse/FLINK-35539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35539: --- Labels: pull-request-available (was: ) > The artifactId of flink-migration-test-utils modu

[jira] [Updated] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35533: --- Labels: pull-request-available (was: ) > FLIP-459: Support Flink hybrid shuffle integration

[jira] [Updated] (FLINK-35532) Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard

[ https://issues.apache.org/jira/browse/FLINK-35532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35532: --- Labels: pull-request-available (was: ) > Prevent Cross-Site Authentication (XSA) attacks on

[jira] [Updated] (FLINK-35531) Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream

[ https://issues.apache.org/jira/browse/FLINK-35531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35531: --- Labels: pull-request-available (was: ) > Avoid calling hsync in flush method in > BaseHado

[jira] [Updated] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20217: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: auto

[jira] [Updated] (FLINK-35527) Polish quickstart guide & clean stale links in docs

[ https://issues.apache.org/jira/browse/FLINK-35527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35527: --- Labels: pull-request-available (was: ) > Polish quickstart guide & clean stale links in doc

[jira] [Updated] (FLINK-34569) 'Streaming File Sink s3 end-to-end test' failed

[ https://issues.apache.org/jira/browse/FLINK-34569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34569: --- Labels: pull-request-available test-stability (was: test-stability) > 'Streaming File Sink

[jira] [Updated] (FLINK-35526) Remove deprecated stedolan/jq Docker image from Flink e2e tests

[ https://issues.apache.org/jira/browse/FLINK-35526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35526: --- Labels: pull-request-available (was: ) > Remove deprecated stedolan/jq Docker image from Fl

[jira] [Updated] (FLINK-35525) HDFS delegation token fetched by custom DelegationTokenProvider is not passed to Yarn AM

[ https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35525: --- Labels: pull-request-available (was: ) > HDFS delegation token fetched by custom Delegatio

[jira] [Updated] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf

[ https://issues.apache.org/jira/browse/FLINK-35498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35498: --- Labels: pull-request-available (was: ) > Unexpected argument name conflict error when do ex

[jira] [Updated] (FLINK-35524) Clear connections pools when reader exist.

[ https://issues.apache.org/jira/browse/FLINK-35524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35524: --- Labels: pull-request-available (was: ) > Clear connections pools when reader exist. > -

[jira] [Updated] (FLINK-35201) Support the execution of drop materialized table in full refresh mode

[ https://issues.apache.org/jira/browse/FLINK-35201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35201: --- Labels: pull-request-available (was: ) > Support the execution of drop materialized table i

[jira] [Updated] (FLINK-35522) The source task may get stuck after a failover occurs in batch jobs

[ https://issues.apache.org/jira/browse/FLINK-35522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35522: --- Labels: pull-request-available (was: ) > The source task may get stuck after a failover occ

[jira] [Updated] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-34172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34172: --- Labels: pull-request-available (was: ) > Add support for altering a distribution via ALTER

[jira] [Updated] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector

[ https://issues.apache.org/jira/browse/FLINK-35516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35516: --- Labels: pull-request-available (was: ) > Update the Experimental annotation to PublicEvolvi

[jira] [Updated] (FLINK-35489) Metaspace size can be too little after autotuning change memory setting

[ https://issues.apache.org/jira/browse/FLINK-35489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35489: --- Labels: pull-request-available (was: ) > Metaspace size can be too little after autotuning

[jira] [Updated] (FLINK-35501) Use common thread pools when transferring RocksDB state files

[ https://issues.apache.org/jira/browse/FLINK-35501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35501: --- Labels: pull-request-available (was: ) > Use common thread pools when transferring RocksDB

[jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26050: --- Labels: pull-request-available (was: ) > Too many small sst files in rocksdb state backend

[jira] [Updated] (FLINK-35510) Implement basic incremental checkpoint for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35510: --- Labels: pull-request-available (was: ) > Implement basic incremental checkpoint for ForStSt

[jira] [Updated] (FLINK-35509) Slack community invite link has expired

[ https://issues.apache.org/jira/browse/FLINK-35509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35509: --- Labels: pull-request-available (was: ) > Slack community invite link has expired >

[jira] [Updated] (FLINK-34482) Rename options for checkpointing

[ https://issues.apache.org/jira/browse/FLINK-34482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34482: --- Labels: pull-request-available (was: ) > Rename options for checkpointing > ---

[jira] [Updated] (FLINK-35504) Improve Elasticsearch 8 connector observability

[ https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35504: --- Labels: pull-request-available (was: ) > Improve Elasticsearch 8 connector observability >

[jira] [Updated] (FLINK-35200) Support the execution of suspend, resume materialized table in full refresh mode

[ https://issues.apache.org/jira/browse/FLINK-35200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35200: --- Labels: pull-request-available (was: ) > Support the execution of suspend, resume materiali

[jira] [Updated] (FLINK-35282) PyFlink Support for Apache Beam > 2.49

[ https://issues.apache.org/jira/browse/FLINK-35282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35282: --- Labels: pull-request-available (was: ) > PyFlink Support for Apache Beam > 2.49 > -

[jira] [Updated] (FLINK-35475) Introduce isInternalSorterSupport to OperatorAttributes

[ https://issues.apache.org/jira/browse/FLINK-35475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35475: --- Labels: pull-request-available (was: ) > Introduce isInternalSorterSupport to OperatorAttri

[jira] [Updated] (FLINK-32081) Compatibility between file-merging on and off across job runs

[ https://issues.apache.org/jira/browse/FLINK-32081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32081: --- Labels: pull-request-available (was: ) > Compatibility between file-merging on and off acro

[jira] [Updated] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35496: --- Labels: pull-request-available (was: ) > The annotations of the new JDBC connector should b

[jira] [Updated] (FLINK-35121) CDC pipeline connector should verify requiredOptions and optionalOptions

[ https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35121: --- Labels: pull-request-available (was: ) > CDC pipeline connector should verify requiredOptio

[jira] [Updated] (FLINK-34613) allow specifing a savepoint file to restart using cli script.

[ https://issues.apache.org/jira/browse/FLINK-34613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34613: --- Labels: pull-request-available (was: ) > allow specifing a savepoint file to restart using

[jira] [Updated] (FLINK-35483) BatchJobRecoveryTest related to JM failover produced no output for 900 second

[ https://issues.apache.org/jira/browse/FLINK-35483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35483: --- Labels: pull-request-available (was: ) > BatchJobRecoveryTest related to JM failover produc

[jira] [Updated] (FLINK-35484) Flink document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35484: --- Labels: pull-request-available (was: ) > Flink document file had removed but website can ac

[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 ] ASF GitHub Bot updated FLINK-34559: --- Labels: pull-request-available (was: ) > TVF Window Aggregations might get stuck >

[jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35363: --- Labels: pull-request-available (was: ) > FLIP-449: Reorganization of flink-connector-jdbc >

[jira] [Updated] (FLINK-35311) FLIP-454: New Apicurio Avro format

[ https://issues.apache.org/jira/browse/FLINK-35311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35311: --- Labels: pull-request-available (was: ) > FLIP-454: New Apicurio Avro format > -

[jira] [Updated] (FLINK-15753) Show non-numeric metrics in Web UI

[ https://issues.apache.org/jira/browse/FLINK-15753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15753: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: auto

[jira] [Updated] (FLINK-35199) Support the execution of create materialized table in full refresh mode

[ https://issues.apache.org/jira/browse/FLINK-35199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35199: --- Labels: pull-request-available (was: ) > Support the execution of create materialized table

[jira] [Updated] (FLINK-33462) Sort out the document page about the new Jdbc source.

[ https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33462: --- Labels: pull-request-available (was: ) > Sort out the document page about the new Jdbc sour

[jira] [Updated] (FLINK-26808) [flink v1.14.2] Submit jobs via REST API not working after set web.submit.enable: false

[ https://issues.apache.org/jira/browse/FLINK-26808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26808: --- Labels: pull-request-available (was: ) > [flink v1.14.2] Submit jobs via REST API not worki

[jira] [Updated] (FLINK-35399) Add documents for batch job master failure recovery

[ https://issues.apache.org/jira/browse/FLINK-35399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35399: --- Labels: pull-request-available (was: ) > Add documents for batch job master failure recover

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