issues@flink.apache.org, 2025-05

You are viewing a plain text version of this content. The canonical link for it is here.

- [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] - posted by "tweise (via GitHub)" <gi...@apache.org> on 2025/05/01 01:24:38 UTC, 5 replies.
- [jira] [Updated] (FLINK-37662) Allow configuration of init/side car containers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/01 01:25:00 UTC, 0 replies.
- Re: [PR] Add Flink CDC v3.4.0 [flink-web] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/05/01 02:36:28 UTC, 3 replies.
- Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/01 06:25:36 UTC, 0 replies.
- Re: [PR] [FLINK-30571] Estimate scalability coefficient from past scaling history using linear regression [flink-kubernetes-operator] - posted by "pchoudhury22 (via GitHub)" <gi...@apache.org> on 2025/05/01 06:33:12 UTC, 9 replies.
- Re: [PR] [FLINK-37747][runtime] Use old subtask count for restored committable objects [flink] - posted by "bjlovegithub (via GitHub)" <gi...@apache.org> on 2025/05/01 07:37:19 UTC, 6 replies.
- Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/01 15:23:26 UTC, 1 replies.
- Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/01 15:36:12 UTC, 19 replies.
- Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/01 15:53:58 UTC, 3 replies.
- [jira] [Created] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/05/01 18:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/05/01 18:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/02 06:25:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-37730) Collect job exceptions as kubernetes events - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2025/05/02 06:41:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-37730) Collect job exceptions as kubernetes events - posted by "Santwana Verma (Jira)" <ji...@apache.org> on 2025/05/02 06:46:00 UTC, 1 replies.
- [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] - posted by "vsantwana (via GitHub)" <gi...@apache.org> on 2025/05/02 07:33:03 UTC, 4 replies.
- [jira] [Updated] (FLINK-37730) Collect job exceptions as kubernetes events - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/02 07:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37730) Collect job exceptions as kubernetes events - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2025/05/02 08:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-33139] Add Prometheus Sink Table API [flink-connector-prometheus] - posted by "nicusX (via GitHub)" <gi...@apache.org> on 2025/05/02 09:45:37 UTC, 10 replies.
- [PR] [hotfix][docs] Fix some issue in DataStream API (V1) / Data Sinks [flink] - posted by "sasakitoa (via GitHub)" <gi...@apache.org> on 2025/05/02 15:18:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/02 16:07:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/02 16:09:00 UTC, 0 replies.
- Re: [PR] [hotfix] Fix typo DataStream [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:12 UTC, 1 replies.
- Re: [PR] [FLIP-278][connector] Add hybrid source connector for table & sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:14 UTC, 1 replies.
- Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:17 UTC, 1 replies.
- Re: [PR] Update content.zh/docs/dev/table/overview.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:31 UTC, 1 replies.
- Re: [PR] [FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:33 UTC, 1 replies.
- Re: [PR] [FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:35 UTC, 1 replies.
- Re: [PR] [FLINK-33856][checkpointing] Add metrics for interaction performance with external storage system in the process of checkpoint making [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:38 UTC, 1 replies.
- Re: [PR] [FLINK-33784][table] Support Configuring CatalogStoreFactory via StreamExecutionEnvironment [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:40 UTC, 1 replies.
- Re: [PR] [hotfix] Static import removed [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:42 UTC, 1 replies.
- Re: [PR] [FLINK-33950][table] Update max aggregate functions to new type system [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:43 UTC, 1 replies.
- Re: [PR] [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:46 UTC, 1 replies.
- Re: [PR] [FLINK-33882] UT/IT for checkpointing statistics [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:48 UTC, 1 replies.
- Re: [PR] [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:49 UTC, 1 replies.
- Re: [PR] [FLINK-33951][table] Use aggCallNeedRetractions instead of needRetrac… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:51 UTC, 1 replies.
- Re: [PR] [FLINK-34004] Harden TestingCheckpointIDCounter [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:53 UTC, 1 replies.
- Re: [PR] [FLINK-33996][table-planner]: Avoid merging projects if leads to redundant computation [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:55 UTC, 1 replies.
- Re: [PR] [hotfix][docs] fix typo in ddl data type [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:57 UTC, 1 replies.
- Re: [PR] fix: missing serialVersionUID of serializable classes [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:25:59 UTC, 1 replies.
- Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:26:01 UTC, 2 replies.
- Re: [PR] [FLINK-33402] 2 CONTINUED [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/04 06:26:04 UTC, 1 replies.
- Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc] - posted by "phamvinh1712 (via GitHub)" <gi...@apache.org> on 2025/05/04 19:17:28 UTC, 5 replies.
- [jira] [Commented] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "David (Jira)" <ji...@apache.org> on 2025/05/04 23:16:00 UTC, 6 replies.
- Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:38 UTC, 1 replies.
- Re: [PR] [FLINK-33373][build] Capture build scans on ge.apache.org to benefit from deep build insights [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:40 UTC, 1 replies.
- Re: [PR] [FLINK-33428] Flink SQL CEP support 'followed','notNext' and 'notFollowedBy' semantics [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:42 UTC, 1 replies.
- Re: [PR] [FLINK-32763][streaming-java] Uncaught exceptions cause retry does not … [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:44 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] modify the Chinese translation content [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:46 UTC, 1 replies.
- Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:48 UTC, 1 replies.
- Re: [PR] [FLINK-33212][core] Introduce job status changed listener for lineage [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:51 UTC, 1 replies.
- Re: [PR] [FLINK-33524][ API / DataStream] fix IntervalJoinOperator 's judgment on isLate function bug [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:54 UTC, 1 replies.
- Re: [PR] [FLINK-33508] [HistoryServer] Support for wildcard paths in Flink History Server for multi cluster environment [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:55 UTC, 1 replies.
- Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:57 UTC, 1 replies.
- Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:25:59 UTC, 2 replies.
- Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:01 UTC, 1 replies.
- Re: [PR] [FLINK-33053][runtime] Refactoring of workaround to fix thread leakage on the ZooKeeper server side. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:05 UTC, 1 replies.
- Re: [PR] [FLINK-33507][json]Support zero-timestamp.behavior option for JSON fo… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:07 UTC, 1 replies.
- Re: [PR] [hotfix] Fix wrong flink-conf.yaml file path [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:08 UTC, 1 replies.
- Re: [PR] [FLINK-33472][Client] Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:10 UTC, 1 replies.
- Re: [PR] [FLINK-33628][runtime] Upgrades default ZooKeeper version from 3.7.1 to 3.8.3 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:13 UTC, 1 replies.
- Re: [PR] [DOC]Update watermark column type [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:15 UTC, 1 replies.
- Re: [PR] [FLINK-33674][table-runtime][table-planner] In the wmassigners module… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:17 UTC, 1 replies.
- Re: [PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:19 UTC, 1 replies.
- Re: [PR] [FLINK-33680][docs]Failed to build document with docker [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:21 UTC, 1 replies.
- Re: [PR] [FLINK-33700] CustomSSLEngineProvider supports SHA-256 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:23 UTC, 1 replies.
- Re: [PR] Draft FLINK-32898 [CI] [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:25 UTC, 1 replies.
- Re: [PR] Bump @adobe/css-tools from 4.0.1 to 4.3.2 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:28 UTC, 2 replies.
- Re: [PR] Clarity And Impact: Revamped Flink Feature Descriptions [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:30 UTC, 1 replies.
- Re: [PR] [FLINK-33684][datastream] Use IncrementalDelayRetryStrategy in CollectResultFetcher [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:32 UTC, 1 replies.
- Re: [PR] [hotfix][sql-client] remove duplicated code in CliUtils [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:34 UTC, 1 replies.
- Re: [PR] [DRAFT] Experiment of bulk sync task states [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:36 UTC, 1 replies.
- Re: [PR] [FLINK-33751] use modules correctly when deserializing json plan [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:38 UTC, 1 replies.
- Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:41 UTC, 3 replies.
- Re: [PR] [FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:42 UTC, 1 replies.
- Re: [PR] [FLINK-33728][k8s] do not rewatch when KubernetesResourceManagerDrive… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:45 UTC, 1 replies.
- Re: [PR] [DRAFT][FLINK-32667] Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:47 UTC, 1 replies.
- Re: [PR] [FLINK-33797] Change log level for Application CANCELED/FAILED logs to WARN [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:48 UTC, 1 replies.
- Re: [PR] [hotfix] [tests] Per-class the lifecycle of mini-cluster in `ClientHeartbeatTest`. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:50 UTC, 1 replies.
- Re: [PR] [FLINK-33685][client] Refactor StandaloneClusterId to distinguish different remote clusters [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:52 UTC, 1 replies.
- Re: [PR] [FLINK-33687][client] Reuse RestClusterClient in StandaloneClusterDescriptor [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:54 UTC, 1 replies.
- Re: [PR] [FLINK-33809] HiveCatalog load hivemetastore-site.xml [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:57 UTC, 1 replies.
- Re: [PR] [FLINK-33686][client] Reuse ClusterDescriptor in AbstractSessionClusterExecutor [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:26:59 UTC, 1 replies.
- Re: [PR] [FLINK-32756][ha] Implement reusable ClientHAServices and reuse it when creating RestClusterClient [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:01 UTC, 1 replies.
- Re: [PR] [FLINK-33688][client] Reuse connections in RestClient to save connection establish time [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:03 UTC, 1 replies.
- Re: [PR] [FLINK-27455][tests] Migrate SnapshotMigrationTestBase to JUnit5 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:06 UTC, 1 replies.
- Re: [PR] [FLINK-25054][table-planner] Extend the exception message for SHA2 function [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:08 UTC, 1 replies.
- Re: [PR] [FLINK-34110] Bump janino from 3.1.10 to 3.1.11 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:10 UTC, 1 replies.
- Re: [PR] [FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:13 UTC, 1 replies.
- Re: [PR] Some refactoring in StreamCommonSubGraphBasedOptimizer. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:15 UTC, 1 replies.
- Re: [PR] [FLINK-34109][connectors] FileSystem sink connector restore job from historical checkpoint bugfix [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:17 UTC, 1 replies.
- Re: [PR] [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate … [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:19 UTC, 1 replies.
- Re: [PR] [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:22 UTC, 1 replies.
- Re: [PR] Update operators link in First Steps documentation [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:23 UTC, 1 replies.
- Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:25 UTC, 1 replies.
- Re: [PR] [DRAFT] new implementation of FLIP-403 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:28 UTC, 1 replies.
- Re: [PR] [WIP] [FLINK-21573][table-planner] Support expression reuse in codegen [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:30 UTC, 1 replies.
- Re: [PR] [hotfix] Fix spelling of RowTimeMiniBatchAssignerOperator class [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:32 UTC, 1 replies.
- Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:35 UTC, 3 replies.
- Re: [PR] [FLINK-33396][table-planner] Fix table alias not be cleared in subquery [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:37 UTC, 1 replies.
- Re: [PR] [FLINK-33549][table-runtime] Enable BatchMultipleInputStreamOperatorFactory to support YieldingOperatorFactory interface [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:38 UTC, 1 replies.
- Re: [PR] [FLINK-34366][table] Add support to group rows by column ordinals [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:41 UTC, 1 replies.
- Re: [PR] [FLINK-34372][table-api] Support DESCRIBE CATALOG [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:42 UTC, 1 replies.
- Re: [PR] [FLINK-34060][table] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:45 UTC, 1 replies.
- Re: [PR] [FLINK-34421] Skip post-compile checks if 'fast' profile is active [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:47 UTC, 1 replies.
- Re: [PR] [FLINK-34431] Move static BlobWriter methods to separate util [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:49 UTC, 1 replies.
- Re: [PR] Chore: Change metric types, "numSplitsProcessed" in metrics.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:51 UTC, 1 replies.
- Re: [PR] [FLINK-34427][runtime] Adds state check to requirementsCheck logic [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:53 UTC, 1 replies.
- Re: [PR] [WIP] Extend error labeling to avoid restart loops. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:55 UTC, 1 replies.
- Re: [PR] [FLINK-34447][test] Hardens ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:57 UTC, 1 replies.
- Re: [PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:27:59 UTC, 1 replies.
- Re: [PR] [FLINK-34463] Open catalog in CatalogManager should use proper context classloader [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:01 UTC, 1 replies.
- Re: [PR] [FLINK-34264[plugins] add pushgateway http basic auth [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:04 UTC, 1 replies.
- Re: [PR] [FLINK-34147][table-planner] Enhance the java doc of TimestampData to distinguish the different usage of Instant and LocalDateTime [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:06 UTC, 1 replies.
- Re: [PR] Bump ip from 2.0.0 to 2.0.1 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:08 UTC, 2 replies.
- Re: [PR] [FLINK-34462][table-planner] Improve the exception for negative parameters in window TVF [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:10 UTC, 1 replies.
- Re: [PR] [FLINK-34480] support user jar class overwrite flink inner when meet the same. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:12 UTC, 1 replies.
- Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:14 UTC, 1 replies.
- Re: [PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:16 UTC, 1 replies.
- Re: [PR] [FLINK-34497][REST] Avoid using system classloader in SerializedThrowableDeserializer [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:20 UTC, 1 replies.
- Re: [PR] [FLINK-34522] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:22 UTC, 1 replies.
- Re: [PR] [FLINK-34535] Support JobPlanInfo for the explain result [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:24 UTC, 1 replies.
- Re: [PR] [FLINK-34542][docs] improved example quickstart build.gradle [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:27 UTC, 1 replies.
- Re: [PR] [FLINK-34508][ci] Migrates S3 ITCases to Minio tests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:29 UTC, 1 replies.
- Re: [PR] [FLINK-34565] Enhance flink kubernetes configMap to accommodate additional configuration files [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/05 06:28:30 UTC, 1 replies.
- Re: [PR] [FLINK-37625][python] Don't skip type validation for Rows made with positional arguments [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/05 08:25:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-37625) PyFlink Table API skips validation for Rows created with positional arguments - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/05 08:26:00 UTC, 0 replies.
- Re: [PR] [hotfix][python] Enable parallel builds for python API docs [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/05 08:26:41 UTC, 0 replies.
- Re: [PR] [hotfix][python] Add pandas type annotations for TableEnvironment.from_pandas and Table.to_pandas [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/05 08:28:15 UTC, 0 replies.
- Re: [PR] [FLINK-37523][CI] Fix Python test/e2e tests missing libpython/python headers [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/05 08:29:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-37523) e2e: Test stream python udf sql job fails - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/05 08:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/05 09:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19 [flink-connector-rabbitmq] - posted by "pfeigl (via GitHub)" <gi...@apache.org> on 2025/05/05 13:28:54 UTC, 3 replies.
- [PR] [FLINK-37632][table] Add changelog support to PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/05/05 17:17:47 UTC, 3 replies.
- [jira] [Updated] (FLINK-37632) Add ChangelogFunction interface - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/05 17:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-37548] Add Model DDL methods in TABLE API [flink] - posted by "yanand0909 (via GitHub)" <gi...@apache.org> on 2025/05/05 19:27:14 UTC, 2 replies.
- Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink] - posted by "mlegore (via GitHub)" <gi...@apache.org> on 2025/05/05 21:25:37 UTC, 0 replies.
- [PR] [FLINK-35019] support convert show create model sql to operation [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/05 23:43:35 UTC, 10 replies.
- [jira] [Updated] (FLINK-35019) Support show create model syntax - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/05 23:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37754) Optimizing OLAP query speed in session cluster. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37754) Optimizing OLAP query speed in session cluster. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37755) Make retryMillis in CollectResultFetcher configurable. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37756) Add a new byte array method for submitting jobGraph. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37757) Add StandaloneJobGraphStore and EmbeddedJobResultStore to skip some IO. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37758) Support skip some checkpoint operators in JobManager. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37759) Support avoid repeatedly downloading user jars in session mode. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/06 01:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36536) Bump commons-text from 1.10.0 to 1.12.0 - posted by "Vivek Dhiman (Jira)" <ji...@apache.org> on 2025/05/06 04:34:00 UTC, 0 replies.
- Re: [PR] [WIP][FLINK-34442][table] Support optimizations for pre-partitioned data sources [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:37 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Flink comment typo in pyflink datastream [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:38 UTC, 1 replies.
- Re: [PR] [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:41 UTC, 1 replies.
- Re: [PR] [FLINK-34597][table] Migrate SimplifyFilterConditionRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:43 UTC, 1 replies.
- Re: [PR] [FLINK-34603][table] Migrate BatchPhysicalBoundedStreamScanRule to java. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:45 UTC, 1 replies.
- Re: [PR] [FLINK-34609][table] Migrate BatchPhysicalScriptTransformRule to java. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:48 UTC, 1 replies.
- Re: [PR] [FLINK-34620][formats][protobuf] add support of recursive schemas to PbToRowTypeUtil [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:50 UTC, 1 replies.
- Re: [PR] [DRAFT][FLINK-34637][table] Migrate JoinConditionEqualityTransferRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:52 UTC, 1 replies.
- Re: [PR] [doc]Fix wrong function name [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:54 UTC, 1 replies.
- Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:57 UTC, 1 replies.
- Re: [PR] [FLINK-34618][table] Migrate SplitPythonConditionFromJoinRule to java. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:25:59 UTC, 1 replies.
- Re: [PR] [FLINK-34670][checkpoint] Use FixedThreadPool to create asyncOperationsThreadPool… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:01 UTC, 1 replies.
- Re: [PR] [FLINK-34676][table] Migrate ConvertToNotInOrInRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:04 UTC, 1 replies.
- Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.6 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:06 UTC, 2 replies.
- Re: [PR] [FLINK-34703][ORC Format][Scaladocs] Update filesystem.md to increment VectorizedRowBatch's row property in the Scala example [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:08 UTC, 1 replies.
- Re: [PR] [WIP][FLINK-34723][parquet] Restrict parquet map keys to be not null [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:11 UTC, 1 replies.
- Re: [PR] [FLINK-34727][REST]fix rest request writer future not return [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:12 UTC, 1 replies.
- Re: [PR] [FLINK-34733] [filesystem] Fix oss filesystem ClassNotFoundException when configure 'fs.oss.credentials.provider'. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:15 UTC, 7 replies.
- Re: [PR] [FLINK-34894][table] Migrate JoinDependentConditionDerivationRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:24 UTC, 1 replies.
- Re: [PR] [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:26 UTC, 1 replies.
- Re: [PR] [FLINK-34924][table] Support partition pushdown for join queries [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:29 UTC, 1 replies.
- Re: [PR] [FLINK-34529][table-planner] Introduce FlinkProjectWindowTransposeRule. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:30 UTC, 1 replies.
- Re: [PR] [FLINK-34939][test] Hardens TestingLeaderElection [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:32 UTC, 1 replies.
- Re: [PR] [FLINK-34513] GroupAggregateRestoreTest.testRestore fails [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:35 UTC, 1 replies.
- Re: [PR] [FLINK-33990][runtime] Use default classloader in TaskManager when there are no user jars for job [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:37 UTC, 1 replies.
- Re: [PR] [FLINK-31497][table] Drop the deprecated CatalogViewImpl [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:39 UTC, 1 replies.
- Re: [PR] Bump express from 4.18.2 to 4.19.2 in /flink-runtime-web/web-dashboard [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:42 UTC, 2 replies.
- Re: [PR] [FLINK-34971]Add the function of History Server cleaning job archives… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:44 UTC, 1 replies.
- Re: [PR] [FLINK-34338][table] Add explanatory exception for wrong named params [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:47 UTC, 1 replies.
- Re: [PR] [FLINK-34937][ci] Updates GitHub actions to use the properly pinned and most-recent version [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:49 UTC, 1 replies.
- Re: [PR] Update example with correct values [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:51 UTC, 1 replies.
- Re: [PR] [FLINK-34405][tests] Fix unstable test RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort1 and testCancelOuterJoinTaskWhileSort2 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:53 UTC, 1 replies.
- Re: [PR] [FLINK-35061][table] Migrate TemporalJoinUtil to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:55 UTC, 1 replies.
- Re: [PR] [FLINK-35037][table-planner]Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:26:57 UTC, 1 replies.
- Re: [PR] [FLINK-35091][Metrics][Minor] Fix incorrect warning msg in JM log when use metric reporter [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-30687][table] Support pushdown for aggregate filters [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:02 UTC, 1 replies.
- Re: [PR] [FLINK-35103] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:04 UTC, 1 replies.
- Re: [PR] [FLINK-35107] Rename flink-connector-datagen-test module folder to flink-connector-datagen-tests [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:06 UTC, 1 replies.
- Re: [PR] [FLINK-35039][rest] Use PUT method supported by YARN web proxy instead of POST [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:09 UTC, 1 replies.
- Re: [PR] [FLINK-35657] Show correct float metric value on flink UI. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:12 UTC, 1 replies.
- Re: [PR] Update windows.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:13 UTC, 1 replies.
- Re: [PR] Update parallel.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:16 UTC, 1 replies.
- Re: [PR] Fix type annotation in `MapState.put_all()` [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:18 UTC, 1 replies.
- Re: [PR] [FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:20 UTC, 1 replies.
- Re: [PR] [FLINK-33210] Cleanup the lineage interface comments [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:22 UTC, 1 replies.
- Re: [PR] [FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:25 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Clarifying sentence on streaming queries [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:27 UTC, 1 replies.
- Re: [PR] [FLINK-20400][e2e] Migrate test_streaming_sql.sh [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:29 UTC, 1 replies.
- Re: [PR] [FLINK-35361]Delete Flinkhistory files that failed to write to the lo… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:31 UTC, 1 replies.
- Re: [PR] [FLINK-35289][core] Batch mode onTimer should support processing ts [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:34 UTC, 1 replies.
- Re: [PR] [FLINK-35406] Use inner serializer when casting RAW type to BINARY or… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:36 UTC, 1 replies.
- Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:38 UTC, 1 replies.
- Re: [PR] [FLINK-35326][hive] add lineage integration for Hive connector [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:40 UTC, 1 replies.
- Re: [PR] [FLINK-35440][Table SQL / JDBC] feat(flink-connection): support isValid for tableau [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:42 UTC, 1 replies.
- Re: [PR] [FLINK-35427][json] Support fail-on-unknown-field config in json format [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:45 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Fix typo in alter.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:46 UTC, 1 replies.
- Re: [PR] [FLINK-34559] Limit Global & Local Aggregation buffers [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:49 UTC, 1 replies.
- Re: [PR] [FLINK-35556] Fix constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:51 UTC, 1 replies.
- Re: [PR] [FLINK-32562][connectors/filesystem] Handle concatenable compressed streams correctly in FileCompactor [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:54 UTC, 1 replies.
- Re: [PR] [FLINK-XXX][planner] Support custom shuffle for lookup join [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:56 UTC, 1 replies.
- Re: [PR] Update flink-operations-playground.md for a typo [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:27:59 UTC, 1 replies.
- Re: [PR] [FLINK-35598][sql-parser] Fix error comparison type ExtendedSqlRowTypeNameSpec#equalsDeep [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:00 UTC, 1 replies.
- Re: [PR] Documentation typo [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:03 UTC, 1 replies.
- Re: [PR] [FLINK-35642] parsing the configuration file,Special handle s3 secret… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:05 UTC, 1 replies.
- Re: [PR] [FLINK-35653][docs] add missing "env.execute" explanation in fraud detection example [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:08 UTC, 1 replies.
- Re: [PR] [FLINK-26940][table] Add the built-in function SUBSTRING_INDEX [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:10 UTC, 1 replies.
- Re: [PR] [hotfix][Table SQL / API] fix create table from values decimal issue [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:14 UTC, 1 replies.
- Re: [PR] [FLINK-26943][table] Add the built-in function DATE_ADD [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:16 UTC, 1 replies.
- Re: [PR] [FLINK-20539][table-planner] Fix type mismatch when casting ROW [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:19 UTC, 1 replies.
- Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:22 UTC, 1 replies.
- Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.18 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:23 UTC, 1 replies.
- Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.19 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:26 UTC, 5 replies.
- Re: [PR] [FLINK-36992][table] Migrate DecomposeGroupingSetsRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:40 UTC, 0 replies.
- Re: [PR] [FLINK-37009][table] Migrate PruneAggregateCallRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:43 UTC, 0 replies.
- Re: [PR] [FLINK-37246] add tokens acquired by current user for token refresh [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/06 06:28:47 UTC, 0 replies.
- [jira] [Created] (FLINK-37760) Bump parquet version to 1.15.2 - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2025/05/06 07:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37760) Bump parquet version to 1.15.2 - posted by "Márton Balassi (Jira)" <ji...@apache.org> on 2025/05/06 07:10:00 UTC, 1 replies.
- Re: [PR] Fixes janino bug returning incorrect results [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/06 07:23:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-37564) Trigger warning event when job fails to provide visibility - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/05/06 07:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-36166][table-planner] Make the test 'testJoinDisorderChangeLog' work again [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/05/06 09:16:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-36166) testJoinDisorderChangeLog failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/05/06 09:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37702) The python cron hadoop pipeline failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 11:31:00 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-37702) The python cron hadoop pipeline failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:22:00 UTC, 10 replies.
- [jira] [Closed] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:40:00 UTC, 6 replies.
- [jira] [Reopened] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:43:00 UTC, 0 replies.
- [jira] (FLINK-37703) The testRecoverFromIntermWithoutAdditionalState test failed of azure cron connector pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/06 12:49:00 UTC, 5 replies.
- [PR] [FLINK-37702][ci] Ensure Python setup/headers for Python tests [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/06 12:50:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-37702) The python cron hadoop pipeline failed of azure ci - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/06 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37762) No Infomation - posted by "911432 (Jira)" <ji...@apache.org> on 2025/05/06 13:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37762) No Infomation in Overview at Flink CDC 3.4 - posted by "911432 (Jira)" <ji...@apache.org> on 2025/05/06 13:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37763) Support multiple tables with set semantics - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/05/06 13:35:00 UTC, 0 replies.
- Re: [PR] [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords calls are made on idle source causing high CPU utilisation and throttling. [FLINK-36939][Connectors/Kinesis] Fix issue where excessive BlockingQueue.poll() in FanOutKinesisShardSplitReader and GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing high CPU utilisation [flink-connector-aws] - posted by "saholman (via GitHub)" <gi...@apache.org> on 2025/05/06 15:15:59 UTC, 3 replies.
- [jira] [Closed] (FLINK-37662) Allow configuration of init/side car containers - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2025/05/06 15:31:00 UTC, 0 replies.
- [PR] [FLINK-37730][Job Manager] Expose JM exception as K8s exceptions [flink-kubernetes-operator] - posted by "vsantwana (via GitHub)" <gi...@apache.org> on 2025/05/06 17:44:16 UTC, 46 replies.
- [jira] [Created] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils - posted by "Purshotam Shah (Jira)" <ji...@apache.org> on 2025/05/06 17:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37764) Add support for configurable custom TrustManagerFactory in SSLUtils - posted by "Purshotam Shah (Jira)" <ji...@apache.org> on 2025/05/06 17:55:00 UTC, 2 replies.
- [PR] [FLINK-xxx][1/N] introduce MODEL keyword for model as argument in fun… [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/06 18:29:56 UTC, 0 replies.
- Re: [PR] [FLINK-xxx][1/N] introduce MODEL keyword for model as argument [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/05/06 18:36:15 UTC, 0 replies.
- [jira] [Commented] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator - posted by "Zach (Jira)" <ji...@apache.org> on 2025/05/06 22:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-36932][metrics] Added resource-level metrics for different states/statuses [flink-kubernetes-operator] - posted by "blaskovicz (via GitHub)" <gi...@apache.org> on 2025/05/06 23:23:54 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37702) The python cron hadoop pipeline failed of azure ci - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/05/07 03:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37702) The python cron hadoop pipeline failed of azure ci - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/05/07 03:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-33721][core] Extend BashJavaUtils to support reading and writing standard yaml file. [flink] - posted by "melin (via GitHub)" <gi...@apache.org> on 2025/05/07 05:19:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector - posted by "Nagesh Honnalli (Jira)" <ji...@apache.org> on 2025/05/07 05:30:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/05/07 05:56:00 UTC, 2 replies.
- Re: [PR] [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow for 1.20 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:32 UTC, 4 replies.
- Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:37 UTC, 1 replies.
- Re: [PR] [hotfix][doc] missing "STATISTICS" sql reserved keyword in zh doc [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:42 UTC, 1 replies.
- Re: [PR] [BP-1.19] [FLINK-35657][runtime-web] use parseFloat for metric value [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:42 UTC, 1 replies.
- Re: [PR] [BP-1.20] [FLINK-35657][runtime-web] use parseFloat for metric value [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:43 UTC, 1 replies.
- Re: [PR] [FLINK-12450] Add leftshift, rightshift functions support in Table API and SQL [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:44 UTC, 1 replies.
- Re: [PR] [FLINK-35797] DRAFT of work for FLIP-456. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:49 UTC, 1 replies.
- Re: [PR] [FLINK-26232][tests][JUnit5 migration] Module:flink-avro [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:25:56 UTC, 1 replies.
- Re: [PR] [FLINK-35560][Table SQL/Gateway] Support custom query operation validator for sql gateway [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:26:04 UTC, 1 replies.
- Re: [PR] Update SimpleStringSchema.java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:26:18 UTC, 1 replies.
- Re: [PR] [FLINK-35864][table] Add CONV function [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:26:19 UTC, 1 replies.
- Re: [PR] [FLINK-35897][Checkpoint] Cleanup completed resource when checkpoint is canceled [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:26:33 UTC, 1 replies.
- Re: [PR] [FLINK-35902][ui] WebUI Metrics RangeError on huge parallelism [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:26:52 UTC, 1 replies.
- Re: [PR] [Fix][javadocs] Fix typo in DataStreamSource [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:13 UTC, 1 replies.
- Re: [PR] [FLINK-35628][docs] Provide a Chinese translation of datagen.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:13 UTC, 1 replies.
- Re: [PR] [FLINK-35925] remove hive connector from main repo [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:31 UTC, 1 replies.
- Re: [PR] [FLINK-36008][Documentation] Script and guidance to preview connector docs contributions [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:33 UTC, 1 replies.
- Re: [PR] [hotfix] Fix npm issue in document Build [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:33 UTC, 1 replies.
- Re: [PR] [FLINK-36029] Add @Nullable Annotation to ValueState's Value Method Return Type [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:35 UTC, 1 replies.
- Re: [PR] [hotfix] [docs/test] Fix docs and testcases of Json format [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/07 06:27:36 UTC, 1 replies.
- [jira] [Created] (FLINK-37766) FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2025/05/07 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37765) Idea import duplicate modules error. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/05/07 06:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] - posted by "lhh-yeah (via GitHub)" <gi...@apache.org> on 2025/05/07 06:49:53 UTC, 3 replies.
- [jira] [Updated] (FLINK-37765) Idea import duplicate modules error. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2025/05/07 07:10:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37766) FlinkSessionJob deletion blocked by finalizer when Flink job already terminal/missing due to HA desync - posted by "Kartikey Pant (Jira)" <ji...@apache.org> on 2025/05/07 07:12:00 UTC, 0 replies.
- [PR] [FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2 [flink] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/05/07 08:03:40 UTC, 2 replies.
- Re: [PR] [FLINK-37365][pyflink] Add API stability decorators for PyFlink APIs [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/07 08:15:16 UTC, 4 replies.
- [PR] [hotfix] Remove unnecessary java.io.Serializable [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/07 08:33:57 UTC, 2 replies.
- [jira] [Created] (FLINK-37767) Update ref version for es connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/05/07 08:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37767) Update ref version for es connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/05/07 08:55:00 UTC, 0 replies.
- [PR] [FLINK-37767][doc] Update reference branch/version for es connector [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/05/07 08:58:19 UTC, 2 replies.
- [jira] [Updated] (FLINK-37767) Update ref version for es connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/07 08:59:00 UTC, 0 replies.
- Re: [PR] [hotfix][build & docs] Update version to 4.1-SNAPSHOT and update docs [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/07 09:06:16 UTC, 8 replies.
- [PR] [hotfix] Remove unnecessary StateBackend [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/07 09:09:59 UTC, 4 replies.
- [jira] [Created] (FLINK-37768) ConstraintEnforcer not handling all constraints - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/07 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37769) Include cause in event when Restarting unhealthy job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/07 09:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37769) Include cause in event when Restarting unhealthy job - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/05/07 09:53:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-37769) Include cause in event when Restarting unhealthy job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/07 09:55:00 UTC, 0 replies.
- [PR] [FLINK-29549]- Updated Flink Glue Catalog integration [flink-connector-aws] - posted by "FranMorilloAWS (via GitHub)" <gi...@apache.org> on 2025/05/07 10:12:20 UTC, 0 replies.
- Re: [PR] [hotfix] sqlserver limit statement support [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/07 10:14:52 UTC, 5 replies.
- Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] - posted by "FranMorilloAWS (via GitHub)" <gi...@apache.org> on 2025/05/07 10:40:45 UTC, 5 replies.
- Re: [PR] [FLINK-37515] Basic support for Blue/Green deployments [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/05/07 11:34:02 UTC, 7 replies.
- [jira] [Commented] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2025/05/07 11:51:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37564) Trigger warning event when job fails to provide visibility - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/07 12:14:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2 [flink] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/05/07 13:46:07 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2 [flink] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/05/07 13:48:56 UTC, 3 replies.
- [PR] [BP-1.19][FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2 [flink] - posted by "mbalassi (via GitHub)" <gi...@apache.org> on 2025/05/07 13:59:42 UTC, 3 replies.
- [jira] [Closed] (FLINK-37632) Add ChangelogFunction interface - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/05/07 15:09:00 UTC, 0 replies.
- Re: [PR] [FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/07 16:16:24 UTC, 0 replies.
- Re: [PR] [FLIP-516][FLINK-37481] Add new multi way join operator [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2025/05/07 17:00:23 UTC, 98 replies.
- Re: [PR] [FLINK-37347][DOCS] Support any column as chunk key column (postgres, orcale, db2, sqlserver) [flink-cdc] - posted by "gtk96 (via GitHub)" <gi...@apache.org> on 2025/05/08 03:22:32 UTC, 12 replies.
- [jira] [Closed] (FLINK-37760) Bump parquet version to 1.15.2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/08 04:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-37676][cdc-common] Add caching mechanism to Selectors for improved performance [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2025/05/08 05:55:43 UTC, 4 replies.
- Re: [PR] [FLINK-36045][flink connector formats]Add support for SharePlex JSON format [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:36 UTC, 1 replies.
- Re: [PR] [FLINK-36046] Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:38 UTC, 1 replies.
- Re: [PR] [hotfix] [API/DataStream]: Ensure the proper triggering functionality of ContinuousProcessingTimeTrigger [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:41 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Fix typo in hive_read_write.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:43 UTC, 1 replies.
- Re: [PR] [FLINK-26081][docs] Update flink build document with maven wrapper [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:46 UTC, 1 replies.
- Re: [PR] [FLINK-36090][Runtime / State Backends] Fix bug with IngestDB restore operation for priority queue state in backend. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:48 UTC, 1 replies.
- Re: [PR] [FLINK-36025][table] Add the built-in function TO_NUMBER [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:50 UTC, 1 replies.
- Re: [PR] [FLINK-33977][runtime] Adaptive scheduler may not minimize the number of TMs during downscaling [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:52 UTC, 31 replies.
- Re: [PR] [FLINK-36152] Fix incorrect type extraction in case of cascaded inheritance when DataTypeHint is not configured [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:54 UTC, 1 replies.
- Re: [PR] [FLINK-26944][table] Add the built-in function ADD_MONTHS [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:56 UTC, 1 replies.
- Re: [PR] [FLINK-35850][table] Add the built-in function DATEDIFF [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:25:58 UTC, 1 replies.
- Re: [PR] [FLINK-36154][formats] Support deserialize json ignore key case [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:01 UTC, 1 replies.
- Re: [PR] Update state_backends.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:03 UTC, 1 replies.
- Re: [PR] Update datastream_api with latest API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:05 UTC, 1 replies.
- Re: [PR] [FLINK-36244] Remove queryable state [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:07 UTC, 1 replies.
- Re: [PR] [hotfix][doc] MT download link to filesystem-test-utils jar [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:10 UTC, 1 replies.
- Re: [PR] Update canal.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:13 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Fix typo in Hive connector overview Python example [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:15 UTC, 1 replies.
- Re: [PR] Detect base href dynamically [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:17 UTC, 1 replies.
- Re: [PR] [FLINK-36399][table] Fix incorrect cast behavior. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:19 UTC, 1 replies.
- Re: [PR] [FLINK-35202][table] Support the execution of alter materialized table set freshness [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/08 06:26:21 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/08 06:29:00 UTC, 0 replies.
- Re: [PR] [FLINK-33388][runtime] Support tasks balancing at TM level for Default Scheduler [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/05/08 08:25:11 UTC, 1 replies.
- [jira] [Created] (FLINK-37770) FLIP-518: Introduce a community review process - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/08 08:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression - posted by "Dominik Bünzli (Jira)" <ji...@apache.org> on 2025/05/08 08:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34016) Janino compile failed when watermark with column by udf - posted by "Dominik Bünzli (Jira)" <ji...@apache.org> on 2025/05/08 08:41:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression - posted by "Dominik Bünzli (Jira)" <ji...@apache.org> on 2025/05/08 09:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-34016) Janino compile failed when watermark with column by udf - posted by "Dominik Bünzli (Jira)" <ji...@apache.org> on 2025/05/08 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37771) Simplify getPartitionedState of AbstractKeyedStateBackend - posted by "Jiaan Geng (Jira)" <ji...@apache.org> on 2025/05/08 09:48:00 UTC, 0 replies.
- [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/08 09:49:30 UTC, 3 replies.
- [jira] [Updated] (FLINK-37771) Simplify getPartitionedState of AbstractKeyedStateBackend - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/08 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/05/08 10:42:00 UTC, 0 replies.
- [PR] [FLINK-37772] Bump connector version to 5.1.0 [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/08 10:42:49 UTC, 1 replies.
- [jira] [Updated] (FLINK-37772) Release flink-connector-aws v5.1.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/08 10:43:00 UTC, 1 replies.
- [PR] [FLINK-37772] Add AWS Connectors v5.1.0 [flink-web] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/08 10:47:52 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/05/08 13:01:00 UTC, 0 replies.
- [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/08 13:01:07 UTC, 4 replies.
- [jira] [Updated] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/08 13:02:00 UTC, 0 replies.
- [PR] [FLINK-37768] ConstraintEnforcer not handling all constraints [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/08 13:35:50 UTC, 4 replies.
- [jira] [Updated] (FLINK-37768) ConstraintEnforcer not handling all constraints - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/08 13:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/08 13:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/05/08 16:02:00 UTC, 0 replies.
- [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (2.0) [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/08 16:04:17 UTC, 3 replies.
- Re: [PR] [Docs] Update mysql-to-doris.md, add scan.startup.mode config to make demo run more smoothly [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 00:04:53 UTC, 0 replies.
- [PR] Model schema client [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/09 00:10:38 UTC, 0 replies.
- Re: [PR] [FLINK-xxx][2/N] extend catalog schema reader to get model [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/05/09 00:15:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2025/05/09 01:50:00 UTC, 3 replies.
- Re: [PR] [FLINK-37552] Support switching between ForStKeyedStatebackend and ForStSyncKeyedStatebackend [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2025/05/09 04:25:33 UTC, 2 replies.
- [jira] [Updated] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/09 04:44:00 UTC, 3 replies.
- Re: [PR] [docs-zh]The description of creating a materialized table does not match the example code,The description states 1 hour, while the code states 10 minutes [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:32 UTC, 1 replies.
- Re: [PR] [runtime-web] chore: update Angular to v15 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:35 UTC, 1 replies.
- Re: [PR] Fixed Flaky test in org.apache.flink.table.planner.plan.hints.stream.StateTtlHintTest#testStateTtlHintWithJoinHint [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:37 UTC, 1 replies.
- Re: [PR] Updated readme with stream-processing [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:39 UTC, 1 replies.
- Re: [PR] [FLINK-36437][hive] Fix hive connector complie error in JDK11 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:41 UTC, 1 replies.
- Re: [PR] [FLINK-36456] [Runtime/Configuration] Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:43 UTC, 1 replies.
- Re: [PR] Fix flaky tests in classes PartitionableSourceTest and PushPartitionIntoTableSourceScanRuleTest [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:45 UTC, 1 replies.
- Re: [PR] [hotfix] Fixing flaky tests in flink-table-planner /hints [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:47 UTC, 1 replies.
- Re: [PR] FLINK-36540.[Runtime / Task] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:49 UTC, 1 replies.
- Re: [PR] FLINK-36505 remove deprecated methods TableFunction [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:51 UTC, 1 replies.
- Re: [PR] Fix typo from MARCO to MACRO [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:54 UTC, 1 replies.
- Re: [PR] [FLINK-36675][table-planner] Always serialize dynamic options to exec json plan [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:56 UTC, 1 replies.
- Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:25:58 UTC, 1 replies.
- Re: [PR] [DRAFT/WIP] [FLINK-25082] OverWindow in batch mode failed [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:00 UTC, 1 replies.
- Re: [PR] [FLINK-36498] [table] Remove deprecated method ResolvedCatalogBaseTablele#getSchema [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:02 UTC, 1 replies.
- Re: [PR] Upgrade com.squareup.okio:okio [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:04 UTC, 1 replies.
- Re: [PR] Event latency does not equal window triggering [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:06 UTC, 1 replies.
- Re: [PR] fix: class-loading-issue [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:08 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Update table environment variable name in common.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:09 UTC, 1 replies.
- Re: [PR] [FLINK-36769] support fury serializer for pyflink [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:12 UTC, 1 replies.
- Re: [PR] [hotfix] [docs]Fix miss semicolon on SELECT & WHERE clause example sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:14 UTC, 1 replies.
- Re: [PR] Test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:17 UTC, 1 replies.
- Re: [PR] [FLINK-37020]Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:18 UTC, 1 replies.
- Re: [PR] [FLINK-36625] add lineage helper class for connector integration [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:20 UTC, 1 replies.
- Re: [PR] Update flink-architecture.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:22 UTC, 1 replies.
- Re: [PR] Update maxwell.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:25 UTC, 1 replies.
- Re: [PR] solve bash-java-utils.sh can't get "env.java.home" in "config.yaml" since 1.20 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:27 UTC, 1 replies.
- Re: [PR] [WIP][table] Algin Calcite Rules. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:29 UTC, 1 replies.
- Re: [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:30 UTC, 2 replies.
- Re: [PR] [FLINK-12173][table] Optimize SELECT DISTINCT [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:32 UTC, 1 replies.
- Re: [PR] [FLINK-35745] add documentation for flink lineage [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:34 UTC, 1 replies.
- Re: [PR] [FLINK-36918][table] Introduce ProcTimeSortOperator in TemporalSort with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:36 UTC, 1 replies.
- Re: [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:38 UTC, 1 replies.
- Re: [PR] [BP-1.20][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:42 UTC, 1 replies.
- Re: [PR] [BP-1.19][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/09 06:26:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2025/05/09 06:55:00 UTC, 0 replies.
- Re: [PR] [FLINK-37545][metrics] Fix StackOverflowError when using MetricGroup in custom WatermarkStrategy (1.20) [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/09 07:00:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/05/09 07:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37640][table-planner] Fix timestamp_ltz is converted timestamp in scan reuse [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/05/09 08:02:06 UTC, 4 replies.
- [jira] [Closed] (FLINK-37674) Add generalized type information to SQL state connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/09 08:51:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37674) Add generalized type information to SQL state connector - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/09 08:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/05/09 09:14:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-37747) GlobalCommitterOperator cannot commit after scaling writer/committer - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/09 10:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/05/09 12:03:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-36876) Operator Heap Memory Leak - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/09 12:05:00 UTC, 0 replies.
- [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] - posted by "fqshopify (via GitHub)" <gi...@apache.org> on 2025/05/09 12:30:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-32609) Kafka table source supports projection push down - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/09 12:31:00 UTC, 0 replies.
- [PR] [hotfix][state] Remove duplicate comparing about intersect group range. [flink] - posted by "littleeleventhwolf (via GitHub)" <gi...@apache.org> on 2025/05/09 12:37:17 UTC, 7 replies.
- [jira] [Commented] (FLINK-32609) Kafka table source supports projection push down - posted by "Calico Shop (Jira)" <ji...@apache.org> on 2025/05/09 13:39:00 UTC, 0 replies.
- Re: [PR] [hotfix][test] Remove redundant keywords and lines for ForStGeneralMultiGetOperationTest.java [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2025/05/09 14:39:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-34430) Akka frame size exceeded with many ByteStreamStateHandle being used - posted by "Trystan (Jira)" <ji...@apache.org> on 2025/05/09 18:04:00 UTC, 0 replies.
- Re: [PR] [FLINK-37721] Fixes janino bug returning incorrect results [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/05/09 18:05:40 UTC, 3 replies.
- [jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/09 18:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs - posted by "Nihar Rao (Jira)" <ji...@apache.org> on 2025/05/09 20:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37773) Extra TMs are started when Jobmanger is OOM killed in some FlinkDeployment runs - posted by "Nihar Rao (Jira)" <ji...@apache.org> on 2025/05/09 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/05/10 01:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/05/10 01:53:00 UTC, 1 replies.
- [PR] FLINK-37774: SQL Server CDC connector incorrectly handles special characters in database and table names [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2025/05/10 01:56:29 UTC, 12 replies.
- Re: [PR] FLINK-25029: Hadoop Caller Context Setting in Flink [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/10 06:25:14 UTC, 0 replies.
- Re: [PR] [FLINK-34251][core] ClosureCleaner to include reference classes for non-serialization exception [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/10 06:25:18 UTC, 0 replies.
- Re: [PR] [FLINK-37184][connector/filesystem] Add ZStandard to supported standard decompressors [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/10 06:25:27 UTC, 1 replies.
- Re: [PR] [hotfix] [docs] Edit Docs link location [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/10 06:25:29 UTC, 0 replies.
- [PR] Fix CVE-2022-25168 [flink] - posted by "th555555 (via GitHub)" <gi...@apache.org> on 2025/05/10 09:54:02 UTC, 4 replies.
- Re: [PR] [FLINK-26760][flink-csv] The new CSV source (file system source + CSV… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/11 06:25:14 UTC, 1 replies.
- Re: [PR] [FLINK-36487] Remove deprecated method createTemporaryView StreamTableE… [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/11 06:25:17 UTC, 1 replies.
- Re: [PR] FLINK-36479 remove deprecated method Table getSchema as [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/11 06:25:19 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/05/11 11:18:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37552) Made StateMetaInfo consistent for ForStKeyeStateBackend and ForStSyncKeyeStateBackend. - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2025/05/11 11:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-37128][pipeline-connector/mysql] Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill [flink-cdc] - posted by "loserwang1024 (via GitHub)" <gi...@apache.org> on 2025/05/12 02:54:34 UTC, 6 replies.
- [jira] [Closed] (FLINK-37767) Update ref version for es connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/05/12 05:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/05/12 05:30:58 UTC, 11 replies.
- [jira] [Assigned] (FLINK-35854) Upgrade Calcite version to 1.35.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/12 05:38:00 UTC, 0 replies.
- Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/05/12 05:40:49 UTC, 8 replies.
- Re: [PR] [FLINK-xx][table] Remove RelBuilder [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/12 06:25:45 UTC, 1 replies.
- Re: [PR] [hotfix][docs] Fix Apache Avro Specification Link [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/12 06:25:48 UTC, 1 replies.
- Re: [PR] [FLINK-36992][table] Migrate SplitAggregateRule to java [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/12 06:25:50 UTC, 1 replies.
- [PR] [FLINK-37747][runtime] Use old subtask count for restored committable… [flink] - posted by "bjlovegithub (via GitHub)" <gi...@apache.org> on 2025/05/12 06:30:23 UTC, 1 replies.
- [PR] [FLINK-35854][table] Upgrade Calcite version to 1.35.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/12 06:49:24 UTC, 21 replies.
- [jira] [Updated] (FLINK-35854) Upgrade Calcite version to 1.35.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/12 06:50:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*` - posted by "Lorenzo Affetti (Jira)" <ji...@apache.org> on 2025/05/12 09:39:00 UTC, 0 replies.
- Re: [PR] [FLINK-37720][table-planner] Enable sink reuse table optimizer by default and apply plan changes to existing test cases [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2025/05/12 11:24:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-37720) Enable sink reuse table optimizer by default and apply plan changes to existing test cases - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/12 11:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37720) Enable sink reuse table optimizer by default and apply plan changes to existing test cases - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/12 11:29:00 UTC, 0 replies.
- Re: [PR] [FLINK-37383][flink-examples]Correct throttling logic on ThrottledIterator [flink] - posted by "rafaelzimmermann (via GitHub)" <gi...@apache.org> on 2025/05/12 15:32:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-37271) Add network channel reconnect capability - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/12 15:45:00 UTC, 0 replies.
- Re: [PR] [FLINK-37478] Adding service labels to flink config [flink] - posted by "jklaw90 (via GitHub)" <gi...@apache.org> on 2025/05/12 17:21:29 UTC, 0 replies.
- [jira] [Created] (FLINK-37775) Consolidate PyFlink development dependencies in pyproject.toml - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/12 17:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37776) Drop support for Python 3.8 - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/12 17:39:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/12 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/12 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37778) model keyword syntax change - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/12 21:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37779) Add getModel to Flink catalog reader etc - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/12 21:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37780) ml_predict sql function skeleton - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/12 21:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-37275][pipeline-connector/mysql] MySQL source connector supports using the base module's source metric statistics [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/05/13 01:04:15 UTC, 0 replies.
- [jira] [Closed] (FLINK-37640) Type timestamp_ltz is converted timestamp wrongly when scanreuse - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/13 01:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37640) Type timestamp_ltz is converted timestamp wrongly when scanreuse - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/13 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37781) Add elasticsearch lookup join document - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/05/13 03:18:00 UTC, 0 replies.
- [PR] [FLINK-37781][doc] Add elasticsearch lookup join document [flink-connector-elasticsearch] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/05/13 03:24:37 UTC, 2 replies.
- [jira] [Updated] (FLINK-37781) Add elasticsearch lookup join document - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/13 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37782) flink-rpc-core RemoteHandshakeMessage nullness annotation - posted by "alan.zhao (Jira)" <ji...@apache.org> on 2025/05/13 04:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-35566] Promote TypeSerializer from PublicEvolving to Public [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/13 06:25:36 UTC, 1 replies.
- [jira] [Updated] (FLINK-37755) Make retryMillis in CollectResultFetcher configurable. - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/13 07:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. - posted by "Xenos (Jira)" <ji...@apache.org> on 2025/05/13 07:54:00 UTC, 0 replies.
- [PR] [FLINK-37677][cdc-common][cdc-runtime] Handle Exclusion of `create.table` Events in Flink CDC Schema Evolution [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/05/13 08:09:46 UTC, 3 replies.
- [jira] [Updated] (FLINK-37677) [cdc-connector] Sink support skip create table event - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/13 08:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35019) Support show create model syntax - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/13 08:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35019) Support show create model syntax - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/13 08:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35019) Support show create model syntax - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/13 08:32:00 UTC, 0 replies.
- Re: [PR] [FLINK-36767] Bumped `cyclonedx-maven-plugin` to `2.9.1` to resolve CVE-2024-38374 [flink] - posted by "vivek807 (via GitHub)" <gi...@apache.org> on 2025/05/13 08:36:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/13 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/13 08:58:00 UTC, 0 replies.
- [PR] [FLINK-37783] Auto-disable buffer debloating for tiered shuffle. [flink] - posted by "dmvk (via GitHub)" <gi...@apache.org> on 2025/05/13 08:59:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/13 09:00:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37783] Auto-disable buffer debloating for tiered shuffle. [flink] - posted by "dmvk (via GitHub)" <gi...@apache.org> on 2025/05/13 09:03:01 UTC, 1 replies.
- Re: [PR] [BP-1.19][FLINK-37783] Auto-disable buffer debloating for tiered shuffle. [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2025/05/13 09:10:17 UTC, 0 replies.
- [jira] [Created] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/05/13 10:02:00 UTC, 0 replies.
- [PR] [docs] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation [flink-cdc] - posted by "beryllw (via GitHub)" <gi...@apache.org> on 2025/05/13 10:06:46 UTC, 1 replies.
- [PR] [hotfix][python][ci] Parallelise Flink Python test execution [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/13 10:12:32 UTC, 3 replies.
- [jira] [Updated] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/13 11:11:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/13 11:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-37784][docs] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/05/13 11:11:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/13 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37785) Cannot set advanced RocksDB options in state processor job - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2025/05/13 11:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/13 12:00:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37786) Infer schema information from the state of Source and emit it to avoid maintaining state in PreTransform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/13 12:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-37718] Refactor ApplicationSubmissionContextReflector to centralize method retrieval and invocation. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/13 12:37:18 UTC, 0 replies.
- [jira] [Created] (FLINK-37787) Refractor Apache Flink project to use Java 21 features - posted by "Pranav Mahajan (Jira)" <ji...@apache.org> on 2025/05/13 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37788) Refractor equalsTo() method in classes to use Java 17 instanceof operator - posted by "Pranav Mahajan (Jira)" <ji...@apache.org> on 2025/05/13 15:06:00 UTC, 0 replies.
- [PR] [FLINK-37788] Use Java 17 instanceof in equals() method in Flink Core… [flink] - posted by "pranav234 (via GitHub)" <gi...@apache.org> on 2025/05/13 15:12:19 UTC, 1 replies.
- [jira] [Updated] (FLINK-37788) Refractor equalsTo() method in classes to use Java 17 instanceof operator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/13 15:13:00 UTC, 0 replies.
- Re: [PR] [FLINK-37583] Upgrade to Kafka 4.0.0 client. [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/13 15:38:15 UTC, 0 replies.
- Re: [PR] [FLINK-37788] Use Java 17 instanceof pattern matching in equals() method in Flink Core… [flink] - posted by "pranav234 (via GitHub)" <gi...@apache.org> on 2025/05/13 15:41:55 UTC, 1 replies.
- [jira] [Created] (FLINK-37789) Integrate with sqlvalidator - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37791) Integrate with sql to rel converter - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37790) Add model factory related interfaces/classes - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37792) Physical rewrite for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37793) Codegen for ml_predict - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37794) ml_evaluate sql function skeleton - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37795) Physical rewrite for ml_evaluate - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37797) Documentation - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37796) Codegen for ml_evaluate - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37798) Persist DelayedScaleDown info in state store - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/05/13 19:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37721) Fix janino bug returning incorrect results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/13 19:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37721) Fix janino bug returning incorrect results - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/13 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37799) Flink native model predict runtime implementation - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/13 21:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37778) model keyword syntax change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/14 03:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37778) model keyword syntax change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/14 03:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37778) model keyword syntax change - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/14 03:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37800) When using jobmanager-pod-template to deploy a Native Kubernetes Application Job, an error message appears in the log: 'Invalid value: "/opt/flink/artifacts": must be unique,' - posted by "Yang Zhou (Jira)" <ji...@apache.org> on 2025/05/14 05:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37800) When using jobmanager-pod-template to deploy a Native Kubernetes Application Job, an error message appears in the log: 'Invalid value: "/opt/flink/artifacts": must be unique,' - posted by "Yang Zhou (Jira)" <ji...@apache.org> on 2025/05/14 05:25:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues - posted by "slankka (Jira)" <ji...@apache.org> on 2025/05/14 06:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/14 07:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37783) TieredStorage doesn't work when Buffer Debloating is enabled - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/14 07:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37718) Refactor ApplicationSubmissionContextReflector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/14 07:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37718) Refactor ApplicationSubmissionContextReflector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/14 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37801) HybridShuffle: RemoteTier should not finish empty segments - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/14 08:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36019) Files under the flink_ha directory can be configured with custom permissions - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 08:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37801) HybridShuffle: RemoteTier should not finish empty segments - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/14 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37802) files in directory job-result-store was incorrect - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 08:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37802) files in directory job-result-store was incorrect - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 08:55:00 UTC, 9 replies.
- [jira] [Created] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/14 08:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37802) files in directory job-result-store was incorrect - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 09:05:00 UTC, 5 replies.
- [jira] (FLINK-37802) files in directory job-result-store was incorrect - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 09:09:00 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-37802) files in directory job-result-store was incorrect - posted by "yanggang (Jira)" <ji...@apache.org> on 2025/05/14 09:19:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/14 10:42:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/14 13:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/15 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37804) Python failed to build wheels on macos - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/15 01:56:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37804) Python failed to build wheels on macos - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/15 01:57:00 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-37804) Python failed to build wheels on macos - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/15 02:06:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37804) Python failed to build wheels on macos - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/05/15 02:17:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37748) Remove JDK only JVM arguments from Flink operator Helm chart - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/15 05:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/15 07:40:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-33963) There is only one UDF instance after serializing the same task - posted by "lifengchao (Jira)" <ji...@apache.org> on 2025/05/15 07:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/15 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37805) Add some time cost logs of some steps - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/15 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37806) Add some time cost metrics of some steps - posted by "Weijun Wang (Jira)" <ji...@apache.org> on 2025/05/15 12:43:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36999) When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2025/05/15 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37807) Report s5cmd cancellation in a nicer way - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/05/15 14:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37808) Checkpoint completed after job failure - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2025/05/15 14:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/15 14:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37768) ConstraintEnforcer not handling all constraints - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/15 15:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35229) join An error occurred when the table was empty - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37147) The where condition run time advance caused a program error - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37549) Some scala and markdown syntax errors in tableApi page - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36609) Protobuf Format not support proto3 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:56:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36735) SupportsRowLevelUpdate gives sink only the values of required columns when specifying RowLevelUpdateInfo#requiredColumns - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36736) DynamicTableSink.Context#getTargetColumns should contains all the columns that sink function will receive - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false' - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 15:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37787) Refractor Apache Flink project to use Java 21 features - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/15 16:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37678) suggest improve doris connector version - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/16 01:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37678) suggest improve doris connector version - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/16 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37809) sqlserver limit statement support - posted by "sleepy0521 (Jira)" <ji...@apache.org> on 2025/05/16 02:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37809) sqlserver limit statement support - posted by "sleepy0521 (Jira)" <ji...@apache.org> on 2025/05/16 02:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37641) Fix: SchemaEvolveE2eITCase.testLenientSchemaEvolution timeout - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/16 03:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37738) [cdc-connector][postgres] Support read changelog as append only mode - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/16 03:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37736) Introduce Flink CDC metrics doc - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/16 03:08:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37630) Support flink cdc pipeline Yarn session mode - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/16 03:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/16 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/16 09:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/16 12:04:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-37801) HybridShuffle: RemoteTier should not finish empty segments - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/16 13:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37801) HybridShuffle: RemoteTier should not finish empty segments - posted by "David Morávek (Jira)" <ji...@apache.org> on 2025/05/16 13:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-37634][pipeline-connector/mysql]When the table name of mysql s… [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/05/16 14:42:41 UTC, 1 replies.
- Re: [PR] [FLINK-37769] Include cause in event when restarting unhealthy job [flink-kubernetes-operator] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/16 14:43:22 UTC, 2 replies.
- [jira] [Updated] (FLINK-37769) Include cause in event when Restarting unhealthy job - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/16 14:44:00 UTC, 0 replies.
- [PR] [hotfix][javadoc] Correct the default value of chaining strategy [flink] - posted by "Myasuka (via GitHub)" <gi...@apache.org> on 2025/05/16 14:44:15 UTC, 2 replies.
- [jira] [Closed] (FLINK-37769) Include cause in event when Restarting unhealthy job - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/16 15:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37776) Drop support for Python 3.8 - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/16 15:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-32097][Connectors/Kinesis] Implement support for Kinesis deaggregation [flink-connector-aws] - posted by "Lzgpom (via GitHub)" <gi...@apache.org> on 2025/05/16 15:55:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/16 15:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-37807][s3][rocksdb] Report s5cmd cancellation in a nicer way [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/16 15:59:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/16 16:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37807) Report s5cmd cancellation in a nicer way - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/16 16:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/16 16:01:00 UTC, 1 replies.
- Re: [PR] [FLINK-37627][BugFix][Connectors/Kinesis] Restarting from a checkpoint/savepoint which coincides with shard split causes data loss [flink-connector-aws] - posted by "leekeiabstraction (via GitHub)" <gi...@apache.org> on 2025/05/16 16:03:05 UTC, 2 replies.
- Re: [PR] [FLINK-37536] [TABLE-SQL] Improve SQL Gateway documentation [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/16 16:09:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-37811) Flink Job stuck in suspend state after losing leadership in Zookeeper HA - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2025/05/17 00:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37811) Flink Job stuck in suspend state after losing leadership in Zookeeper HA - posted by "Arun Lakshman (Jira)" <ji...@apache.org> on 2025/05/17 00:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37812) Fix broken links to Apache Avro in doc and code - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/05/17 02:29:00 UTC, 0 replies.
- [PR] [FLINK-37812][doc] Fix broken links to Apache Avro in doc and code [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/05/17 02:31:15 UTC, 6 replies.
- [jira] [Updated] (FLINK-37812) Fix broken links to Apache Avro in doc and code - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/17 02:32:00 UTC, 0 replies.
- [PR] [hotfix][config] split long JAVA opts into multiple lines for readability. [flink] - posted by "joyCurry30 (via GitHub)" <gi...@apache.org> on 2025/05/17 05:00:19 UTC, 2 replies.
- Re: [PR] FLINK-36485 remove deprecated method fromDataStream [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/17 06:25:10 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/17 14:55:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37810] Update log4j to 2.24.3 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/17 14:58:50 UTC, 3 replies.
- Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] - posted by "JinkunLiu (via GitHub)" <gi...@apache.org> on 2025/05/17 15:18:47 UTC, 3 replies.
- [jira] [Updated] (FLINK-37780) ml_predict sql function type inference and argument validation - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/17 22:54:00 UTC, 1 replies.
- Re: [PR] [FLINK-36844][docs]Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 00:05:07 UTC, 2 replies.
- Re: [PR] [FLINK-36805][cdc-common] Add ConfigShade interface to support encryption of sensitive configuration items and provide a base64 encoding implementation [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 00:05:08 UTC, 0 replies.
- Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink] - posted by "dyccode (via GitHub)" <gi...@apache.org> on 2025/05/18 03:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] - posted by "laughingman7743 (via GitHub)" <gi...@apache.org> on 2025/05/18 06:04:53 UTC, 0 replies.
- Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 06:25:29 UTC, 0 replies.
- Re: [PR] [FLINK-36600][FLINK-36601][jdbc-driver] Add JobID property to FlinkResultSet so that application can get job id when using flink jdbc driver to commit job [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 06:25:33 UTC, 1 replies.
- Re: [PR] [FLINK-36617] migrate kyro package [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 06:25:36 UTC, 1 replies.
- Re: [PR] [FLINK-36898][Table] Support SQL FLOOR and CEIL functions with NanoSecond and MicroSecond for TIMESTAMP_TLZ [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/18 06:25:38 UTC, 0 replies.
- Re: [PR] [FLINK-37810] Update log4j to 2.24.3 [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/18 06:41:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/18 06:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-37779][2/N] extend catalog schema reader to get model [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/05/19 02:08:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-37779) Add getModel to Flink catalog reader etc - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/19 02:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37779) Add getModel to Flink catalog reader etc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/19 02:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37779) Add getModel to Flink catalog reader etc - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/19 02:10:00 UTC, 0 replies.
- Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/05/19 02:12:42 UTC, 0 replies.
- Re: [PR] [FLINK-37665]: Simplify DoubleMaximum.clone() Implementation [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/05/19 02:27:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-37665) Simplify DoubleMaximum.clone() Implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/19 02:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37665) Simplify DoubleMaximum.clone() Implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/19 02:29:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37665) Simplify DoubleMaximum.clone() Implementation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/19 02:29:00 UTC, 0 replies.
- Re: [PR] [hotfix] Remove unnecessary method override for method invoke [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/05/19 02:33:06 UTC, 1 replies.
- Re: [PR] [FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec… [flink] - posted by "lsyldliu (via GitHub)" <gi...@apache.org> on 2025/05/19 02:46:19 UTC, 0 replies.
- [PR] [hotfix][cdc][docs] Build 3.4 docs and mark it as stable. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/19 04:06:01 UTC, 2 replies.
- Re: [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/19 06:25:47 UTC, 0 replies.
- Re: [PR] Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.7.1 in /flink-end-to-end-tests/flink-sql-client-test [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/19 06:26:08 UTC, 0 replies.
- [I] Issue with Flink Application Mode args – Custom Command Not Executing as Expected [flink-shaded] - posted by "bilal-07 (via GitHub)" <gi...@apache.org> on 2025/05/19 07:11:57 UTC, 0 replies.
- Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/19 08:14:50 UTC, 0 replies.
- [PR] [FLINK-XXXX] [helm] Move inline ConfigMap to dedicated template and add checksum annotation [flink-kubernetes-operator] - posted by "fallen-up (via GitHub)" <gi...@apache.org> on 2025/05/19 09:03:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration - posted by "melin (Jira)" <ji...@apache.org> on 2025/05/19 09:21:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration - posted by "melin (Jira)" <ji...@apache.org> on 2025/05/19 09:24:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration - posted by "melin (Jira)" <ji...@apache.org> on 2025/05/19 09:26:00 UTC, 1 replies.
- [PR] [BP-1.20][FLINK-37810] Update log4j to 2.24.3 [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/19 09:59:03 UTC, 3 replies.
- [PR] [hotfix][ci] Ensure presence of Python.h headers in Github Actions runners [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/19 10:40:26 UTC, 2 replies.
- Re: [PR] [FLINK-37789][3/N] introduce ml builtin sql functions and sql validator changes [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/05/19 11:04:44 UTC, 16 replies.
- [jira] [Updated] (FLINK-37789) Integrate with sqlvalidator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/19 11:05:00 UTC, 0 replies.
- Re: [PR] [helm] Move inline ConfigMap to dedicated template and add checksum annotation [flink-kubernetes-operator] - posted by "fallen-up (via GitHub)" <gi...@apache.org> on 2025/05/19 11:24:04 UTC, 0 replies.
- [PR] [hotfix][s3] Improve interruption handling for s5cmd [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/19 12:51:05 UTC, 4 replies.
- [jira] [Created] (FLINK-37813) JobManager failover during allocation slots causes ResourceManager to release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/19 13:09:00 UTC, 0 replies.
- [PR] V3.1 restore checkpoint arraylist NPE [flink-connector-elasticsearch] - posted by "thbay (via GitHub)" <gi...@apache.org> on 2025/05/19 13:16:36 UTC, 1 replies.
- [jira] [Updated] (FLINK-37813) JobManager failover during allocation slots causes ResourceManager to release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/19 13:34:00 UTC, 4 replies.
- [PR] V3.1 do not retry failed index operations [flink-connector-elasticsearch] - posted by "thbay (via GitHub)" <gi...@apache.org> on 2025/05/19 13:46:06 UTC, 0 replies.
- Re: [PR] [FLINK-37733] Externalise DynamoDB connector IT Test to E2E test package [flink-connector-aws] - posted by "leekeiabstraction (via GitHub)" <gi...@apache.org> on 2025/05/19 14:39:58 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37810) update log4j to 2.24.3 to fix critical vulnerabilities - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/19 15:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-34466][LINEAGE] Support dataset type facet for Avro [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/19 16:22:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-37481) FLIP-516: Multi way join operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/19 16:27:00 UTC, 3 replies.
- Re: [PR] [FLINK-35870] Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2025/05/19 16:31:50 UTC, 0 replies.
- [jira] [Created] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/19 17:38:00 UTC, 0 replies.
- [PR] [ENGT-2178] Publish in prod ECR [flink-kubernetes-operator] - posted by "OctavioBR (via GitHub)" <gi...@apache.org> on 2025/05/19 18:37:47 UTC, 2 replies.
- [jira] [Created] (FLINK-37815) JDBC lookup cache - dont query db even if missing - posted by "tooptoop4 (Jira)" <ji...@apache.org> on 2025/05/19 22:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37724) Add AsyncTableFunction as new UDF type - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/19 22:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/19 22:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37816) FLIP-491: BundledAggregateFunction for batched aggregation - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/19 22:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37816) FLIP-491: BundledAggregateFunction for batched aggregation - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/19 22:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37817) Add Bundled Aggregate API and operator for group by - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/19 22:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-37630] Support flink cdc pipeline Yarn session mode [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/05/20 02:03:02 UTC, 1 replies.
- [PR] Polish cdc 3.4 blogpost documentation [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/05/20 02:59:41 UTC, 0 replies.
- Re: [PR] [minor][blog] Polish Flink CDC 3.4 blogpost [flink-web] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2025/05/20 04:00:55 UTC, 0 replies.
- Re: [PR] [FLINK-37591][table] Add some PruneEmptyRules [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2025/05/20 04:04:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-37591) Add Some PruneEmptyRules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/20 04:05:00 UTC, 0 replies.
- Re: [PR] [hotfix] Supports specifying routing fields [flink-connector-elasticsearch] - posted by "ethan-xiao (via GitHub)" <gi...@apache.org> on 2025/05/20 06:07:21 UTC, 1 replies.
- [PR] [FLINK-37790][4/N] introduce model provider related interfaces [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/20 06:23:37 UTC, 6 replies.
- [jira] [Updated] (FLINK-37790) Add model factory related interfaces/classes - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/20 06:24:00 UTC, 0 replies.
- Re: [PR] [FLINK-37245] Prevent masking null values in BinaryRowData [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/20 06:25:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2025/05/20 07:05:00 UTC, 3 replies.
- Re: [PR] [FLINK-35097][table] Fix 'raw' format deserialization [flink] - posted by "fabrizziocht (via GitHub)" <gi...@apache.org> on 2025/05/20 07:28:44 UTC, 0 replies.
- [jira] [Created] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/20 07:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-36180] Fix batch message data loss [flink-connector-pulsar] - posted by "fabrizziocht (via GitHub)" <gi...@apache.org> on 2025/05/20 08:06:50 UTC, 1 replies.
- Re: [PR] [FLINK-36770][Connectors/AWS] make AWS sink writers use ResultHandler, move flink version to 1.20 [flink-connector-aws] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2025/05/20 08:14:41 UTC, 0 replies.
- [PR] [FLINK-37818] Fix Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/05/20 08:38:18 UTC, 6 replies.
- [jira] [Updated] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/20 08:39:00 UTC, 3 replies.
- Re: [PR] [FLINK-37510] Avoid duplicate calculations for SlidingEventTimeWindows [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/20 08:53:15 UTC, 0 replies.
- Re: [PR] [FLINK-37512] Fix the OOM for SlidingEventTimeWindows [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/20 08:54:41 UTC, 0 replies.
- Re: [PR] [hotfix] Correct the comments for FlinkSecurityManager [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/20 08:56:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-34112) JavaCodeSplitter OOM - posted by "Juliusz Nadberezny (Jira)" <ji...@apache.org> on 2025/05/20 09:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-37738][cdc-connector][postgres] Support read changelog as append only mode [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/20 09:49:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-37404) Reenable Migration Tests for Filnk 2.x - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2025/05/20 10:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/20 11:58:43 UTC, 3 replies.
- [jira] [Created] (FLINK-37819) Add column expansion test for model TVF - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/20 19:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37820) AsyncScalarFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/20 20:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop. [flink-connector-aws] - posted by "aws-nageshvh (via GitHub)" <gi...@apache.org> on 2025/05/20 21:38:24 UTC, 7 replies.
- [jira] [Updated] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/20 21:39:00 UTC, 1 replies.
- Re: [PR] [FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length [flink] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2025/05/20 23:10:26 UTC, 2 replies.
- Re: [PR] [FLINK-37652][Connectors/Opensearch] Move to Flink to 2.0.0 [flink-connector-opensearch] - posted by "reta (via GitHub)" <gi...@apache.org> on 2025/05/20 23:39:26 UTC, 2 replies.
- [jira] [Created] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/21 03:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/21 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/21 03:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37816) FLIP-491: BundledAggregateFunction for batched aggregation - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/21 03:51:00 UTC, 0 replies.
- [PR] [hotfix] Fix invalid comments in Committer [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/21 07:31:37 UTC, 5 replies.
- [PR] [hotfix] Fix typo in ElasticsearchEmitter [flink-connector-elasticsearch] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2025/05/21 07:43:40 UTC, 2 replies.
- [PR] Upgrade to JOSDK 5.1 [flink-kubernetes-operator] - posted by "csviri (via GitHub)" <gi...@apache.org> on 2025/05/21 07:53:00 UTC, 1 replies.
- [PR] docs: updated StarRocks documentation link [flink-cdc] - posted by "zhuxt2015 (via GitHub)" <gi...@apache.org> on 2025/05/21 07:54:48 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/21 08:01:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/21 09:14:00 UTC, 1 replies.
- [PR] [FLINK-37818] Fix Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. [4.0] [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/05/21 09:16:41 UTC, 1 replies.
- [jira] [Created] (FLINK-37823) Add Python 3.12 support - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/21 10:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37823) Add Python 3.12 support - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/21 10:14:00 UTC, 4 replies.
- [PR] [FLINK-37823][python] Add Python 3.12 support [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/21 10:47:44 UTC, 2 replies.
- [jira] [Created] (FLINK-37824) Paimon connector lost column comment in CreateTableEvent - posted by "linqigeng (Jira)" <ji...@apache.org> on 2025/05/21 10:57:00 UTC, 0 replies.
- [PR] [FLINK-37577][pipeline-connector/paimon] Fix missing column comment [flink-cdc] - posted by "qg-lin (via GitHub)" <gi...@apache.org> on 2025/05/21 11:40:53 UTC, 3 replies.
- [jira] [Resolved] (FLINK-37818) Kafka connector requires unqiue TransactionalIdPrefix even for non-EOS settings. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/21 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37825) Standard YAML convert and dump failed - posted by "melin (Jira)" <ji...@apache.org> on 2025/05/21 13:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37825) Standard YAML convert and dump failed - posted by "melin (Jira)" <ji...@apache.org> on 2025/05/21 13:23:00 UTC, 2 replies.
- [PR] [FLINK-37817] Adds bundled aggregates for group by (FLIP-491) [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/05/21 15:29:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-37817) Add Bundled Aggregate API and operator for group by - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/21 15:30:00 UTC, 0 replies.
- [PR] [FLINK-37804][python] Limit Cython < 3 [flink] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/05/22 01:34:23 UTC, 2 replies.
- [jira] [Updated] (FLINK-37804) Python failed to build wheels on macos - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 01:35:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/22 01:39:00 UTC, 4 replies.
- Re: [PR] docs: minor updates to Iceberg sink reference [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/22 01:53:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-37823) Add Python 3.12 support - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/05/22 02:58:00 UTC, 0 replies.
- [PR] [FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOp… [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/05/22 03:06:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37826) Some serde-related perfs regression since May 19th - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/05/22 04:23:00 UTC, 0 replies.
- [PR] [FLINK-37780] predict sql function type inference and validation [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/22 05:15:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-37826) Some serde-related perfs regression since May 19th - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/22 05:40:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37827) Failed to use `SHOW CREATE TABLE` for MATERIALIZED_TABLE - posted by "yanghuai (Jira)" <ji...@apache.org> on 2025/05/22 06:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/22 06:25:42 UTC, 0 replies.
- [PR] [FLINK-37827][table] Fix use `SHOW CREATE TABLE` for MATERIALIZED_TABLE [flink] - posted by "yanghuaiGit (via GitHub)" <gi...@apache.org> on 2025/05/22 06:28:39 UTC, 5 replies.
- [jira] [Updated] (FLINK-37827) Failed to use `SHOW CREATE TABLE` for MATERIALIZED_TABLE - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 06:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37790) Add model factory related interfaces/classes - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/22 08:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37790) Add model factory related interfaces/classes - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/22 08:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37790) Add model factory related interfaces/classes - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/22 08:05:00 UTC, 0 replies.
- [PR] [FLINK-37804][python][build] Fix build mac wheels error in GHA [flink] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/05/22 09:00:28 UTC, 3 replies.
- [jira] [Created] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability. - posted by "JunboWang (Jira)" <ji...@apache.org> on 2025/05/22 09:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34864) [enhancement] [ cdc-connector] [ignore no primary key table] When using regular expressions to synchronize the entire database with Flink CDC, skip tables that do not have a primary key. - posted by "zengyi (Jira)" <ji...@apache.org> on 2025/05/22 09:24:00 UTC, 0 replies.
- [PR] [hotfix] Remove useless imports. [flink-cdc] - posted by "joyCurry30 (via GitHub)" <gi...@apache.org> on 2025/05/22 09:46:26 UTC, 3 replies.
- [jira] [Created] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/22 09:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37820) AsyncScalarFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/22 10:32:00 UTC, 1 replies.
- [PR] [FLINK-37820][table-planner] Support `AsyncScalarFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/22 10:37:29 UTC, 2 replies.
- [PR] [BP-2.0][FLINK-37820][table-planner] Support `AsyncScalarFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/22 10:43:20 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-37820][table-planner] Support `AsyncScalarFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/22 10:43:33 UTC, 2 replies.
- [PR] [BP-1.19][FLINK-37820][table-planner] Support `AsyncScalarFunction` registration via `CompiledPlan` [flink] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/22 10:44:05 UTC, 2 replies.
- [jira] [Resolved] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2025/05/22 11:10:00 UTC, 0 replies.
- [PR] [FLINK-37776][python] Drop python 3.8 support [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/22 12:12:42 UTC, 12 replies.
- [jira] [Updated] (FLINK-37776) Drop support for Python 3.8 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 12:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37830) Restore checkpoint state in the ES connector fails with NPE on ArrayList when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 - posted by "Thomas Bay (Jira)" <ji...@apache.org> on 2025/05/22 12:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37830) Restore checkpoint state in the ES connector fails with NPE on ArrayList when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 - posted by "Thomas Bay (Jira)" <ji...@apache.org> on 2025/05/22 12:30:00 UTC, 6 replies.
- [jira] [Created] (FLINK-37831) Failed index operations are not retried when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 - posted by "Thomas Bay (Jira)" <ji...@apache.org> on 2025/05/22 12:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37831) Failed index operations are not retried when using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1 - posted by "Thomas Bay (Jira)" <ji...@apache.org> on 2025/05/22 12:47:00 UTC, 1 replies.
- [PR] [FLINK-37829] ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2025/05/22 15:39:19 UTC, 8 replies.
- [jira] [Updated] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 15:40:00 UTC, 0 replies.
- [PR] [FLINK-37292] [cdc] Remove the flink-kubernetes dependencies during the packaging of flink-cdc-dist [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2025/05/22 17:10:24 UTC, 2 replies.
- [jira] [Updated] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 17:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37778) model keyword syntax change - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/22 18:47:00 UTC, 1 replies.
- Re: [PR] [FLINK-37724] Adds AsyncTableFunction as a fully supported UDF type [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/22 21:31:17 UTC, 2 replies.
- [jira] [Updated] (FLINK-37724) Add AsyncTableFunction as new UDF type - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/22 21:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/05/22 22:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/05/22 22:38:00 UTC, 2 replies.
- [jira] [Created] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2025/05/22 23:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2025/05/22 23:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37833) Code generated for binary key in BatchExecExchange causes incorrect shuffle - posted by "Venkata krishnan Sowrirajan (Jira)" <ji...@apache.org> on 2025/05/22 23:17:00 UTC, 4 replies.
- [PR] Fix HashPartitioner codegen for BINARY/VARBINARY type by evaluating B… [flink] - posted by "venkata91 (via GitHub)" <gi...@apache.org> on 2025/05/22 23:21:15 UTC, 1 replies.
- [jira] [Created] (FLINK-37834) Flink JDBC support ClickHouse Dialect - posted by "Arsene (Jira)" <ji...@apache.org> on 2025/05/23 00:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "yux (Jira)" <ji...@apache.org> on 2025/05/23 01:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-36794] [cdc-composer/cli] pipeline cdc connector support multiple data sources [flink-cdc] - posted by "linjianchang (via GitHub)" <gi...@apache.org> on 2025/05/23 01:44:31 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2025/05/23 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/23 02:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect - posted by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2025/05/23 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37837) Always Add create.table to include.schema.changes option - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/23 04:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37836) FLIP-486 Introduce a new DeltaJoin - posted by "Xuyang Zhong (Jira)" <ji...@apache.org> on 2025/05/23 04:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37813) JobManager re-allocation slots when exit causes ResourceManager to release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/23 06:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37813) JobManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/23 06:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37813) SlotManager re-allocation slots upon failover causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/23 06:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37813) JobManager re-allocation slots upon exit causes ResourceManager start more TaskManager and release unwanted TaskManager failure - posted by "Baozhu Zhao (Jira)" <ji...@apache.org> on 2025/05/23 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37838) Introduce Model Function implementations based on OpenAI API - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/05/23 06:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37838) Introduce Model Function implementations based on OpenAI API - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/05/23 06:55:00 UTC, 0 replies.
- [PR] [FLINK-37804][python][build] Fix build mac wheels error on Python3.8 in GHA [flink] - posted by "HuangXingBo (via GitHub)" <gi...@apache.org> on 2025/05/23 07:09:38 UTC, 3 replies.
- [jira] [Resolved] (FLINK-37804) Python failed to build wheels on macos - posted by "Xingbo Huang (Jira)" <ji...@apache.org> on 2025/05/23 07:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/23 08:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36767) Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/23 08:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37411) Introduce the rollback mechanism for Autoscaler - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/23 08:48:00 UTC, 0 replies.
- Re: [PR] FLINK-37833: Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] - posted by "selectboydata (via GitHub)" <gi...@apache.org> on 2025/05/23 10:02:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/23 10:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition - posted by "david radley (Jira)" <ji...@apache.org> on 2025/05/23 10:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-31215) Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2025/05/23 10:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37824) Paimon connector lost column comment in CreateTableEvent - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/23 11:12:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37824) Paimon connector lost column comment in CreateTableEvent - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/23 11:13:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/23 11:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37789) Integrate with sqlvalidator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/23 13:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37789) Integrate with sqlvalidator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/23 13:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37789) Integrate with sqlvalidator - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/23 13:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37838) Introduce Model Function implementations based on OpenAI API - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/23 16:46:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37777) FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/23 16:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-37209][transform] Add built-in Qwen model for transform. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/24 00:04:40 UTC, 0 replies.
- Re: [PR] when i pakcage cdc-3.3.0, my idea has some error, add maven-gpg-plugin [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/24 00:04:42 UTC, 1 replies.
- Re: [PR] [FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINARY type by evaluating Unsafe.arrayBaseOffset(byte[].class) in TM rather than in JM [flink] - posted by "venkata91 (via GitHub)" <gi...@apache.org> on 2025/05/24 00:09:11 UTC, 3 replies.
- [jira] [Created] (FLINK-37839) Add COPYFILE_DISABLE=1 parameter to avoid generating ._* files when using mac tar to package - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/05/24 02:03:00 UTC, 0 replies.
- [PR] [FLINK-37839][tools]Fix source release package contains ._* files [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/05/24 02:14:13 UTC, 2 replies.
- [jira] [Updated] (FLINK-37839) Add COPYFILE_DISABLE=1 parameter to avoid generating ._* files when using mac tar to package - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/24 02:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2025/05/24 04:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-33584][Filesystems] Update Hadoop Filesystem dependencies to 3.3.6 [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/24 06:25:08 UTC, 1 replies.
- [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc] - posted by "yzeng1618 (via GitHub)" <gi...@apache.org> on 2025/05/24 08:04:04 UTC, 8 replies.
- [jira] [Updated] (FLINK-34864) [enhancement] [ cdc-connector] [ignore no primary key table] When using regular expressions to synchronize the entire database with Flink CDC, skip tables that do not have a primary key. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/24 08:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37621) EnableAsyncState doesn't seem to do anything on DataStream API and misleading error message - posted by "Antti Kaikkonen (Jira)" <ji...@apache.org> on 2025/05/24 12:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37621) EnableAsyncState doesn't seem to do anything on DataStream API and misleading error message - posted by "Antti Kaikkonen (Jira)" <ji...@apache.org> on 2025/05/24 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37840) Row writer should honor null uncompact BigDecimal and Timestamp - posted by "Deng Ziming (Jira)" <ji...@apache.org> on 2025/05/24 13:16:00 UTC, 0 replies.
- [PR] [FLINK-37840] [table] Row writer should honor null uncompact BigDecimal and Timestamp [flink] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2025/05/24 13:21:01 UTC, 8 replies.
- [jira] [Updated] (FLINK-37840) Row writer should honor null uncompact BigDecimal and Timestamp - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/24 13:22:00 UTC, 0 replies.
- [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] - posted by "Biasqo (via GitHub)" <gi...@apache.org> on 2025/05/24 14:08:02 UTC, 4 replies.
- [jira] [Updated] (FLINK-37834) Flink JDBC support ClickHouse Dialect - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/24 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37841) Having adaptive retry strategy causing issues in DDB Connector - posted by "Abhi Gupta (Jira)" <ji...@apache.org> on 2025/05/24 18:21:00 UTC, 0 replies.
- [PR] [FLINK-37841][Connectors/DynamoDB] Using standard retry strategy instead of adaptive retry strategy to build ddb streams client [flink-connector-aws] - posted by "gguptp (via GitHub)" <gi...@apache.org> on 2025/05/24 18:24:07 UTC, 2 replies.
- [jira] [Updated] (FLINK-37841) Having adaptive retry strategy causing issues in DDB Connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/24 18:25:00 UTC, 1 replies.
- Re: [PR] [FLINK-36785][cdc][starrocks] Improve Starrocks unsupported field error return value [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/25 00:05:16 UTC, 1 replies.
- Re: [PR] [FLINK-36851][table] Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/25 06:25:10 UTC, 0 replies.
- Re: [PR] [FLINK-36881][table] Introduce GroupTableAggFunction in GroupTableAggregate with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/25 06:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/25 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/25 10:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/25 10:03:00 UTC, 3 replies.
- Re: [PR] [FLINK-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. [flink] - posted by "xing1mo (via GitHub)" <gi...@apache.org> on 2025/05/25 11:17:24 UTC, 0 replies.
- Re: [PR] [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark. [flink] - posted by "xing1mo (via GitHub)" <gi...@apache.org> on 2025/05/25 11:18:30 UTC, 0 replies.
- [jira] [Created] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/25 16:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java - posted by "Kenneth William Krugler (Jira)" <ji...@apache.org> on 2025/05/25 17:48:00 UTC, 0 replies.
- [PR] FLINK-36236 Fix overriding the connection provider in JdbcSourceBuilder [flink-connector-jdbc] - posted by "rajucomp (via GitHub)" <gi...@apache.org> on 2025/05/25 18:15:24 UTC, 2 replies.
- Re: [PR] [FLINK-37216] Default MAX_BATCH_SIZE_IN_BYTES should be greater than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 00:04:58 UTC, 0 replies.
- Re: [PR] [FLINK-37199][doc] Update configuration in quickstart. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 00:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-36669][pipeline-connector][ES] The flink version of ES should use parent's pom [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 00:05:04 UTC, 1 replies.
- [jira] [Created] (FLINK-37845) Remove FlinkRexBuilder#makeIn - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 00:06:00 UTC, 0 replies.
- [PR] [FLINK-37845][table] Remove FlinkRexBuilder#makeIn [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/26 00:08:42 UTC, 3 replies.
- [jira] [Updated] (FLINK-37845) Remove FlinkRexBuilder#makeIn - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/26 00:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 00:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37652) [Connectors/Opensearch] Move to Flink to 2.0.0 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 00:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37846) [Unstable test] MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37847) [umbrella] Unstable test in FlinkCDC project - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 02:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37846) [Unstable test] MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 02:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37461) [Unstable Test Case] MySqlToPaimonE2eITCase#testSyncWholeDatabase - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 02:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 02:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 02:49:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 02:49:00 UTC, 0 replies.
- Re: [PR] Add an example to use PTF [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/05/26 02:51:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-37799) Flink native model predict runtime implementation - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/05/26 03:02:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37848) After timestamp mode is enabled, newly added tables will not have all their data synchronized. - posted by "Darcy Lin (Jira)" <ji...@apache.org> on 2025/05/26 03:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37774) SQL Server CDC connector incorrectly handles special characters in database and table names - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37849) Model provider factory discover - posted by "Hao Li (Jira)" <ji...@apache.org> on 2025/05/26 04:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37838) Introduce Model Function implementations based on OpenAI API - posted by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2025/05/26 05:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37839) Add COPYFILE_DISABLE=1 parameter to avoid generating ._* files when using mac tar to package - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 06:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 06:11:00 UTC, 1 replies.
- [PR] [FLINK-37849][7/N] model provider factory discovery [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/26 06:17:32 UTC, 2 replies.
- [jira] [Updated] (FLINK-37849) Model provider factory discover - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/26 06:18:00 UTC, 0 replies.
- Re: [PR] [FLINK-36849][table] Introduce AppendOnlyFirstNFunction in Rank with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:25:47 UTC, 0 replies.
- Re: [PR] [FLINK-36869][table] Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:26:07 UTC, 0 replies.
- Re: [PR] Bump com.nimbusds:nimbus-jose-jwt from 4.41.1 to 9.37.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:26:28 UTC, 2 replies.
- Re: [PR] [FLINK-36936][table] Introduce UpdatableTopNFunction in Rank with Async State API [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:26:29 UTC, 0 replies.
- Re: [PR] [FLINK-37103] The parameters passed when calling method FactoryUtil.createDynamicTableSource are inconsistent [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:26:50 UTC, 1 replies.
- Re: [PR] [hotfix] Fixed a typo in state_backends.md [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:27:31 UTC, 1 replies.
- Re: [PR] [FLINK-37153] Monitor late event count in temporal join [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:27:32 UTC, 1 replies.
- Re: [PR] [FLINK-37207][runtime] Don't clear distributed cache in StreamExecutionEnvironment.configure [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/26 06:28:13 UTC, 1 replies.
- [PR] [FLINK-37850][table] Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/26 06:53:34 UTC, 3 replies.
- Re: [PR] [FLINK-37780][5/N] predict sql function type inference and validation [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2025/05/26 07:07:39 UTC, 6 replies.
- [jira] [Resolved] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver) - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/26 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37851) Migrate state processor API from source API v1 to source API v2 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/26 08:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37849) Model provider factory discover - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 11:55:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37849) Model provider factory discover - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 11:55:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37849) Model provider factory discover - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/26 11:56:00 UTC, 0 replies.
- [PR] [FLINK-37730] Improve exception recording ts initialization + 2.0 compatibility [flink-kubernetes-operator] - posted by "gyfora (via GitHub)" <gi...@apache.org> on 2025/05/26 14:19:04 UTC, 8 replies.
- [jira] [Commented] (FLINK-37823) Add Python 3.12 support - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/26 16:34:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2025/05/26 17:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37852) SQL Server CDC cannot capture changes from tables with special characters - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2025/05/26 17:55:00 UTC, 0 replies.
- [PR] [FLINK-37843][python] Fix version of protobuf used for code generation [flink] - posted by "autophagy (via GitHub)" <gi...@apache.org> on 2025/05/26 18:27:09 UTC, 2 replies.
- [jira] [Updated] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/26 18:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/05/26 19:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists - posted by "Jerome Gagnon (Jira)" <ji...@apache.org> on 2025/05/26 19:49:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists - posted by "Jerome Gagnon (Jira)" <ji...@apache.org> on 2025/05/26 19:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists - posted by "Jerome Gagnon (Jira)" <ji...@apache.org> on 2025/05/26 19:50:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37845) Remove FlinkRexBuilder#makeIn - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 20:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37845) Remove FlinkRexBuilder#makeIn - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/26 20:27:00 UTC, 0 replies.
- Re: [PR] [FLINK-37223] Add the missing documents and parameters of MySQL CDC. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/27 00:04:49 UTC, 2 replies.
- Re: [PR] [FLINK-37465][docs] Update options for OceanBase connector [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/27 01:29:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37465) [Docs] Update options for oceanbase connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/27 01:30:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/05/27 01:48:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/27 02:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/27 02:08:00 UTC, 1 replies.
- Re: [PR] [FLINK-35713][common] Support set parallelism in source and sink [flink-cdc] - posted by "ChaomingZhangCN (via GitHub)" <gi...@apache.org> on 2025/05/27 03:01:54 UTC, 0 replies.
- [jira] [Created] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2025/05/27 03:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-37604] Generate static UIDs for pipeline operators [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/27 04:19:10 UTC, 2 replies.
- [PR] [hotfix][docs] Support any column as chunk key column (postgres, orcale, db2, sqlserver) [flink-cdc] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2025/05/27 04:36:29 UTC, 1 replies.
- [jira] [Closed] (FLINK-37820) AsyncScalarFunction UDFs cannot be loaded via CompiledPlan - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/27 05:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-37125] [conf] fixed env.log.max java.lang.NumberFormatException [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/27 06:25:37 UTC, 1 replies.
- Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/27 06:25:39 UTC, 1 replies.
- [PR] [FLINK-37560][FLINK-37561][events] Report a bunch of system events and document events reporting system [flink] - posted by "pnowojski (via GitHub)" <gi...@apache.org> on 2025/05/27 07:12:43 UTC, 15 replies.
- [jira] [Updated] (FLINK-37560) Document events reporting - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/27 07:13:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2025/05/27 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37855) Reduce the time cost in MySqlSchemaUtils#listTables - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/27 08:29:00 UTC, 0 replies.
- [PR] [FLINK-37763][table] Support multiple table arguments in PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2025/05/27 08:38:20 UTC, 7 replies.
- [jira] [Updated] (FLINK-37763) Support multiple tables with set semantics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/27 08:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37730) Collect job exceptions as kubernetes events - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/27 08:39:00 UTC, 0 replies.
- Re: [PR] [hotfix] Update META-INF/NOTICE files [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/27 08:45:30 UTC, 0 replies.
- [jira] [Created] (FLINK-37856) Sink option hints are not present in compiled plan - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/27 09:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/05/27 09:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink - posted by "Poorvank Bhatia (Jira)" <ji...@apache.org> on 2025/05/27 09:55:00 UTC, 0 replies.
- [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/05/27 10:18:13 UTC, 10 replies.
- [jira] [Updated] (FLINK-37856) Sink option hints are not present in compiled plan - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/27 10:19:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/27 10:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/27 10:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/27 10:47:30 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/27 12:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37125) env.log.max Log4j java.lang.NumberFormatException - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/27 12:45:00 UTC, 1 replies.
- [PR] [release] Main branch updates after release cut [flink-kubernetes-operator] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/05/27 12:55:54 UTC, 1 replies.
- [jira] [Created] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/27 19:21:00 UTC, 0 replies.
- Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink] - posted by "cnauroth (via GitHub)" <gi...@apache.org> on 2025/05/27 20:07:27 UTC, 0 replies.
- [PR] [FLINK-37857][tests] Add a DSV2 sink implementation to tests which can collect data [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/05/27 21:12:41 UTC, 3 replies.
- [jira] [Updated] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/27 21:13:00 UTC, 1 replies.
- [jira] [Created] (FLINK-37858) Migrate state processor API from source v1 to source v2 API - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/27 21:18:00 UTC, 0 replies.
- [PR] [FLINK-37791][6/N] model sql to rel converter [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/28 00:13:15 UTC, 15 replies.
- [jira] [Updated] (FLINK-37791) Integrate with sql to rel converter - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/28 00:14:00 UTC, 0 replies.
- [PR] [hotfix]Adds Override annotation [flink] - posted by "luyizhizaio (via GitHub)" <gi...@apache.org> on 2025/05/28 03:09:09 UTC, 1 replies.
- [jira] [Updated] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 06:06:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 06:07:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 06:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 06:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 06:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37733) Externalise DynamoDB connector IT Test to E2E test package - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37688) FLIP-524: Amazon CloudWatch Metric Sink Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:09:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:11:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-37683) [Connector][AWS] SSO credentials fail because of shaded dependencies missing - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37648) Flink Kinesis connector lost track of 1 shard. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37273) Dynamodb Streams getRecords call adaptive delay - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37004) Implement Multithreaded SourceReader - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37563) Add additional metrics for DDB connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36971) Add Sqs Sink SQL connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36770) Support Request Timeout for AWS sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36828) Implement example for customers to perform KPL Deaggregation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36671) Kinesis Table API for new KDS source does not support metadata. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36770) Support Request Timeout for AWS sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36672) Kinesis Table API for new KDS source should infer region from streamARN - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36412) Retry strategies on Kinesis Sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36296) Add incremental shard discovery for DDB Streams source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36432) FLIP-438: Amazon SQS Source Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36359) IT case for DDB Streams connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-29311) Unable to use http for Kinesis consumer when testing locally - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31946) DynamoDB Sink Allow Multiple Item Writes - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34520) Confusing MIT language in the NOTICE file - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33132) Flink Connector Redshift Implementation (Table-API) - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32696) Promote Kinesis connector support to PublicEvolving - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34340) Implement DDB Streams Table API support - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-27941) [JUnit5 Migration] Module: flink-connector-kinesis - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35989) Document and log error on partially failed requests for AWS sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34023) Expose Kinesis client retry config in sink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26933) FlinkKinesisConsumer incorrectly determines shards as newly discovered when tested against Kinesalite when consuming DynamoDB streams - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25733) Create A migration guide for Kinesis Table API connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20294) Expose value format metadata in Kinesis table source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31854) FLIP-307:[Phase 1] [Sink Support] Flink Connector Redshift - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32097) Implement support for Kinesis deaggregation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35541) Introduce retry limiting for AWS connector sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-13291) Cannot provide AWS Direct Connect ENDPOINT - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20350) Incompatible Connectors due to Guava conflict - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-30092) Improve Table API experience for Flink DOUBLE type - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21228) Deadlock in KinesisProducer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36057) Allow specifying ARN for AWS connector resources - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26008) Update Kinesalite docker container reference - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-29549) Add Aws Glue Catalog support in Flink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-22473) Kinesis connector options are not listed by its factory - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31988) Implement Python wrapper for new KDS source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33991) Custom Error Handling for Kinesis Polling Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-32394) Init.pos is partially stored in connector state - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected in Kinesis Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-16839) Connectors Kinesis metrics can be disabled - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-31942) Support Conditional Writes in DynamoDB connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36947) Rate limiting the GetRecord call frequency - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37416) DDB Streams connector flink state inconsistency issue - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37416) DDB Streams connector flink state inconsistency issue - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36328) Making the log for child not found as debug - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36215) Child shards are getting started with LATEST shard iterator even when parents are not expired - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:21:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37858) Migrate state processor API from source v1 to source v2 API - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/28 07:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36195) Generalized retry configuration in flink-connector-base - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:25:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-36195) Generalized retry configuration in flink-connector-base - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:25:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36138) KinesisStreamsSource.build() should have helpful null errors - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36195) Generalized retry configuration in flink-connector-base - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35660) Implement parent-child ordering for DDB Streams source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34407) Flaky tests causing workflow timeout - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34892) Nightly AWS connectors build fails on running python tests - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:29:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:29:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:32:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26069) KinesisFirehoseSinkITCase failed due to org.testcontainers.containers.ContainerLaunchException: Container startup failed - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-25949) [FLIP-171] Kinesis Firehose sink builder falls back to wrong http protocol. - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-11042) testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-26300) KinesisFirehoseSinkITCase failed on azure IOException - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5953) Sample Kinesis Scala code doesn't work - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:35:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 07:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37853) FLIP-530: Dynamic job configuration - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2025/05/28 07:48:00 UTC, 0 replies.
- [PR] Bump connector version to 5.1.0 [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/28 07:58:43 UTC, 0 replies.
- [jira] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 09:30:00 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-37767][doc] Update reference branch/version for es connector [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2025/05/28 09:34:43 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-37767) Update ref version for es connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2025/05/28 09:36:00 UTC, 1 replies.
- [PR] [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws [flink-connector-aws] - posted by "hlteoh37 (via GitHub)" <gi...@apache.org> on 2025/05/28 09:46:57 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-37687) Bump flink-connector-aws to 2.0 - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2025/05/28 09:49:00 UTC, 0 replies.
- [PR] Develop [flink-connector-jdbc] - posted by "Biasqo (via GitHub)" <gi...@apache.org> on 2025/05/28 10:05:50 UTC, 0 replies.
- [jira] [Created] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly - posted by "MOBIN (Jira)" <ji...@apache.org> on 2025/05/28 11:18:00 UTC, 0 replies.
- [PR] [FLINK-37860][pipeline-connector/paimon]Fix Committer.createContext not passing OperatorStateStore correctly [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2025/05/28 11:19:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/28 11:20:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 11:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37821) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/28 11:40:00 UTC, 0 replies.
- [PR] Kubernetes Operator 1.12.0 release [flink-web] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/05/28 12:10:23 UTC, 9 replies.
- [jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/28 12:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/28 12:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2025/05/28 12:40:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37246) Delegation Token expire after enable delegation token framework - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/28 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37861) FLIP-520: Simplify StructuredType handling - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/05/28 13:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37701) The testRecoverLocallyFromProcessCrashWithWorkingDirectory test failed of azure cron adaptive scheduler pipeline - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2025/05/28 13:27:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/28 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37862) Implement data type improvements for StructuredType - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/05/28 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37863) DynamicKafkaSource support in PyFlink - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2025/05/28 15:28:00 UTC, 0 replies.
- [PR] [FLINK-37863] add DynamicKafkaSource interface [flink-connector-kafka] - posted by "lgo (via GitHub)" <gi...@apache.org> on 2025/05/28 15:30:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-37863) DynamicKafkaSource support in PyFlink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/28 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer - posted by "Joey Pereira (Jira)" <ji...@apache.org> on 2025/05/28 15:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/05/28 15:51:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37780) ml_predict sql function type inference and argument validation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/28 16:06:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37780) ml_predict sql function type inference and argument validation - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2025/05/28 16:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37812) Fix broken links to Apache Avro in doc and code - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/05/28 17:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2025/05/28 17:47:00 UTC, 0 replies.
- [PR] Bump commons-beanutils:commons-beanutils from 1.8.3 to 1.10.1.redhat-00001 in /flink-yarn [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/05/28 17:48:24 UTC, 1 replies.
- [PR] Bump commons-beanutils:commons-beanutils from 1.9.4 to 1.11.0 in /flink-filesystems/flink-s3-fs-presto [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2025/05/28 18:02:02 UTC, 1 replies.
- [PR] [FLINK-28847] Removed Extraneous Semicolon [flink] - posted by "rionmonster (via GitHub)" <gi...@apache.org> on 2025/05/28 18:40:50 UTC, 4 replies.
- [jira] [Updated] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/28 18:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28847) Typo in FileSinkProgram.java in file-sink-file-test module - posted by "Rion Williams (Jira)" <ji...@apache.org> on 2025/05/28 18:43:00 UTC, 0 replies.
- [PR] [hotfix] Fix typo in StreamingJobGraphGenerator config [flink] - posted by "nateab (via GitHub)" <gi...@apache.org> on 2025/05/28 19:24:15 UTC, 3 replies.
- [jira] [Closed] (FLINK-37763) Support multiple tables with set semantics - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2025/05/28 19:44:00 UTC, 0 replies.
- [PR] Flink 1.20 with Pulsar 3.0.12 [flink-connector-pulsar] - posted by "JohnBattista (via GitHub)" <gi...@apache.org> on 2025/05/28 20:49:40 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37865) Add documentation for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/29 00:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37865) Add documentation for AsyncTableFunction - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2025/05/29 00:13:00 UTC, 0 replies.
- [PR] [FLINK-37865] Adds documentation for AsyncTableFunction [flink] - posted by "AlanConfluent (via GitHub)" <gi...@apache.org> on 2025/05/29 00:22:17 UTC, 13 replies.
- [jira] [Updated] (FLINK-37865) Add documentation for AsyncTableFunction - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/29 00:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37863) DynamicKafkaSource support in PyFlink - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2025/05/29 01:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37812) Fix broken links to Apache Avro in doc and code - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2025/05/29 01:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/29 03:09:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/29 03:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/29 03:36:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/29 03:44:00 UTC, 0 replies.
- [PR] Model physical [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2025/05/29 04:37:21 UTC, 1 replies.
- [jira] [Resolved] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/29 06:52:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/29 06:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2025/05/29 06:52:00 UTC, 0 replies.
- [PR] [BP-2.0][FLINK-37761][runtime] Fix unstable test testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2025/05/29 07:28:15 UTC, 2 replies.
- [jira] [Created] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/05/29 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/05/29 08:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector - posted by "Daren Wong (Jira)" <ji...@apache.org> on 2025/05/29 08:35:00 UTC, 3 replies.
- [jira] [Created] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2025/05/29 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/05/29 09:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/05/29 09:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "junzhong qin (Jira)" <ji...@apache.org> on 2025/05/29 09:29:00 UTC, 3 replies.
- [PR] Flink 36112- testing [flink] - posted by "liangyu-1 (via GitHub)" <gi...@apache.org> on 2025/05/29 10:07:27 UTC, 6 replies.
- [jira] [Created] (FLINK-37870) Unaligned checkpoint is disabled unexpectedly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/05/29 10:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37869) FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/05/29 10:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/29 15:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] - posted by "kgeis (via GitHub)" <gi...@apache.org> on 2025/05/29 19:17:12 UTC, 0 replies.
- [jira] [Created] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/29 21:39:00 UTC, 0 replies.
- [PR] [FLINK-37871][table] Remove `FlinkRelMdUtil#getJoinDistinctRowCount` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/29 21:42:59 UTC, 2 replies.
- [jira] [Updated] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/29 21:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37872) Autoscaler computes negative true processing rate - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/05/29 22:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/30 02:04:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36188) HBase disable buffer flush lose efficacy - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 02:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util - posted by "Weihua Hu (Jira)" <ji...@apache.org> on 2025/05/30 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 03:06:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 03:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 03:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful - posted by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 03:14:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2025/05/30 03:56:00 UTC, 0 replies.
- [PR] Update the slack invitation link [flink-web] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2025/05/30 03:58:22 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/30 04:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37604) Flink CDC pipeline composer doesn't assign UIDs to operators - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/30 06:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37604) Flink CDC pipeline composer doesn't assign UIDs to operators - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/30 06:05:00 UTC, 0 replies.
- Re: [PR] [FLINK-37159][runtime] Fix the test timeout by yielding Modifier thread [flink] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2025/05/30 06:25:36 UTC, 1 replies.
- [jira] [Updated] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2025/05/30 07:30:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule - posted by "Stepan Stepanishchev (Jira)" <ji...@apache.org> on 2025/05/30 07:35:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2025/05/30 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37874) FLIP-519: Introduce async lookup key ordered mode - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/05/30 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37875) Introduce the option and the support of planner - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/05/30 08:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37875) Introduce the option and the support of planner - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/30 08:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-37874) FLIP-519: Introduce async lookup key ordered mode - posted by "dalongliu (Jira)" <ji...@apache.org> on 2025/05/30 08:02:00 UTC, 0 replies.
- [PR] [FLINK-37875][table] Introduce key ordered async lookup join in planner [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/05/30 08:15:36 UTC, 15 replies.
- [jira] [Updated] (FLINK-37875) Introduce the option and the support of planner - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/30 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37876) Introduce key ordered component in runtime - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/05/30 08:23:00 UTC, 0 replies.
- [PR] [FLINK-37876][table] Introduce async execution controller framework in table runtime [flink] - posted by "xishuaidelin (via GitHub)" <gi...@apache.org> on 2025/05/30 08:27:37 UTC, 1 replies.
- [jira] [Updated] (FLINK-37876) Introduce key ordered component in runtime - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/30 08:28:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-37877) Add the key ordered operator in table runtime - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/05/30 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37877) Add the key ordered operator in table runtime - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2025/05/30 08:32:00 UTC, 0 replies.
- [PR] [FLINK-37855-][cdc-connector-mysql] Reduce the time cost in MySqlSchemaUtils#listTables [flink-cdc] - posted by "zhyayun (via GitHub)" <gi...@apache.org> on 2025/05/30 08:39:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-37855) Reduce the time cost in MySqlSchemaUtils#listTables - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/30 08:40:00 UTC, 0 replies.
- [PR] [FLINK-37866] Migrate glue schema registry e2e test to use aws-kinesis-streams connector [flink-connector-aws] - posted by "darenwkt (via GitHub)" <gi...@apache.org> on 2025/05/30 08:53:53 UTC, 0 replies.
- [jira] [Created] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 10:13:00 UTC, 0 replies.
- [PR] Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/30 10:16:18 UTC, 1 replies.
- [PR] [FLINK-37870][checkpoint] Fix the bug that unaligned checkpoint is disabled for all connections unexpectedly [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2025/05/30 10:32:26 UTC, 5 replies.
- [PR] Add Flink 1.19.3 release [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/30 11:18:38 UTC, 0 replies.
- [jira] [Created] (FLINK-37879) transform concat function don't support utf-8 and cast don't support STRING - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/05/30 13:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-37879) transform concat function don't support utf-8 and cast don't support STRING - posted by "Xin Gong (Jira)" <ji...@apache.org> on 2025/05/30 13:06:00 UTC, 0 replies.
- [PR] [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/05/30 13:11:05 UTC, 2 replies.
- [jira] [Updated] (FLINK-37851) Migrate state processor API from source API v1 to source API v2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/30 13:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-37878][table] Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2025/05/30 13:42:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2025/05/30 13:43:00 UTC, 0 replies.
- [PR] Add Flink 1.20.2 release [flink-web] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2025/05/30 17:55:16 UTC, 0 replies.
- [jira] [Created] (FLINK-37880) build_wheels_on_macos fails every time - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 18:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-37880) build_wheels_on_macos fails every time - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2025/05/30 19:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 19:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 19:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 19:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2025/05/30 19:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-37872) Autoscaler computes negative true processing rate - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2025/05/30 20:16:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-37856) Sink option hints are not present in compiled plan - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2025/05/31 07:38:00 UTC, 0 replies.
- Re: [PR] [WIP][FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2025/05/31 07:42:57 UTC, 2 replies.
- [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [2.0] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2025/05/31 07:43:48 UTC, 1 replies.
- [jira] [Assigned] (FLINK-37872) Autoscaler computes negative true processing rate - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2025/05/31 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-37881) Drop gosu in favour of Dockerfile's USER - posted by "Avi Sanwal (Jira)" <ji...@apache.org> on 2025/05/31 12:54:00 UTC, 0 replies.