[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27954: - Fix Version/s: 1.18.0 (was: 1.17.0) > JobVertexFlameGraphHandler does

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

[ https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28109: - Fix Version/s: 1.18.0 (was: 1.17.0) > Delete useful code in the row

[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 ] Xintong Song updated FLINK-28022: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support Google Cloud PubSub

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

[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27858: - Fix Version/s: 1.18.0 (was: 1.17.0) > Hive source support filter push

[jira] [Updated] (FLINK-28071) Support missing built-in functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28071: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support missing built-in functions

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

[ https://issues.apache.org/jira/browse/FLINK-29027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29027: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix HiveTableSink failed to report

[jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28120: - Fix Version/s: 1.18.0 (was: 1.17.0) > Meet assert error:

[jira] [Updated] (FLINK-28046) Annotate SourceFunction as deprecated

[ https://issues.apache.org/jira/browse/FLINK-28046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28046: - Fix Version/s: 1.18.0 (was: 1.17.0) > Annotate SourceFunction as

[jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code

[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29040: - Fix Version/s: 1.18.0 (was: 1.17.0) > When using the JDBC Catalog, the

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

[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28399: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor CheckedThread to accept

[jira] [Updated] (FLINK-29031) FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29031: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[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 ] Xintong Song updated FLINK-29192: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add completeness test for built-in

[jira] [Updated] (FLINK-29179) Translate "Temporal Table Function" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29179: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate "Temporal Table

[jira] [Updated] (FLINK-28352) [Umbrella] Make Pulsar connector stable

[ https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28352: - Fix Version/s: 1.18.0 (was: 1.17.0) > [Umbrella] Make Pulsar connector

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28440: - Fix Version/s: 1.18.0 (was: 1.17.0) > EventTimeWindowCheckpointingITCase

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

[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28398: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[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 ] Xintong Song updated FLINK-29559: - Fix Version/s: 1.18.0 (was: 1.17.0) > Disable Join Reorder and Hash join

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

[ https://issues.apache.org/jira/browse/FLINK-28401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28401: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove snapshot repo from

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

[ https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29530: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[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 ] Xintong Song updated FLINK-28516: - Fix Version/s: 1.18.0 (was: 1.17.0) > UI is misleading when source

[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 ] Xintong Song updated FLINK-28428: - Fix Version/s: 1.18.0 (was: 1.17.0) > Example in the Elasticsearch doc

[jira] [Updated] (FLINK-28650) Flink SQL Parsing bug for METADATA

[ https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28650: - Fix Version/s: 1.18.0 (was: 1.17.0) > Flink SQL Parsing bug for METADATA

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

[ https://issues.apache.org/jira/browse/FLINK-28538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28538: - Fix Version/s: 1.18.0 (was: 1.17.0) > Eagerly emit a watermark the first

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

[ https://issues.apache.org/jira/browse/FLINK-28726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28726: - Fix Version/s: 1.18.0 (was: 1.17.0) > CompileException:

[jira] [Updated] (FLINK-29802) ChangelogStateBackend supports native savepoint

[ https://issues.apache.org/jira/browse/FLINK-29802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29802: - Fix Version/s: 1.18.0 (was: 1.17.0) > ChangelogStateBackend supports

[jira] [Updated] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

[ https://issues.apache.org/jira/browse/FLINK-28620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28620: - Fix Version/s: 1.18.0 (was: 1.17.0) > SQL Client doesn't properly print

[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 ] Xintong Song updated FLINK-28732: - Fix Version/s: 1.18.0 (was: 1.17.0) > Deprecate ambiguous

[jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28764: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support more than 64 distinct

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

[ https://issues.apache.org/jira/browse/FLINK-29776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29776: - Fix Version/s: 1.18.0 (was: 1.17.0) > [JUnit5 Migration] Module:

[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 ] Xintong Song updated FLINK-28777: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add configure session API for sql

[jira] [Updated] (FLINK-28744) Upgrade Calcite version to 1.31

[ https://issues.apache.org/jira/browse/FLINK-28744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28744: - Fix Version/s: 1.18.0 (was: 1.17.0) > Upgrade Calcite version to 1.31 >

[jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type

[ https://issues.apache.org/jira/browse/FLINK-28830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28830: - Fix Version/s: 1.18.0 (was: 1.17.0) > new stack udtf doesn't support

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

[ https://issues.apache.org/jira/browse/FLINK-28813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28813: - Fix Version/s: 1.18.0 (was: 1.17.0) > new stach builtinfunction

[jira] [Updated] (FLINK-28838) Avoid to notify the elementQueue consumer when the fetch result is empty

[ https://issues.apache.org/jira/browse/FLINK-28838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28838: - Fix Version/s: 1.18.0 (was: 1.17.0) > Avoid to notify the elementQueue

[jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28897: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fail to use udf in added jar when

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

[ https://issues.apache.org/jira/browse/FLINK-28893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28893: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add conv function supported in SQL

[jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29941: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support SQL Client connects to SQL

[jira] [Updated] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog

[ https://issues.apache.org/jira/browse/FLINK-29355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29355: - Fix Version/s: 1.18.0 (was: 1.17.0) > Sql parse failed because of Desc

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

[ https://issues.apache.org/jira/browse/FLINK-29001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29001: - Fix Version/s: 1.18.0 (was: 1.17.0) > Migrate datadog reporter to v2

[jira] [Updated] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey

[ https://issues.apache.org/jira/browse/FLINK-29967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29967: - Fix Version/s: 1.18.0 (was: 1.17.0) > Optimize determinism requirements

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29021: - Fix Version/s: 1.18.0 (was: 1.17.0) > [Umbrella] Add docs for Hive

[jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value

[ https://issues.apache.org/jira/browse/FLINK-29058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29058: - Fix Version/s: 1.18.0 (was: 1.17.0) > Analyze table xxx For columns will

[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 ] Xintong Song updated FLINK-29150: - Fix Version/s: 1.18.0 (was: 1.17.0) > TIMESTAMPDIFF microsecond unit

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

[ https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28901: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[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 ] Xintong Song updated FLINK-30399: - Fix Version/s: 1.18.0 (was: 1.17.0) > Enable connectors to use config

[jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax

[ https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29368: - Fix Version/s: 1.18.0 (was: 1.17.0) > Modify DESCRIBE statement docs for

[jira] [Updated] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29370: - Fix Version/s: 1.18.0 (was: 1.17.0) > Protobuf in flink-sql-protobuf is

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

[ https://issues.apache.org/jira/browse/FLINK-29003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29003: - Fix Version/s: 1.18.0 (was: 1.17.0) > sqlServerDialect should support

[jira] [Updated] (FLINK-30068) Allow users to configure what to do with errors while committing transactions during recovery in KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-30068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30068: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow users to configure what to

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

[ https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29240: - Fix Version/s: 1.18.0 (was: 1.17.0) > Unify the ClassLoader in

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

[ https://issues.apache.org/jira/browse/FLINK-29060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29060: - Fix Version/s: 1.18.0 (was: 1.17.0) > can not set

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

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29339: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29459: - Fix Version/s: 1.18.0 (was: 1.17.0) > Sink v2 has bugs in supporting

[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 ] Xintong Song updated FLINK-30467: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve the accuracy of estimating

[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 ] Xintong Song updated FLINK-29547: - Fix Version/s: 1.18.0 (was: 1.17.0) > Select a[1] which is array type

[jira] [Updated] (FLINK-29551) Improving adaptive hash join by using sort merge join strategy per partition instead of all partitions

[ https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29551: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improving adaptive hash join by

[jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message

[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29646: - Fix Version/s: 1.18.0 (was: 1.17.0) > SQL Gateway should return a

[jira] [Updated] (FLINK-30598) Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan

[ https://issues.apache.org/jira/browse/FLINK-30598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30598: - Fix Version/s: 1.18.0 (was: 1.17.0) > Wrong code generated for

[jira] [Updated] (FLINK-29656) Modify all join-related sql tests to make having statistics as the default choice

[ https://issues.apache.org/jira/browse/FLINK-29656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29656: - Fix Version/s: 1.18.0 (was: 1.17.0) > Modify all join-related sql tests

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

[ https://issues.apache.org/jira/browse/FLINK-29717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29717: - Fix Version/s: 1.18.0 (was: 1.17.0) > Supports hive udaf such as

[jira] [Updated] (FLINK-29723) Supports hive first_value function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29723: - Fix Version/s: 1.18.0 (was: 1.17.0) > Supports hive first_value function

[jira] [Updated] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30613: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve resolving schema

[jira] [Updated] (FLINK-29724) Supports hive last_value function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29724: - Fix Version/s: 1.18.0 (was: 1.17.0) > Supports hive last_value function

[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 ] Xintong Song updated FLINK-29775: - Fix Version/s: 1.18.0 (was: 1.17.0) > [JUnit5 Migration] Module:

[jira] [Updated] (FLINK-29813) Remove deprecated Curator API usages

[ https://issues.apache.org/jira/browse/FLINK-29813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29813: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove deprecated Curator API

[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 ] Xintong Song updated FLINK-30087: - Fix Version/s: 1.18.0 (was: 1.17.0) > sql-gateway-api is bundled twice

[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 ] Xintong Song updated FLINK-29858: - Fix Version/s: 1.18.0 (was: 1.17.0) > Jdbc reading supports setting

[jira] [Updated] (FLINK-30112) Improve docs re state compression

[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30112: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve docs re state compression

[jira] [Updated] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink

[ https://issues.apache.org/jira/browse/FLINK-30166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30166: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor tests that use the

[jira] [Updated] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30275: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[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 ] Xintong Song updated FLINK-30285: - Fix Version/s: 1.18.0 (was: 1.17.0) > Inline checkstyle config into pom

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30289: - Fix Version/s: 1.18.0 (was: 1.17.0) > RateLimitedSourceReader uses wrong

[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 ] Xintong Song updated FLINK-30290: - Fix Version/s: 1.18.0 (was: 1.17.0) > IteratorSourceReaderBase should

[jira] [Updated] (FLINK-30379) Decouple connector docs integration from connector releases

[ https://issues.apache.org/jira/browse/FLINK-30379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30379: - Fix Version/s: 1.18.0 (was: 1.17.0) > Decouple connector docs

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29863: - Fix Version/s: 1.18.0 (was: 1.17.0) > Properly handle NaN/Infinity in

[jira] [Updated] (FLINK-29866) Split flink-dist

[ https://issues.apache.org/jira/browse/FLINK-29866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29866: - Fix Version/s: 1.18.0 (was: 1.17.0) > Split flink-dist >

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

[ https://issues.apache.org/jira/browse/FLINK-29912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29912: - Fix Version/s: 1.18.0 (was: 1.17.0) > jdbc scan.partition.column can

[jira] [Updated] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30989: - Fix Version/s: (was: 1.17.0) > Configuration table.exec.spill-compression.block-size not

[jira] [Updated] (FLINK-30651) Move utility methods to CatalogTest and remove CatalogTestUtils class

[ https://issues.apache.org/jira/browse/FLINK-30651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30651: - Fix Version/s: 1.18.0 (was: 1.17.0) > Move utility methods to

[jira] [Updated] (FLINK-30664) [Connector/Hive] cleanup hive/haoop package ambiguous package dependencies

[ https://issues.apache.org/jira/browse/FLINK-30664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30664: - Fix Version/s: 1.18.0 (was: 1.17.0) > [Connector/Hive] cleanup

[jira] [Updated] (FLINK-30667) remove the planner @internal dependency in flink-connector-hive

[ https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30667: - Fix Version/s: 1.18.0 (was: 1.17.0) > remove the planner @internal

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30524: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support full screen viewing on the

[jira] [Updated] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-31418: - Fix Version/s: 1.18.0 (was: 1.17.0) >

[jira] [Updated] (FLINK-31562) Finalize release 1.17.0

[ https://issues.apache.org/jira/browse/FLINK-31562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-31562: - Fix Version/s: 1.18.0 (was: 1.17.0) > Finalize release 1.17.0 >

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30583: - Fix Version/s: 1.18.0 (was: 1.17.0) > Provide the flame graph to the

[jira] [Updated] (FLINK-30578) Publish SBOM artifacts

[ https://issues.apache.org/jira/browse/FLINK-30578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30578: - Fix Version/s: 1.18.0 (was: 1.17.0) > Publish SBOM artifacts >

[jira] [Updated] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30959: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve the documentation of

[jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output

[ https://issues.apache.org/jira/browse/FLINK-30970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30970: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix SQL Client doc still uses old

[jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected

[ https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30821: - Fix Version/s: 1.18.0 (was: 1.17.0) > The optimized exec plan generated

[jira] [Updated] (FLINK-30932) Enabling producer metrics for KafkaSink is not documented

[ https://issues.apache.org/jira/browse/FLINK-30932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30932: - Fix Version/s: 1.18.0 (was: 1.17.0) > Enabling producer metrics for

[jira] [Updated] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-31305: - Fix Version/s: 1.18.0 (was: 1.17.0) > KafkaWriter doesn't wait for

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

[ https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-31006: - Fix Version/s: 1.18.0 (was: 1.17.0) > job is not finished when using

[jira] [Closed] (FLINK-31321) Yarn-session mode, securityConfiguration supports dynamic configuration

[ https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31321. Fix Version/s: 1.17.0 Resolution: Fixed - master (1.18):

[jira] [Assigned] (FLINK-31321) Yarn-session mode, securityConfiguration supports dynamic configuration

[ https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-31321: Assignee: felixzh > Yarn-session mode, securityConfiguration supports dynamic

[jira] [Closed] (FLINK-27677) Kubernetes reuse rest.bind-port, but do not support a range of ports

[ https://issues.apache.org/jira/browse/FLINK-27677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27677. Resolution: Not A Bug > Kubernetes reuse rest.bind-port, but do not support a range of ports >

[jira] [Closed] (FLINK-31247) Support for fine-grained resource allocation (slot sharing groups) at the TableAPI level

[ https://issues.apache.org/jira/browse/FLINK-31247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31247. Resolution: Won't Do > Support for fine-grained resource allocation (slot sharing groups) at the

[jira] [Commented] (FLINK-31247) Support for fine-grained resource allocation (slot sharing groups) at the TableAPI level

[ https://issues.apache.org/jira/browse/FLINK-31247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698269#comment-17698269 ] Xintong Song commented on FLINK-31247: -- I'm afraid this is not feasible. SlotSharingGroup defines

[jira] [Commented] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694486#comment-17694486 ] Xintong Song commented on FLINK-30829: -- Sorting subtasks by busy/idle/backpressure time sounds to

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