[jira] [Updated] (FLINK-23870) Test the ability for ignoring in-flight data on recovery

[ https://issues.apache.org/jira/browse/FLINK-23870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23870: - Fix Version/s: (was: 1.14.0) 1.15.0 > Test the ability for ignoring in-fl

[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 ] Xintong Song updated FLINK-23216: - Fix Version/s: (was: 1.14.0) 1.15.0 > RM keeps allocating and freeing slo

[jira] [Updated] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22828: - Fix Version/s: (was: 1.14.0) 1.15.0 > Allow using a custom AWS credential

[jira] [Updated] (FLINK-21790) Shuffle data directories to make directory selection of different TaskManagers fairer

[ https://issues.apache.org/jira/browse/FLINK-21790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21790: - Fix Version/s: (was: 1.14.0) 1.15.0 > Shuffle data directories to make di

[jira] [Updated] (FLINK-23545) Use new schema in SqlCreateTableConverter

[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23545: - Fix Version/s: (was: 1.14.0) 1.15.0 > Use new schema in SqlCreateTableCon

[jira] [Updated] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options

[ https://issues.apache.org/jira/browse/FLINK-23358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23358: - Fix Version/s: (was: 1.14.0) 1.15.0 > Refactor CoreOptions parent-first p

[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 ] Xintong Song updated FLINK-22805: - Fix Version/s: (was: 1.14.0) 1.15.0 > Dynamic configuration of Flink chec

[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 ] Xintong Song updated FLINK-21876: - Fix Version/s: (was: 1.14.0) 1.15.0 > Handle it properly when the returne

[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 ] Xintong Song updated FLINK-22299: - Fix Version/s: (was: 1.14.0) 1.15.0 > should remind users to ignoreParseE

[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 ] Xintong Song updated FLINK-21871: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support watermark for Hive and File

[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 ] Xintong Song updated FLINK-22282: - Fix Version/s: (was: 1.14.0) 1.15.0 > Move creation of SplitEnumerator to

[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 ] Xintong Song updated FLINK-21971: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support FLIP-27 based kafka source

[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 ] Xintong Song updated FLINK-21711: - Fix Version/s: (was: 1.14.0) 1.15.0 > DataStreamSink doesn't allow settin

[jira] [Updated] (FLINK-23668) Check Log Pollution for 1.14 release

[ https://issues.apache.org/jira/browse/FLINK-23668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23668: - Fix Version/s: (was: 1.14.0) 1.15.0 > Check Log Pollution for 1.14 releas

[jira] [Updated] (FLINK-21784) Allow extension of HeapBackend RestoreOperation

[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21784: - Fix Version/s: (was: 1.14.0) 1.15.0 > Allow extension of HeapBackend Rest

[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 ] Xintong Song updated FLINK-23350: - Fix Version/s: (was: 1.14.0) 1.15.0 > Write doc for change log disorder b

[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 ] Xintong Song updated FLINK-22553: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve error reporting on TM conne

[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 ] Xintong Song updated FLINK-22418: - Fix Version/s: (was: 1.14.0) 1.15.0 > The currently activated tab in the

[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 ] Xintong Song updated FLINK-22243: - Fix Version/s: (was: 1.14.0) 1.15.0 > Reactive Mode parallelism changes a

[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 ] Xintong Song updated FLINK-21966: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support Kinesis connector in Python

[jira] [Updated] (FLINK-22975) Specify port or range for k8s service

[ https://issues.apache.org/jira/browse/FLINK-22975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22975: - Fix Version/s: (was: 1.14.0) 1.15.0 > Specify port or range for k8s servi

[jira] [Updated] (FLINK-21783) Allow extension of HeapBackend SnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21783: - Fix Version/s: (was: 1.14.0) 1.15.0 > Allow extension of HeapBackend Snap

[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 ] Xintong Song updated FLINK-2: - Fix Version/s: (was: 1.14.0) 1.15.0 > Global config is logged twice by th

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22059: - Fix Version/s: (was: 1.14.0) 1.15.0 > add a new option is rocksdb stateba

[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 ] Xintong Song updated FLINK-22605: - Fix Version/s: (was: 1.14.0) 1.15.0 > Python UDF should only be created o

[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 ] Xintong Song updated FLINK-21765: - Fix Version/s: (was: 1.14.0) 1.15.0 > Remove implementation-specific Metr

[jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators

[ https://issues.apache.org/jira/browse/FLINK-22909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22909: - Fix Version/s: (was: 1.14.0) 1.15.0 > Supports change log inputs for even

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22578: - Fix Version/s: (was: 1.14.0) 1.15.0 > deployment configuration page miss

[jira] [Updated] (FLINK-22230) Misleading TaskExecutorResourceUtils log messages

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

[jira] [Updated] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21407: - Fix Version/s: (was: 1.14.0) 1.15.0 > Clarify which sources and APIs supp

[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 ] Xintong Song updated FLINK-21409: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add Avro to DataTypes & Serializati

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

[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23412: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve sourceSink description > --

[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

[ https://issues.apache.org/jira/browse/FLINK-21648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21648: - Fix Version/s: (was: 1.14.0) 1.15.0 > FLIP-151: Incremental snapshots for

[jira] [Updated] (FLINK-23451) FLIP-183: Dynamic buffer size adjustment (Buffer debloat)

[ https://issues.apache.org/jira/browse/FLINK-23451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23451: - Fix Version/s: (was: 1.14.0) 1.15.0 > FLIP-183: Dynamic buffer size adjus

[jira] [Updated] (FLINK-21636) Setup a global timeout for all tests

[ https://issues.apache.org/jira/browse/FLINK-21636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21636: - Fix Version/s: (was: 1.14.0) 1.15.0 > Setup a global timeout for all test

[jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES

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

[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 ] Xintong Song updated FLINK-22235: - Fix Version/s: (was: 1.14.0) 1.15.0 > Document stability concerns of flam

[jira] [Updated] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22956: - Fix Version/s: (was: 1.14.0) 1.15.0 > Stream Over TTL should use enableTi

[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 ] Xintong Song updated FLINK-21940: - Fix Version/s: (was: 1.14.0) 1.15.0 > Rowtime/proctime should be obtained

[jira] [Updated] (FLINK-21649) Refactor CopyOnWrite state classes

[ https://issues.apache.org/jira/browse/FLINK-21649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21649: - Fix Version/s: (was: 1.14.0) 1.15.0 > Refactor CopyOnWrite state 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 ] Xintong Song updated FLINK-22146: - Fix Version/s: (was: 1.14.0) 1.15.0 > Migrate StateBackend related Chines

[jira] [Updated] (FLINK-23549) Kafka table connector create table example in docs has syntax error

[ https://issues.apache.org/jira/browse/FLINK-23549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23549: - Fix Version/s: (was: 1.14.0) 1.15.0 > Kafka table connector create table

[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 ] Xintong Song updated FLINK-6: - Fix Version/s: (was: 1.14.0) 1.15.0 > Insufficient slots when submitting

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22040: - Fix Version/s: (was: 1.14.0) 1.15.0 > Maven: Entry has not been leased fr

[jira] [Updated] (FLINK-22237) Flamegraph component calls draw method from template

[ https://issues.apache.org/jira/browse/FLINK-22237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22237: - Fix Version/s: (was: 1.14.0) 1.15.0 > Flamegraph component calls draw met

[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 ] Xintong Song updated FLINK-23141: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support KafkaSerializationSchema in

[jira] [Updated] (FLINK-22228) Random log exception when tasks finish after a checkpoint was started

[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-8: - Fix Version/s: (was: 1.14.0) 1.15.0 > Random log exception when tasks fin

[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 ] Xintong Song updated FLINK-21953: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add documentation on batch mode sup

[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 ] Xintong Song updated FLINK-21578: - Fix Version/s: (was: 1.14.0) 1.15.0 > Closeable Sink Committer/GlobalComm

[jira] [Updated] (FLINK-21639) docs still state that AsyncWaitOperator is not chainable

[ https://issues.apache.org/jira/browse/FLINK-21639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21639: - Fix Version/s: (was: 1.14.0) 1.15.0 > docs still state that AsyncWaitOper

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21022: - Fix Version/s: (was: 1.14.0) 1.15.0 > flink-connector-es add onSuccess ha

[jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment

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

[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 ] Xintong Song updated FLINK-21053: - Fix Version/s: (was: 1.14.0) 1.15.0 > Prevent potential RejectedExecution

[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 ] Xintong Song updated FLINK-21179: - Fix Version/s: (was: 1.14.0) 1.15.0 > Make sure that the open/close metho

[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 ] Xintong Song updated FLINK-21184: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support temporary table/function fo

[jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-20853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20853: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add reader schema null check for Av

[jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution

[ https://issues.apache.org/jira/browse/FLINK-21408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21408: - Fix Version/s: (was: 1.14.0) 1.15.0 > Clarify which DataStream sources su

[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 ] Xintong Song updated FLINK-20952: - Fix Version/s: (was: 1.14.0) 1.15.0 > Changelog json formats should suppo

[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 ] Xintong Song updated FLINK-20946: - Fix Version/s: (was: 1.14.0) 1.15.0 > Optimize Python ValueState Implemen

[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 ] Xintong Song updated FLINK-21634: - Fix Version/s: (was: 1.14.0) 1.15.0 > ALTER TABLE statement enhancement >

[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 ] Xintong Song updated FLINK-20920: - Fix Version/s: (was: 1.14.0) 1.15.0 > Document how to connect to kerberiz

[jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21559: - Fix Version/s: (was: 1.14.0) 1.15.0 > Python DataStreamTests::test_proces

[jira] [Updated] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

[ https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20896: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support SupportsAggregatePushDown f

[jira] [Updated] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20955: - Fix Version/s: (was: 1.14.0) 1.15.0 > Refactor HBase Source in accordance

[jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20865: - Fix Version/s: (was: 1.14.0) 1.15.0 > Prevent potential resource deadlock

[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 ] Xintong Song updated FLINK-20484: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve hive temporal table except

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20788: - Fix Version/s: (was: 1.14.0) 1.15.0 > It doesn't support to use cube/roll

[jira] [Updated] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20895: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support LocalAggregatePushDown in B

[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 ] Xintong Song updated FLINK-20834: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add metrics for reporting the memor

[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 ] Xintong Song updated FLINK-20687: - Fix Version/s: (was: 1.14.0) 1.15.0 > Missing 'yarn-application' target i

[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 ] Xintong Song updated FLINK-20578: - Fix Version/s: (was: 1.14.0) 1.15.0 > Cannot create empty array using ARR

[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 ] Xintong Song updated FLINK-20849: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve JavaDoc and logging of new

[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 ] Xintong Song updated FLINK-20572: - Fix Version/s: (was: 1.14.0) 1.15.0 > HiveCatalog should be a standalone

[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 ] Xintong Song updated FLINK-20794: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support to select distinct columns

[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 ] Xintong Song updated FLINK-20656: - Fix Version/s: (was: 1.14.0) 1.15.0 > Update docs for new KafkaSource con

[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 ] Xintong Song updated FLINK-20154: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve error messages when using C

[jira] [Updated] (FLINK-20787) Improve the Table API to make it usable

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20787: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve the Table API to make it us

[jira] [Updated] (FLINK-20767) add nested field support for SupportsFilterPushDown

[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20767: - Fix Version/s: (was: 1.14.0) 1.15.0 > add nested field support for Suppor

[jira] [Updated] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20726: - Fix Version/s: (was: 1.14.0) 1.15.0 > Introduce Pulsar connector > --

[jira] [Updated] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20188: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add Documentation for new File Sour

[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 ] Xintong Song updated FLINK-20280: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support batch mode for Python DataS

[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 ] Xintong Song updated FLINK-19881: - Fix Version/s: (was: 1.14.0) 1.15.0 > Optimize temporal join with upsert-

[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 ] Xintong Song updated FLINK-20518: - Fix Version/s: (was: 1.14.0) 1.15.0 > WebUI should escape characters in m

[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20190: - Fix Version/s: (was: 1.14.0) 1.15.0 > A New Window Trigger that can trigg

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

[ https://issues.apache.org/jira/browse/FLINK-19527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19527: - Fix Version/s: (was: 1.14.0) 1.15.0 > Update SQL Pages >

[jira] [Updated] (FLINK-19967) Clean legacy classes for Parquet and Orc

[ https://issues.apache.org/jira/browse/FLINK-19967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19967: - Fix Version/s: (was: 1.14.0) 1.15.0 > Clean legacy classes for Parquet an

[jira] [Updated] (FLINK-19965) Refactor HiveMapredSplitReader to adapt to the new hive source

[ https://issues.apache.org/jira/browse/FLINK-19965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19965: - Fix Version/s: (was: 1.14.0) 1.15.0 > Refactor HiveMapredSplitReader to a

[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 ] Xintong Song updated FLINK-20110: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support 'merge' method for first_va

[jira] [Updated] (FLINK-19845) Migrate all FileSystemFormatFactory implementations

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

[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 ] Xintong Song updated FLINK-20036: - Fix Version/s: (was: 1.14.0) 1.15.0 > Join Has NoUniqueKey when using min

[jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page

[ https://issues.apache.org/jira/browse/FLINK-20246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20246: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add documentation on Python worker

[jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner

[ https://issues.apache.org/jira/browse/FLINK-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19230: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support Python UDAF on blink batch

[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 ] Xintong Song updated FLINK-19895: - Fix Version/s: (was: 1.14.0) 1.15.0 > Unify Life Cycle Management of Resu

[jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down

[ https://issues.apache.org/jira/browse/FLINK-19819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19819: - Fix Version/s: (was: 1.14.0) 1.15.0 > SourceReaderBase supports limit pus

[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 ] Xintong Song updated FLINK-20091: - Fix Version/s: (was: 1.14.0) 1.15.0 > Introduce avro.ignore-parse-errors

[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 ] Xintong Song updated FLINK-19007: - Fix Version/s: (was: 1.14.0) 1.15.0 > Automatically set presto staging di

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19722: - Fix Version/s: (was: 1.14.0) 1.15.0 > Pushdown Watermark to SourceProvide

[jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing

[ https://issues.apache.org/jira/browse/FLINK-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19613: - Fix Version/s: (was: 1.14.0) 1.15.0 > Create flink-connector-files-test-u

[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 ] Xintong Song updated FLINK-19659: - Fix Version/s: (was: 1.14.0) 1.15.0 > Array type supports equals and not_

[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 ] Xintong Song updated FLINK-19647: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support the limit push down for the

<    2   3   4   5   6   7   8   9   >