[jira] [Updated] (FLINK-25283) End-to-end application modules create oversized jars

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25283: --- Fix Version/s: 2.0.0 (was: 1.20.0) > End-to-end application modules create ov

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26942: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Support SELECT clause in CREATE TABLE(CT

[jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34445: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Integrate new endpoint with Flink UI met

[jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35557: --- Fix Version/s: 2.0.0 (was: 1.20.0) (was: 1.19.2) > Mem

[jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-19254: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Invalid UTF-8 start byte exception > --

[jira] [Updated] (FLINK-25350) Verify stability guarantees of annotated classes

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25350: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Verify stability guarantees of annotated

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-12352: --- Fix Version/s: 2.0.0 (was: 1.20.0) > [FLIP-36] [Phase 1] Support cache() / in

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21765: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Remove implementation-specific MetricGro

[jira] [Updated] (FLINK-29547) Select a[1] which is array type for parquet complex type throw ClassCastException

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29547: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Select a[1] which is array type for par

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30380: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Look into enabling parallel compilation

[jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-22926: --- Fix Version/s: 2.0.0 (was: 1.20.0) > IDLE FLIP-27 source should go ACTIVE whe

[jira] [Updated] (FLINK-34503) Migrate JoinDeriveNullFilterRule

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34503: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Migrate JoinDeriveNullFilterRule > -

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17826: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Add missing custom query support on new

[jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21125: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Sum or Sum0 overflow quietly > -

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15645: --- Fix Version/s: 2.0.0 (was: 1.20.0) > enable COPY TO/FROM in Postgres JDBC sou

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28042: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Create an extension for resetting HiveCo

[jira] [Updated] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28428: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Example in the Elasticsearch doc of faul

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-16466: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Group by on event time should produce in

[jira] [Updated] (FLINK-35062) Migrate RewriteMultiJoinConditionRule

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35062: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Migrate RewriteMultiJoinConditionRule >

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21648: --- Fix Version/s: 2.0.0 (was: 1.20.0) > FLIP-151: Incremental snapshots for heap

[jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-15000: --- Fix Version/s: 2.0.0 (was: 1.20.0) > WebUI Metrics is very slow in large para

[jira] [Updated] (FLINK-24386) JobMaster should guard against exceptions from OperatorCoordinator

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24386: --- Fix Version/s: 2.0.0 (was: 1.20.0) > JobMaster should guard against exception

[jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-25887: --- Fix Version/s: 2.0.0 (was: 1.20.0) > FLIP-193: Snapshots ownership follow ups

[jira] [Updated] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33895: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Implement restore tests for PythonGroupW

[jira] [Updated] (FLINK-26477) Finalize the window support in Python DataStream API

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26477: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Finalize the window support in Python Da

[jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-24951: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Allow watch bookmarks to mitigate freque

[jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34670: --- Fix Version/s: 2.0.0 (was: 1.20.0) > The asyncOperationsThreadPool in Subtask

[jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-20920: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Document how to connect to kerberized HM

[jira] [Updated] (FLINK-34094) Document new AsyncScalarFunction

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34094: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Document new AsyncScalarFunction > -

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-16776: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Support schema evolution for Hive tables

[jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28777: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Add configure session API for sql gatewa

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-12491: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Incorrect documentation for directory pa

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14934: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Remove error log statement in ES connect

[jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28398: --- Fix Version/s: 2.0.0 (was: 1.20.0) > CheckpointCoordinatorTriggeringTest.disc

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21876: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Handle it properly when the returned val

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34129: --- Fix Version/s: 2.0.0 (was: 1.20.0) > MiniBatchGlobalGroupAggFunction will mak

[jira] [Updated] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32699: --- Fix Version/s: 2.0.0 (was: 1.20.0) > select typeof(proctime()); throw excepti

Re: [PR] [hotfix] [docs] Fix broken link to "Anatomy of the Flink distribution" in dev/configuration/connector [flink]

2024-07-09 Thread via GitHub
hlteoh37 merged PR #24906: URL: https://github.com/apache/flink/pull/24906 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

Re: [PR] [FLINK-33545][Connectors/Kafka] KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching [flink-connector-kafka]

2024-07-09 Thread via GitHub
AHeise commented on code in PR #70: URL: https://github.com/apache/flink-connector-kafka/pull/70#discussion_r1671715837 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java: ## @@ -72,12 +74,17 @@ private static Properties

[jira] [Updated] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35435: --- Release Note: In Flink 1.20, We have introduced timeout configuration to `AsyncSink` with `retryOnTi

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

2024-07-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: Anupam Aggarwal > Add JSON_QUOTE and JSON_UNQUOTE function > --

[jira] [Updated] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35435: --- Release Note: In Flink 1.20, We have introduced timeout configuration to AsyncSink with retryOnTimeo

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

2024-07-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: (was: Anupam) > Add JSON_QUOTE and JSON_UNQUOTE function >

[jira] [Assigned] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

2024-07-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34111: -- Assignee: Anupam (was: Jeyhun Karimov) > Add JSON_QUOTE and JSON_UNQUOTE function >

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

2024-07-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864495#comment-17864495 ] Martijn Visser commented on FLINK-25217: [~fsk119]  Since Flink 1.15 actually. 

Re: [PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc]

2024-07-09 Thread via GitHub
lvyanquan closed pull request #3463: [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. URL: https://github.com/apache/flink-cdc/pull/3463 -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-35802) Deadlock may happen after adding new tables

2024-07-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35802: --- Labels: pull-request-available (was: ) > Deadlock may happen after adding new tables >

[PR] [FLINK-35802][mysql] clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method. [flink-cdc]

2024-07-09 Thread via GitHub
lvyanquan opened a new pull request, #3463: URL: https://github.com/apache/flink-cdc/pull/3463 See https://issues.apache.org/jira/browse/FLINK-35802 for more details. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864493#comment-17864493 ] Weijie Guo edited comment on FLINK-35753 at 7/10/24 6:31 AM: -

[jira] [Closed] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35753. -- Fix Version/s: 1.20.0 Resolution: Fixed > ParquetColumnarRowInputFormatTest.testContinuousRepet

[jira] [Commented] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864493#comment-17864493 ] Weijie Guo commented on FLINK-35753: After checking the commits for the failed cases

[jira] [Comment Edited] (FLINK-35753) ParquetColumnarRowInputFormatTest.testContinuousRepetition(int) failed due to ArrayIndexOutOfBoundsException

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864493#comment-17864493 ] Weijie Guo edited comment on FLINK-35753 at 7/10/24 6:30 AM: -

Re: [PR] [FLINK-35749] Kafka sink component will lose data when kafka cluster is unavailable for a while [flink-connector-kafka]

2024-07-09 Thread via GitHub
AHeise commented on PR #107: URL: https://github.com/apache/flink-connector-kafka/pull/107#issuecomment-2219662290 There is an arch unit rule violation: ``` 2024-07-09T13:48:15.4851704Z [ERROR] Architecture Violation [Priority: MEDIUM] - Rule 'ITCASE tests should use a MiniClust

[jira] [Commented] (FLINK-35802) Deadlock may happen after adding new tables

2024-07-09 Thread ruofan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864490#comment-17864490 ] ruofan commented on FLINK-35802: Please assign this to me, thanks. > Deadlock may happe

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21634: --- Fix Version/s: 2.0.0 (was: 1.20.0) > ALTER TABLE statement enhancement >

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14867: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Move TextInputFormat & TextOutputFormat

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-17011: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Introduce builder to create AbstractStre

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14410: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Retrieve CharacterFilter once after regi

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-18986: --- Fix Version/s: 2.0.0 (was: 1.20.0) > KubernetesSessionCli creates RestCluster

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-21375: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Refactor HybridMemorySegment > -

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

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-18201: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Support create_function in Python Table

[jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-22240: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Sanity/phrasing pass for ExternalResourc

[jira] [Created] (FLINK-35802) Deadlock may happen after adding new tables

2024-07-09 Thread LvYanquan (Jira)
LvYanquan created FLINK-35802: - Summary: Deadlock may happen after adding new tables Key: FLINK-35802 URL: https://issues.apache.org/jira/browse/FLINK-35802 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version [flink]

2024-07-09 Thread via GitHub
flinkbot commented on PR #25065: URL: https://github.com/apache/flink/pull/25065#issuecomment-2219548572 ## CI report: * 4be52c4e48622e7c8b69ee11aa43973e1e8e76d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32239) Unify TestJvmProcess and TestProcessBuilder

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32239: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Unify TestJvmProcess and TestProcessBuil

[jira] [Updated] (FLINK-26081) Update document,becasue of add maven wrapper.

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26081: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Update document,becasue of add maven wra

[jira] [Updated] (FLINK-33319) Add AverageTime metric to measure delta change in GC time

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33319: --- Fix Version/s: 2.0.0 (was: 1.20.0) > Add AverageTime metric to measure delta

[jira] [Assigned] (FLINK-35683) [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35683: -- Assignee: Weijie Guo > [Release-1.20] Verify that no exclusions were erroneously added to th

[jira] [Closed] (FLINK-35680) [Release-1.20] Review Release Notes in JIRA

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35680. -- Resolution: Done > [Release-1.20] Review Release Notes in JIRA > -

[PR] [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version [flink]

2024-07-09 Thread via GitHub
1996fanrui opened a new pull request, #25065: URL: https://github.com/apache/flink/pull/25065 ## What is the purpose of the change https://github.com/apache/flink/pull/23859 only updated the English version, this PR updates the zh doc. ## Brief change log [FLINK-3373

[jira] [Commented] (FLINK-35680) [Release-1.20] Review Release Notes in JIRA

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864474#comment-17864474 ] Weijie Guo commented on FLINK-35680: [~fanrui] and I have reviewed all JIRA related

[jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26050: --- Release Note: In some cases, the number of files produced by RocksDB state backend grows indefinite

[jira] [Updated] (FLINK-35680) [Release-1.20] Review Release Notes in JIRA

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35680: --- Fix Version/s: 1.20.0 > [Release-1.20] Review Release Notes in JIRA > --

[jira] [Assigned] (FLINK-35680) [Release-1.20] Review Release Notes in JIRA

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35680: -- Assignee: Weijie Guo (was: Ufuk Celebi) > [Release-1.20] Review Release Notes in JIRA >

[jira] [Assigned] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35801: -- Assignee: Zakelly Lan > testSwitchFromEnablingToDisablingFileMerging failed in AZP >

[jira] [Updated] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35801: --- Priority: Blocker (was: Major) > testSwitchFromEnablingToDisablingFileMerging failed in AZP > -

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864472#comment-17864472 ] Rui Fan commented on FLINK-35624: - Thanks for the quikc feedback! Looking forward to you

[jira] [Created] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35801: -- Summary: testSwitchFromEnablingToDisablingFileMerging failed in AZP Key: FLINK-35801 URL: https://issues.apache.org/jira/browse/FLINK-35801 Project: Flink Issue

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

2024-07-09 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864470#comment-17864470 ] Zakelly Lan commented on FLINK-35624: - [~fanrui] I'm investigating on the github act

[jira] [Commented] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864471#comment-17864471 ] Weijie Guo commented on FLINK-35801: https://dev.azure.com/apache-flink/apache-flink

[jira] [Updated] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35801: --- Description: {code:java} Jul 09 15:12:51 15:12:51.261 [ERROR] Failures: Jul 09 15:12:51 15:12:51.26

[jira] [Commented] (FLINK-33730) Update the compatibility table to only include last three released versions

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864467#comment-17864467 ] Rui Fan commented on FLINK-33730: - Merged to master(1.19) via: a2cf8fca7b229dcfd49d0b2c2

[jira] [Commented] (FLINK-33730) Update the compatibility table to only include last three released versions

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864466#comment-17864466 ] Rui Fan commented on FLINK-33730: - [https://github.com/apache/flink/pull/23859] only upd

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

2024-07-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864464#comment-17864464 ] Shengkai Fang commented on FLINK-25217: --- [~twalthr] hello, I see most of issues ha

[jira] [Comment Edited] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864459#comment-17864459 ] Rui Fan edited comment on FLINK-35624 at 7/10/24 4:00 AM: -- Hi [

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864459#comment-17864459 ] Rui Fan commented on FLINK-35624: - Hi [~zakelly] , I saw FLINK-35778 and FLINK-35784 are

[jira] [Comment Edited] (FLINK-35784) The cp file-merging directory not properly registered in SharedStateRegistry

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864457#comment-17864457 ] Rui Fan edited comment on FLINK-35784 at 7/10/24 3:40 AM: -- http

[jira] [Commented] (FLINK-35784) The cp file-merging directory not properly registered in SharedStateRegistry

2024-07-09 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864457#comment-17864457 ] Rui Fan commented on FLINK-35784: - [https://github.com/apache/flink/actions/runs/9857042

[jira] [Resolved] (FLINK-35738) Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-35738. Resolution: Done > Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state

[jira] [Commented] (FLINK-35738) Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864455#comment-17864455 ] Weijie Guo commented on FLINK-35738: Thanks [~samrat007] for the careful verificatio

[jira] [Comment Edited] (FLINK-35793) BatchSQLTest.testBatchSQL failed in hybrid shuffle mode

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864453#comment-17864453 ] Weijie Guo edited comment on FLINK-35793 at 7/10/24 3:30 AM: -

[jira] [Commented] (FLINK-35793) BatchSQLTest.testBatchSQL failed in hybrid shuffle mode

2024-07-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864453#comment-17864453 ] Weijie Guo commented on FLINK-35793: remove hs type via bbbaa7ac303421cb420b1bfc6beb

Re: [PR] [FLINK-35793][tests] Remove hybrid shuffle types from BatchSQLTest temporarily [flink]

2024-07-09 Thread via GitHub
reswqa merged PR #25060: URL: https://github.com/apache/flink/pull/25060 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-34111][table] Add support for json_quote, json_unquote, address PR feedback #24156 [flink]

2024-07-09 Thread via GitHub
anupamaggarwal commented on code in PR #24967: URL: https://github.com/apache/flink/pull/24967#discussion_r1671531397 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala: ## @@ -604,6 +604,49 @@ class ScalarFunct

Re: [PR] [FLINK-34111][table] Add support for json_quote, json_unquote, address PR feedback #24156 [flink]

2024-07-09 Thread via GitHub
anupamaggarwal commented on PR #24967: URL: https://github.com/apache/flink/pull/24967#issuecomment-2219410170 thanks @snuyanzin for your review! I think both these cases are related to inconsistent behavior (IIUC) of `IS JSON` function which is used in json_unquote implementation for che

Re: [PR] [FLINK-34111][table] Add support for json_quote, json_unquote, address PR feedback #24156 [flink]

2024-07-09 Thread via GitHub
anupamaggarwal commented on code in PR #24967: URL: https://github.com/apache/flink/pull/24967#discussion_r1671499749 ## docs/data/sql_functions.yml: ## @@ -377,6 +377,12 @@ string: - sql: SUBSTR(string, integer1[, integer2]) table: STRING.substr(INTEGER1[, INTEGER2])

[jira] [Created] (FLINK-35800) Update chinese documentation for json_(un)quote function

2024-07-09 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-35800: --- Summary: Update chinese documentation for json_(un)quote function Key: FLINK-35800 URL: https://issues.apache.org/jira/browse/FLINK-35800 Project: Flink

[jira] [Commented] (FLINK-34111) Add JSON_QUOTE and JSON_UNQUOTE function

2024-07-09 Thread Anupam Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864437#comment-17864437 ] Anupam Aggarwal commented on FLINK-34111: - Adding link to Jira for chinese trans

Re: [PR] [hotfix][checkpoint] Rename file-merging options in documents [flink]

2024-07-09 Thread via GitHub
fredia merged PR #25048: URL: https://github.com/apache/flink/pull/25048 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [FLINK-35791][kafka] add database and table info of canal/debezium json format for kafka sink. [flink-cdc]

2024-07-09 Thread via GitHub
lvyanquan commented on code in PR #3461: URL: https://github.com/apache/flink-cdc/pull/3461#discussion_r1671446357 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializ

  1   2   3   >