[jira] [Closed] (FLINK-31443) FineGrainedSlotManager maintain some redundant task managers

[ https://issues.apache.org/jira/browse/FLINK-31443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31443. Fix Version/s: 1.18.0 Resolution: Done master (1.18):

[jira] [Comment Edited] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719744#comment-17719744 ] Xintong Song edited comment on FLINK-31974 at 5/5/23 8:45 AM: -- Thanks all

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719744#comment-17719744 ] Xintong Song commented on FLINK-31974: -- Thanks all for the explanation and patience. It seems

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719580#comment-17719580 ] Xintong Song commented on FLINK-31974: -- cc [~wangyang0918] > JobManager crashes after

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719331#comment-17719331 ] Xintong Song commented on FLINK-31974: -- [~gyfora], bq. Flink treats only very few errors fatal. IO

[jira] [Commented] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

[ https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719309#comment-17719309 ] Xintong Song commented on FLINK-31984: -- Thanks for fixing it, [~mapohl]. And sorry for causing this

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719228#comment-17719228 ] Xintong Song commented on FLINK-31974: -- [~gyfora], IMO, errors that Flink cannot recover from by

[jira] [Closed] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

[ https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31984. Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Done

[jira] [Assigned] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

[ https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-31984: Assignee: Mingliang Liu > Savepoint on S3 should be relocatable if entropy injection is

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719209#comment-17719209 ] Xintong Song commented on FLINK-31974: -- Not sure about never giving fatal exceptions. I personally

[jira] [Assigned] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-31974: Assignee: Weijie Guo (was: Weijie Tong) > JobManager crashes after

[jira] [Assigned] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-31974: Assignee: Weijie Tong > JobManager crashes after KubernetesClientException exception

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719187#comment-17719187 ] Xintong Song commented on FLINK-31974: -- [~mapohl], There're two paths for JobMaster to handle the

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719116#comment-17719116 ] Xintong Song commented on FLINK-31974: -- Thanks [~sergiosp] for reporting, and thanks [~mapohl] for

[jira] [Closed] (FLINK-27328) Could not resolve ResourceManager address

[ https://issues.apache.org/jira/browse/FLINK-27328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27328. Resolution: Not A Bug Closing the ticket due to: 1. There's no further feedback from the user on

[jira] [Closed] (FLINK-27750) The configuration of JobManagerOption.TOTAL_PROCESS_MEMORY(jobmanager.memory.process.size) not work

[ https://issues.apache.org/jira/browse/FLINK-27750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27750. Resolution: Not A Bug Closing the ticket due to: 1. 1.14.4 is no longer supported. 2. User should

[jira] [Commented] (FLINK-27719) Create Apache Flink slack workspace

[ https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711656#comment-17711656 ] Xintong Song commented on FLINK-27719: -- Yes. Thanks for the reminder. > Create Apache Flink slack

[jira] [Closed] (FLINK-27723) Slack: revisit how this communication channel works

[ https://issues.apache.org/jira/browse/FLINK-27723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27723. Resolution: Resolved > Slack: revisit how this communication channel works >

[jira] [Closed] (FLINK-27719) Create Apache Flink slack workspace

[ https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27719. Resolution: Resolved > Create Apache Flink slack workspace > ---

[jira] [Closed] (FLINK-31652) Flink should handle the delete event if the pod was deleted while pending

[ https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31652. Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fixed

[jira] [Closed] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout

[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27576. Resolution: Duplicate > Flink will request new pod when jm pod is delete, but will remove when >

[jira] [Assigned] (FLINK-31652) Flink should handle the delete event if the pod was deleted while pending

[ https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-31652: Assignee: xingbe > Flink should handle the delete event if the pod was deleted while

[jira] [Commented] (FLINK-31652) Flink should handle the delete event if the pod was deleted while pending

[ https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706651#comment-17706651 ] Xintong Song commented on FLINK-31652: -- [~xiasun] You are assigned. Please go ahead. > Flink

[jira] [Commented] (FLINK-31652) Flink should handle the delete event if the pod was deleted while pending

[ https://issues.apache.org/jira/browse/FLINK-31652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706356#comment-17706356 ] Xintong Song commented on FLINK-31652: -- [~xiasun], thanks for reporting this. I think this is a

[jira] [Closed] (FLINK-31444) FineGrainedSlotManager reclaims slots when job is finished

[ https://issues.apache.org/jira/browse/FLINK-31444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31444. Fix Version/s: 1.18.0 Resolution: Fixed master (1.18):

[jira] [Closed] (FLINK-31441) FineGrainedSlotManager support select slot evenly

[ https://issues.apache.org/jira/browse/FLINK-31441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31441. Fix Version/s: 1.18.0 Resolution: Done master (1.18):

[jira] [Updated] (FLINK-28074) show statistics details for DESCRIBE EXTENDED

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

[jira] [Updated] (FLINK-28929) Add built-in datediff function.

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

[jira] [Updated] (FLINK-29172) Add built-in string_split function.

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

[jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29330: - Fix Version/s: 1.18.0 (was: 1.17.0) > Provide better logs of MiniCluster

[jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-26761: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix the cast exception thrown by

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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-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

[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-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

[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

[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

[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

[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

[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

[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 &

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

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