[jira] [Updated] (FLINK-23657) Cleanup metric reporter modules

[ https://issues.apache.org/jira/browse/FLINK-23657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23657: Fix Version/s: 1.16.0 > Cleanup metric reporter modules > --- > >

[jira] [Updated] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20794: Fix Version/s: 1.16.0 > Support to select distinct columns in the Table API >

[jira] [Updated] (FLINK-21971) Support FLIP-27 based kafka source connector in PyFlink DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21971: Fix Version/s: 1.16.0 > Support FLIP-27 based kafka source connector in PyFlink DataStream API > -

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-26129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26129: Fix Version/s: 1.16.0 > Using fail method instead of kill method when yarn application deployment > error

[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17826: Fix Version/s: 1.16.0 > Add missing custom query support on new jdbc connector > -

[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log

[ https://issues.apache.org/jira/browse/FLINK-19846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19846: Fix Version/s: 1.16.0 > Grammar mistakes in annotations and log > ---

[jira] [Updated] (FLINK-18753) Support local recovery for Unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18753: Fix Version/s: 1.16.0 > Support local recovery for Unaligned checkpoints > ---

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18592: Fix Version/s: 1.16.0 > StreamingFileSink fails due to truncating HDFS file failure >

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

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-12692: Fix Version/s: 1.16.0 > Support disk spilling in HeapKeyedStateBackend > -

[jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21302: Fix Version/s: 1.16.0 > Fix NPE when use row_number() in over agg > --

[jira] [Updated] (FLINK-27186) support ElasticSearch 8

[ https://issues.apache.org/jira/browse/FLINK-27186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27186: Fix Version/s: 1.16.0 > support ElasticSearch 8 > --- > > Key: FLINK-2

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14148: Fix Version/s: 1.16.0 > Investigate pushing predicate/projection to underlying Hive input format > ---

[jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names

[ https://issues.apache.org/jira/browse/FLINK-20518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20518: Fix Version/s: 1.16.0 > WebUI should escape characters in metric names > -

[jira] [Updated] (FLINK-26240) PulsarSinkITCase.tearDown failed in azure

[ https://issues.apache.org/jira/browse/FLINK-26240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26240: Fix Version/s: 1.16.0 > PulsarSinkITCase.tearDown failed in azure > --

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23031: Fix Version/s: 1.16.0 > Support to emit window result with periodic or non_periodic >

[jira] [Updated] (FLINK-22567) OrcFsStreamingSinkITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-22567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22567: Fix Version/s: 1.16.0 > OrcFsStreamingSinkITCase crashes JVM > > >

[jira] [Updated] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18958: Fix Version/s: 1.16.0 > Lose column comment when create table > - > >

[jira] [Updated] (FLINK-23887) Check thread pollution for 1.14

[ https://issues.apache.org/jira/browse/FLINK-23887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23887: Fix Version/s: 1.16.0 > Check thread pollution for 1.14 > --- > >

[jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15351: Fix Version/s: 1.16.0 > develop PostgresCatalog to connect Flink with Postgres tables and ecosystem >

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

[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23216: Fix Version/s: 1.16.0 > RM keeps allocating and freeing slots after a TM lost until its heartbeat > timeo

[jira] [Updated] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21317: Fix Version/s: 1.16.0 > Downstream keyed state not work after FlinkKafkaShuffle >

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24048: Fix Version/s: 1.16.0 > Move changeLog inference out of optimizing phase > ---

[jira] [Updated] (FLINK-21966) Support Kinesis connector in Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-21966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21966: Fix Version/s: 1.16.0 > Support Kinesis connector in Python DataStream API. >

[jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16774: Fix Version/s: 1.16.0 > expose HBaseUpsertSinkFunction hTableName and schema for other system > --

[jira] [Updated] (FLINK-26154) SavepointFormatITCase times out on azure

[ https://issues.apache.org/jira/browse/FLINK-26154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26154: Fix Version/s: 1.16.0 > SavepointFormatITCase times out on azure > ---

[jira] [Updated] (FLINK-14471) Hide error message when metric api failed

[ https://issues.apache.org/jira/browse/FLINK-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14471: Fix Version/s: 1.16.0 > Hide error message when metric api failed > --

[jira] [Updated] (FLINK-22558) testcontainers fail to start ResourceReaper

[ https://issues.apache.org/jira/browse/FLINK-22558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22558: Fix Version/s: 1.16.0 > testcontainers fail to start ResourceReaper >

[jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16073: Fix Version/s: 1.16.0 > Translate "State & Fault Tolerance" pages into Chinese > -

[jira] [Updated] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-22821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22821: Fix Version/s: 1.16.0 > FlinkKafkaProducerMigrationTest fails with "Address already in use" >

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-12352: Fix Version/s: 1.16.0 > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default > S

[jira] [Updated] (FLINK-26505) Support non equality condition for left semi join in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26505: Fix Version/s: 1.16.0 > Support non equality condition for left semi join in Hive dialect > --

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17785: Fix Version/s: 1.16.0 > Refactor orc shim to create a OrcShimFactory in hive > ---

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18742: Fix Version/s: 1.16.0 > Some configuration args do not take effect at client > ---

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

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

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16609: Fix Version/s: 1.16.0 > Promotes the column name representation of SQL-CLI > -

[jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs

[ https://issues.apache.org/jira/browse/FLINK-20818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20818: Fix Version/s: 1.16.0 > End to end test produce excessive amount of logs > ---

[jira] [Updated] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17482: Fix Version/s: 1.16.0 > KafkaITCase.testMultipleSourcesOnePartition unstable > ---

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

[ https://issues.apache.org/jira/browse/FLINK-15860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15860: Fix Version/s: 1.16.0 > Store temporary functions as CatalogFunctions in FunctionCatalog > ---

[jira] [Updated] (FLINK-18231) flink kafka connector exists same qualified class name, whch will cause conflicts when user has all the versions of flink-kafka-connector

[ https://issues.apache.org/jira/browse/FLINK-18231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18231: Fix Version/s: 1.16.0 > flink kafka connector exists same qualified class name, whch will cause > conflic

[jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer

[ https://issues.apache.org/jira/browse/FLINK-24226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24226: Fix Version/s: 1.16.0 > Improve error message when trying Presto S3 FS with recoverable writer > -

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21711: Fix Version/s: 1.16.0 > DataStreamSink doesn't allow setting maxParallelism >

[jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username

[ https://issues.apache.org/jira/browse/FLINK-19562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19562: Fix Version/s: 1.16.0 > the /flink/docs/docker/run.sh cause an error with numeric username > -

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

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

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26568: Fix Version/s: 1.16.0 > BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing > ou

[jira] [Updated] (FLINK-24791) py37-cython failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-24791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24791: Fix Version/s: 1.16.0 > py37-cython failed on AZP > - > > Key: FLI

[jira] [Updated] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20887: Fix Version/s: 1.16.0 > Non-deterministic functions return different values even if it is referred > with

[jira] [Updated] (FLINK-21962) SQL Group Windows do not work on Flink 1.11

[ https://issues.apache.org/jira/browse/FLINK-21962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21962: Fix Version/s: 1.16.0 > SQL Group Windows do not work on Flink 1.11 > ---

[jira] [Updated] (FLINK-24362) Consider reworking handlers to use composition

[ https://issues.apache.org/jira/browse/FLINK-24362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24362: Fix Version/s: 1.16.0 > Consider reworking handlers to use composition > -

[jira] [Updated] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22805: Fix Version/s: 1.16.0 > Dynamic configuration of Flink checkpoint interval > -

[jira] [Updated] (FLINK-24787) Add more details of state latency tracking documentation

[ https://issues.apache.org/jira/browse/FLINK-24787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24787: Fix Version/s: 1.16.0 > Add more details of state latency tracking documentation > ---

[jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files

[ https://issues.apache.org/jira/browse/FLINK-22897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22897: Fix Version/s: 1.16.0 > FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many > sm

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22826: Fix Version/s: 1.16.0 > flink sql1.13.1 causes data loss based on change log stream data join > --

[jira] [Updated] (FLINK-24786) Introduce RocksDB's statistics related options

[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24786: Fix Version/s: 1.16.0 > Introduce RocksDB's statistics related options > -

[jira] [Updated] (FLINK-24637) Move savepoint disposal operation cache into Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-24637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24637: Fix Version/s: 1.16.0 > Move savepoint disposal operation cache into Dispatcher >

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21876: Fix Version/s: 1.16.0 > Handle it properly when the returned value of Python UDF doesn't match the > defi

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

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

[jira] [Updated] (FLINK-23379) interval left join null value result out of order

[ https://issues.apache.org/jira/browse/FLINK-23379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23379: Fix Version/s: 1.16.0 > interval left join null value result out of order > -

[jira] [Updated] (FLINK-25349) Add test that ensures that parameter/return types have the same or stronger stability guarantee than method

[ https://issues.apache.org/jira/browse/FLINK-25349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25349: Fix Version/s: 1.16.0 > Add test that ensures that parameter/return types have the same or stronger > sta

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

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

[jira] [Updated] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26788: Fix Version/s: 1.16.0 > AbstractDeserializationSchema should add cause when thow a > FlinkRuntimeExceptio

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18807: Fix Version/s: 1.16.0 > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout > expir

[jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23403: Fix Version/s: 1.16.0 > Decrease default values for heartbeat timeout and interval > -

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

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

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13856: Fix Version/s: 1.16.0 > Reduce the delete file api when the checkpoint is completed >

[jira] [Updated] (FLINK-24313) JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start after 10000ms"

[ https://issues.apache.org/jira/browse/FLINK-24313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24313: Fix Version/s: 1.16.0 > JdbcCatalogFactoryTest fails due to "Gave up waiting for server to start > after

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20576: Fix Version/s: 1.16.0 > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Updated] (FLINK-22366) HiveSinkCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22366: Fix Version/s: 1.16.0 > HiveSinkCompactionITCase fails on azure > ---

[jira] [Updated] (FLINK-25231) Update PyFlink to use the new type system

[ https://issues.apache.org/jira/browse/FLINK-25231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25231: Fix Version/s: 1.16.0 > Update PyFlink to use the new type system > --

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

[ https://issues.apache.org/jira/browse/FLINK-21053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21053: Fix Version/s: 1.16.0 > Prevent potential RejectedExecutionExceptions in CheckpointCoordinator > failing

[jira] [Updated] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19830: Fix Version/s: 1.16.0 > Properly implements processing-time temporal table join >

[jira] [Updated] (FLINK-21438) Broken links in content.zh/docs/concepts/flink-architecture.md

[ https://issues.apache.org/jira/browse/FLINK-21438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21438: Fix Version/s: 1.16.0 > Broken links in content.zh/docs/concepts/flink-architecture.md > -

[jira] [Updated] (FLINK-25561) Execution mode of batch mode job web ui shows pipeline

[ https://issues.apache.org/jira/browse/FLINK-25561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25561: Fix Version/s: 1.16.0 > Execution mode of batch mode job web ui shows pipeline >

[jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard

[ https://issues.apache.org/jira/browse/FLINK-23855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23855: Fix Version/s: 1.16.0 > Table API & SQL Configuration Not displayed on flink dashboard > -

[jira] [Updated] (FLINK-24173) BatchFileSystemITCaseBase.testProjectPushDown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24173: Fix Version/s: 1.16.0 > BatchFileSystemITCaseBase.testProjectPushDown hangs on azure > ---

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21799: Fix Version/s: 1.16.0 > Detect and fail explicitly on managed memory leaking > ---

[jira] [Updated] (FLINK-25352) Update stability annotations to include the since and missedGraduations fields

[ https://issues.apache.org/jira/browse/FLINK-25352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25352: Fix Version/s: 1.16.0 > Update stability annotations to include the since and missedGraduations fields > -

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24237: Fix Version/s: 1.16.0 > Consider disabling or lowering DNS caching timeout in docker image > -

[jira] [Updated] (FLINK-21340) CheckForbiddenMethodsUsage is not run and fails

[ https://issues.apache.org/jira/browse/FLINK-21340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21340: Fix Version/s: 1.16.0 > CheckForbiddenMethodsUsage is not run and fails >

[jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18566: Fix Version/s: 1.16.0 > Add Support for Azure Cognitive Search DataStream Connector >

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

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

[jira] [Updated] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

[ https://issues.apache.org/jira/browse/FLINK-26645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26645: Fix Version/s: 1.16.0 > Pulsar Source subscribe to a single topic partition will consume all > partitions

[jira] [Updated] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24261: Fix Version/s: 1.16.0 > KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic" >

[jira] [Updated] (FLINK-24584) ClientTest.testRequestUnavailableHost fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24584: Fix Version/s: 1.16.0 > ClientTest.testRequestUnavailableHost fails on azure > ---

[jira] [Updated] (FLINK-24201) HistoryServer didn't contain TaskManager Logs

[ https://issues.apache.org/jira/browse/FLINK-24201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24201: Fix Version/s: 1.16.0 > HistoryServer didn't contain TaskManager Logs > --

[jira] [Updated] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25318: Fix Version/s: 1.16.0 > Improvement of scheduler and execution for Flink OLAP > --

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

[ https://issues.apache.org/jira/browse/FLINK-23141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23141: Fix Version/s: 1.16.0 > Support KafkaSerializationSchema in Kafka connector for Python DataStream API > --

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18996: Fix Version/s: 1.16.0 > Avoid disorder for time interval join > - > >

[jira] [Updated] (FLINK-20560) history-server: update archives while they're being loaded

[ https://issues.apache.org/jira/browse/FLINK-20560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20560: Fix Version/s: 1.16.0 > history-server: update archives while they're being loaded > -

[jira] [Updated] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-23795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23795: Fix Version/s: 1.16.0 > JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE > -

[jira] [Updated] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23324: Fix Version/s: 1.16.0 > Postgres of JDBC Connector enable case-sensitive. > --

[jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16582: Fix Version/s: 1.16.0 > NettyBufferPoolTest may have warns on NettyBuffer leak >

[jira] [Updated] (FLINK-23880) WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with Artificial Failure

[ https://issues.apache.org/jira/browse/FLINK-23880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23880: Fix Version/s: 1.16.0 > WindowAggregateITCase.testCascadeEventTimeTumbleWindowWithOffset fail with > Art

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19647: Fix Version/s: 1.16.0 > Support the limit push down for the hbase connector >

[jira] [Updated] (FLINK-24430) Clean up log pollution

[ https://issues.apache.org/jira/browse/FLINK-24430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24430: Fix Version/s: 1.16.0 > Clean up log pollution > -- > > Key: FLINK-244

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16908: Fix Version/s: 1.16.0 > FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while > init

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-11937: Fix Version/s: 1.16.0 > Resolve small file problem in RocksDB incremental checkpoint > ---

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

[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20578: Fix Version/s: 1.16.0 > Cannot create empty array using ARRAY[] > ---

[jira] [Updated] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21564: Fix Version/s: 1.16.0 > CommonTestUtils.waitUntilCondition could fail with condition meets before > --

[jira] [Updated] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24696: Fix Version/s: 1.16.0 > Translate how to configure unaligned checkpoints into Chinese > --

<    1   2   3   4   5   6   7   8   >