[jira] [Updated] (FLINK-30457) Introduce period compaction to FRocksDB

[ https://issues.apache.org/jira/browse/FLINK-30457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30457: - Fix Version/s: 1.18.0 (was: 1.17.0) > Introduce period compaction to FRoc

[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 ] Xintong Song updated FLINK-29343: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix fail to execute ddl in HiveDial

[jira] [Updated] (FLINK-30380) Look into enabling parallel compilation on CI

[ https://issues.apache.org/jira/browse/FLINK-30380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30380: - Fix Version/s: 1.18.0 (was: 1.17.0) > Look into enabling parallel compila

[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 ] Xintong Song updated FLINK-9879: Fix Version/s: 1.18.0 (was: 1.17.0) > Find sane defaults for (advanced) SSL

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

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13015: - Fix Version/s: 1.18.0 (was: 1.17.0) > Create validators, strategies and t

[jira] [Updated] (FLINK-30660) move SQLClientHiveITCase and TestHiveCatalogFactory to flink-connector-hive e2e

[ https://issues.apache.org/jira/browse/FLINK-30660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30660: - Fix Version/s: 1.18.0 (was: 1.17.0) > move SQLClientHiveITCase and TestHi

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

[ https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12491: - Fix Version/s: 1.18.0 (was: 1.17.0) > Incorrect documentation for directo

[jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15351: - Fix Version/s: 1.18.0 (was: 1.17.0) > develop PostgresCatalog to connect

[jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment

[ https://issues.apache.org/jira/browse/FLINK-14707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14707: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor checkpoint related methods

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

[ https://issues.apache.org/jira/browse/FLINK-14879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14879: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support 'DESCRIBE DATABSE databaseN

[jira] [Updated] (FLINK-29844) FLIP-263: Improve resolving schema compatibility

[ https://issues.apache.org/jira/browse/FLINK-29844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29844: - Fix Version/s: 1.18.0 (was: 1.17.0) > FLIP-263: Improve resolving schema

[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 ] Xintong Song updated FLINK-12273: - Fix Version/s: 1.18.0 (was: 1.17.0) > The default value of CheckpointRete

[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 ] Xintong Song updated FLINK-12352: - Fix Version/s: 1.18.0 (was: 1.17.0) > [FLIP-36] [Phase 1] Support cache()

[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 ] Xintong Song updated FLINK-14125: - Fix Version/s: 1.18.0 (was: 1.17.0) > Display memory and CPU usage in the

[jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration

[ https://issues.apache.org/jira/browse/FLINK-14410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14410: - Fix Version/s: 1.18.0 (was: 1.17.0) > Retrieve CharacterFilter once after

[jira] [Updated] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format

[ https://issues.apache.org/jira/browse/FLINK-14148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14148: - Fix Version/s: 1.18.0 (was: 1.17.0) > Investigate pushing predicate/proje

[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 ] Xintong Song updated FLINK-15000: - Fix Version/s: 1.18.0 (was: 1.17.0) > WebUI Metrics is very slow in large

[jira] [Updated] (FLINK-6810) Add a set of built-in functions to Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-6810: Fix Version/s: 1.18.0 (was: 1.17.0) > Add a set of built-in functions to Tab

[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 ] Xintong Song updated FLINK-14684: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Pinterest to Chinese Powered By

[jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing

[ https://issues.apache.org/jira/browse/FLINK-15645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15645: - Fix Version/s: 1.18.0 (was: 1.17.0) > enable COPY TO/FROM in Postgres JDB

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-11937: - Fix Version/s: 1.18.0 (was: 1.17.0) > Resolve small file problem in Rocks

[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 ] Xintong Song updated FLINK-15860: - Fix Version/s: 1.18.0 (was: 1.17.0) > Store temporary functions as Catalo

[jira] [Updated] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16027: - Fix Version/s: 1.18.0 (was: 1.17.0) > kafka connector's 'connector.topic'

[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 ] Xintong Song updated FLINK-11868: - Fix Version/s: 1.18.0 (was: 1.17.0) > [filesystems] Introduce listStatusI

[jira] [Updated] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16155: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate "Operator/Process Functio

[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 ] Xintong Song updated FLINK-16077: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate "Custom State Serializati

[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 ] Xintong Song updated FLINK-16137: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate all DataStream API relate

[jira] [Updated] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map

[ https://issues.apache.org/jira/browse/FLINK-12412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12412: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow ListTypeInfo used for java.ut

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12590: - Fix Version/s: 1.18.0 (was: 1.17.0) > Replace http links in documentation

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12692: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support disk spilling in HeapKeyedS

[jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12358: - Fix Version/s: 1.18.0 (was: 1.17.0) > Verify whether rest documenation ne

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13910: - Fix Version/s: 1.18.0 (was: 1.17.0) > Many serializable classes have no e

[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 ] Xintong Song updated FLINK-13735: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support session window with blink p

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

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16143: - Fix Version/s: 1.18.0 (was: 1.17.0) > Turn on more date time functions of

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

[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13876: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove ExecutionConfig field from P

[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 ] Xintong Song updated FLINK-14340: - Fix Version/s: 1.18.0 (was: 1.17.0) > Specify an unique DFSClient name fo

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

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14383: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support python UDFs with constant v

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

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14500: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support Flink Python User-Defined S

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14032: - Fix Version/s: 1.18.0 (was: 1.17.0) > Make the cache size of RocksDBPrior

[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 ] Xintong Song updated FLINK-14471: - Fix Version/s: 1.18.0 (was: 1.17.0) > Hide error message when metric api

[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 ] Xintong Song updated FLINK-14122: - Fix Version/s: 1.18.0 (was: 1.17.0) > Extend State Processor API to read

[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 ] Xintong Song updated FLINK-16774: - Fix Version/s: 1.18.0 (was: 1.17.0) > expose HBaseUpsertSinkFunction hTab

[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16776: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support schema evolution for Hive t

[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 ] Xintong Song updated FLINK-14028: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support to configure the log level

[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 ] Xintong Song updated FLINK-14222: - Fix Version/s: 1.18.0 (was: 1.17.0) > Optimize for Python UDFs with all p

[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 ] Xintong Song updated FLINK-15003: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve hive test performance > ---

[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 ] Xintong Song updated FLINK-17589: - Fix Version/s: 1.18.0 (was: 1.17.0) > Extend StreamingFileSink to Support

[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 ] Xintong Song updated FLINK-16701: - Fix Version/s: 1.18.0 (was: 1.17.0) > Elasticsearch sink support alias fo

[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 ] Xintong Song updated FLINK-17274: - Fix Version/s: 1.18.0 (was: 1.17.0) > Maven: Premature end of Content-Len

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

[ https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14351: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor MetricRegistry delimiter r

[jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core

[ https://issues.apache.org/jira/browse/FLINK-14867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14867: - Fix Version/s: 1.18.0 (was: 1.17.0) > Move TextInputFormat & TextOutputFo

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

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17362: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve table examples to reflect l

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15018: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add event time page to Concepts > -

[jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

[ https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15183: - Fix Version/s: 1.18.0 (was: 1.17.0) > Use SQL-CLI to TPC-DS E2E test > --

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15471: - Fix Version/s: 1.18.0 (was: 1.17.0) > HA e2e check for empty .out files d

[jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option

[ https://issues.apache.org/jira/browse/FLINK-17535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17535: - Fix Version/s: 1.18.0 (was: 1.17.0) > Treat min/max as part of the hierar

[jira] [Updated] (FLINK-14934) Remove error log statement in ES connector

[ https://issues.apache.org/jira/browse/FLINK-14934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14934: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove error log statement in ES co

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

[ https://issues.apache.org/jira/browse/FLINK-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14690: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support 'DESCRIBE CATALOG catalogNa

[jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column

[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15553: - Fix Version/s: 1.18.0 (was: 1.17.0) > Create table ddl support comment a

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

[ https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17405: - Fix Version/s: 1.18.0 (was: 1.17.0) > add test cases for cancel job in SQ

[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 ] Xintong Song updated FLINK-15729: - Fix Version/s: 1.18.0 (was: 1.17.0) > Table planner dependency instructio

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

[ https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15460: - Fix Version/s: 1.18.0 (was: 1.17.0) > planner dependencies won't be neces

[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 ] Xintong Song updated FLINK-16073: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate "State & Fault Tolerance"

[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 ] Xintong Song updated FLINK-15973: - Fix Version/s: 1.18.0 (was: 1.17.0) > Optimize the execution plan where i

[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()

[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15740: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove Deadline#timeLeft() > --

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15532: - Fix Version/s: 1.18.0 (was: 1.17.0) > Enable strict capacity limit for me

[jira] [Updated] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17916: - Fix Version/s: 1.18.0 (was: 1.17.0) > Provide API to separate KafkaShuffl

[jira] [Updated] (FLINK-18201) Support create_function in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18201: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support create_function in Python T

[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 ] Xintong Song updated FLINK-15859: - Fix Version/s: 1.18.0 (was: 1.17.0) > Unify identifiers in the interface

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16548: - Fix Version/s: 1.18.0 (was: 1.17.0) > Expose consistent environment varia

[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 ] Xintong Song updated FLINK-16323: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support to join a static table in s

[jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18565: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Support for Azure Event Grid Da

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

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16023: - Fix Version/s: 1.18.0 (was: 1.17.0) > jdbc connector's 'connector.table'

[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 ] Xintong Song updated FLINK-16466: - Fix Version/s: 1.18.0 (was: 1.17.0) > Group by on event time should produ

[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 ] Xintong Song updated FLINK-18199: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate "Filesystem SQL Connector

[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 ] Xintong Song updated FLINK-16609: - Fix Version/s: 1.18.0 (was: 1.17.0) > Promotes the column name representa

[jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17011: - Fix Version/s: 1.18.0 (was: 1.17.0) > Introduce builder to create Abstrac

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

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18634: - Fix Version/s: 1.18.0 (was: 1.17.0) > FlinkKafkaProducerITCase.testRecove

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

[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18578: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add rejecting checkpoint logic in s

[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 ] Xintong Song updated FLINK-18624: - Fix Version/s: 1.18.0 (was: 1.17.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 ] Xintong Song updated FLINK-16126: - Fix Version/s: 1.18.0 (was: 1.17.0) > Translate all connector related pag

[jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments

[ https://issues.apache.org/jira/browse/FLINK-18986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18986: - Fix Version/s: 1.18.0 (was: 1.17.0) > KubernetesSessionCli creates RestCl

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

[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16531: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add full integration tests for "GRO

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

[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19034: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove deprecated StreamExecutionEn

[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 ] Xintong Song updated FLINK-16799: - Fix Version/s: 1.18.0 (was: 1.17.0) > add hive partition limit when read

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

[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16762: - Fix Version/s: 1.18.0 (was: 1.17.0) > Relocation Beam dependency of PyFli

[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 ] Xintong Song updated FLINK-16800: - Fix Version/s: 1.18.0 (was: 1.17.0) > TypeMappingUtils#checkIfCompatible

[jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown

[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16952: - Fix Version/s: 1.18.0 (was: 1.17.0) > Parquet file system format support

[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 ] Xintong Song updated FLINK-19038: - Fix Version/s: 1.18.0 (was: 1.17.0) > It doesn't support to call Table.li

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17785: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor orc shim to create a OrcSh

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18742: - Fix Version/s: 1.18.0 (was: 1.17.0) > Some configuration args do not take

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17337: - Fix Version/s: 1.18.0 (was: 1.17.0) > Send UPDATE messages instead of INS

[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 ] Xintong Song updated FLINK-17642: - Fix Version/s: 1.18.0 (was: 1.17.0) > Exception while reading broken ORC

[jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL.

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17755: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support side-output of expiring sta

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

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17784: - Fix Version/s: 1.18.0 (was: 1.17.0) > Better detection for parquet and or

[jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners

[ https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19499: - Fix Version/s: 1.18.0 (was: 1.17.0) > Expose Metric Groups to Split Assig

[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 ] Xintong Song updated FLINK-17683: - Fix Version/s: 1.18.0 (was: 1.17.0) > Pojo with no-args constructor will

[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 ] Xintong Song updated FLINK-18022: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add e2e test for new streaming file

[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: 1.18.0 (was: 1.17.0) > Introduce avro.ignore-parse-errors

[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 ] Xintong Song updated FLINK-17826: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add missing custom query support on

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