[jira] [Updated] (FLINK-38194) Iceberg connector supports auto-creating namespace

[ https://issues.apache.org/jira/browse/FLINK-38194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38194: --- Labels: pull-request-available (was: ) > Iceberg connector supports auto-creating namespace

[jira] [Updated] (FLINK-36359) IT case for DDB Streams connector

[ https://issues.apache.org/jira/browse/FLINK-36359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36359: --- Labels: pull-request-available (was: ) > IT case for DDB Streams connector > --

[jira] [Updated] (FLINK-38193) Upgrade org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 to mitigate CVE-2025-48924

[ https://issues.apache.org/jira/browse/FLINK-38193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38193: --- Labels: pull-request-available (was: ) > Upgrade org.apache.commons:commons-lang3 from 3.12

[jira] [Updated] (FLINK-38192) Improve DynamicSourceUtils exception msg

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

[jira] [Updated] (FLINK-38164) MySQL connector support LONG and LONG VARCHAR type

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

[jira] [Updated] (FLINK-38188) PostgreSQL connector database name validation logic is inverted in getValidateDatabaseName method

[ https://issues.apache.org/jira/browse/FLINK-38188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38188: --- Labels: bug easyfix postgresql pull-request-available validation (was: bug easyfix postgres

[jira] [Updated] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes

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

[jira] [Updated] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info.

[ https://issues.apache.org/jira/browse/FLINK-38184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38184: --- Labels: pull-request-available (was: ) > CDC no need to getCopyOfBuffer for each split info

[jira] [Updated] (FLINK-38123) The autoscaling example image is based on Flink 1.18 rather than 1.20.1.

[ https://issues.apache.org/jira/browse/FLINK-38123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38123: --- Labels: pull-request-available (was: ) > The autoscaling example image is based on Flink 1.

[jira] [Updated] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38183: --- Labels: pull-request-available (was: ) > Data loss when cdc reading mysql that has out of o

[jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator

[ https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37869: --- Labels: pull-request-available (was: ) > FINISHED bouned job can't be cleanup by the Flink

[jira] [Updated] (FLINK-37735) Replace class.newInstance with constructor.newInstance

[ https://issues.apache.org/jira/browse/FLINK-37735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37735: --- Labels: pull-request-available (was: ) > Replace class.newInstance with constructor.newInst

[jira] [Updated] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal

[ https://issues.apache.org/jira/browse/FLINK-38181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38181: --- Labels: pull-request-available (was: ) > Code generation fails for ROW() with CAST to SMALL

[jira] [Updated] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception

[ https://issues.apache.org/jira/browse/FLINK-38180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38180: --- Labels: pull-request-available (was: ) > Race condition between failing Task and cancelatio

[jira] [Updated] (FLINK-38179) Build Failure Due to os-maven-plugin Missing Support

[ https://issues.apache.org/jira/browse/FLINK-38179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38179: --- Labels: pull-request-available (was: ) > Build Failure Due to os-maven-plugin Missing Suppo

[jira] [Updated] (FLINK-37937) Test Cassandra source in real cluster conditions to better test the split.

[ https://issues.apache.org/jira/browse/FLINK-37937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37937: --- Labels: pull-request-available (was: ) > Test Cassandra source in real cluster conditions t

[jira] [Updated] (FLINK-38177) ALTER TABLE .. MODIFY WATERMARK might reset current distribution

[ https://issues.apache.org/jira/browse/FLINK-38177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38177: --- Labels: pull-request-available (was: ) > ALTER TABLE .. MODIFY WATERMARK might reset curren

[jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator

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

[jira] [Updated] (FLINK-38176) Release kafka connector 4.0.1

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

[jira] [Updated] (FLINK-38171) Add 2.1 to PreviousDocs list

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

[jira] [Updated] (FLINK-38141) Iceberg sink has an incorrect type conversion

[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38141: --- Labels: CDC Sink iceberg pull-request-available (was: CDC Sink iceberg) > Iceberg sink has

[jira] [Updated] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter

[ https://issues.apache.org/jira/browse/FLINK-38154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38154: --- Labels: pull-request-available (was: ) > Add HTTP support to OpenTelemetry Reporter > -

[jira] [Updated] (FLINK-38158) FLIP-484: Add custom metric variables to operators

[ https://issues.apache.org/jira/browse/FLINK-38158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38158: --- Labels: pull-request-available (was: ) > FLIP-484: Add custom metric variables to operators

[jira] [Updated] (FLINK-38159) Update commons-lang3 to mitigate CVE-2025-48924

[ https://issues.apache.org/jira/browse/FLINK-38159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38159: --- Labels: pull-request-available (was: ) > Update commons-lang3 to mitigate CVE-2025-48924 >

[jira] [Updated] (FLINK-38156) Pipeline E2E tests are currently bound to fail.

[ https://issues.apache.org/jira/browse/FLINK-38156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38156: --- Labels: pull-request-available (was: ) > Pipeline E2E tests are currently bound to fail. >

[jira] [Updated] (FLINK-38151) Class MetricFetcherImpl's method fetchMetrics failed log level adjustment to error

[ https://issues.apache.org/jira/browse/FLINK-38151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38151: --- Labels: pull-request-available (was: ) > Class MetricFetcherImpl's method fetchMetrics fail

[jira] [Updated] (FLINK-38150) Fail in planning if window boundary is not numeric/interval_day_time

[ https://issues.apache.org/jira/browse/FLINK-38150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38150: --- Labels: pull-request-available (was: ) > Fail in planning if window boundary is not numeric

[jira] [Updated] (FLINK-38149) Convert COLUMN_LIST to DescriptorType

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

[jira] [Updated] (FLINK-38147) Add Flink 2.1 support to operator

[ https://issues.apache.org/jira/browse/FLINK-38147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38147: --- Labels: pull-request-available (was: ) > Add Flink 2.1 support to operator > --

[jira] [Updated] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

[ https://issues.apache.org/jira/browse/FLINK-35746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35746: --- Labels: pull-request-available (was: ) > Add logic to override observed config based on set

[jira] [Updated] (FLINK-38143) Pyflink flat YAML based config support is broken

[ https://issues.apache.org/jira/browse/FLINK-38143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38143: --- Labels: pull-request-available (was: ) > Pyflink flat YAML based config support is broken >

[jira] [Updated] (FLINK-38142) Bump the version of Paimon flink to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-38142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38142: --- Labels: pull-request-available (was: ) > Bump the version of Paimon flink to 1.2.0 > --

[jira] [Updated] (FLINK-38137) RocksDB State Backend Null Serialization Causes NPE and Asymmetric (De)Serialization Logic

[ https://issues.apache.org/jira/browse/FLINK-38137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38137: --- Labels: pull-request-available (was: ) > RocksDB State Backend Null Serialization Causes NP

[jira] [Updated] (FLINK-38134) Cannot recognize DropColumnEvent in method SchemaMergingUtils.getSchemaDifference.

[ https://issues.apache.org/jira/browse/FLINK-38134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38134: --- Labels: pull-request-available (was: ) > Cannot recognize DropColumnEvent in method > Sche

[jira] [Updated] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations

[ https://issues.apache.org/jira/browse/FLINK-38140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38140: --- Labels: pull-request-available (was: ) > Change name from table.exec.async-scalar.buffer-ca

[jira] [Updated] (FLINK-38093) Update version of Fabric8 to 7.3.1

[ https://issues.apache.org/jira/browse/FLINK-38093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38093: --- Labels: pull-request-available (was: ) > Update version of Fabric8 to 7.3.1 > -

[jira] [Updated] (FLINK-38139) Schema changes still caused issues after enabling scan.parse.online.schema.changes.enabled

[ https://issues.apache.org/jira/browse/FLINK-38139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38139: --- Labels: pull-request-available (was: ) > Schema changes still caused issues after enabling

[jira] [Updated] (FLINK-38138) Array OOB error when trying to get a binary from a non-zero offset from a vector

[ https://issues.apache.org/jira/browse/FLINK-38138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38138: --- Labels: pull-request-available (was: ) > Array OOB error when trying to get a binary from a

[jira] [Updated] (FLINK-38136) Add restore tests for PTFs

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

[jira] [Updated] (FLINK-35855) Upgrade Calcite version to 1.36.0

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

[jira] [Updated] (FLINK-38135) Non-existent method for RAW type hashing

[ https://issues.apache.org/jira/browse/FLINK-38135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38135: --- Labels: pull-request-available (was: ) > Non-existent method for RAW type hashing > ---

[jira] [Updated] (FLINK-38114) Allow offloading of task restore

[ https://issues.apache.org/jira/browse/FLINK-38114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38114: --- Labels: pull-request-available (was: ) > Allow offloading of task restore > ---

[jira] [Updated] (FLINK-38010) [Release-2.1] Create a release branch

[ https://issues.apache.org/jira/browse/FLINK-38010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38010: --- Labels: pull-request-available (was: ) > [Release-2.1] Create a release branch > -

[jira] [Updated] (FLINK-37988) Add left join support for AsyncTableFunction

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

[jira] [Updated] (FLINK-38034) raise back the visibility of org.apache.flink.streaming.runtime.operators.GenericWriteAheadSinkTest to public

[ https://issues.apache.org/jira/browse/FLINK-38034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38034: --- Labels: pull-request-available (was: ) > raise back the visibility of > org.apache.flink.s

[jira] [Updated] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service

[ https://issues.apache.org/jira/browse/FLINK-38111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38111: --- Labels: cdc enhancement pull-request-available (was: cdc enhancement) > Migrate OceanBase C

[jira] [Updated] (FLINK-38121) Build python wheel on linux failed

[ https://issues.apache.org/jira/browse/FLINK-38121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38121: --- Labels: pull-request-available (was: ) > Build python wheel on linux failed > -

[jira] [Updated] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32695: --- Labels: pull-request-available (was: ) > Migrate SourceFunction in Tests to Source V2 API >

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38109: --- Labels: pull-request-available (was: ) > BlobServer isn't associated with the correct bind-

[jira] [Updated] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins

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

[jira] [Updated] (FLINK-38112) Change default of yarn.application-attempt-failures-validity-interval to -1

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

[jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule

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

[jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE

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

[jira] [Updated] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types

[ https://issues.apache.org/jira/browse/FLINK-37914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37914: --- Labels: pull-request-available (was: ) > Implement OBJECT_UPDATE Function for In-Place Modi

[jira] [Updated] (FLINK-38113) Rethrow fatal or OOM errors from Execution.deploy

[ https://issues.apache.org/jira/browse/FLINK-38113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38113: --- Labels: pull-request-available (was: ) > Rethrow fatal or OOM errors from Execution.deploy

[jira] [Updated] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

[ https://issues.apache.org/jira/browse/FLINK-38108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38108: --- Labels: pull-request-available (was: ) > Incorrect conversion from Java BigDecimal to SQL D

[jira] [Updated] (FLINK-38044) [UI] upgrade runtime web Angular framework and related deps to lastest version

[ https://issues.apache.org/jira/browse/FLINK-38044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38044: --- Labels: pull-request-available (was: ) > [UI] upgrade runtime web Angular framework and rel

[jira] [Updated] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38098: --- Labels: pull-request-available (was: ) > When submitting a task with the flink run command,

[jira] [Updated] (FLINK-26823) Make Cassandra Source available for Flink SQL users

[ https://issues.apache.org/jira/browse/FLINK-26823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26823: --- Labels: pull-request-available (was: ) > Make Cassandra Source available for Flink SQL user

[jira] [Updated] (FLINK-38105) AttributeError: 'pyflink.fn_execution.table.window_aggregate_fast.S' object has no attribute 'get_accumulators'

[ https://issues.apache.org/jira/browse/FLINK-38105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38105: --- Labels: pull-request-available (was: ) > AttributeError: 'pyflink.fn_execution.table.window

[jira] [Updated] (FLINK-38103) DataTypeFactory cannot restore inline structured types

[ https://issues.apache.org/jira/browse/FLINK-38103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38103: --- Labels: pull-request-available (was: ) > DataTypeFactory cannot restore inline structured t

[jira] [Updated] (FLINK-38097) Add finalizer to custom Role example for Cluster Scoped Flink Operator

[ https://issues.apache.org/jira/browse/FLINK-38097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38097: --- Labels: documentaion pull-request-available (was: documentaion) > Add finalizer to custom R

[jira] [Updated] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-38081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38081: --- Labels: pull-request-available (was: ) > FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Sy

[jira] [Updated] (FLINK-37968) Upgrade Netty version to 4.1.118+ in flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-37968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37968: --- Labels: pull-request-available (was: ) > Upgrade Netty version to 4.1.118+ in flink-connect

[jira] [Updated] (FLINK-38035) Security Vulnerability in PyFlink Logging Mechanism (PythonEnvUtils.java)

[ https://issues.apache.org/jira/browse/FLINK-38035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38035: --- Labels: pull-request-available (was: ) > Security Vulnerability in PyFlink Logging Mechanis

[jira] [Updated] (FLINK-38094) Introduce pyflink.__version__

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

[jira] [Updated] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing

[ https://issues.apache.org/jira/browse/FLINK-32033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32033: --- Labels: pull-request-available (was: ) > Resource lifecycle state shows stable even if appl

[jira] [Updated] (FLINK-38091) Update japicmp configuration post 1.20.2

[ https://issues.apache.org/jira/browse/FLINK-38091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38091: --- Labels: pull-request-available (was: ) > Update japicmp configuration post 1.20.2 > ---

[jira] [Updated] (FLINK-38092) Update japicmp configuration post 1.19.3

[ https://issues.apache.org/jira/browse/FLINK-38092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38092: --- Labels: pull-request-available (was: ) > Update japicmp configuration post 1.19.3 > ---

[jira] [Updated] (FLINK-38031) Support and Release Connectors for Flink 2.1

[ https://issues.apache.org/jira/browse/FLINK-38031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38031: --- Labels: pull-request-available (was: ) > Support and Release Connectors for Flink 2.1 > ---

[jira] [Updated] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types

[ https://issues.apache.org/jira/browse/FLINK-38090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38090: --- Labels: pull-request-available (was: ) > TableResult.collect() returns incorrect SQL inline

[jira] [Updated] (FLINK-38089) Avoid pushing down non-deterministic filter in agg, join and union

[ https://issues.apache.org/jira/browse/FLINK-38089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38089: --- Labels: pull-request-available (was: ) > Avoid pushing down non-deterministic filter in agg

[jira] [Updated] (FLINK-38087) Improve OperationExecutor error messages and Java stream usage

[ https://issues.apache.org/jira/browse/FLINK-38087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38087: --- Labels: pull-request-available (was: ) > Improve OperationExecutor error messages and Java

[jira] [Updated] (FLINK-38086) Make ChangelogNormalize reusable if possible

[ https://issues.apache.org/jira/browse/FLINK-38086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38086: --- Labels: pull-request-available (was: ) > Make ChangelogNormalize reusable if possible > ---

[jira] [Updated] (FLINK-28648) Allow session deletion to block on any running job

[ https://issues.apache.org/jira/browse/FLINK-28648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28648: --- Labels: pull-request-available (was: ) > Allow session deletion to block on any running job

[jira] [Updated] (FLINK-38082) User's async function timeout call may result in unexpected retries

[ https://issues.apache.org/jira/browse/FLINK-38082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38082: --- Labels: pull-request-available (was: ) > User's async function timeout call may result in u

[jira] [Updated] (FLINK-38079) Add Pipeline support for DateType and TimeType

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

[jira] [Updated] (FLINK-38017) [Release-2.1] Add release note for release 2.1

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

[jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction

[ https://issues.apache.org/jira/browse/FLINK-37913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37913: --- Labels: pull-request-available (was: ) > Implement OBJECT_OF Function for Structured Type

[jira] [Updated] (FLINK-38047) Bump cert-manager in the Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-38047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38047: --- Labels: dependency pull-request-available (was: dependency) > Bump cert-manager in the Kube

[jira] [Updated] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD

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

[jira] [Updated] (FLINK-38073) Add documentation for the MultiJoin Operator

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

[jira] [Updated] (FLINK-38051) Fix flaky test JobAutoScalerImplTest

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

[jira] [Updated] (FLINK-38069) The nullability of function ENCODE return type differs in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-38069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38069: --- Labels: pull-request-available (was: ) > The nullability of function ENCODE return type dif

[jira] [Updated] (FLINK-38068) Fix distribution

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

[jira] [Updated] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

[ https://issues.apache.org/jira/browse/FLINK-38065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38065: --- Labels: pull-request-available (was: ) > Mismatching bracket in PostgresOffset#toString > -

[jira] [Updated] (FLINK-38064) Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1

[ https://issues.apache.org/jira/browse/FLINK-38064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38064: --- Labels: pull-request-available (was: ) > Bump cyclonedx-maven-plugin from 2.7.7 to 2.9.1 >

[jira] [Updated] (FLINK-38046) Solve the issue of missing one piece of data

[ https://issues.apache.org/jira/browse/FLINK-38046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38046: --- Labels: pull-request-available (was: ) > Solve the issue of missing one piece of data > ---

[jira] [Updated] (FLINK-38048) flink-connector-parent java version should be set to 11

[ https://issues.apache.org/jira/browse/FLINK-38048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38048: --- Labels: pull-request-available (was: ) > flink-connector-parent java version should be set

[jira] [Updated] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

[ https://issues.apache.org/jira/browse/FLINK-38063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38063: --- Labels: pull-request-available (was: ) > Update dependencies in the Flink Connector Kafka P

[jira] [Updated] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names

[ https://issues.apache.org/jira/browse/FLINK-38050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38050: --- Labels: pull-request-available (was: ) > Flink UI has fixed dropdown width and truncates me

[jira] [Updated] (FLINK-38057) Connector emit time lag may be a wrong value

[ https://issues.apache.org/jira/browse/FLINK-38057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38057: --- Labels: pull-request-available (was: ) > Connector emit time lag may be a wrong value > ---

[jira] [Updated] (FLINK-38042) Warn the user on full table scans

[ https://issues.apache.org/jira/browse/FLINK-38042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38042: --- Labels: pull-request-available (was: ) > Warn the user on full table scans > --

[jira] [Updated] (FLINK-38062) ENCODE behaves wrong

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

[jira] [Updated] (FLINK-38060) Github action build python wheel on linux failed

[ https://issues.apache.org/jira/browse/FLINK-38060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38060: --- Labels: pull-request-available (was: ) > Github action build python wheel on linux failed >

[jira] [Updated] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake

[ https://issues.apache.org/jira/browse/FLINK-36962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36962: --- Labels: pull-request-available (was: ) > push down non-deterministic filter after stream jo

[jira] [Updated] (FLINK-37983) Upgrade Kafka Client version to 3.9.1

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

[jira] [Updated] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs

[ https://issues.apache.org/jira/browse/FLINK-37895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37895: --- Labels: pull-request-available (was: ) > "Failed to fetch job exceptions from REST API for

[jira] [Updated] (FLINK-38033) Job upgrades fail for operator v1.12

[ https://issues.apache.org/jira/browse/FLINK-38033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38033: --- Labels: pull-request-available (was: ) > Job upgrades fail for operator v1.12 > ---

[jira] [Updated] (FLINK-38041) Schema.Builder#fromResolvedSchema drops comments

[ https://issues.apache.org/jira/browse/FLINK-38041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38041: --- Labels: pull-request-available (was: ) > Schema.Builder#fromResolvedSchema drops comments >

  1   2   3   4   5   6   7   8   9   10   >