[jira] [Updated] (FLINK-19670) Query on a view of temporal join throws ParseException

[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19670: Fix Version/s: 1.16.0 > Query on a view of temporal join throws ParseException > -

[jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/FLINK-20155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20155: Fix Version/s: 1.16.0 > java.lang.OutOfMemoryError: Direct buffer memory > ---

[jira] [Updated] (FLINK-23105) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots fail

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

[jira] [Updated] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18706: Fix Version/s: 1.16.0 > Stop with savepoint cannot guarantee exactly-once for kafka source > -

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14500: Fix Version/s: 1.16.0 > Support Flink Python User-Defined Stateless Function for Table - Phase 2 > ---

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

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

[jira] [Updated] (FLINK-17855) UDF with parameter Array(Row) can not work

[ https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17855: Fix Version/s: 1.16.0 > UDF with parameter Array(Row) can not work > -

[jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

[ https://issues.apache.org/jira/browse/FLINK-22701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22701: Fix Version/s: 1.16.0 > "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg >

[jira] [Updated] (FLINK-23881) SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result"

[ https://issues.apache.org/jira/browse/FLINK-23881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23881: Fix Version/s: 1.16.0 > SemiJoinITCase.testExistsWithOver4 fails with "failed to fetch next result" >

[jira] [Updated] (FLINK-26351) After scaling a flink task running on k8s, the flink web ui graph always shows the parallelism of the first deployment.

[ https://issues.apache.org/jira/browse/FLINK-26351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26351: Fix Version/s: 1.16.0 > After scaling a flink task running on k8s, the flink web ui graph always > shows

[jira] [Updated] (FLINK-25867) [ZH] Add ChangelogBackend documentation

[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25867: Fix Version/s: 1.16.0 > [ZH] Add ChangelogBackend documentation > ---

[jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector

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

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24122: Fix Version/s: 1.16.0 > Add support to do clean in history server > --

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

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

[jira] [Updated] (FLINK-25325) Migration Flink from Junit4 to Junit5

[ https://issues.apache.org/jira/browse/FLINK-25325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25325: Fix Version/s: 1.16.0 > Migration Flink from Junit4 to Junit5 > - > >

[jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target

[ https://issues.apache.org/jira/browse/FLINK-20154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20154: Fix Version/s: 1.16.0 > Improve error messages when using CLI with wrong target >

[jira] [Updated] (FLINK-26756) Failed to deserialize for match recognize

[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26756: Fix Version/s: 1.16.0 > Failed to deserialize for match recognize > --

[jira] [Updated] (FLINK-24788) Report RocksDB statistics as metrics

[ https://issues.apache.org/jira/browse/FLINK-24788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24788: Fix Version/s: 1.16.0 > Report RocksDB statistics as metrics > > >

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19881: Fix Version/s: 1.16.0 > Optimize temporal join with upsert-Source(upsert-kafka) >

[jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes

[ https://issues.apache.org/jira/browse/FLINK-25350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25350: Fix Version/s: 1.16.0 > Verify stability guarantees of annotated classes > ---

[jira] [Updated] (FLINK-22146) Migrate StateBackend related Chinese docs to latest state backend

[ https://issues.apache.org/jira/browse/FLINK-22146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22146: Fix Version/s: 1.16.0 > Migrate StateBackend related Chinese docs to latest state backend > --

[jira] [Updated] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink

[ https://issues.apache.org/jira/browse/FLINK-20946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20946: Fix Version/s: 1.16.0 > Optimize Python ValueState Implementation In PyFlink > ---

[jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures

[ https://issues.apache.org/jira/browse/FLINK-22553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22553: Fix Version/s: 1.16.0 > Improve error reporting on TM connection failures > --

[jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14879: Fix Version/s: 1.16.0 > Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client > -

[jira] [Updated] (FLINK-23589) Support Avro Microsecond precision

[ https://issues.apache.org/jira/browse/FLINK-23589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23589: Fix Version/s: 1.16.0 > Support Avro Microsecond precision > -- > >

[jira] [Updated] (FLINK-22892) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-22892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22892: Fix Version/s: 1.16.0 > Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end > te

[jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format

[ https://issues.apache.org/jira/browse/FLINK-20952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20952: Fix Version/s: 1.16.0 > Changelog json formats should support inherit options from JSON format > -

[jira] [Updated] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25256: Fix Version/s: 1.16.0 > Savepoints do not work with ExternallyInducedSources > ---

[jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20420: Fix Version/s: 1.16.0 > ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds >

[jira] [Updated] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22457: Fix Version/s: 1.16.0 > KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of > timeou

[jira] [Updated] (FLINK-24192) Sql get plan failed. All the inputs have relevant nodes, however the cost is still infinite

[ https://issues.apache.org/jira/browse/FLINK-24192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24192: Fix Version/s: 1.16.0 > Sql get plan failed. All the inputs have relevant nodes, however the cost is > st

[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

[ https://issues.apache.org/jira/browse/FLINK-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-9879: --- Fix Version/s: 1.16.0 > Find sane defaults for (advanced) SSL session parameters > --

[jira] [Updated] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream

[ https://issues.apache.org/jira/browse/FLINK-23310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23310: Fix Version/s: 1.16.0 > Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is > a

[jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22585: Fix Version/s: 1.16.0 > Add deprecated message when "-m yarn-cluster" is used > --

[jira] [Updated] (FLINK-23921) WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable

[ https://issues.apache.org/jira/browse/FLINK-23921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23921: Fix Version/s: 1.16.0 > WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable > -

[jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM

[ https://issues.apache.org/jira/browse/FLINK-19935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19935: Fix Version/s: 1.16.0 > Supports configure heap memory of sql-client to avoid OOM > --

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21307: Fix Version/s: 1.16.0 > Revisit activation model of FlinkSecurityManager > ---

[jira] [Updated] (FLINK-23867) FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-23867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23867: Fix Version/s: 1.16.0 > FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with > Il

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18202: Fix Version/s: 1.16.0 > Introduce Protobuf format > - > > Key: FLI

[jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE

[ https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18624: Fix Version/s: 1.16.0 > Document CREATE TEMPORARY TABLE > --- > >

[jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

[ https://issues.apache.org/jira/browse/FLINK-14222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14222: Fix Version/s: 1.16.0 > Optimize for Python UDFs with all parameters are constant values > ---

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

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

[jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

[ https://issues.apache.org/jira/browse/FLINK-22235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22235: Fix Version/s: 1.16.0 > Document stability concerns of flamegraphs for heavier jobs >

[jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15729: Fix Version/s: 1.16.0 > Table planner dependency instructions for executing in IDE can be improved > -

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20091: Fix Version/s: 1.16.0 > Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema > ---

[jira] [Updated] (FLINK-26144) SavepointFormatITCase did NOT fail with changelog.enabled randomized

[ https://issues.apache.org/jira/browse/FLINK-26144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26144: Fix Version/s: 1.16.0 > SavepointFormatITCase did NOT fail with changelog.enabled randomized > --

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20849: Fix Version/s: 1.16.0 > Improve JavaDoc and logging of new KafkaSource > -

[jira] [Updated] (FLINK-19527) Update SQL Pages

[ https://issues.apache.org/jira/browse/FLINK-19527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19527: Fix Version/s: 1.16.0 > Update SQL Pages > > > Key: FLINK-19527 >

[jira] [Updated] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

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

[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client

[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22065: Fix Version/s: 1.16.0 > Improve the error message when input invalid command in the sql client > -

[jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

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

[jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field

[ https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17987: Fix Version/s: 1.16.0 > KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error > reading

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20687: Fix Version/s: 1.16.0 > Missing 'yarn-application' target in CLI help message > --

[jira] [Updated] (FLINK-21953) Add documentation on batch mode support of Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21953: Fix Version/s: 1.16.0 > Add documentation on batch mode support of Python DataStream API > ---

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22607: Fix Version/s: 1.16.0 > Examples use deprecated AscendingTimestampExtractor >

[jira] [Updated] (FLINK-20280) Support batch mode for Python DataStream API

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

[jira] [Updated] (FLINK-23778) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure

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

[jira] [Updated] (FLINK-24259) Exception message when Kafka topic is null in FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24259: Fix Version/s: 1.16.0 > Exception message when Kafka topic is null in FlinkKafkaConsumer > ---

[jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18627: Fix Version/s: 1.16.0 > Get unmatch filter method records to side output > ---

[jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client

[ https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17405: Fix Version/s: 1.16.0 > add test cases for cancel job in SQL client >

[jira] [Updated] (FLINK-22222) Global config is logged twice by the client for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-2: Fix Version/s: 1.16.0 > Global config is logged twice by the client for batch jobs > -

[jira] [Updated] (FLINK-24078) Remove brackets around variables

[ https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24078: Fix Version/s: 1.16.0 > Remove brackets around variables > > >

[jira] [Updated] (FLINK-23533) Split InputSelection into public and internal parts

[ https://issues.apache.org/jira/browse/FLINK-23533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23533: Fix Version/s: 1.16.0 > Split InputSelection into public and internal parts >

[jira] [Updated] (FLINK-24854) StateHandleSerializationTest unit test error

[ https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24854: Fix Version/s: 1.16.0 > StateHandleSerializationTest unit test error > ---

[jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14028: Fix Version/s: 1.16.0 > Support to configure the log level of the Python user-defined functions >

[jira] [Updated] (FLINK-21769) Encapsulate component meta data

[ https://issues.apache.org/jira/browse/FLINK-21769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21769: Fix Version/s: 1.16.0 > Encapsulate component meta data > --- > >

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

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

[jira] [Updated] (FLINK-24721) Update the based on the Maven official indication

[ https://issues.apache.org/jira/browse/FLINK-24721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24721: Fix Version/s: 1.16.0 > Update the based on the Maven official indication > -

[jira] [Updated] (FLINK-22344) KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue times out

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

[jira] [Updated] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs

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

[jira] [Updated] (FLINK-15130) Drop "RequiredParameters" and "Options"

[ https://issues.apache.org/jira/browse/FLINK-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15130: Fix Version/s: 1.16.0 > Drop "RequiredParameters" and "Options" > ---

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

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

[jira] [Updated] (FLINK-22834) KafkaITCase.testBigRecordJob times out on azure

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

[jira] [Updated] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException

[ https://issues.apache.org/jira/browse/FLINK-22742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22742: Fix Version/s: 1.16.0 > Lookup join condition with process time throws > org.codehaus.commons.compiler.Co

[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs

[ https://issues.apache.org/jira/browse/FLINK-19263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19263: Fix Version/s: 1.16.0 > Enforce alphabetical order in configuration option docs >

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23350: Fix Version/s: 1.16.0 > Write doc for change log disorder by special operators > -

[jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void

[ https://issues.apache.org/jira/browse/FLINK-22209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22209: Fix Version/s: 1.16.0 > Make StreamTask#triggerCheckpointAsync return void > -

[jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25291: Fix Version/s: 1.16.0 > Add failure cases in DataStream source and sink suite of connector testing > fram

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16799: Fix Version/s: 1.16.0 > add hive partition limit when read from hive > ---

[jira] [Updated] (FLINK-25587) HiveCatalogITCase crashed on Azure with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25587: Fix Version/s: 1.16.0 > HiveCatalogITCase crashed on Azure with exit code 239 > --

[jira] [Updated] (FLINK-26369) Translate the part zh-page mixed with not be translated.

[ https://issues.apache.org/jira/browse/FLINK-26369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26369: Fix Version/s: 1.16.0 > Translate the part zh-page mixed with not be translated. > --

[jira] [Updated] (FLINK-24590) Consider removing timeout from FlinkMatchers#futureWillCompleteExceptionally

[ https://issues.apache.org/jira/browse/FLINK-24590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24590: Fix Version/s: 1.16.0 > Consider removing timeout from FlinkMatchers#futureWillCompleteExceptionally > ---

[jira] [Updated] (FLINK-23694) KafkaWriterITCase hangs on azure

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

[jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14690: Fix Version/s: 1.16.0 > Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL > Cl

[jira] [Updated] (FLINK-17372) SlotManager should expose total required resources

[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17372: Fix Version/s: 1.16.0 > SlotManager should expose total required resources > -

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

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

[jira] [Updated] (FLINK-20787) Improve the Table API to solve user friction

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20787: Fix Version/s: 1.16.0 > Improve the Table API to solve user friction > ---

[jira] [Updated] (FLINK-20474) flink cep results of doc is not right

[ https://issues.apache.org/jira/browse/FLINK-20474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20474: Fix Version/s: 1.16.0 > flink cep results of doc is not right > - > >

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15378: Fix Version/s: 1.16.0 > StreamFileSystemSink supported mutil hdfs plugins. > -

[jira] [Updated] (FLINK-18213) refactor kafka sql connector to use just one shade to compatible 0.10.0.2 +

[ https://issues.apache.org/jira/browse/FLINK-18213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18213: Fix Version/s: 1.16.0 > refactor kafka sql connector to use just one shade to compatible 0.10.0.2 + >

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

[ https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20572: Fix Version/s: 1.16.0 > HiveCatalog should be a standalone module > --

[jira] [Updated] (FLINK-25316) BlobServer can get stuck during shutdown

[ https://issues.apache.org/jira/browse/FLINK-25316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25316: Fix Version/s: 1.16.0 > BlobServer can get stuck during shutdown > ---

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-3: Fix Version/s: 1.16.0 > Explicitly configure rest.address in distribution config > ---

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

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

[jira] [Updated] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24483: Fix Version/s: 1.16.0 > Document what is Public API and what compatibility guarantees Flink is > providin

[jira] [Updated] (FLINK-21898) JobRetrievalITCase crash

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

[jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate

[ https://issues.apache.org/jira/browse/FLINK-20305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20305: Fix Version/s: 1.16.0 > Iterative job with maxWaitTimeMillis does not terminate >

[jira] [Updated] (FLINK-23390) FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed

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

[jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong

[ https://issues.apache.org/jira/browse/FLINK-21940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21940: Fix Version/s: 1.16.0 > Rowtime/proctime should be obtained from getTimestamp instead of getLong > ---

[jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

[ https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21179: Fix Version/s: 1.16.0 > Make sure that the open/close methods of the Python DataStream Function are > not

<    1   2   3   4   5   6   7   8   >