Re: [PR] [FLINK-37521][runtime] Introduce KeyedCoProcessOperator with async state API [flink]

2025-03-30 Thread via GitHub
Zakelly commented on code in PR #26328: URL: https://github.com/apache/flink/pull/26328#discussion_r2020488907 ## flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/co/AsyncKeyedCoProcessOperatorWithWatermarkDelay.java: ## @@ -0,0 +1,66 @@ +/* + * Lic

Re: [PR] [FLINK-27801][csv] Not to flush stream when call addElement method in CsvBulkWriter [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19826: [FLINK-27801][csv] Not to flush stream when call addElement method in CsvBulkWriter URL: https://github.com/apache/flink/pull/19826 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-27859][hive] Hive dialect should support create table whose name begins with digits [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19858: [FLINK-27859][hive] Hive dialect should support create table whose name begins with digits URL: https://github.com/apache/flink/pull/19858 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

Re: [PR] fix the syntax for multiple insert [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19776: URL: https://github.com/apache/flink/pull/19776#issuecomment-2765257101 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-20060][Connectors / Kinesis] Add a Collector to KinsesisDeserializationSchema [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19417: [FLINK-20060][Connectors / Kinesis] Add a Collector to KinsesisDeserializationSchema URL: https://github.com/apache/flink/pull/19417 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-27438][table-planner] Fix the constructing a map array. Backport 1.14 [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19670: URL: https://github.com/apache/flink/pull/19670#issuecomment-2765256691 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-28034] [StateBackends] Avoid classcastexception in creating a checkpoint with merge windows [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19971: [FLINK-28034] [StateBackends] Avoid classcastexception in creating a checkpoint with merge windows URL: https://github.com/apache/flink/pull/19971 -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-27243][table] Support SHOW PARTITIONS statement for partitioned table [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19553: URL: https://github.com/apache/flink/pull/19553#issuecomment-2765256171 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] feat([FLINK-13414]/scala): Add support to last scala version 2.12.15 and remove code deprecated [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19634: URL: https://github.com/apache/flink/pull/19634#issuecomment-2765256482 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26725][table] Support the new type inference in Scala Table API aggregate functions [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19237: URL: https://github.com/apache/flink/pull/19237#issuecomment-2765254859 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19291: [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting URL: https://github.com/apache/flink/pull/19291 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [FLINK-27043][table] Removing old csv format references [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19349: URL: https://github.com/apache/flink/pull/19349#issuecomment-2765255610 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26397][docs-zh] Chinese Translation - Add documentation for Ki… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19631: [FLINK-26397][docs-zh] Chinese Translation - Add documentation for Ki… URL: https://github.com/apache/flink/pull/19631 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-26773][runtime] Fix ResourceManager leader election reconnect … [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19730: [FLINK-26773][runtime] Fix ResourceManager leader election reconnect … URL: https://github.com/apache/flink/pull/19730 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source URL: https://github.com/apache/flink/pull/19152 -- 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

Re: [PR] [FLINK-24306][table]Group by index throw SqlValidatorException [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20183: [FLINK-24306][table]Group by index throw SqlValidatorException URL: https://github.com/apache/flink/pull/20183 -- 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

Re: [PR] [FLINK-30005][docs]Translate "State Schema Evolution" into Chinese [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #21307: URL: https://github.com/apache/flink/pull/21307#issuecomment-2765258522 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27941][kinesis][test] Migrate tests to junit5 [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20129: [FLINK-27941][kinesis][test] Migrate tests to junit5 URL: https://github.com/apache/flink/pull/20129 -- 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 t

Re: [PR] [FLINK-30036][kubernetes] force delete pod when the k8s node is under NotReady state [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #21329: [FLINK-30036][kubernetes] force delete pod when the k8s node is under NotReady state URL: https://github.com/apache/flink/pull/21329 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [Flink]fixed big decimal converter exception. [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #21293: URL: https://github.com/apache/flink/pull/21293#issuecomment-2765258433 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-25097][table-planner] Fix bug in inner join when the filter co… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #20086: URL: https://github.com/apache/flink/pull/20086#issuecomment-2765258121 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix] [docs] Translate a Chinese comment into English [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19950: URL: https://github.com/apache/flink/pull/19950#issuecomment-2765257792 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-19004][hive] Replace min with first_value in FlinkAggregateExp… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19905: [FLINK-19004][hive] Replace min with first_value in FlinkAggregateExp… URL: https://github.com/apache/flink/pull/19905 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-26764][sql] Support respect/ignore nulls for FIRST_VALUE/LAST_VALUE [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #20130: URL: https://github.com/apache/flink/pull/20130#issuecomment-2765258246 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-29980] Handle partition keys directly in hive bulk format [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #21290: URL: https://github.com/apache/flink/pull/21290#issuecomment-2765258373 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [Flink]fixed big decimal converter exception. [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #21293: [Flink]fixed big decimal converter exception. URL: https://github.com/apache/flink/pull/21293 -- 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 spec

Re: [PR] [FLINK-26764][sql] Support respect/ignore nulls for FIRST_VALUE/LAST_VALUE [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20130: [FLINK-26764][sql] Support respect/ignore nulls for FIRST_VALUE/LAST_VALUE URL: https://github.com/apache/flink/pull/20130 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

Re: [PR] [FLINK-12130][clients] : Allow dynamic loading of kerberos keytab from client end [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #21276: URL: https://github.com/apache/flink/pull/21276#issuecomment-2765258334 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27857][hive] HiveSource supports filter push down for orc format [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20016: [FLINK-27857][hive] HiveSource supports filter push down for orc format URL: https://github.com/apache/flink/pull/20016 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

Re: [PR] [FLINK-25097][table-planner] Fix bug in inner join when the filter co… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20086: [FLINK-25097][table-planner] Fix bug in inner join when the filter co… URL: https://github.com/apache/flink/pull/20086 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-27964][python] Support Cassandra connector in Python DataStream API [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #20120: [FLINK-27964][python] Support Cassandra connector in Python DataStream API URL: https://github.com/apache/flink/pull/20120 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

Re: [PR] [FLINK-27964][python] Support Cassandra connector in Python DataStream API [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #20120: URL: https://github.com/apache/flink/pull/20120#issuecomment-2765258168 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-24666][table-runtime] Add job level table.exec.state-stale.error-handling option and apply to related stateful stream operators [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #20051: URL: https://github.com/apache/flink/pull/20051#issuecomment-2765258072 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix] [docs] Translate a Chinese comment into English [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19950: [hotfix] [docs] Translate a Chinese comment into English URL: https://github.com/apache/flink/pull/19950 -- 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

Re: [PR] Flink 24960 fix race condition test [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19857: Flink 24960 fix race condition test URL: https://github.com/apache/flink/pull/19857 -- 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 comme

Re: [PR] [FLINK-27922][table-planner][realease-1.15] Flink SQL unique key lost when set table.exec.mini-batch.enabled=true [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19901: [FLINK-27922][table-planner][realease-1.15] Flink SQL unique key lost when set table.exec.mini-batch.enabled=true URL: https://github.com/apache/flink/pull/19901 -- This is an automated message from the Apache Git Service. To respond to the mes

Re: [PR] [FLINK-24960][flink-yarn-tests] fix race condition with new stdout line [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19863: URL: https://github.com/apache/flink/pull/19863#issuecomment-2765257557 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26415][hive] Hive dialect supports create/alter partitioned view [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19900: URL: https://github.com/apache/flink/pull/19900#issuecomment-2765257659 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27616][Table SQL/Planner] Modify the spelling mistakes of the … [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19783: URL: https://github.com/apache/flink/pull/19783#issuecomment-2765257200 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] Flink 24960 fix race condition test [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19857: URL: https://github.com/apache/flink/pull/19857#issuecomment-2765257424 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27801][csv] Not to flush stream when call addElement method in CsvBulkWriter [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19826: URL: https://github.com/apache/flink/pull/19826#issuecomment-2765257298 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26764][table-planner] Support RESPECT NULLS for function FIRST_VALUE/LAST_VALUE [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19884: URL: https://github.com/apache/flink/pull/19884#issuecomment-2765257604 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26428][docs-zh] Translate "Stateful Stream Processing" to Chinese [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #18970: [FLINK-26428][docs-zh] Translate "Stateful Stream Processing" to Chinese URL: https://github.com/apache/flink/pull/18970 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-27748][Runtime/Coordination] AdaptiveScheduler support operator fixed parallelism [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19801: URL: https://github.com/apache/flink/pull/19801#issuecomment-2765257249 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix] [docs] Fix use cases for HashMapStateBackend [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19861: [hotfix] [docs] Fix use cases for HashMapStateBackend URL: https://github.com/apache/flink/pull/19861 -- 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

Re: [PR] [hotfix] [docs] Fix use cases for HashMapStateBackend [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19861: URL: https://github.com/apache/flink/pull/19861#issuecomment-2765257511 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19837: URL: https://github.com/apache/flink/pull/19837#issuecomment-2765257338 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27640] Suggest use of maven wrapper (mvnw) [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19782: URL: https://github.com/apache/flink/pull/19782#issuecomment-2765257142 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-24960][yarn-tests] show eventual failure due to race condition [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19855: [FLINK-24960][yarn-tests] show eventual failure due to race condition URL: https://github.com/apache/flink/pull/19855 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-27391][hive] Hive dialect supports create/alter/write/read Hive's bucketed table [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19731: [FLINK-27391][hive] Hive dialect supports create/alter/write/read Hive's bucketed table URL: https://github.com/apache/flink/pull/19731 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

Re: [PR] [FLINK-24960][yarn-tests] show eventual failure due to race condition [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19855: URL: https://github.com/apache/flink/pull/19855#issuecomment-2765257389 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26773][runtime] Fix ResourceManager leader election reconnect … [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19730: URL: https://github.com/apache/flink/pull/19730#issuecomment-2765256938 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [connectors][aws-base] Using entrySet for map iterate [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19722: [connectors][aws-base] Using entrySet for map iterate URL: https://github.com/apache/flink/pull/19722 -- 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

Re: [PR] [hotfix] [docs]: Fix docunment mongodb.md [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19767: URL: https://github.com/apache/flink/pull/19767#issuecomment-2765257061 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27748][Runtime/Coordination] AdaptiveScheduler support operator fixed parallelism [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19801: [FLINK-27748][Runtime/Coordination] AdaptiveScheduler support operator fixed parallelism URL: https://github.com/apache/flink/pull/19801 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [connectors][aws-base] Using entrySet for map iterate [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19722: URL: https://github.com/apache/flink/pull/19722#issuecomment-2765256894 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27616][Table SQL/Planner] Modify the spelling mistakes of the … [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19783: [FLINK-27616][Table SQL/Planner] Modify the spelling mistakes of the … URL: https://github.com/apache/flink/pull/19783 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-27640] Suggest use of maven wrapper (mvnw) [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19782: [FLINK-27640] Suggest use of maven wrapper (mvnw) URL: https://github.com/apache/flink/pull/19782 -- 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

Re: [PR] [hotfix] [docs]: Fix docunment mongodb.md [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19767: [hotfix] [docs]: Fix docunment mongodb.md URL: https://github.com/apache/flink/pull/19767 -- 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

Re: [PR] [FLINK-27438][table-planner] Fix the constructing a map array. Backport 1.14 [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19670: [FLINK-27438][table-planner] Fix the constructing a map array. Backport 1.14 URL: https://github.com/apache/flink/pull/19670 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] feat([FLINK-13414]/scala): Add support to last scala version 2.12.15 and remove code deprecated [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19634: feat([FLINK-13414]/scala): Add support to last scala version 2.12.15 and remove code deprecated URL: https://github.com/apache/flink/pull/19634 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-27401] CEP supports accumulator in IterativeCondition [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19674: URL: https://github.com/apache/flink/pull/19674#issuecomment-2765256735 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27391][hive] Hive dialect supports create/alter/write/read Hive's bucketed table [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19731: URL: https://github.com/apache/flink/pull/19731#issuecomment-2765256981 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex Integer == check to equals check [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19654: [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex Integer == check to equals check URL: https://github.com/apache/flink/pull/19654 -- This is an automated message from the Apache Git Service. To respond to th

Re: [PR] [FLINK-27438][table-planner] Fix the constructing a map array [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19648: URL: https://github.com/apache/flink/pull/19648#issuecomment-2765256569 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27465] Handle conversion of negative long to timestamp in Avro… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19704: [FLINK-27465] Handle conversion of negative long to timestamp in Avro… URL: https://github.com/apache/flink/pull/19704 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex Integer == check to equals check [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19654: URL: https://github.com/apache/flink/pull/19654#issuecomment-2765256610 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-25567][table] Add support casting of multisets to multisets [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19637: [FLINK-25567][table] Add support casting of multisets to multisets URL: https://github.com/apache/flink/pull/19637 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [FLINK-25567][table] Add support casting of multisets to multisets [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19637: URL: https://github.com/apache/flink/pull/19637#issuecomment-2765256515 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix][table] Remove implicit set of legacy cast to DISABLED [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19622: URL: https://github.com/apache/flink/pull/19622#issuecomment-2765256395 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27242][table] Support RENAME PARTITION statement for partitioned table [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19558: URL: https://github.com/apache/flink/pull/19558#issuecomment-2765256217 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27258] [Doc] fix chinese deployment doc malformed text [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19484: [FLINK-27258] [Doc] fix chinese deployment doc malformed text URL: https://github.com/apache/flink/pull/19484 -- 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 t

Re: [PR] [FLINK-25928][table-planner] Throw validation error early for CAST [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19426: [FLINK-25928][table-planner] Throw validation error early for CAST URL: https://github.com/apache/flink/pull/19426 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [FLINK 26389][tests] update deprecated operators in e2e tests [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19414: [FLINK 26389][tests] update deprecated operators in e2e tests URL: https://github.com/apache/flink/pull/19414 -- 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

Re: [PR] [hotfix][yarn] Fixed typo for the description of yarn.security.kerber… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19367: URL: https://github.com/apache/flink/pull/19367#issuecomment-2765255654 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-24577][table-planner] Implement Cast from BINARY to RAW [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19409: URL: https://github.com/apache/flink/pull/19409#issuecomment-2765255694 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix][yarn] Fixed typo for the description of yarn.security.kerber… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19367: [hotfix][yarn] Fixed typo for the description of yarn.security.kerber… URL: https://github.com/apache/flink/pull/19367 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19310: [FLINK-26967][state/heap] Fix race condition in CopyOnWriteStateMap URL: https://github.com/apache/flink/pull/19310 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-21783][state/heap] Allow snapshotting customization [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19306: URL: https://github.com/apache/flink/pull/19306#issuecomment-2765255235 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-21783][state/heap] Allow snapshotting customization [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19306: [FLINK-21783][state/heap] Allow snapshotting customization URL: https://github.com/apache/flink/pull/19306 -- 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 g

Re: [PR] [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19305: [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes URL: https://github.com/apache/flink/pull/19305 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-21649][state/heap] Allow extension of CopyOnWriteState classes [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19305: URL: https://github.com/apache/flink/pull/19305#issuecomment-2765255194 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [hotfix][docs]Modify the Chinese comments to English in python datastream_tutorial.md [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19245: [hotfix][docs]Modify the Chinese comments to English in python datastream_tutorial.md URL: https://github.com/apache/flink/pull/19245 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-27242][table] Support RENAME PARTITION statement for partitioned table [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19558: [FLINK-27242][table] Support RENAME PARTITION statement for partitioned table URL: https://github.com/apache/flink/pull/19558 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-26725][table] Support the new type inference in Scala Table API aggregate functions [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19237: [FLINK-26725][table] Support the new type inference in Scala Table API aggregate functions URL: https://github.com/apache/flink/pull/19237 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

Re: [PR] [FLINK-26678][shell] replace the repeated log4j-console.properties wi… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19112: [FLINK-26678][shell] replace the repeated log4j-console.properties wi… URL: https://github.com/apache/flink/pull/19112 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-26678][shell] replace the repeated log4j-console.properties wi… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19112: URL: https://github.com/apache/flink/pull/19112#issuecomment-2765254616 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27239][table-planner] rewrite PreValidateReWriter from scala to java [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19465: [FLINK-27239][table-planner] rewrite PreValidateReWriter from scala to java URL: https://github.com/apache/flink/pull/19465 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] Update stateful-stream-processing.md [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19452: Update stateful-stream-processing.md URL: https://github.com/apache/flink/pull/19452 -- 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 comm

Re: [PR] Update stateful-stream-processing.md [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19452: URL: https://github.com/apache/flink/pull/19452#issuecomment-2765255957 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26581]Job supports the HADOOP_USER_NAME [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19037: URL: https://github.com/apache/flink/pull/19037#issuecomment-2765254526 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26498][table-runtime] The window result may not have been emit… [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19036: [FLINK-26498][table-runtime] The window result may not have been emit… URL: https://github.com/apache/flink/pull/19036 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] [FLINK-27201][table] Remove CollectTableSink [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19436: URL: https://github.com/apache/flink/pull/19436#issuecomment-2765255920 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state. [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-2765254420 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-25928][table-planner] Throw validation error early for CAST [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19426: URL: https://github.com/apache/flink/pull/19426#issuecomment-2765255881 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK 26389][tests] update deprecated operators in e2e tests [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19414: URL: https://github.com/apache/flink/pull/19414#issuecomment-2765255738 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26428][docs-zh] Significant differences of Fault Tolerance between English and Chinese version [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #18985: URL: https://github.com/apache/flink/pull/18985#issuecomment-2765254231 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-27043][table] Removing old csv format references [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19349: [FLINK-27043][table] Removing old csv format references URL: https://github.com/apache/flink/pull/19349 -- 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 t

Re: [PR] [FLINK-26965][state] Allow reuse of PeriodicMaterializationManager [flink]

2025-03-30 Thread via GitHub
github-actions[bot] commented on PR #19312: URL: https://github.com/apache/flink/pull/19312#issuecomment-2765255534 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

Re: [PR] [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion [flink]

2025-03-30 Thread via GitHub
github-actions[bot] closed pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion URL: https://github.com/apache/flink/pull/19309 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

  1   2   >