[jira] [Updated] (FLINK-25252) Check whether Kafka E2E tests could be run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25252: Fix Version/s: 1.16.0 > Check whether Kafka E2E tests could be run on Java 11 > --

[jira] [Updated] (FLINK-23679) PyFlink end-to-end test fail due to test script contains errors

[ https://issues.apache.org/jira/browse/FLINK-23679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23679: Fix Version/s: 1.16.0 > PyFlink end-to-end test fail due to test script contains errors >

[jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class.

[ https://issues.apache.org/jira/browse/FLINK-17683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17683: Fix Version/s: 1.16.0 > Pojo with no-args constructor will be treated as ROW when returned by > ScalarFun

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

[ https://issues.apache.org/jira/browse/FLINK-21765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21765: Fix Version/s: 1.16.0 > Remove implementation-specific MetricGroup parents > -

[jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16531: Fix Version/s: 1.16.0 > Add full integration tests for "GROUPING SETS" for streaming mode > --

[jira] [Updated] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s

[ https://issues.apache.org/jira/browse/FLINK-22842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22842: Fix Version/s: 1.16.0 > Streaming File Sink end-to-end test fail due to not finish after 900s > --

[jira] [Updated] (FLINK-23902) Support Hive version 2.3.8

[ https://issues.apache.org/jira/browse/FLINK-23902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23902: Fix Version/s: 1.16.0 > Support Hive version 2.3.8 > -- > > Key: F

[jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator

[ https://issues.apache.org/jira/browse/FLINK-24386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24386: Fix Version/s: 1.16.0 > JobMaster should guard against exceptions from OperatorCoordinator > -

[jira] [Updated] (FLINK-19085) Remove deprecated methods for writing CSV and Text files from DataStream

[ https://issues.apache.org/jira/browse/FLINK-19085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19085: Fix Version/s: 1.16.0 > Remove deprecated methods for writing CSV and Text files from DataStream > ---

[jira] [Updated] (FLINK-25290) Add table source and sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25290: Fix Version/s: 1.16.0 > Add table source and sink test suite in connector testing framework >

[jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent

[ https://issues.apache.org/jira/browse/FLINK-22418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22418: Fix Version/s: 1.16.0 > The currently activated tab in the same page isn't consistent > --

[jira] [Updated] (FLINK-25469) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown fails on AZP

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

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21634: Fix Version/s: 1.16.0 (was: 1.15.0) > ALTER TABLE statement enhancement > -

[jira] [Updated] (FLINK-24242) KafkaSinkITCase.testAbortTransactionsOfPendingCheckpointsAfterFailure fails due to NoSuchFileException

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

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19659: Fix Version/s: 1.16.0 > Array type supports equals and not_equals operator when element types are > diffe

[jira] [Updated] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

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

[jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15460: Fix Version/s: 1.16.0 > planner dependencies won't be necessary for JDBC connector > -

[jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page

[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14684: Fix Version/s: 1.16.0 > Add Pinterest to Chinese Powered By page > ---

[jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism

[ https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15000: Fix Version/s: 1.16.0 > WebUI Metrics is very slow in large parallelism >

[jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19432: Fix Version/s: 1.16.0 > Whether to capture the updates which don't change any monitored columns >

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

[ https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16800: Fix Version/s: 1.16.0 > TypeMappingUtils#checkIfCompatible didn't deal with nested types > ---

[jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family

[ https://issues.apache.org/jira/browse/FLINK-19895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19895: Fix Version/s: 1.16.0 > Unify Life Cycle Management of ResultPartitionType Pipelined Family >

[jira] [Updated] (FLINK-23683) KafkaSinkITCase hangs on azure

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

[jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS

[ https://issues.apache.org/jira/browse/FLINK-20920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20920: Fix Version/s: 1.16.0 > Document how to connect to kerberized HMS > --

[jira] [Updated] (FLINK-24707) Upgrade Curator framework dependecy.

[ https://issues.apache.org/jira/browse/FLINK-24707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24707: Fix Version/s: 1.16.0 > Upgrade Curator framework dependecy. > > >

[jira] [Updated] (FLINK-24330) HiveRunnerITCase JVM crash

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

[jira] [Updated] (FLINK-25710) Multiple Kafka IT cases fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-25710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25710: Fix Version/s: 1.16.0 > Multiple Kafka IT cases fail with "ContainerLaunch Container startup failed" > ---

[jira] [Updated] (FLINK-25612) Update the outdated illustration of ExecutionState in the documentation

[ https://issues.apache.org/jira/browse/FLINK-25612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25612: Fix Version/s: 1.16.0 > Update the outdated illustration of ExecutionState in the documentation >

[jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

[ https://issues.apache.org/jira/browse/FLINK-24688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24688: Fix Version/s: 1.16.0 > yarn.application-attempt-failures-validity-interval link url is invalid >

[jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22243: Fix Version/s: 1.16.0 > Reactive Mode parallelism changes are not shown in the job graph > visualization

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15745: Fix Version/s: 1.16.0 > KafkaITCase.testKeyValueSupport failure due to assertion error. >

[jira] [Updated] (FLINK-23387) WindowRankITCase.testEventTimeTumbleWindowWithoutRankNumber fails on azure

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

[jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked

[ https://issues.apache.org/jira/browse/FLINK-22605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22605: Fix Version/s: 1.16.0 > Python UDF should only be created once regardless of how many times it is > invok

[jira] [Updated] (FLINK-25419) Support the metadata column to generate dynamic index

[ https://issues.apache.org/jira/browse/FLINK-25419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25419: Fix Version/s: 1.16.0 > Support the metadata column to generate dynamic index > -

[jira] [Updated] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13809: Fix Version/s: 1.16.0 > The log directory of Flink Python API is unwritable if it is installed via > "su

[jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21871: Fix Version/s: 1.16.0 > Support watermark for Hive and Filesystem streaming source > -

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21693: Fix Version/s: 1.16.0 > TestStreamEnvironment does not implement executeAsync > --

[jira] [Updated] (FLINK-23412) Improve sourceSink description

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

[jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16762: Fix Version/s: 1.16.0 > Relocation Beam dependency of PyFlink > - > >

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17784: Fix Version/s: 1.16.0 > Better detection for parquet and orc in hive > ---

[jira] [Updated] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13876: Fix Version/s: 1.16.0 > Remove ExecutionConfig field from PojoSerializer > ---

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20110: Fix Version/s: 1.16.0 > Support 'merge' method for first_value and last_value UDAF > -

[jira] [Updated] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

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

[jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts

[ https://issues.apache.org/jira/browse/FLINK-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14918: Fix Version/s: 1.16.0 > Add performance e2e test module and scripts >

[jira] [Updated] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

[ https://issues.apache.org/jira/browse/FLINK-26003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26003: Fix Version/s: 1.16.0 > Use Jackson serialization for persisting TaskExecutor state to working > director

[jira] [Updated] (FLINK-23932) KafkaTableITKafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue hangs on AzureCase

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

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22282: Fix Version/s: 1.16.0 > Move creation of SplitEnumerator to the SourceCoordinator thread > ---

[jira] [Updated] (FLINK-18442) Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest`

[ https://issues.apache.org/jira/browse/FLINK-18442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18442: Fix Version/s: 1.16.0 > Move `testSessionWindowsWithContinuousEventTimeTrigger` to > `ContinuousEventTime

[jira] [Updated] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15123: Fix Version/s: 1.16.0 > remove uniqueKeys from FlinkStatistic in blink planner >

[jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs

[ https://issues.apache.org/jira/browse/FLINK-21409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21409: Fix Version/s: 1.16.0 > Add Avro to DataTypes & Serialization docs > -

[jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-12491: Fix Version/s: 1.16.0 > Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS > --

[jira] [Updated] (FLINK-24517) Streamline Flink releases

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

[jira] [Updated] (FLINK-24666) The lenient option was not exposed to users on RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24666: Fix Version/s: 1.16.0 > The lenient option was not exposed to users on RetractableTopNFunction > -

[jira] [Updated] (FLINK-23970) Split off the behaviour for finished StreamTask(s)

[ https://issues.apache.org/jira/browse/FLINK-23970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23970: Fix Version/s: 1.16.0 > Split off the behaviour for finished StreamTask(s) > -

[jira] [Updated] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20036: Fix Version/s: 1.16.0 > Join Has NoUniqueKey when using mini-batch > -

[jira] [Updated] (FLINK-18777) Supports schema registry catalog

[ https://issues.apache.org/jira/browse/FLINK-18777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18777: Fix Version/s: 1.16.0 > Supports schema registry catalog > > >

[jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

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

[jira] [Updated] (FLINK-23576) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to Artificial Failure

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

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20656: Fix Version/s: 1.16.0 > Update docs for new KafkaSource connector. > -

[jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

[ https://issues.apache.org/jira/browse/FLINK-20834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20834: Fix Version/s: 1.16.0 > Add metrics for reporting the memory usage and CPU usage of the Python UDF > work

[jira] [Updated] (FLINK-24949) KafkaITCase.testBigRecordJob fails on azure

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

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19034: Fix Version/s: 1.16.0 > Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries > ---

[jira] [Updated] (FLINK-23254) Upgrade Test Framework to JUnit 5

[ https://issues.apache.org/jira/browse/FLINK-23254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23254: Fix Version/s: 1.16.0 > Upgrade Test Framework to JUnit 5 > - > >

[jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

[ https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23849: Fix Version/s: 1.16.0 > Support react to the node decommissioning change state on yarn and do > graceful

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17642: Fix Version/s: 1.16.0 > Exception while reading broken ORC file is hidden > --

[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21613: Fix Version/s: 1.16.0 > Parse Compute Column with `IN` expression throws NPE > ---

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19362: Fix Version/s: 1.16.0 > Remove confusing comment for `DOT` operator codegen >

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24536: Fix Version/s: 1.16.0 > flink sql where condition is not supported != writing > -

[jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly

[ https://issues.apache.org/jira/browse/FLINK-21125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21125: Fix Version/s: 1.16.0 > Sum or Sum0 overflow quietly > > > Ke

[jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21578: Fix Version/s: 1.16.0 > Closeable Sink Committer/GlobalCommitter were created to function in onestep > du

[jira] [Updated] (FLINK-15973) Optimize the execution plan where it refers the Python UDF result field in the where clause

[ https://issues.apache.org/jira/browse/FLINK-15973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15973: Fix Version/s: 1.16.0 > Optimize the execution plan where it refers the Python UDF result field in > the

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13015: Fix Version/s: 1.16.0 > Create validators, strategies and transformations required for porting > logical

[jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

[ https://issues.apache.org/jira/browse/FLINK-23737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23737: Fix Version/s: 1.16.0 > Ensure publish-to-dockerhub.sh only publish specific flink versions >

[jira] [Updated] (FLINK-18873) Make the WatermarkStrategy API more scala friendly

[ https://issues.apache.org/jira/browse/FLINK-18873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18873: Fix Version/s: 1.16.0 > Make the WatermarkStrategy API more scala friendly > -

[jira] [Updated] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

[ https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16775: Fix Version/s: 1.16.0 > expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system > ---

[jira] [Updated] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25447: Fix Version/s: 1.16.0 > batch query cannot generate plan when a sorted view into multi sinks > ---

[jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-15859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-15859: Fix Version/s: 1.16.0 > Unify identifiers in the interface methods of CatalogManager > ---

[jira] [Updated] (FLINK-26921) KafkaSinkE2ECase.testStartFromSavepoint failed on azure

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

[jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector

[ https://issues.apache.org/jira/browse/FLINK-21184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21184: Fix Version/s: 1.16.0 > Support temporary table/function for hive connector >

[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

[ https://issues.apache.org/jira/browse/FLINK-19007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-19007: Fix Version/s: 1.16.0 > Automatically set presto staging directory to io.tmp.dirs > --

[jira] [Updated] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22739: Fix Version/s: 1.16.0 > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to > TestTimedOutExce

[jira] [Updated] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

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

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-14383: Fix Version/s: 1.16.0 > Support python UDFs with constant value of time interval types > -

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17362: Fix Version/s: 1.16.0 > Improve table examples to reflect latest status >

[jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API.

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

[jira] [Updated] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

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

[jira] [Updated] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24497: Fix Version/s: 1.16.0 > Kafka metrics fetching throws IllegalStateException > ---

[jira] [Updated] (FLINK-24191) Adjusting number of buffers besides buffer size

[ https://issues.apache.org/jira/browse/FLINK-24191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24191: Fix Version/s: 1.16.0 > Adjusting number of buffers besides buffer size >

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20484: Fix Version/s: 1.16.0 > Improve hive temporal table exception > -- >

[jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable

[ https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23564: Fix Version/s: 1.16.0 > Make taskmanager.out and taskmanager.err rollable > --

[jira] [Updated] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs

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

[jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24376: Fix Version/s: 1.16.0 > Operator name in OperatorCoordinator should not use chained name > ---

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13400: Fix Version/s: 1.16.0 > Remove Hive and Hadoop dependencies from SQL Client >

[jira] [Updated] (FLINK-22226) Insufficient slots when submitting jobs results in massive stacktrace

[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-6: Fix Version/s: 1.16.0 > Insufficient slots when submitting jobs results in massive stacktrace > --

[jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24951: Fix Version/s: 1.16.0 > Allow watch bookmarks to mitigate frequent watcher rebuilding > --

[jira] [Updated] (FLINK-23660) Hive Catalog support truncate table

[ https://issues.apache.org/jira/browse/FLINK-23660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23660: Fix Version/s: 1.16.0 > Hive Catalog support truncate table > --- > >

[jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16143: Fix Version/s: 1.16.0 > Turn on more date time functions of blink planner > --

[jira] [Updated] (FLINK-26045) Document error status codes for the REST API

[ https://issues.apache.org/jira/browse/FLINK-26045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26045: Fix Version/s: 1.16.0 > Document error status codes for the REST API > ---

[jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16126: Fix Version/s: 1.16.0 > Translate all connector related pages into Chinese > -

[jira] [Updated] (FLINK-23555) Improve common subexpression elimination by using local references

[ https://issues.apache.org/jira/browse/FLINK-23555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23555: Fix Version/s: 1.16.0 > Improve common subexpression elimination by using local references > -

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