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

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

[jira] [Updated] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-26944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26944: Fix Version/s: 1.20.0 > Add ADD_MONTHS supported in SQL and Table API > --

[jira] [Updated] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32953: Fix Version/s: 1.20.0 > [State TTL]resolve data correctness problem after ttl was changed > -

[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19038: Fix Version/s: 1.20.0 > It doesn't support to call Table.limit() continuously > --

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

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

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

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

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33558: Fix Version/s: 1.20.0 > Externalize Elasticsearch Python connector code >

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

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

[jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24636: Fix Version/s: 1.20.0 > Move cluster deletion operation cache into ResourceManager > -

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31729: Fix Version/s: 1.20.0 > Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN > --

[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 ] lincoln lee updated FLINK-19895: Fix Version/s: 1.20.0 > Unify Life Cycle Management of ResultPartitionType Pipelined Family >

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

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

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

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

[jira] [Updated] (FLINK-24125) Rethink relationship between DeclarativeSlotPool and *Bridge

[ https://issues.apache.org/jira/browse/FLINK-24125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24125: Fix Version/s: 1.20.0 > Rethink relationship between DeclarativeSlotPool and *Bridge > ---

[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 ] lincoln lee updated FLINK-21408: Fix Version/s: 1.20.0 > Clarify which DataStream sources support Batch execution > ---

[jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page

[ https://issues.apache.org/jira/browse/FLINK-14125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14125: Fix Version/s: 1.20.0 > Display memory and CPU usage in the overview page > --

[jira] [Updated] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

[ https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26942: Fix Version/s: (was: 1.19.0) > Support SELECT clause in CREATE TABLE(CTAS) > -

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12273: Fix Version/s: (was: 1.19.0) > The default value of CheckpointRetentionPolicy should be RETAIN

[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 ] lincoln lee updated FLINK-24688: Fix Version/s: (was: 1.19.0) > yarn.application-attempt-failures-validity-interval link url is

[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 ] lincoln lee updated FLINK-18199: Fix Version/s: 1.20.0 > Translate "Filesystem SQL Connector" page into Chinese > -

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14122: Fix Version/s: (was: 1.19.0) > Extend State Processor API to read ListCheckpointed operator st

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30379: Fix Version/s: (was: 1.19.0) > Decouple connector docs integration from connector releases > -

[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 ] lincoln lee updated FLINK-15729: Fix Version/s: (was: 1.19.0) > Table planner dependency instructions for executing in IDE can

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

[ https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29031: Fix Version/s: 1.20.0 > FlinkKinesisConsumerTest.testSourceSynchronization failed with > Assertio

[jira] [Updated] (FLINK-32873) Add configuration to allow disabling SQL query hints

[ https://issues.apache.org/jira/browse/FLINK-32873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32873: Fix Version/s: (was: 1.19.0) > Add configuration to allow disabling SQL query hints >

[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 ] lincoln lee updated FLINK-21648: Fix Version/s: 1.20.0 > FLIP-151: Incremental snapshots for heap-based state backend > ---

[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 ] lincoln lee updated FLINK-25612: Fix Version/s: 1.20.0 > Update the outdated illustration of ExecutionState in the documentation >

[jira] [Updated] (FLINK-32537) Add compatibility annotation for REST API classes

[ https://issues.apache.org/jira/browse/FLINK-32537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32537: Fix Version/s: (was: 1.19.0) > Add compatibility annotation for REST API classes > ---

[jira] [Updated] (FLINK-25353) Add tests to ensure API graduation process is honoured

[ https://issues.apache.org/jira/browse/FLINK-25353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25353: Fix Version/s: (was: 1.19.0) > Add tests to ensure API graduation process is honoured > --

[jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27364: Fix Version/s: 1.20.0 > Support DESC EXTENDED partition statement for partitioned table >

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27191: Fix Version/s: (was: 1.19.0) > Support multi kerberos-enabled Hive clusters > ---

[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 ] lincoln lee updated FLINK-25291: Fix Version/s: 1.20.0 > Add failure cases in DataStream source and sink suite of connector testing

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

[ https://issues.apache.org/jira/browse/FLINK-28838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28838: Fix Version/s: (was: 1.19.0) > Avoid to notify the elementQueue consumer when the fetch result

[jira] [Updated] (FLINK-27074) python_job.py should write to TEST_DATA_DIR

[ https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27074: Fix Version/s: (was: 1.19.0) > python_job.py should write to TEST_DATA_DIR > -

[jira] [Updated] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25068: Fix Version/s: 1.20.0 > Show the maximum parallelism (number of key groups) of a job in Web UI > -

[jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page

[ https://issues.apache.org/jira/browse/FLINK-14125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14125: Fix Version/s: (was: 1.19.0) > Display memory and CPU usage in the overview page > ---

[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 ] lincoln lee updated FLINK-21940: Fix Version/s: 1.20.0 > Rowtime/proctime should be obtained from getTimestamp instead of getLong >

[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 ] lincoln lee updated FLINK-22553: Fix Version/s: 1.20.0 > Improve error reporting on TM connection failures > --

[jira] [Updated] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

[ https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26942: Fix Version/s: 1.20.0 > Support SELECT clause in CREATE TABLE(CTAS) >

[jira] [Updated] (FLINK-29343) Fix fail to execute ddl in HiveDialect when use specifc catalog in sql statement

[ https://issues.apache.org/jira/browse/FLINK-29343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29343: Fix Version/s: 1.20.0 > Fix fail to execute ddl in HiveDialect when use specifc catalog in sql >

[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 ] lincoln lee updated FLINK-9879: --- Fix Version/s: 1.20.0 > Find sane defaults for (advanced) SSL session parameters > --

[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 ] lincoln lee updated FLINK-23849: Fix Version/s: 1.20.0 > Support react to the node decommissioning change state on yarn and do > g

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

[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29040: Fix Version/s: 1.20.0 > When using the JDBC Catalog, the custom cannot be applied because it is fi

[jira] [Updated] (FLINK-24636) Move cluster deletion operation cache into ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24636: Fix Version/s: (was: 1.19.0) > Move cluster deletion operation cache into ResourceManager > --

[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 ] lincoln lee updated FLINK-3: Fix Version/s: 1.20.0 > Explicitly configure rest.address in distribution config > ---

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

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

[jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19482: Fix Version/s: 1.20.0 > OrcRowInputFormat does not define serialVersionUID > -

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

[ https://issues.apache.org/jira/browse/FLINK-30284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30284: Fix Version/s: 1.20.0 > Make datadog reporter url configurable > -

[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 ] lincoln lee updated FLINK-20578: Fix Version/s: 1.20.0 > Cannot create empty array using ARRAY[] >

[jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister

[ https://issues.apache.org/jira/browse/FLINK-25862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25862: Fix Version/s: 1.20.0 > Refactor SharedStateRegistry to not limit StreamStateHandle to > register

[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 ] lincoln lee updated FLINK-25290: Fix Version/s: 1.20.0 > Add table source and sink test suite in connector testing framework >

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

[ https://issues.apache.org/jira/browse/FLINK-29355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29355: Fix Version/s: (was: 1.19.0) > Sql parse failed because of Desc catalog.database.table is inco

[jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16137: Fix Version/s: 1.20.0 > Translate all DataStream API related pages into Chinese > ---

[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 ] lincoln lee updated FLINK-14028: Fix Version/s: 1.20.0 > Support to configure the log level of the Python user-defined functions >

[jira] [Updated] (FLINK-24901) Some further improvements of the pluggable shuffle framework

[ https://issues.apache.org/jira/browse/FLINK-24901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24901: Fix Version/s: (was: 1.19.0) > Some further improvements of the pluggable shuffle framework >

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

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

[jira] [Updated] (FLINK-33561) Externalize Pulsar Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33561: Fix Version/s: 1.20.0 > Externalize Pulsar Python connector code > ---

[jira] [Updated] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

[ https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24900: Fix Version/s: (was: 1.19.0) > Support to run multiple shuffle plugins in one session cluster

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27080: Fix Version/s: (was: 1.19.0) > Enable builds for pull requests > -

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

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

[jira] [Updated] (FLINK-28042) Create an extension for resetting HiveConf

[ https://issues.apache.org/jira/browse/FLINK-28042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28042: Fix Version/s: (was: 1.19.0) > Create an extension for resetting HiveConf > --

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-29060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29060: Fix Version/s: (was: 1.19.0) > can not set rewriteBatchedStatements parameter for JDBC catalog

[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 ] lincoln lee updated FLINK-14222: Fix Version/s: (was: 1.19.0) > Optimize for Python UDFs with all parameters are constant value

[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 ] lincoln lee updated FLINK-19895: Fix Version/s: (was: 1.19.0) > Unify Life Cycle Management of ResultPartitionType Pipelined Fa

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

[ https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30821: Fix Version/s: 1.20.0 > The optimized exec plan generated by > OverAggregateTest#testDiffPartitio

[jira] [Updated] (FLINK-33674) In the wmassigners module, words are misspelled

[ https://issues.apache.org/jira/browse/FLINK-33674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33674: Fix Version/s: (was: 1.19.0) > In the wmassigners module, words are misspelled > -

[jira] [Updated] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators

[ https://issues.apache.org/jira/browse/FLINK-24666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24666: Fix Version/s: 1.20.0 > Add job level "table.exec.state-stale.error-handling" option and apply to

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

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

[jira] [Updated] (FLINK-33894) Implement restore tests for PythonGroupAggregate node

[ https://issues.apache.org/jira/browse/FLINK-33894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33894: Fix Version/s: (was: 1.19.0) > Implement restore tests for PythonGroupAggregate node > ---

[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 ] lincoln lee updated FLINK-21022: Fix Version/s: (was: 1.19.0) > flink-connector-es add onSuccess handler after bulk process for

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

[ https://issues.apache.org/jira/browse/FLINK-28813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28813: Fix Version/s: 1.20.0 > new stach builtinfunction validateClassForRuntime it not correct > --

[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 ] lincoln lee updated FLINK-20305: Fix Version/s: 1.20.0 > Iterative job with maxWaitTimeMillis does not terminate >

[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 ] lincoln lee updated FLINK-14684: Fix Version/s: 1.20.0 > Add Pinterest to Chinese Powered By page > ---

[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 ] lincoln lee updated FLINK-19007: Fix Version/s: 1.20.0 > Automatically set presto staging directory to io.tmp.dirs > --

[jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28909: Fix Version/s: (was: 1.19.0) > Add ribbon filter policy option in RocksDBConfiguredOptions > -

[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 ] lincoln lee updated FLINK-22553: Fix Version/s: (was: 1.19.0) > Improve error reporting on TM connection failures > ---

[jira] [Updated] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-34079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34079: Fix Version/s: 1.20.0 > FLIP-405: Migrate string configuration key to ConfigOption > -

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17274: Fix Version/s: (was: 1.19.0) > Maven: Premature end of Content-Length delimited message body >

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

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

[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 ] lincoln lee updated FLINK-21876: Fix Version/s: 1.20.0 > Handle it properly when the returned value of Python UDF doesn't match the

[jira] [Updated] (FLINK-25354) Document API graduation process

[ https://issues.apache.org/jira/browse/FLINK-25354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25354: Fix Version/s: (was: 1.19.0) > Document API graduation process > -

[jira] [Updated] (FLINK-33162) seperate the executor in DefaultDispatcherResourceManagerComponentFactory for MetricFetcher and webMonitorEndpoint

[ https://issues.apache.org/jira/browse/FLINK-33162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33162: Fix Version/s: 1.20.0 > seperate the executor in DefaultDispatcherResourceManagerComponentFactory

[jira] [Updated] (FLINK-32871) Support BuiltInMethod TO_TIMESTAMP with timezone options

[ https://issues.apache.org/jira/browse/FLINK-32871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32871: Fix Version/s: (was: 1.19.0) > Support BuiltInMethod TO_TIMESTAMP with timezone options >

[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 ] lincoln lee updated FLINK-20834: Fix Version/s: 1.20.0 > Add metrics for reporting the memory usage and CPU usage of the Python UDF

[jira] [Updated] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32488: Fix Version/s: 1.20.0 > Introduce configuration to control ExecutionGraph cache in REST API >

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

[ https://issues.apache.org/jira/browse/FLINK-29240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29240: Fix Version/s: (was: 1.19.0) > Unify the ClassLoader in StreamExecutionEnvironment and TableEn

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12352: Fix Version/s: (was: 1.19.0) > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Tabl

[jira] [Updated] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25027: Fix Version/s: 1.20.0 > Allow GC of a finished job's JobMaster before the slot timeout is reached

[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 ] lincoln lee updated FLINK-20920: Fix Version/s: (was: 1.19.0) > Document how to connect to kerberized HMS > ---

[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 ] lincoln lee updated FLINK-17642: Fix Version/s: 1.20.0 > Exception while reading broken ORC file is hidden > --

[jira] [Updated] (FLINK-30050) [Umbrella] Externalize Flink connectors

[ https://issues.apache.org/jira/browse/FLINK-30050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30050: Fix Version/s: (was: 1.19.0) > [Umbrella] Externalize Flink connectors > -

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31729: Fix Version/s: (was: 1.19.0) > Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN > ---

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

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

[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 ] lincoln lee updated FLINK-16799: Fix Version/s: 1.20.0 > add hive partition limit when read from hive > ---

[jira] [Updated] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33819: Fix Version/s: (was: 1.19.0) > Support setting CompressType in RocksDBStateBackend > -

[jira] [Updated] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34129: Fix Version/s: (was: 1.19.0) > MiniBatchGlobalGroupAggFunction will make -D as +I then make +I

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

[ https://issues.apache.org/jira/browse/FLINK-25352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25352: Fix Version/s: (was: 1.19.0) > Update stability annotations to include the since and missedGra

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