[jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery

[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19774: Fix Version/s: 1.20.0 > Introduce Sub Partition View Version for Approximate Local Recovery >

[jira] [Updated] (FLINK-25043) Allow calls to public @VisibleForTesting from the same package

[ https://issues.apache.org/jira/browse/FLINK-25043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25043: Fix Version/s: 1.20.0 > Allow calls to public @VisibleForTesting from the same package > -

[jira] [Updated] (FLINK-32745) Add a flag to skip InputSelectable preValidate step

[ https://issues.apache.org/jira/browse/FLINK-32745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32745: Fix Version/s: 1.20.0 > Add a flag to skip InputSelectable preValidate step >

[jira] [Updated] (FLINK-32184) Use revision version property

[ https://issues.apache.org/jira/browse/FLINK-32184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32184: Fix Version/s: 1.20.0 > Use revision version property > - > >

[jira] [Updated] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32427: Fix Version/s: 1.20.0 > FLIP-295: Support lazy initialization of catalogs and persistence of catal

[jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-26664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26664: Fix Version/s: 1.20.0 > Improve Python exception messages to be more Pythonic in PyFlink > ---

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

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

[jira] [Updated] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline

[ https://issues.apache.org/jira/browse/FLINK-27849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27849: Fix Version/s: 1.20.0 > Harden correctness for non-deterministic updates present in the changelog

[jira] [Updated] (FLINK-27596) [Umbrella] Optimize Hive source

[ https://issues.apache.org/jira/browse/FLINK-27596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27596: Fix Version/s: 1.20.0 > [Umbrella] Optimize Hive source > > >

[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 ] lincoln lee updated FLINK-21125: Fix Version/s: 1.20.0 > Sum or Sum0 overflow quietly > > >

[jira] [Updated] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

[ https://issues.apache.org/jira/browse/FLINK-33202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33202: Fix Version/s: 1.20.0 > FLIP-327: Support switching from batch to stream mode to improve throughpu

[jira] [Updated] (FLINK-34033) flink json supports raw type

[ https://issues.apache.org/jira/browse/FLINK-34033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34033: Fix Version/s: 1.20.0 > flink json supports raw type > - > >

[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 ] lincoln lee updated FLINK-19613: Fix Version/s: 1.20.0 > Create flink-connector-files-test-utils for formats testing >

[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 ] lincoln lee updated FLINK-16800: Fix Version/s: 1.20.0 > TypeMappingUtils#checkIfCompatible didn't deal with nested types > ---

[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 ] lincoln lee updated FLINK-20110: Fix Version/s: 1.20.0 > Support 'merge' method for first_value and last_value UDAF > -

[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: 1.20.0 > Update stability annotations to include the since and missedGraduations fi

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

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

[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 ] lincoln lee updated FLINK-16126: Fix Version/s: 1.20.0 > Translate all connector related pages into Chinese > -

[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 ] lincoln lee updated FLINK-15000: Fix Version/s: 1.20.0 > WebUI Metrics is very slow in large parallelism >

[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 ] lincoln lee updated FLINK-24386: Fix Version/s: 1.20.0 > JobMaster should guard against exceptions from OperatorCoordinator > -

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

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

[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 ] lincoln lee updated FLINK-23555: Fix Version/s: 1.20.0 > Improve common subexpression elimination by using local references > -

[jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

[ https://issues.apache.org/jira/browse/FLINK-17589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-17589: Fix Version/s: 1.20.0 > Extend StreamingFileSink to Support Streaming Hive Connector > ---

[jira] [Updated] (FLINK-32530) array_position semantic should align with array_contains instead of spark

[ https://issues.apache.org/jira/browse/FLINK-32530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32530: Fix Version/s: 1.20.0 > array_position semantic should align with array_contains instead of spark

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

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

[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: 1.20.0 > Maven: Premature end of Content-Length delimited message body > --

[jira] [Updated] (FLINK-33120) FLIP-361: Improve GC Metrics

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

[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 ] lincoln lee updated FLINK-23660: Fix Version/s: 1.20.0 > Hive Catalog support truncate table > ---

[jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API

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

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

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

[jira] [Updated] (FLINK-23445) Separate data and timer connection into different channels for Python Table API operators

[ https://issues.apache.org/jira/browse/FLINK-23445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23445: Fix Version/s: 1.20.0 > Separate data and timer connection into different channels for Python Tabl

[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink

[ https://issues.apache.org/jira/browse/FLINK-18022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18022: Fix Version/s: 1.20.0 > Add e2e test for new streaming file sink > ---

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30524: Fix Version/s: 1.20.0 > Support full screen viewing on the Logs/Stdout/Thread Dump page >

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

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

[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 ] lincoln lee updated FLINK-17683: Fix Version/s: 1.20.0 > Pojo with no-args constructor will be treated as ROW when returned by > S

[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 ] lincoln lee updated FLINK-15973: Fix Version/s: 1.20.0 > Optimize the execution plan where it refers the Python UDF result field in

[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: 1.20.0 > Enable builds for pull requests > --- > >

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

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

[jira] [Updated] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-27401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27401: Fix Version/s: 1.20.0 > CEP supports AggregateFunction in IterativeCondition > ---

[jira] [Updated] (FLINK-34397) Resource wait timeout can't be disabled

[ https://issues.apache.org/jira/browse/FLINK-34397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34397: Fix Version/s: 1.20.0 > Resource wait timeout can't be disabled >

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

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

[jira] [Updated] (FLINK-32264) Add FIELD support in SQL & Table API

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

[jira] [Updated] (FLINK-29368) Modify DESCRIBE statement docs for new syntax

[ https://issues.apache.org/jira/browse/FLINK-29368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29368: Fix Version/s: 1.20.0 > Modify DESCRIBE statement docs for new syntax > --

[jira] [Updated] (FLINK-26840) [minor refactor] Add a general TopNBufferCacheRemovalListener for topN function

[ https://issues.apache.org/jira/browse/FLINK-26840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26840: Fix Version/s: 1.20.0 > [minor refactor] Add a general TopNBufferCacheRemovalListener for topN >

[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: 1.20.0 > python_job.py should write to TEST_DATA_DIR >

[jira] [Updated] (FLINK-33085) Improve the error message when the invalidate lookupTableSource without primary key is used as temporal join table

[ https://issues.apache.org/jira/browse/FLINK-33085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33085: Fix Version/s: 1.20.0 > Improve the error message when the invalidate lookupTableSource without >

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31116: Fix Version/s: 1.20.0 > Support taskmanager related parameters in session mode Support job > gran

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

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

[jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16323: Fix Version/s: 1.20.0 > Support to join a static table in streaming mode > ---

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

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

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-14340: Fix Version/s: 1.20.0 > Specify an unique DFSClient name for Hadoop FileSystem > -

[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: 1.20.0 > Add configuration to allow disabling SQL query hints > ---

[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 ] lincoln lee updated FLINK-15859: Fix Version/s: 1.20.0 > Unify identifiers in the interface methods of CatalogManager > ---

[jira] [Updated] (FLINK-26253) Speed up detection of dropped message in MessageSerializationTest

[ https://issues.apache.org/jira/browse/FLINK-26253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26253: Fix Version/s: 1.20.0 > Speed up detection of dropped message in MessageSerializationTest > --

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

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

[jira] [Updated] (FLINK-28919) Add built-in generate_series function.

[ https://issues.apache.org/jira/browse/FLINK-28919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28919: Fix Version/s: 1.20.0 > Add built-in generate_series function. > -

[jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system

[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33950: Fix Version/s: 1.20.0 > Update max aggregate functions to new type system > --

[jira] [Updated] (FLINK-27858) Hive source support filter push down for parquet format

[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27858: Fix Version/s: 1.20.0 > Hive source support filter push down for parquet format >

[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 ] lincoln lee updated FLINK-22975: Fix Version/s: 1.20.0 > Specify port or range for k8s service > --

[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: 1.20.0 > Decouple connector docs integration from connector releases >

[jira] [Updated] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32444: Fix Version/s: 1.20.0 > Enable object reuse for Flink SQL jobs by default > --

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

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

[jira] [Updated] (FLINK-28583) make flink dist log4j dependency simple and clear

[ https://issues.apache.org/jira/browse/FLINK-28583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28583: Fix Version/s: 1.20.0 > make flink dist log4j dependency simple and clear > --

[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: 1.20.0 > Document how to connect to kerberized HMS > --

[jira] [Updated] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

[ https://issues.apache.org/jira/browse/FLINK-28120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28120: Fix Version/s: 1.20.0 > Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost the

[jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side

[ https://issues.apache.org/jira/browse/FLINK-31193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31193: Fix Version/s: 1.20.0 > The option `table.exec.hive.native-agg-function.enabled` should work at jo

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-13735: Fix Version/s: 1.20.0 > Support session window with blink planner in batch mode >

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

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

[jira] [Updated] (FLINK-31245) Adaptive scheduler does not reset the state of GlobalAggregateManager when rescaling

[ https://issues.apache.org/jira/browse/FLINK-31245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31245: Fix Version/s: 1.20.0 > Adaptive scheduler does not reset the state of GlobalAggregateManager when

[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: 1.20.0 > Optimize for Python UDFs with all parameters are constant values > ---

[jira] [Updated] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32142: Fix Version/s: 1.20.0 > Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type"

[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: 1.20.0 > MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when

[jira] [Updated] (FLINK-25725) Agile configurable modules in web ui

[ https://issues.apache.org/jira/browse/FLINK-25725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25725: Fix Version/s: 1.20.0 > Agile configurable modules in web ui > ---

[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: 1.20.0 > Support BuiltInMethod TO_TIMESTAMP with timezone options > ---

[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: 1.20.0 > In the wmassigners module, words are misspelled >

[jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18734: Fix Version/s: 1.20.0 > Add documentation for DynamoStreams Consumer CDC > ---

[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: 1.20.0 > Support setting CompressType in RocksDBStateBackend >

[jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices.

[ https://issues.apache.org/jira/browse/FLINK-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16701: Fix Version/s: 1.20.0 > Elasticsearch sink support alias for indices. > --

[jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24757: Fix Version/s: 1.20.0 > Yarn application is not terminated after the job finishes when submitting

[jira] [Updated] (FLINK-24306) group by index throw SqlValidatorException

[ https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24306: Fix Version/s: 1.20.0 > group by index throw SqlValidatorException > -

[jira] [Updated] (FLINK-29717) Supports hive udaf such as sum/count by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29717: Fix Version/s: 1.20.0 > Supports hive udaf such as sum/count by native implementation >

[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: 1.20.0 > Table planner dependency instructions for executing in IDE can be improved

[jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25322: Fix Version/s: 1.20.0 > Support no-claim mode in changelog state backend > ---

[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: 1.20.0 > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with defa

[jira] [Updated] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog

[ https://issues.apache.org/jira/browse/FLINK-29776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29776: Fix Version/s: 1.20.0 > [JUnit5 Migration] Module: flink-statebackend-changelog >

[jira] [Updated] (FLINK-29724) Supports hive last_value function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29724: Fix Version/s: 1.20.0 > Supports hive last_value function by native implementation > -

[jira] [Updated] (FLINK-29027) Fix HiveTableSink failed to report statistic to hive metastore in stream mode

[ https://issues.apache.org/jira/browse/FLINK-29027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29027: Fix Version/s: 1.20.0 > Fix HiveTableSink failed to report statistic to hive metastore in stream m

[jira] [Updated] (FLINK-23900) Migrate to ClusterActorRefProvider

[ https://issues.apache.org/jira/browse/FLINK-23900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23900: Fix Version/s: 1.20.0 > Migrate to ClusterActorRefProvider > -- >

[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 ] lincoln lee updated FLINK-20518: Fix Version/s: 1.20.0 > WebUI should escape characters in metric names > -

[jira] [Updated] (FLINK-15003) Improve hive test performance

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

[jira] [Updated] (FLINK-29058) Analyze table xxx For columns will thrown error while encounter String type column with null value

[ https://issues.apache.org/jira/browse/FLINK-29058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29058: Fix Version/s: 1.20.0 > Analyze table xxx For columns will thrown error while encounter String typ

[jira] [Updated] (FLINK-31654) DataStreamUtils.reinterpretAsKeyedStream() should not override the user specified chaining strategy.

[ https://issues.apache.org/jira/browse/FLINK-31654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31654: Fix Version/s: 1.20.0 > DataStreamUtils.reinterpretAsKeyedStream() should not override the user >

[jira] [Updated] (FLINK-32738) PROTOBUF format supports projection push down

[ https://issues.apache.org/jira/browse/FLINK-32738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32738: Fix Version/s: 1.20.0 > PROTOBUF format supports projection push down > --

[jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType

[ https://issues.apache.org/jira/browse/FLINK-23869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23869: Fix Version/s: 1.20.0 > Correct javadoc of ExecutionConfig#registerKryoType >

[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 ] lincoln lee updated FLINK-20246: Fix Version/s: 1.20.0 > Add documentation on Python worker memory tuning in the memory tuning page

[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 ] lincoln lee updated FLINK-19362: Fix Version/s: 1.20.0 > Remove confusing comment for `DOT` operator codegen >

[jira] [Updated] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable

[ https://issues.apache.org/jira/browse/FLINK-27591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27591: Fix Version/s: 1.20.0 > Improve the plan for batch queries when statistics is unavailable > -

[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: 1.20.0 > Some further improvements of the pluggable shuffle framework > ---

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

[ https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-11868: Fix Version/s: 1.20.0 > [filesystems] Introduce listStatusIterator API to file system > --

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

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

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