issues@flink.apache.org, 2024-12

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

- [jira] [Updated] (FLINK-36684) Support read changelog as append only mode for MySQL CDC connector - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/12/01 00:22:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-36573) Add table information of binlog offsets when checkpointing - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/12/01 00:27:00 UTC, 1 replies.
- Re: [PR] [FLINK-33265] Support source parallelism setting for Kafka connector [flink-connector-kafka] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/01 00:27:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-36683) Support metadata 'row_kind' virtual column for Mongo CDC Connector - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/12/01 00:28:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36681) Wrong chunks splitting query in incremental snapshot reading section in mysql cdc doc - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/12/01 00:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-36682][mysql][mongodb] Add scan.chunk.assign.strategy to avoid OOM exception. [flink-cdc] - posted by "herunkang2018 (via GitHub)" <gi...@apache.org> on 2024/12/01 00:49:46 UTC, 3 replies.
- Re: [PR] [FLINK-36442][postgres-cdc] Add insert-only change stream option [flink-cdc] - posted by "herunkang2018 (via GitHub)" <gi...@apache.org> on 2024/12/01 01:16:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36442) Add option to handle insert-only changeless in Postgres CDC connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/01 01:17:00 UTC, 0 replies.
- [PR] [FLINK-34467] add lineage integration for jdbc connector [flink-connector-jdbc] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2024/12/01 05:25:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-36805) Add support for using encrypted passwords in pipeline definitions - posted by "Eaugene Thomas (Jira)" <ji...@apache.org> on 2024/12/01 05:33:00 UTC, 1 replies.
- Re: [PR] [FLINK-33571][table] Override json-path version for Calcite 1.32 to deal with CVE [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/01 15:34:25 UTC, 2 replies.
- Re: [PR] [FLINK-35490] Migrate tests to JUnit 5 and AssertJ [flink-cdc] - posted by "morazow (via GitHub)" <gi...@apache.org> on 2024/12/01 23:49:40 UTC, 1 replies.
- Re: [PR] [cdc-connector][db2]Flink cdc pipeline support db2 source [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/02 00:04:38 UTC, 1 replies.
- Re: [PR] [FLINK-36097][Connectors/Mongodb] Add timeseries support for SampleSplitter [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2024/12/02 01:19:15 UTC, 0 replies.
- Re: [PR] [FLINK-36075] Add pagination partitioning strategy [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2024/12/02 01:23:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36075) Add paginate partition strategy for mongodb connector - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/12/02 01:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/02 02:09:00 UTC, 0 replies.
- Re: [PR] [FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18 [flink] - posted by "simplejason (via GitHub)" <gi...@apache.org> on 2024/12/02 03:03:43 UTC, 11 replies.
- [jira] [Commented] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/02 03:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-36792][table] Remove FlinkJoinPushExpressionsRule. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/02 03:36:10 UTC, 2 replies.
- [jira] [Updated] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/02 03:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/02 03:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/02 03:46:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36647) Support TimestampDiff function in cdc pipeline transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/02 03:48:00 UTC, 0 replies.
- Re: [PR] [FLINK-36756][sql-gateway] Bump up the sql gateway rest version [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/02 03:50:41 UTC, 2 replies.
- [jira] [Assigned] (FLINK-36758) Introduce driver to load the application in application mode - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/02 03:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-36739] [WebFrontend] Update the NodeJS to v22.11.0 (LTS) [flink] - posted by "simplejason (via GitHub)" <gi...@apache.org> on 2024/12/02 05:34:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-36739) Update NodeJS to v22 (LTS) - posted by "Jason TANG (Jira)" <ji...@apache.org> on 2024/12/02 05:40:00 UTC, 1 replies.
- Re: [PR] [FLINK-28897] [TABLE-SQL] Fail to use udf in added jar when enabling checkpoint [flink] - posted by "ammu20-dev (via GitHub)" <gi...@apache.org> on 2024/12/02 05:47:35 UTC, 23 replies.
- [jira] [Created] (FLINK-36823) Drain state requests after the user function perform snapshotState - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/02 06:50:00 UTC, 0 replies.
- [PR] [FLINK-36823][Checkpointing] Drain state requests after the user function perform snapshotState [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/02 07:00:52 UTC, 2 replies.
- [jira] [Updated] (FLINK-36823) Drain state requests after the user function perform snapshotState - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/02 07:01:00 UTC, 0 replies.
- Re: [PR] [FLINK-36194][Runtime] Handle the Graceful close of ExecutionGraphInfoStore from ClusterEntrypoint [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/02 07:27:51 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/02 08:05:00 UTC, 0 replies.
- [PR] [FLINK-36824][table] Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/02 08:10:14 UTC, 3 replies.
- [jira] [Updated] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/02 08:11:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-35156) Wire new operators for async state with DataStream V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/02 08:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35156) Wire new operators for async state with DataStream V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/02 08:15:00 UTC, 1 replies.
- Re: [PR] [FLINK-36803][cdc-connector][base] Use the same format `tableId:chunkId` for splitId in SnapshotSplit [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/02 08:37:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36803) Use fixed format for SnapshotSplit's splitId in all connectors - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/02 08:38:00 UTC, 0 replies.
- Re: [PR] [tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/02 08:38:33 UTC, 0 replies.
- Re: [PR] [FLINK-36625] add lineage helper class for connector integration [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/02 08:43:33 UTC, 10 replies.
- Re: [PR] [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/02 08:45:34 UTC, 5 replies.
- [jira] [Updated] (FLINK-36773) Introduce new Group Agg Operator with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/02 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36825) Introduce FastTop1Function in Rank with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/02 08:55:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36021) Delegating the responsibility for compression to every tier - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36591) WikipediaEditsSourceTest fails in all cases - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:10:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36161) Integration Test Example uses deprecated SinkFunction - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:11:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/02 09:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36825) Introduce FastTop1Function in Rank with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/02 09:17:00 UTC, 2 replies.
- Re: [PR] [FLINK-36535][autoscaler] Optimize the scale down logic based on historical parallelism to reduce the rescale frequency [flink-kubernetes-operator] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2024/12/02 09:18:19 UTC, 4 replies.
- [PR] [FLINK-36825][table] Introduce FastTop1Function in Rank with Async State API [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/02 09:23:16 UTC, 6 replies.
- [jira] [Updated] (FLINK-36739) Update NodeJS to v22 (LTS) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/12/02 09:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36739) Update NodeJS to v22 (LTS) - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/12/02 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36826) Default configurations fail all to start Flink java 17 images - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/12/02 09:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36826) Default configurations fail all to start Flink java 17 images - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/12/02 09:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36716) Address vulnerabilities in Flink UI - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/12/02 09:53:00 UTC, 2 replies.
- Re: [PR] [FLINK-36451][runtime] Replaces LeaderElection#hasLeadership with LeaderElection#runAsLeader [flink] - posted by "zentol (via GitHub)" <gi...@apache.org> on 2024/12/02 09:59:23 UTC, 7 replies.
- [jira] [Created] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page - posted by "Robin Moffatt (Jira)" <ji...@apache.org> on 2024/12/02 10:00:02 UTC, 0 replies.
- [PR] [FLINK-36827] CDC quickstart tidyup [flink-cdc] - posted by "rmoff (via GitHub)" <gi...@apache.org> on 2024/12/02 10:05:52 UTC, 3 replies.
- [jira] [Updated] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/02 10:06:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-36826) Default configurations fail to start Flink java 17 images - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/12/02 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36828) Implement example for customers to perform KPL Deaggregation - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/12/02 10:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/02 10:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36827) [Docs] Tidy up Flink CDC Doris/MySQL quickstart page - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/02 10:33:00 UTC, 0 replies.
- [PR] [FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2024/12/02 10:56:02 UTC, 33 replies.
- [jira] [Updated] (FLINK-36740) Update frontend dependencies to address vulnerabilities - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/02 10:57:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-36716) Address vulnerabilities in Flink UI - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/12/02 11:00:00 UTC, 6 replies.
- Re: [PR] [FLINK-33389][runtime] Support tasks balancing at slot level for Adaptive Scheduler [flink] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2024/12/02 11:02:48 UTC, 1 replies.
- Re: [PR] [FLINK-36821] Update to Kafka 3.9.0 [flink-connector-kafka] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/02 11:19:57 UTC, 3 replies.
- [PR] [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 to fi… [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/02 11:26:32 UTC, 0 replies.
- Re: [PR] [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 [1.20] [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/02 11:27:25 UTC, 0 replies.
- Re: [PR] [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 [1.19] [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/02 11:41:41 UTC, 1 replies.
- [jira] [Created] (FLINK-36829) Add better validation of pipeline config - posted by "Robin Moffatt (Jira)" <ji...@apache.org> on 2024/12/02 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36830) Overried json-path version used by Calcite Bridge - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/02 12:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36830) Override json-path version used by Calcite Bridge - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/02 12:10:00 UTC, 1 replies.
- Re: [PR] [FLINK-36830][table] Override json-path version in Calcite to deal with CVE [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/02 12:10:51 UTC, 3 replies.
- [PR] [docs] Cleanup pipeline example / remove 'will soon' from reference to transform support [flink-cdc] - posted by "rmoff (via GitHub)" <gi...@apache.org> on 2024/12/02 12:31:14 UTC, 0 replies.
- Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink] - posted by "MartijnVisser (via GitHub)" <gi...@apache.org> on 2024/12/02 13:09:38 UTC, 4 replies.
- [jira] [Commented] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/02 13:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/02 13:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/02 15:03:00 UTC, 2 replies.
- [PR] [docs] Fix ToC to include H1 [flink-cdc] - posted by "rmoff (via GitHub)" <gi...@apache.org> on 2024/12/02 15:40:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-36766) Use pyflink to create remote env - posted by "William Que (Jira)" <ji...@apache.org> on 2024/12/02 16:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36061) Support Apache iceberg for pipeline connector - posted by "Robin Moffatt (Jira)" <ji...@apache.org> on 2024/12/02 18:06:00 UTC, 0 replies.
- [PR] Update flink-architecture.md [flink] - posted by "harikamisetty (via GitHub)" <gi...@apache.org> on 2024/12/02 18:49:17 UTC, 4 replies.
- Re: [PR] [FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. [flink] - posted by "becketqin (via GitHub)" <gi...@apache.org> on 2024/12/02 21:51:29 UTC, 0 replies.
- Re: [PR] [FLINK-36688][table-planner] Sort metadata keys when reusing source [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/02 22:18:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/03 02:16:00 UTC, 0 replies.
- Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] - posted by "JNSimba (via GitHub)" <gi...@apache.org> on 2024/12/03 02:17:30 UTC, 0 replies.
- Re: [PR] [FLINK-36815][API] Fix series bugs of DSv2 [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/03 02:18:14 UTC, 0 replies.
- [jira] [Closed] (FLINK-36815) series bugs of DSv2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/03 02:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36535) Optimize the scale down logic based on historical parallelism - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/03 02:36:00 UTC, 0 replies.
- [PR] Update maxwell.md [flink] - posted by "Altku (via GitHub)" <gi...@apache.org> on 2024/12/03 02:52:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-36816) Support source parallelism setting for JDBC connector - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/03 02:55:00 UTC, 1 replies.
- [PR] [FLINK-35156][Runtime] Rework: Make operators of DataStream V2 integrate with async state processing framework [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/03 03:19:22 UTC, 5 replies.
- [jira] [Commented] (FLINK-36823) Drain state requests after the user function perform snapshotState - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/03 03:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36823) Drain state requests after the user function perform snapshotState - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/03 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36831) Introduce AppendOnlyTopNFunction in Rank with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/03 03:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36831) Introduce AppendOnlyTopNFunction in Rank with Async State API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/03 03:52:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36825) Introduce FastTop1Function in Rank with Async State API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/03 03:52:00 UTC, 0 replies.
- [PR] [FLINK-36831][table] Introduce AppendOnlyTopNFunction in Rank with Async State API [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/03 05:37:01 UTC, 2 replies.
- [jira] [Updated] (FLINK-36831) Introduce AppendOnlyTopNFunction in Rank with Async State API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 05:38:00 UTC, 0 replies.
- [PR] [FLINK-36758][sql-gateway] Introduce driver to load the application in application mode [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/03 05:47:46 UTC, 3 replies.
- [jira] [Updated] (FLINK-36758) Introduce driver to load the application in application mode - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 05:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36756) Bump up the sql-gateway rest api version - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/03 05:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36756) Bump up the sql-gateway rest api version - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/03 05:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36759) Intrdouce REST API to deploy script - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/03 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36832) Remove deprecated class in flink-connector-kafka - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/03 06:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36833) In the case of database sharding, the target table is created with the primary key plus the sharding key. - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/12/03 07:21:00 UTC, 0 replies.
- [PR] [FLINK-36832] Remove Deprecated classes and relevant tests. [flink-connector-kafka] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/03 07:22:49 UTC, 3 replies.
- [jira] [Updated] (FLINK-36832) Remove deprecated class in flink-connector-kafka - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36834) Custom data distribution key - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/12/03 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36835) Memory lease in flink-s3-fs module due to hadoop aws version 3.x - posted by "JinxinTang (Jira)" <ji...@apache.org> on 2024/12/03 07:40:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36826) Default configurations fail to start Flink java 17 images - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 07:46:00 UTC, 0 replies.
- [PR] [FLINK-36835][flink-s3-fs-hadoop] Fix memory lease in flink-s3-fs-hadoop [flink] - posted by "TJX2014 (via GitHub)" <gi...@apache.org> on 2024/12/03 07:56:28 UTC, 4 replies.
- [jira] [Updated] (FLINK-36835) Memory lease in flink-s3-fs module due to hadoop aws version 3.x - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 07:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36774) SQL gateway should support executing multiple SQL statements once - posted by "tim yu (Jira)" <ji...@apache.org> on 2024/12/03 08:02:00 UTC, 1 replies.
- Re: [PR] [FLINK-36783][table-planner] Use validated SqlNode in 'asQuery' while converting SqlCreateTableAS to CreateTableASOperation [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/03 08:06:07 UTC, 0 replies.
- [PR] [WIP] Introduce generalized watermarks [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2024/12/03 08:06:08 UTC, 2 replies.
- [jira] [Resolved] (FLINK-36783) CTAS from VALUES throws ValidatioonException - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/03 08:07:00 UTC, 0 replies.
- Re: [PR] [FLINK-36379] Improve (Global)Committer with UC disabled [1.20] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/03 09:16:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-36788) Add coverage for GlobalCommitter for SinkV2 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 09:17:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36379) Improve (Global)Committer with UC disabled - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 09:18:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36379) Improve (Global)Committer with UC disabled - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 09:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36788) Add coverage for GlobalCommitter for SinkV2 - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 09:18:00 UTC, 1 replies.
- [PR] [FLINK-36368] Do not prematurely merge CommittableManager (#25405) [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/03 09:27:30 UTC, 1 replies.
- [jira] [Created] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/12/03 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36837) Introduce new RowTimeDeduplicateFunction with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/03 09:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36837) Introduce RowTimeDeduplicateFunction with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/03 09:40:00 UTC, 1 replies.
- [PR] [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/03 09:53:45 UTC, 2 replies.
- [PR] [WIP][FLINK-35652] Shuffle input stream of lookup join based on LOOKUP hint [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/03 10:10:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 10:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/03 10:11:00 UTC, 0 replies.
- Re: [PR] [WIP][FLINK-35652] Support Custom Data Distribution for Input Stream of Lookup Join [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/03 10:18:25 UTC, 0 replies.
- Re: [PR] [FLINK-30371][Connector/JDBC] Fix the problem of JdbcOutputFormat database connection leak [flink-connector-jdbc] - posted by "tamirsagi (via GitHub)" <gi...@apache.org> on 2024/12/03 11:24:06 UTC, 5 replies.
- [jira] [Commented] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/12/03 11:27:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-36829) Add better validation of pipeline config - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/03 11:29:00 UTC, 0 replies.
- [PR] [FLINK-36759][sql-gateway] Add REST API to deploy script in application mode [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/03 11:37:25 UTC, 3 replies.
- [jira] [Updated] (FLINK-36759) Intrdouce REST API to deploy script - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 11:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35156) Wire new operators for async state with DataStream V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/03 11:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35156) Wire new operators for async state with DataStream V2 - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/03 11:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-36771][cdc-base][mysql] Fix UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] [flink-cdc] - posted by "gong (via GitHub)" <gi...@apache.org> on 2024/12/03 12:02:40 UTC, 1 replies.
- [PR] [WIP] Introduce Generalized Watermark for DSv2 [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2024/12/03 12:37:15 UTC, 6 replies.
- [jira] [Created] (FLINK-36838) [state] Join background threads when ForSt state backend quit - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/03 12:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-36780] Kafka source disables partition discovery unexpectedly [flink-connector-kafka] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/03 13:11:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-36780) Kafka source disable partition discovery unexpectedly - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 13:19:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36780) Kafka source disable partition discovery unexpectedly - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/03 13:19:00 UTC, 0 replies.
- [PR] [FLINK-36838][state] Join background threads when ForSt state backend quit [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/03 14:10:03 UTC, 2 replies.
- [jira] [Updated] (FLINK-36838) [state] Join background threads when ForSt state backend quit - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 14:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-33761][Connector/JDBC] Add Snowflake JDBC Dialect [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/03 14:50:48 UTC, 4 replies.
- Re: [PR] [FLINK-36816] Support source parallelism setting for JDBC connector [flink-connector-jdbc] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/03 15:01:17 UTC, 0 replies.
- Re: [PR] [FLINK-36702][sql-gateway] Introduce ScripExecutor to run the script [flink] - posted by "hackergin (via GitHub)" <gi...@apache.org> on 2024/12/03 15:03:32 UTC, 5 replies.
- Re: [PR] [FLINK-35114] Remove old Table API implementations, update Table API and Schema stack [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2024/12/03 16:17:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35114) Remove old Table API implementations, update Schema stack - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35114) Remove old Table API implementations, update Schema stack - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34929) Create "flink-connector-kudu" repository - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34931) Update Kudu DataStream connector to use Sink V2 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35114) Remove old Table API implementations, update Schema stack - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35114) Remove old Table API implementations, update Schema stack - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36839) Update Kudu version to 1.17.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/03 16:37:00 UTC, 0 replies.
- [PR] [FLINK-36839] Update Kudu version to 1.17.1 [flink-connector-kudu] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2024/12/03 16:45:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-36839) Update Kudu version to 1.17.1 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 16:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-19059) Support to consume retractions for OVER WINDOW operator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/12/03 17:29:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-19059) Support to consume retractions for OVER WINDOW operator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/12/03 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36840) Multiple time-related built-in functions cannot be called - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/03 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36841) Incorrect error message for CURRENT_TIMESTAMP - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/03 19:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36841) Incorrect error message for CURRENT_TIMESTAMP - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/03 19:17:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36841) Incorrect error message for functions without parenthesis - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/03 19:19:00 UTC, 0 replies.
- [PR] [FLINK-36809][table] Add correct call syntax for functions without () [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2024/12/03 19:59:22 UTC, 9 replies.
- [jira] [Commented] (FLINK-36098) Add support for Table Comments in Flink SQL ALTER TABLE statements - posted by "Alexey Leonov-Vendrovskiy (Jira)" <ji...@apache.org> on 2024/12/03 21:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36098) Add support for Table Comments in Flink SQL ALTER TABLE statements - posted by "Alexey Leonov-Vendrovskiy (Jira)" <ji...@apache.org> on 2024/12/03 21:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36842) FlinkPipelineComposer allows injecting StreamExecutionEnvironment - posted by "Max Feng (Jira)" <ji...@apache.org> on 2024/12/03 22:29:00 UTC, 0 replies.
- [PR] [FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment [flink-cdc] - posted by "maxf-decodable (via GitHub)" <gi...@apache.org> on 2024/12/03 22:37:54 UTC, 1 replies.
- [jira] [Updated] (FLINK-36842) FlinkPipelineComposer allows injecting StreamExecutionEnvironment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/03 22:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/12/04 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36843) Remove deprecated method in flink-table-planner - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/04 02:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36838) [state] Join background threads when ForSt state backend quit - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/04 02:41:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36838) [state] Join background threads when ForSt state backend quit - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/04 02:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-36315][cdc-base]The flink-cdc-base module supports source metric statistics [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/04 02:54:23 UTC, 3 replies.
- [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] - posted by "uicosp (via GitHub)" <gi...@apache.org> on 2024/12/04 03:56:44 UTC, 4 replies.
- [jira] [Updated] (FLINK-36165) Support capturing snapshot data with conditions - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/04 03:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/04 04:01:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35385) upgrader flink dependency version to 1.19 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/04 04:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35385) upgrader flink dependency version to 1.19 - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/04 04:06:00 UTC, 0 replies.
- Re: [PR] [hotfix][core] Simplify Histogram [flink] - posted by "klistopad (via GitHub)" <gi...@apache.org> on 2024/12/04 07:09:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/04 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36844) Postgres CDC document add mapping from postgres timestamp_tz to flink timestamp ltz - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/04 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36845) SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/04 08:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36845) SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/04 08:28:00 UTC, 2 replies.
- [PR] Flink 33387 33388 draft2 for CI [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/04 08:47:33 UTC, 5 replies.
- [jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support - posted by "Cheng Pan (Jira)" <ji...@apache.org> on 2024/12/04 08:56:00 UTC, 0 replies.
- [PR] [FLINK-36845][flink-connector-test-utils] Set operatorUid to CollectStreamSink in SinkTestSuiteBase/SourceTestSuiteBase. [flink] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/04 09:09:20 UTC, 6 replies.
- [jira] [Created] (FLINK-36846) Composer support add custom Operator after Source - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/12/04 09:23:00 UTC, 0 replies.
- [PR] [FLINK-36648] Bump Flink version to Flink 2.0-preview1 [flink-connector-kafka] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/04 09:46:42 UTC, 2 replies.
- [jira] [Updated] (FLINK-36648) Release flink-connector-kafka v4.0.0 for Flink 2.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/04 09:47:00 UTC, 0 replies.
- [PR] [hotfix][config] Do not use deprecated configs in example config.yaml [flink] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/12/04 10:02:07 UTC, 3 replies.
- Re: [PR] [FLINK-35652] Support Custom Data Distribution for Input Stream of Lookup Join [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/04 10:07:01 UTC, 14 replies.
- [PR] Flink 33387 33388 draft1 poc [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/04 10:25:15 UTC, 0 replies.
- Re: [PR] Flink 33387 33388 draft1 for CI [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/04 10:32:33 UTC, 2 replies.
- [PR] [FLINK-36072][runtime] Sort-merge shuffle supports accumulating small buffers to reduce network overhead. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/04 11:12:11 UTC, 7 replies.
- [jira] [Updated] (FLINK-36072) Optimizing the Overhead of the Network Layer in Adaptive Execution Scenarios - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/04 11:13:00 UTC, 0 replies.
- [PR] [FLINK-36836][Autoscaler] Supports config the upper and lower limits of target utilization [flink-kubernetes-operator] - posted by "huyuanfeng2018 (via GitHub)" <gi...@apache.org> on 2024/12/04 11:24:53 UTC, 20 replies.
- [jira] [Updated] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/04 11:25:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36845) SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/04 11:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36817) Give users ability to provide their own KafkaConsumer when using flink-connector-kafka - posted by "david radley (Jira)" <ji...@apache.org> on 2024/12/04 11:52:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-6131) Add side inputs for DataStream API - posted by "Salva (Jira)" <ji...@apache.org> on 2024/12/04 12:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36640) Provide an easy way to reset autoscaling - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/12/04 12:23:00 UTC, 0 replies.
- Re: [PR] [FLINK-36840][table] Add correct call syntax for functions without () [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/04 12:57:38 UTC, 1 replies.
- [jira] [Updated] (FLINK-36840) Multiple time-related built-in functions cannot be called - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/04 12:58:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36840) Multiple time-related built-in functions cannot be called - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 12:59:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36840) Multiple time-related built-in functions cannot be called - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 12:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36840) Multiple time-related built-in functions cannot be called - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 12:59:00 UTC, 0 replies.
- [PR] solve bash-java-utils.sh can't get "env.java.home" in "config.yaml" since 1.20 [flink] - posted by "chn5944 (via GitHub)" <gi...@apache.org> on 2024/12/04 13:05:52 UTC, 14 replies.
- Re: [PR] [FLINK-36822][build] Enable spotless for java 21 [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/04 14:29:41 UTC, 8 replies.
- Re: [PR] [FLINK-36679][runtime] Add a metric to track checkpoint _metadata size [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/04 16:18:58 UTC, 2 replies.
- [jira] [Commented] (FLINK-36664) [Window]The window with window_offset will lose data. - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/04 16:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-36664][Window]Window with offset need deal offset when cal nextTriggerWatermark. [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/04 16:35:04 UTC, 9 replies.
- [jira] [Commented] (FLINK-36663) [Window]The first processWatermark() after Sliding Window restore may have extra expired data. - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/04 16:36:00 UTC, 0 replies.
- Re: [PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2024/12/04 16:36:24 UTC, 4 replies.
- [jira] [Assigned] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 16:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36675) Dynamic option hints will not take effect when restoring exec plan from json plan without setting 'table.plan.compile.catalog-objects' to 'all' - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/12/04 17:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/04 18:29:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.779 to fix vulnerability - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:02:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:02:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36688) table.optimizer.reuse-source-enabled may cause disordered metadata columns when reading from Kafka. - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36689) [UI] Upgrade runtime web Angular framework and associated deps to latest version - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/12/04 22:11:00 UTC, 0 replies.
- [PR] Bump d3-color, @antv/g-base and d3-interpolate in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 22:12:41 UTC, 6 replies.
- [PR] Bump ws and socket.io in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/04 22:16:01 UTC, 5 replies.
- [jira] [Commented] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:32:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/04 22:32:00 UTC, 0 replies.
- Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 00:04:43 UTC, 4 replies.
- Re: [PR] Handle map and array types binary record data [flink-cdc] - posted by "umeshdangat (via GitHub)" <gi...@apache.org> on 2024/12/05 00:59:42 UTC, 9 replies.
- [jira] [Created] (FLINK-36847) Table API toDataStream() cannot be converted to an enum type field - posted by "LuJiang (Jira)" <ji...@apache.org> on 2024/12/05 02:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36676) Flink CDC SQL Server Connector Missing Data - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/05 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/05 03:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/05 03:44:00 UTC, 2 replies.
- [PR] [FLINK-36848][table] Remove FlinkLimit0RemoveRule [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/05 03:46:25 UTC, 7 replies.
- Re: [PR] [FLINK-35472] Improve tests for Elasticsearch 8 connector [flink-connector-elasticsearch] - posted by "liuml07 (via GitHub)" <gi...@apache.org> on 2024/12/05 05:38:23 UTC, 1 replies.
- [jira] [Created] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/05 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36850) Adapting batch job progress recovery with StreamGraph adaptive optimization - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/05 06:30:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36850) Adapting batch job progress recovery with StreamGraph adaptive optimization - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/05 06:30:00 UTC, 0 replies.
- [PR] [FLINK-36849][table] Introduce AppendOnlyFirstNFunction in Rank with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/05 06:48:30 UTC, 5 replies.
- [jira] [Updated] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 06:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/05 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36851) Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/05 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/05 06:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/05 07:02:00 UTC, 0 replies.
- [PR] [FLINK-xx][table] Algin Calcite Rules. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/05 07:05:46 UTC, 3 replies.
- [jira] [Created] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/05 07:15:00 UTC, 0 replies.
- [PR] [FLINK-34974][state] Support getOrCreateKeyedState for AsyncKeyedStateBackend [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/05 07:19:09 UTC, 7 replies.
- [jira] [Updated] (FLINK-34974) FLIP-424: Asynchronous State APIs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 07:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-22155][table] EXPLAIN statement should validate insert and query separately [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/05 07:34:58 UTC, 0 replies.
- Re: [PR] [FLINK-36593][runtime] Upgrade io.airlift:aircompressor to 0.27 [1.20] [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 07:48:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 07:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 07:50:00 UTC, 0 replies.
- [PR] [FLINK-36852][pipeline-connector-paimon] Set independent MemoryPoolFactory for each table to avoid StackOverflow error. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/05 08:03:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-36852) Avoid StackOverflowError in Paimon Pipeline sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 08:04:00 UTC, 0 replies.
- [PR] Flink 36798 [flink-cdc] - posted by "rodeo-rider (via GitHub)" <gi...@apache.org> on 2024/12/05 08:37:30 UTC, 1 replies.
- Re: [PR] Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 08:40:13 UTC, 3 replies.
- Re: [PR] [FLINK-36790][cdc-connector][paimon] set waitCompaction with true dur… [flink-cdc] - posted by "stayrascal (via GitHub)" <gi...@apache.org> on 2024/12/05 08:51:09 UTC, 4 replies.
- Re: [PR] [FLINK-36368] Do not prematurely merge CommittableManager [1.19] (#25405) [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 08:52:52 UTC, 1 replies.
- [jira] [Updated] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/12/05 08:54:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36733) Don't transition task to RUNNING until the inputs are recovered (UC) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/12/05 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36854) Column comments and default expressions gone after being transformed - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/05 10:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36854) Column comments and default expressions gone after being transformed - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/05 10:50:00 UTC, 1 replies.
- Re: [PR] [WIP][table] Algin Calcite Rules. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/05 11:24:02 UTC, 2 replies.
- Re: [PR] [FLINK-36484] [TABLE-SQL] Remove deprecated methods StreamTableEnvironment#registerFunction [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 11:33:07 UTC, 2 replies.
- Re: [PR] [FLINK-36488] [TABLE SQL/API] Remove deprecated methods StreamTableEnvironment.toAppendStream from flink-table-api-java-bridge module [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 11:35:49 UTC, 1 replies.
- [PR] [FLINK-36854] Fix comments and default expressions missing after being transformed [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/05 11:47:30 UTC, 4 replies.
- [jira] [Updated] (FLINK-36854) Column comments and default expressions gone after being transformed - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 11:48:00 UTC, 1 replies.
- Re: [PR] [FLINK-36784][common] Support to add metadata columns for data in the meta fields of DataChangeEvent at transform [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/05 11:53:49 UTC, 8 replies.
- Re: [PR] [hotfix] [docs] Correct inaccurate description of JobMaster's role in Flink JobManager [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 12:09:07 UTC, 6 replies.
- Re: [PR] Add blogpost for new Prometheus connector [flink-web] - posted by "dannycranmer (via GitHub)" <gi...@apache.org> on 2024/12/05 12:31:22 UTC, 1 replies.
- Re: [PR] [FLINK-36455] Sinks retry synchronously [1.20] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/05 13:05:23 UTC, 2 replies.
- [jira] [Created] (FLINK-36855) Implement Source API in Kudu connector - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/05 13:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-36663][Window]Fix the first processWatermark has extra data after restore by restore timeService's watermark. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 14:04:15 UTC, 2 replies.
- Re: [PR] [FLINK-36675][table-planner] Always serialize dynamic options to exec json plan [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/05 14:18:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-36368) Fix subtask management in CommittableCollector - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/05 14:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36368) Fix subtask management in CommittableCollector - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/05 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/05 16:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/05 16:41:00 UTC, 0 replies.
- [PR] [FLINK-36379] Improve (Global)Committer with UC disabled [1.19] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/05 16:51:03 UTC, 2 replies.
- [PR] [FLINK-36455] Sinks retry synchronously [1.19] [flink] - posted by "AHeise (via GitHub)" <gi...@apache.org> on 2024/12/05 16:53:16 UTC, 2 replies.
- [jira] [Created] (FLINK-36857) Bump scala version to 2.12.20 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 17:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36857) Bump scala version to 2.12.20 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 17:19:00 UTC, 1 replies.
- [PR] [FLINK-36857] Bump scala version to 2.12.20 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 17:24:25 UTC, 14 replies.
- Re: [PR] [FLINK-36537] Bump snappy-java from 1.1.10.4 to 1.1.10.7 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 21:18:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36537) Bump snappy-java from 1.1.10.4 to 1.1.10.7 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 21:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36537) Bump snappy-java from 1.1.10.4 to 1.1.10.7 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/05 21:19:00 UTC, 0 replies.
- [PR] Bump org.apache.avro:avro from 1.8.2 to 1.11.4 in /flink-connectors/flink-connector-hive [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 21:19:28 UTC, 3 replies.
- [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.115.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 21:19:39 UTC, 3 replies.
- [PR] Bump cookie and socket.io in /flink-runtime-web/web-dashboard [flink] - posted by "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/05 21:19:59 UTC, 4 replies.
- Re: [PR] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 21:37:02 UTC, 2 replies.
- Re: [PR] [FLINK-33956] Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 21:40:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-33956) Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 21:41:00 UTC, 0 replies.
- Re: [PR] [FLINK-29420][Build] Upgrade Zookeeper to 3.7.2 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 21:42:01 UTC, 1 replies.
- Re: [PR] fix(sec): upgrade com.google.guava:guava to 32.0.0-jre [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/05 21:47:40 UTC, 1 replies.
- [PR] [FLINK-12173][table] Optimize SELECT DISTINCT [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/05 22:10:04 UTC, 23 replies.
- [jira] [Updated] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/05 22:11:00 UTC, 1 replies.
- Re: [PR] [FLINK-36224][docs] Add the version mapping between pipeline connectors and flink [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/06 00:04:27 UTC, 1 replies.
- [PR] [FLINK-19059]: Support non-time retract mode for OverAggregate operator [flink] - posted by "bvarghese1 (via GitHub)" <gi...@apache.org> on 2024/12/06 01:16:46 UTC, 4 replies.
- [jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success - posted by "Jake.zhang (Jira)" <ji...@apache.org> on 2024/12/06 01:44:00 UTC, 0 replies.
- Re: [PR] [FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/06 01:55:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-36315) The flink-cdc-base module supports source metric statistics - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/06 03:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36315) The flink-cdc-base module supports source metric statistics - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/06 03:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36811) MySQL CDC source set is processing backlog during snapshot phase - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/12/06 06:31:00 UTC, 1 replies.
- Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink] - posted by "kumar-mallikarjuna (via GitHub)" <gi...@apache.org> on 2024/12/06 07:14:06 UTC, 3 replies.
- [jira] [Created] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/06 07:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/06 07:29:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/06 07:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36379) Improve (Global)Committer with UC disabled - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/06 09:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/06 09:03:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/06 09:03:00 UTC, 1 replies.
- Re: [PR] [BP-3.2][docs] Update download links to up-to-date cdc version [flink-cdc] - posted by "GOODBOY008 (via GitHub)" <gi...@apache.org> on 2024/12/06 09:31:08 UTC, 4 replies.
- Re: [PR] [FLINK-36791][table] Remove FlinkPruneEmptyRules. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/06 09:58:40 UTC, 12 replies.
- Re: [PR] [FLINK-33387][runtime] Introduce the abstraction and the interface about loading [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/06 10:38:25 UTC, 1 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 2024/12/06 10:51:19 UTC, 3 replies.
- [jira] [Updated] (FLINK-33388) Support tasks balancing at TM level for Default Scheduler - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/06 10:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35519) Flink Job fails with SingleValueAggFunction received more than one element - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/06 11:23:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35519) Flink Job fails with SingleValueAggFunction received more than one element - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/06 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36859) Wrong epoch/watermark firing in async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/06 11:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/06 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36860) Adjust internal state v2 interface hierarchy - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/06 11:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36760) Support to deploy script via sql client - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/06 12:07:00 UTC, 0 replies.
- [PR] [FLINK-36760][sql-client] Supports to deploy script via sql client [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/06 12:13:24 UTC, 3 replies.
- [jira] [Updated] (FLINK-36760) Support to deploy script via sql client - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/06 12:14:00 UTC, 0 replies.
- [PR] [FLINK-36856][runtime] CollectSinkOperatorFactory batch size and socket timeout config fix [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2024/12/06 12:44:51 UTC, 14 replies.
- [jira] [Updated] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/06 12:45:00 UTC, 1 replies.
- Re: [PR] [FLINK-35966][runtime] Introduce the TASKS for TaskManagerLoadBalanceMode enum [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/06 12:48:42 UTC, 0 replies.
- [PR] [FLINK-36840][table] Add correct call syntax for functions without `()` [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2024/12/06 13:27:43 UTC, 8 replies.
- [jira] [Closed] (FLINK-36066) Introducing the AdaptiveGraphGenerator component - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2024/12/06 14:00:00 UTC, 0 replies.
- [PR] [FLINK-36612][core] Fix TypeSerializer to detect lombok boolean with is prefix [flink] - posted by "gaborgsomogyi (via GitHub)" <gi...@apache.org> on 2024/12/06 15:28:20 UTC, 7 replies.
- [jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/12/06 15:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36836) Autoscaler Supports config the upper and lower limits of target utilization. - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/06 16:14:00 UTC, 0 replies.
- [PR] Update blogpost for Prometheus connector [flink-web] - posted by "foxus (via GitHub)" <gi...@apache.org> on 2024/12/06 17:23:09 UTC, 0 replies.
- Re: [PR] [FLINK-35887][core] Fix the issue where the getSuperclass of an interface returns null without checking [flink] - posted by "bhales42 (via GitHub)" <gi...@apache.org> on 2024/12/06 18:21:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/06 20:01:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/06 20:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36861) CREATE TABLE AS with METADATA columns doesn't work - posted by "Sergio Peña (Jira)" <ji...@apache.org> on 2024/12/06 20:25:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36861) CREATE TABLE AS with METADATA columns doesn't work - posted by "Sergio Peña (Jira)" <ji...@apache.org> on 2024/12/06 20:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36822) Enable spotless for java 21 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/06 20:39:00 UTC, 0 replies.
- [PR] [FLINK-36861][table-planner] CREATE TABLE AS with METADATA columns doesn't work [flink] - posted by "spena (via GitHub)" <gi...@apache.org> on 2024/12/06 20:49:03 UTC, 8 replies.
- Re: [PR] [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/06 21:20:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34674) Migrate CalcSnapshotTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/06 21:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34674) Migrate CalcSnapshotTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/06 21:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36822) Enable spotless for java 21 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/06 21:22:00 UTC, 0 replies.
- Re: [PR] Update joining.md [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/06 21:32:42 UTC, 1 replies.
- [PR] [FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] - posted by "hanyuzheng7 (via GitHub)" <gi...@apache.org> on 2024/12/06 21:40:34 UTC, 61 replies.
- [jira] [Updated] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/06 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36862) Implement additional TO_TIMESTAMP_LTZ() functions - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/06 21:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36830) Override json-path version used by Calcite Bridge - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/06 22:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36862) Implement additional TO_TIMESTAMP_LTZ() functions - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/12/06 23:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36862) Implement additional TO_TIMESTAMP_LTZ() functions - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/07 00:03:00 UTC, 3 replies.
- Re: [PR] use lazy initialization to resolve circular dependency between the `DataFieldSerializer`, `DataTypeSerializer`, and `RowTypeSerializer` classes that causes NPE for certain RowTypes like nested row type [flink-cdc] - posted by "umeshdangat (via GitHub)" <gi...@apache.org> on 2024/12/07 00:19:19 UTC, 0 replies.
- Re: [PR] [hotfix] Fixing flaky tests in flink-table-planner /hints [flink] - posted by "mihirgune (via GitHub)" <gi...@apache.org> on 2024/12/07 04:42:13 UTC, 0 replies.
- [PR] [FLINK-36860][State/v2] Make internal list state inherit the internal merging state [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/07 04:52:19 UTC, 4 replies.
- [jira] [Updated] (FLINK-36860) Adjust internal state v2 interface hierarchy - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/07 04:53:00 UTC, 0 replies.
- [PR] [FLINK-36859][Runtime] Fix wrong epoch/watermark firing in async state processing [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/07 09:29:18 UTC, 3 replies.
- [jira] [Updated] (FLINK-36859) Wrong epoch/watermark firing in async state processing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/07 09:30:00 UTC, 0 replies.
- Re: [PR] [docs] Update download links to up-to-date cdc version [flink-cdc] - posted by "GOODBOY008 (via GitHub)" <gi...@apache.org> on 2024/12/07 10:14:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-33117) a wrong scala example in udfs page - posted by "cuiyanxiang (Jira)" <ji...@apache.org> on 2024/12/07 15:40:00 UTC, 2 replies.
- Re: [PR] Automatically convert flink CDC Version [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 00:04:59 UTC, 3 replies.
- Re: [PR] [minor][test] Remove duplicate test code [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 00:05:08 UTC, 2 replies.
- Re: [PR] [cdc-connector][oracle]Flink cdc pipeline support oracle source [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/08 00:05:10 UTC, 0 replies.
- Re: [PR] [FLINK-35857] fix redeploy failed deployment without latest checkpoint [flink-kubernetes-operator] - posted by "chenyuzhi459 (via GitHub)" <gi...@apache.org> on 2024/12/08 02:51:01 UTC, 1 replies.
- Re: [PR] [FLINK-36282][pipeline-connector][cdc-connector][mysql]fix incorrect data type of TINYINT(1) in mysql pipeline connector [flink-cdc] - posted by "boerzi (via GitHub)" <gi...@apache.org> on 2024/12/08 03:22:09 UTC, 0 replies.
- [PR] [FLINK-35745] add documentation for flink lineage [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2024/12/08 06:17:59 UTC, 25 replies.
- [jira] [Updated] (FLINK-35745) Add namespace convention doc for Flink lineage - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/08 06:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-36634][table] Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime. [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2024/12/08 09:16:14 UTC, 4 replies.
- [jira] [Commented] (FLINK-36508) Remove all deprecated methods in `SymbolType ` - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/08 13:40:00 UTC, 1 replies.
- Re: [PR] [HOTFIX] Fix avro specification link in Docs [flink] - posted by "henneberger (via GitHub)" <gi...@apache.org> on 2024/12/08 18:35:04 UTC, 0 replies.
- Re: [PR] [HOTFIX][docs] Fix avro specification link in Docs [flink] - posted by "henneberger (via GitHub)" <gi...@apache.org> on 2024/12/08 18:52:09 UTC, 0 replies.
- Re: [PR] [FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/09 00:05:01 UTC, 3 replies.
- [jira] [Created] (FLINK-36863) Use the maximum parallelism in the past scale-down.interval window when scaling down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/09 02:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36863) Use the maximum parallelism in the past scale-down.interval window when scaling down - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/09 02:59:00 UTC, 4 replies.
- [jira] [Resolved] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/09 03:10:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36859) Wrong epoch/watermark firing in async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/09 03:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36859) Wrong epoch/watermark firing in async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/09 03:16:00 UTC, 0 replies.
- [PR] [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down [flink-kubernetes-operator] - posted by "1996fanrui (via GitHub)" <gi...@apache.org> on 2024/12/09 03:25:16 UTC, 3 replies.
- [jira] [Created] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/09 03:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled - posted by "Aniruddh J (Jira)" <ji...@apache.org> on 2024/12/09 05:53:00 UTC, 0 replies.
- Re: [PR] [FLINK-36749][state/forst] Implement rescaling for ForStStateBackend [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/09 06:09:12 UTC, 4 replies.
- [jira] [Resolved] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/09 07:29:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35652) FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/09 07:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails - posted by "yanpengshi (Jira)" <ji...@apache.org> on 2024/12/09 07:46:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails - posted by "yanpengshi (Jira)" <ji...@apache.org> on 2024/12/09 07:46:00 UTC, 0 replies.
- [PR] [FLINK-36862][table] Implement additional TO_TIMESTAMP_LTZ() functions [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/09 07:49:46 UTC, 189 replies.
- [jira] [Created] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/09 08:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36866) Support more CDC YAML numeric casting paths - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/09 08:19:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36866) Support more CDC YAML numeric casting paths - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/09 08:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36866) Support more CDC YAML numeric casting paths - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/09 08:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 08:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 08:33:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 08:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 08:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 08:34:00 UTC, 0 replies.
- [PR] [FLINK-36858][pipeline-connector][kafka] Fix compatibility with Flink 1.20 JsonRowDataSerializationSchema [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2024/12/09 08:42:11 UTC, 6 replies.
- Re: [PR] [FLINK-36757][sql-gateway] Introduce ScripExecutor to run the script [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/09 09:15:25 UTC, 2 replies.
- [jira] [Updated] (FLINK-36757) Introduce ScripExecutor to run the script - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/09 09:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36867) flink on k8s operator could not create TM - posted by "周龙华 (Jira)" <ji...@apache.org> on 2024/12/09 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36867) flink on k8s operator could not create TM - posted by "周龙华 (Jira)" <ji...@apache.org> on 2024/12/09 09:51:00 UTC, 0 replies.
- [PR] [FLINK-36864] Fix unable to use numeric literals that goes beyond Int32 range [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/09 09:52:36 UTC, 2 replies.
- [jira] [Updated] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/09 09:53:00 UTC, 1 replies.
- Re: [PR] [FLINK-36546] Handle batch sources in DataSinkTranslator [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/09 11:54:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36868) Provide file system methods with string parameters for ForSt JNI - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/09 12:18:00 UTC, 0 replies.
- [PR] [FLINK-36866] Fix unable to narrow casting on numeric values [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/09 12:49:40 UTC, 12 replies.
- [jira] [Updated] (FLINK-36866) Support more CDC YAML numeric casting paths - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/09 12:50:00 UTC, 1 replies.
- [PR] [FLINK-36851][table] Introduce TemporalProcessTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/09 12:51:50 UTC, 23 replies.
- [jira] [Created] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/09 13:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36856) CollectSinkOperatorFactory is not respecting batch size and socket timeout configs - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/09 13:15:00 UTC, 0 replies.
- [PR] [hotfix] [docs] Fix the google-java-format level in docs in line with PR 25714 [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/09 13:15:23 UTC, 12 replies.
- [jira] [Resolved] (FLINK-36845) SourceTestSuiteBase/SinkTestSuiteBase will fail with `this operator belongs to is not initialized` error - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/09 13:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36866) Support more CDC YAML numeric casting paths - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/09 13:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/09 13:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/09 13:41:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36861) CREATE TABLE AS with METADATA columns doesn't work - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/09 13:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36830) Override json-path version used by Calcite Bridge - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/09 14:07:00 UTC, 0 replies.
- Re: [PR] [hotfix][Connector/Elasticsearch] Update version to 3.1-SNAPSHOT [flink-connector-elasticsearch] - posted by "dannycranmer (via GitHub)" <gi...@apache.org> on 2024/12/09 15:19:43 UTC, 1 replies.
- [PR] [FLINK-36651][Connectors/Elasticsearch] Fix IT test not compatible with 1.20, drop main branch tests for 1.18 [flink-connector-elasticsearch] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2024/12/09 15:35:19 UTC, 2 replies.
- [PR] [BP-1.20][FLINK-36451][runtime] Replaces LeaderElection#hasLeadership with LeaderElection#runAsLeader [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/09 16:27:39 UTC, 8 replies.
- [jira] [Commented] (FLINK-36870) Start scale down timer after initial scale up - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/09 16:28:00 UTC, 2 replies.
- [jira] [Created] (FLINK-36870) Start scale down timer after initial scale up - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/09 16:28:00 UTC, 0 replies.
- [PR] [BP-1.19][FLINK-36451][runtime] Replaces LeaderElection#hasLeadership with LeaderElection#runAsLeader [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/09 16:28:23 UTC, 9 replies.
- [jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/09 16:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/12/09 17:22:00 UTC, 0 replies.
- Re: [PR] [FLINK-17183][table] support 'create table [if not exists]' syntax [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/09 18:31:48 UTC, 1 replies.
- Re: [PR] [FLINK-18704][table] Add DECIMAL type in datagen [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/09 18:39:58 UTC, 1 replies.
- [PR] [docs] Fix Apache Avro Specification Link. [flink] - posted by "donPain (via GitHub)" <gi...@apache.org> on 2024/12/09 20:28:00 UTC, 2 replies.
- [PR] [FLINK-36871] add rescale metrics in scheduler [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2024/12/09 23:32:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/09 23:33:00 UTC, 0 replies.
- Re: [PR] [WIP][FLINK-36871] add rescale metrics in scheduler [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/09 23:52:03 UTC, 7 replies.
- [jira] [Created] (FLINK-36872) The standby jobmanager webui cannot view the taskmanager logs - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/12/10 01:53:00 UTC, 0 replies.
- [PR] bkbase flink [flink] - posted by "37-pro (via GitHub)" <gi...@apache.org> on 2024/12/10 02:25:38 UTC, 3 replies.
- Re: [PR] [FLINK-34545][cdc-pipeline-connector]Add OceanBase pipeline connector to Flink CDC [flink-cdc] - posted by "yuanoOo (via GitHub)" <gi...@apache.org> on 2024/12/10 02:33:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-36860) Adjust internal state v2 interface hierarchy - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/10 03:30:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36860) Adjust internal state v2 interface hierarchy - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/10 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/12/10 04:03:00 UTC, 0 replies.
- [PR] [FLINK-36868][State] Provide file system methods with string parameters for ForSt JNI [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/10 05:41:43 UTC, 13 replies.
- [jira] [Updated] (FLINK-36868) Provide file system methods with string parameters for ForSt JNI - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 05:42:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/12/10 06:16:00 UTC, 3 replies.
- [jira] [Created] (FLINK-36874) KafkaSourceBuilder in pyflink did not implement setDeserializer() method - posted by "Shuyi Chen (Jira)" <ji...@apache.org> on 2024/12/10 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36875) Complete timer before emiting watermark - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/10 06:48:00 UTC, 0 replies.
- [PR] [FLINK-34973][runtime] Complete timer before emitting watermark [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/10 06:53:04 UTC, 4 replies.
- [jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 06:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-36508][table-common] Remove all deprecated methods in SymbolType [flink] - posted by "lajith2006 (via GitHub)" <gi...@apache.org> on 2024/12/10 06:54:20 UTC, 3 replies.
- [jira] [Updated] (FLINK-36508) Remove all deprecated methods in `SymbolType ` - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36876) Operator Heap Memory Leak - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/12/10 08:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36876) Operator Heap Memory Leak - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/12/10 08:02:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default - posted by "Cheng Pan (Jira)" <ji...@apache.org> on 2024/12/10 08:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36876) Operator Heap Memory Leak - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/12/10 08:49:00 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-36876) Operator Heap Memory Leak - posted by "chenyuzhi (Jira)" <ji...@apache.org> on 2024/12/10 08:52:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36877) Kafka Sink output canal-json format of deleted record is incorrect format. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/10 09:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36877) Kafka Sink output canal-json format of deleted record is incorrect format. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/10 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/10 09:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/10 09:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36879) CDC yaml transform supports to convert delete as insert - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/10 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36879) CDC yaml transform supports to convert delete as insert - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/10 09:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36876) Operator Heap Memory Leak - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/12/10 09:26:00 UTC, 0 replies.
- [PR] [FLINK-36879][runtime] Support to convert delete as insert in transform [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/10 09:31:16 UTC, 20 replies.
- [jira] [Updated] (FLINK-36879) CDC yaml transform supports to convert delete as insert - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 09:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36854) Column comments and default expressions gone after being transformed - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/10 09:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/10 09:54:00 UTC, 1 replies.
- [PR] [hotfix] [gitignore] ignore .vscode folder in .gitignore [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/10 10:22:16 UTC, 2 replies.
- Re: [PR] [FLINK-36745][docs] Make FixedSizeSplitFetcherManager and FixedFetcherSizeSourceReader examples match Flink 2.0-preview API [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2024/12/10 10:48:35 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/10 10:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/10 10:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/10 10:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36745) Code snippets on the Data Sources page use deprecated (and removed in 2.0) APIs - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/10 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36880) Hybrid Shuffle support batch job recovery - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/12/10 11:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36880) Hybrid Shuffle support batch job recovery - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/10 11:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/10 11:09:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21 - posted by "david radley (Jira)" <ji...@apache.org> on 2024/12/10 11:19:00 UTC, 0 replies.
- Re: [PR] [FLINK-36875][runtime] Complete timer before emitting watermark [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/10 12:01:22 UTC, 8 replies.
- [jira] [Updated] (FLINK-36875) Complete timer before emiting watermark - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 12:02:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36869) Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/10 12:04:00 UTC, 1 replies.
- [PR] [FLINK-36877][pipeline-connector-kafka] Fix the output of canal-json for Kafka Sink when the record is deleted record. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/10 12:25:14 UTC, 2 replies.
- [PR] [hotfix] Remove Java 8 in README [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/10 12:25:23 UTC, 3 replies.
- [jira] [Updated] (FLINK-36877) Kafka Sink output canal-json format of deleted record is incorrect format. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 12:26:00 UTC, 0 replies.
- [PR] [FLINK-36869][table] Introduce TemporalRowTimeJoinOperator in TemporalJoin with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/10 12:34:15 UTC, 1 replies.
- [jira] [Created] (FLINK-36881) Introduce GroupTableAggFunction in GroupTableAggregate with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/10 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/10 13:04:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36849) Introduce AppendOnlyFirstNFunction in Rank with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/10 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36883) Views should keep the time attributes of the query - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/10 13:27:00 UTC, 0 replies.
- [PR] [FLINK-366883] Adapt time attributes from the VIEWs query [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2024/12/10 13:31:20 UTC, 5 replies.
- Re: [PR] [hotfix][docs] Fix Apache Avro Specification Link. [flink] - posted by "donPain (via GitHub)" <gi...@apache.org> on 2024/12/10 13:33:48 UTC, 16 replies.
- Re: [PR] [FLINK-36883] Adapt time attributes from the VIEWs query [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2024/12/10 14:26:10 UTC, 8 replies.
- [jira] [Updated] (FLINK-36883) Views should keep the time attributes of the query - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/10 14:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/10 14:37:00 UTC, 1 replies.
- [jira] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/10 14:57:00 UTC, 0 replies.
- [jira] (FLINK-35792) Sorting by proctime does not work in rank - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/10 14:57:00 UTC, 0 replies.
- [PR] Flink 1.20 test [flink] - posted by "37-pro (via GitHub)" <gi...@apache.org> on 2024/12/10 15:35:31 UTC, 1 replies.
- [PR] Flink 1.20 for bkbase [flink] - posted by "37-pro (via GitHub)" <gi...@apache.org> on 2024/12/10 15:47:50 UTC, 1 replies.
- Re: [PR] [FLINK-30284][flink-metrics] Adding datacenter url property to datadog [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/10 18:08:23 UTC, 3 replies.
- [jira] [Created] (FLINK-36884) GCS 503 Error Codes for `flink-checkpoints//shared/` file after upload complete - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2024/12/10 18:57:00 UTC, 0 replies.
- Re: [PR] [fix-issue-2676] repair a snapshot-split bug: [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/11 00:04:42 UTC, 1 replies.
- Re: [PR] [legal] Add third-party OSS NOTICE [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/11 01:11:51 UTC, 2 replies.
- [PR] Flink 1.20 for bkbase [flink] - posted by "37-pro (via GitHub)" <gi...@apache.org> on 2024/12/11 01:50:19 UTC, 2 replies.
- [PR] [FLINK-36738][Connectors/MongoDB][test] Fix Weekly CI for MongoDB connector fails on jdk21 [flink-connector-mongodb] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2024/12/11 02:09:33 UTC, 1 replies.
- [jira] [Updated] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 02:10:00 UTC, 0 replies.
- [PR] [FLINK-36878][pipeline-connector][kafka] Shade org.apache.kafka with … [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/11 02:45:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 02:46:00 UTC, 0 replies.
- [PR] [FLINK-36611][pipeline-connector][kafka] Add schema info to output of Kafka sink [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2024/12/11 02:57:08 UTC, 2 replies.
- [jira] [Updated] (FLINK-36611) Add schema info to output of Kafka sink - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 02:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36757) Introduce ScripExecutor to run the script - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/11 03:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36757) Introduce ScripExecutor to run the script - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/11 03:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/12/11 03:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-33927) Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS) - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/12/11 03:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36878) Shade kafka dependency in cdc yaml with the same path as sql connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/11 03:41:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36738) Weekly CI for MongoDB connector fails on jdk21 - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/12/11 04:02:00 UTC, 0 replies.
- Re: [PR] [FLINK-33927][table] Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS) [flink] - posted by "liyubin117 (via GitHub)" <gi...@apache.org> on 2024/12/11 04:20:02 UTC, 1 replies.
- Re: [PR] [FLINK-33921][table] Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig [flink] - posted by "liyubin117 (via GitHub)" <gi...@apache.org> on 2024/12/11 04:56:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-36480) Remove all deprecated methods in `TableConfig` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/11 05:09:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36480) Remove all deprecated methods in `TableConfig` - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/12/11 05:15:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36868) Provide file system methods with string parameters for ForSt JNI - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/11 06:09:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36868) Provide file system methods with string parameters for ForSt JNI - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/11 06:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36875) Complete timer before emiting watermark - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/11 06:13:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-33927) Cleanup usage of deprecated ExecutionConfigOptions#(TABLE_EXEC_SHUFFLE_MODE, TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS) - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/12/11 06:17:00 UTC, 0 replies.
- [PR] [hotfix] Remove broken MySQL incremental sources used in tests [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/11 06:17:24 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2024/12/11 06:22:00 UTC, 0 replies.
- [PR] [FLINK-36761][docs] Add document about how to use SQL Gateway and SQL Client to deploy script [flink] - posted by "fsk119 (via GitHub)" <gi...@apache.org> on 2024/12/11 06:29:43 UTC, 11 replies.
- [jira] [Updated] (FLINK-36761) Add document about how to deploy script with SQL Client and SQL Gateway - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 06:30:00 UTC, 0 replies.
- Re: [PR] [cdc-pipeline-connector][mysql] Fix precision problem of BIT type conversion [flink-cdc] - posted by "Sukang1002 (via GitHub)" <gi...@apache.org> on 2024/12/11 06:30:47 UTC, 1 replies.
- Re: [PR] [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA… [flink] - posted by "chenshaojin (via GitHub)" <gi...@apache.org> on 2024/12/11 06:43:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large. - posted by "林健昌 (Jira)" <ji...@apache.org> on 2024/12/11 07:06:00 UTC, 0 replies.
- [PR] [hotfix] Remove requiremenet for java 8 in docs [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/11 08:01:11 UTC, 3 replies.
- [PR] [FLINK-36881][table] Introduce GroupTableAggFunction in GroupTableAggregate with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/11 08:44:34 UTC, 21 replies.
- [PR] [FLINK-36883] Adapt time attributes from the VIEWs query (#25779) [flink] - posted by "dawidwys (via GitHub)" <gi...@apache.org> on 2024/12/11 08:45:54 UTC, 4 replies.
- [jira] [Updated] (FLINK-33921) Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/12/11 08:47:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/11 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5 - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/11 08:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-33921][table] Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig [flink] - posted by "liyubin117 (via GitHub)" <gi...@apache.org> on 2024/12/11 08:52:27 UTC, 5 replies.
- [jira] [Created] (FLINK-36886) Support interruptible timers with async state processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/11 08:53:00 UTC, 0 replies.
- [PR] [FLINK-36876] Support external eventLoopGroup for RestClient [flink] - posted by "chenyuzhi459 (via GitHub)" <gi...@apache.org> on 2024/12/11 08:56:14 UTC, 11 replies.
- [jira] [Assigned] (FLINK-35472) Improve tests for Elasticsearch 8 connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/11 08:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35472) Improve tests for Elasticsearch 8 connector - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/11 08:58:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36861) CREATE TABLE AS with METADATA columns doesn't work - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/11 09:17:00 UTC, 0 replies.
- Re: [PR] [FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc] - posted by "AppleJunJiang (via GitHub)" <gi...@apache.org> on 2024/12/11 10:13:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-35670) Support Postgres CDC Pipeline Source - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 10:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-36068][runtime] Support scheduling based on adaptive job graph. [flink] - posted by "zhuzhurk (via GitHub)" <gi...@apache.org> on 2024/12/11 10:19:25 UTC, 1 replies.
- [PR] [FLINK-36811][mysql] MySQL cdc setIsProcessingBacklog in snapshot phase and exit when snapshot phase finished [flink-cdc] - posted by "Shawn-Hx (via GitHub)" <gi...@apache.org> on 2024/12/11 11:06:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 11:33:00 UTC, 0 replies.
- Re: [PR] [FLINK-34672][runtime] Fixes deadlock risk in DefaultLeaderElectionService [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/11 11:33:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/11 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/11 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 15:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 15:38:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 15:39:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 15:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/11 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist' - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/11 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/11 16:26:00 UTC, 0 replies.
- [PR] [FLINK-36890] Update observedGeneration on NOOP reconciliation [flink-kubernetes-operator] - posted by "mxm (via GitHub)" <gi...@apache.org> on 2024/12/11 16:28:15 UTC, 4 replies.
- [jira] [Updated] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 16:29:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2024/12/11 17:05:00 UTC, 0 replies.
- [jira] (FLINK-34369) Elasticsearch connector supports SSL context - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/12/11 18:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34369) Elasticsearch connector supports SSL context - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/12/11 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2024/12/11 19:40:00 UTC, 0 replies.
- [PR] FLINK-36891: MySQL CDC connector produces corrupted state in case of serialization failure [flink-cdc] - posted by "morozov (via GitHub)" <gi...@apache.org> on 2024/12/11 20:01:49 UTC, 6 replies.
- [jira] [Updated] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/11 20:02:00 UTC, 2 replies.
- Re: [PR] [hotfix] Update weekly CI to v4.0 [flink-connector-hbase] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2024/12/11 20:07:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-36875) Complete timer before emiting watermark - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/12 02:42:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36875) Complete timer before emiting watermark - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/12 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36892) Properly handle the watermark status - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/12 03:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36892) Properly handle the watermark status - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/12 03:56:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist' - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2024/12/12 04:21:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36893) Support periodic full checkpoint - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/12/12 05:31:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35257) optimize the handling of schema.change.behavior as EXCEPTION - posted by "yanghuai (Jira)" <ji...@apache.org> on 2024/12/12 06:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35257) When schema.change.behavior is exception, the task should throw an exception failure after all downstream data is flushed. - posted by "yanghuai (Jira)" <ji...@apache.org> on 2024/12/12 06:26:00 UTC, 1 replies.
- [PR] [FLINK-35257][cdc-runtime]when schema.change.behavior is `exception`,… [flink-cdc] - posted by "yanghuaiGit (via GitHub)" <gi...@apache.org> on 2024/12/12 06:30:54 UTC, 2 replies.
- [jira] [Commented] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/12 06:45:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36775) fetchSize set in OracleIncrementalSource is not working - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36778) losing data when using rowid as the chunk key column in OracleIncrementalSource.java - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36776) OracleIncrementalSource does not support partitioned table - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:51:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36775) fetchSize set in OracleIncrementalSource is not working - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36777) The implementation of getting chunk key column in ChunkUtils.java is weired - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36778) losing data when using rowid as the chunk key column in OracleIncrementalSource.java - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:53:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36776) OracleIncrementalSource does not support partitioned table - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36894) rowId comparision is incorrect in oracle connector - posted by "shaohui hong (Jira)" <ji...@apache.org> on 2024/12/12 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/12/12 07:26:00 UTC, 0 replies.
- [PR] [FLINK-36895] The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2024/12/12 07:29:40 UTC, 2 replies.
- [jira] [Updated] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/12 07:30:00 UTC, 3 replies.
- [PR] [FlinkFLINK-36895]The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. [flink-cdc] - posted by "Mrart (via GitHub)" <gi...@apache.org> on 2024/12/12 07:35:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34369) Elasticsearch connector supports SSL context - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 07:56:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist' - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/12 08:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/12 08:22:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-34273) git fetch fails on CI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/12 08:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36883) Views should keep the time attributes of the query - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/12/12 08:36:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/12 08:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36753) Adaptive Scheduler actively triggers a Checkpoint - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2024/12/12 08:48:00 UTC, 0 replies.
- [PR] [FLINK-36067][runtime] Support optimize stream graph based on input info. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/12 08:49:41 UTC, 16 replies.
- [jira] [Updated] (FLINK-36067) Introducing the StreamGraphOptimizer component - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/12 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36896) Table API trim expression incorrectly translated to SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 08:52:00 UTC, 0 replies.
- [PR] [FLINK-36896] Table API trim expression incorrectly translated to SQL [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/12 08:56:30 UTC, 0 replies.
- [jira] [Updated] (FLINK-36896) Table API trim expression incorrectly translated to SQL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/12 08:57:00 UTC, 0 replies.
- [PR] [FLINK-36892][Runtime] Properly handle the watermark status within async state processing [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/12 09:06:07 UTC, 25 replies.
- Re: [PR] [FLINK-36896][table] Table API trim expression incorrectly translated to SQL [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/12 09:12:08 UTC, 3 replies.
- Re: [PR] [WIP][FLINK-36862][table] Implement additional TO_TIMESTAMP_LTZ() functions [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/12 09:46:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/12/12 10:28:00 UTC, 3 replies.
- Re: [PR] [FLINK-36578][MySQL] Added modified JsonStringFormatter and option use.legacy.json.format [flink-cdc] - posted by "SML0127 (via GitHub)" <gi...@apache.org> on 2024/12/12 10:47:14 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36068) Support for adaptive job scheduling based on StreamGraph - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/12 10:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36068) Support for adaptive job scheduling based on StreamGraph - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/12 10:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36067) Support optimize stream graph based on input info. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/12 11:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation - posted by "liudu (Jira)" <ji...@apache.org> on 2024/12/12 11:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36896) Table API trim expression incorrectly translated to SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 12:25:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36896) Table API trim expression incorrectly translated to SQL - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 12:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-36690][runtime] Fix schema operator hanging under extreme parallelized pressure [flink-cdc] - posted by "Shawn-Hx (via GitHub)" <gi...@apache.org> on 2024/12/12 13:03:08 UTC, 3 replies.
- [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file - posted by "Adam Domański (Jira)" <ji...@apache.org> on 2024/12/12 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36897) Error in calling processElement for AbstractAsynchronous StateStreamOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/12 13:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/12 13:40:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36893) Support periodic full checkpoint - posted by "Ryan van Huuksloot (Jira)" <ji...@apache.org> on 2024/12/12 15:23:00 UTC, 3 replies.
- Re: [PR] [FLINK-36499][table]Remove deprecated method `SupportsProjectionPushD… [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/12 16:11:48 UTC, 1 replies.
- Re: [PR] [FLINK-36497][table]Remove all deprecated methods `CatalogTable` [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/12 16:23:40 UTC, 0 replies.
- Re: [PR] [FLINK-36504][table]Remove all deprecated methods `ModuleFactory` [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/12 16:26:29 UTC, 0 replies.
- Re: [PR] [FLINK-36617] migrate kyro package [flink] - posted by "tomncooper (via GitHub)" <gi...@apache.org> on 2024/12/12 16:32:12 UTC, 3 replies.
- [jira] [Closed] (FLINK-36893) Support periodic full checkpoint - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/12/12 17:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/12/12 17:31:00 UTC, 0 replies.
- Re: [PR] [hotfix] Various hotfixes from a static code analysis [flink] - posted by "rmetzger (via GitHub)" <gi...@apache.org> on 2024/12/12 17:40:54 UTC, 0 replies.
- Re: [PR] [FLINK-34602][table] Migrate StreamPhysicalWindowJoinRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/12 19:58:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-34602) Migrate StreamPhysicalWindowJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 20:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34602) Migrate StreamPhysicalWindowJoinRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 20:00:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 20:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 20:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/12 20:02:00 UTC, 0 replies.
- Re: [PR] [BP-1.17][FLINK-31839][filesystems] Fix flink-s3-fs-hadoop and flink-s3-fs-presto plugin collision [flink] - posted by "mschonmeier (via GitHub)" <gi...@apache.org> on 2024/12/12 20:58:59 UTC, 1 replies.
- [jira] [Created] (FLINK-36898) Support SQL FLOOR and CEIL functions with NanoSecond - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2024/12/13 01:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36898) Support SQL FLOOR and CEIL functions with NanoSecond - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2024/12/13 01:11:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-36898) Support SQL FLOOR and CEIL functions with NanoSecond for TIMESTAMP_TLZ - posted by "Hanyu Zheng (Jira)" <ji...@apache.org> on 2024/12/13 01:43:00 UTC, 4 replies.
- Re: [PR] [FLINK-36575][runtime] ExecutionVertexInputInfo supports consuming subpartition groups [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/13 02:10:14 UTC, 13 replies.
- [jira] [Closed] (FLINK-36072) Optimizing the Overhead of the Network Layer in Adaptive Execution Scenarios - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/13 02:15:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36576) Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/13 03:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/13 03:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/13 03:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/13 03:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/13 04:07:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36899) Introduce metrics for cache - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/13 04:25:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36819) [state/forst] Support link() in ForStFlinkFileSystem - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/13 04:26:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36819) [state/forst] Support link() in ForStFlinkFileSystem - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/13 04:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/12/13 06:07:00 UTC, 3 replies.
- Re: [PR] [FLINK-36871][runtime] add rescale metrics in scheduler [flink] - posted by "HuangZhenQiu (via GitHub)" <gi...@apache.org> on 2024/12/13 06:26:37 UTC, 6 replies.
- Re: [PR] [FLINK-34688][cdc-connector] CDC framework split snapshot chunks asynchronously [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/13 06:49:16 UTC, 5 replies.
- [jira] [Assigned] (FLINK-36771) Flink cdc UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/13 07:14:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36771) Flink cdc UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/13 07:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-36009] Architecture tests refactor [flink-connector-jdbc] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/13 08:32:19 UTC, 2 replies.
- Re: [PR] [FLINK-36742][cdc-base][oracle] Filter unacked split for no capture tables when task restore from state [flink-cdc] - posted by "gong (via GitHub)" <gi...@apache.org> on 2024/12/13 09:40:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/13 10:06:00 UTC, 1 replies.
- [PR] [FLINK-36763 / 36690][runtime] Support new "distributed" schema evolution topology & fix parallelized hang glitch [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/13 10:13:55 UTC, 21 replies.
- [jira] [Updated] (FLINK-36763) Support schema inference and evolution with single-table-mutliple-partition sources - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/13 10:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36882) Introduce MiniBatchGroupAggFunction in GroupAggregate with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/13 10:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-30274) Upgrade commons-collections 3.x to commons-collections4 - posted by "Andrius Baltrunas (Jira)" <ji...@apache.org> on 2024/12/13 11:30:00 UTC, 0 replies.
- [PR] [FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent [flink-cdc] - posted by "Jzjsnow (via GitHub)" <gi...@apache.org> on 2024/12/13 11:48:13 UTC, 3 replies.
- [jira] [Updated] (FLINK-36701) Pipeline failover again after handling a schema change event as the first event after a failover - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/13 11:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/12/13 12:30:00 UTC, 6 replies.
- [PR] [FLINK-36889] Mention locking down a Flink cluster in the 'Production Readiness Checklist' [flink] - posted by "Samrat002 (via GitHub)" <gi...@apache.org> on 2024/12/13 12:31:10 UTC, 7 replies.
- [jira] [Updated] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist' - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/13 12:32:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-28867) Parquet reader support nested type in array/map type - posted by "Nicolas Ferrario (Jira)" <ji...@apache.org> on 2024/12/13 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Mika Naylor (Jira)" <ji...@apache.org> on 2024/12/13 15:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/12/13 15:17:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/13 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36901) Backport Update the NodeJS to v22.11.0 (LTS) - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/12/13 15:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36901) [Backport] Update the NodeJS to v22.11.0 (LTS) - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/12/13 15:44:00 UTC, 0 replies.
- [PR] [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2024/12/13 15:46:28 UTC, 0 replies.
- Re: [PR] [BP-1.20][FLINK-36739] Update the NodeJS to v22.11.0 (LTS) [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/13 15:51:51 UTC, 4 replies.
- [jira] [Updated] (FLINK-36716) Address vulnerabilities in Flink UI - posted by "Mehdi (Jira)" <ji...@apache.org> on 2024/12/13 16:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36900) Migrate away from Anaconda for managing Python environments for Flink Python - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/13 16:21:00 UTC, 2 replies.
- [jira] [Created] (FLINK-36902) Security Manager deprecation - posted by "Liam Miller-Cushon (Jira)" <ji...@apache.org> on 2024/12/13 21:40:00 UTC, 0 replies.
- Re: [PR] [FLINK-36452][mysql] Replace ArrayList with TreeSet to speed up searching of FinishedSnapshotSplitInfo for specific chunkKey. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/14 00:04:30 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/14 03:40:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/14 03:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-30975) Migrate aws sdk from v1 to v2 - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2024/12/14 06:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules - posted by "Samrat Deb (Jira)" <ji...@apache.org> on 2024/12/14 06:53:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-35068) Introduce built-in serialization support for Set - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-34123) Introduce built-in serialization support for Map and List - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:11:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-34123) Introduce built-in serialization support for Map and List - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:11:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-35068) Introduce built-in serialization support for Set - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35458) Flink 2.0: Add serializer upgrade test for set serializer - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:14:00 UTC, 2 replies.
- [jira] [Created] (FLINK-36903) Add switch for built-in serialization support for common collection types - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:14:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36903) Flink 2.0: Add switch for built-in serialization support for common collection types - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36904) Fix document error on how to programmatically configure serialization - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/14 13:38:00 UTC, 1 replies.
- [PR] [FLINK-36904] Fix document error on how to programmatically configure serialization [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2024/12/14 13:43:52 UTC, 5 replies.
- [PR] [FLINK-34124] Disable Kyro by default [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2024/12/14 14:43:11 UTC, 1 replies.
- [jira] [Updated] (FLINK-34124) Flink 2.0: Disable Kyro by default - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/14 14:44:00 UTC, 0 replies.
- [PR] [FLINK-34123][FLINK-35068][FLINK-36903] Introduce built-in serialization support for common collection types [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2024/12/14 16:18:55 UTC, 16 replies.
- [PR] [FLINK-36069][runtime/rest] Extending job detail rest API to expose json stream graph [flink] - posted by "yuchen-ecnu (via GitHub)" <gi...@apache.org> on 2024/12/15 13:24:41 UTC, 45 replies.
- [jira] [Updated] (FLINK-36069) Extending job detail rest API to adapt to Incremental JobGraph Generation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/15 13:25:00 UTC, 0 replies.
- [jira] (FLINK-35555) Serializing List with null values throws NPE - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/15 14:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/15 14:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19 [flink-connector-rabbitmq] - posted by "alenzo-arch (via GitHub)" <gi...@apache.org> on 2024/12/15 16:21:49 UTC, 1 replies.
- [jira] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation - posted by "liudu (Jira)" <ji...@apache.org> on 2024/12/16 01:29:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36897) Error executing processElement when inheriting from AbstractAsyncStateStreamOperator - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/16 02:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36892) Properly handle the watermark status - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/16 02:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36892) Properly handle the watermark status - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/16 02:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36904) Fix document error on how to programmatically configure serialization - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/16 05:21:00 UTC, 0 replies.
- [PR] [FLINK-36904][BP-1.20] Fix document error on how to programmatically configure serialization [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2024/12/16 05:27:20 UTC, 7 replies.
- [jira] [Created] (FLINK-36905) Update Chinese document to reflect the changes of FLIP-398 - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/16 05:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36906) Optimize the logic for determining if a split is finished. - posted by "xiaochen.zhou (Jira)" <ji...@apache.org> on 2024/12/16 05:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36906) Optimize the logic for determining if a split is finished. - posted by "xiaochen.zhou (Jira)" <ji...@apache.org> on 2024/12/16 05:37:00 UTC, 3 replies.
- [PR] [FLINK-36906] Optimize the logic for determining if a split is finished [flink-connector-kafka] - posted by "xiaochen-zhou (via GitHub)" <gi...@apache.org> on 2024/12/16 05:38:22 UTC, 3 replies.
- [PR] [hotfix][configuration] Remove the deprecated test class TaskManagerLoadBalanceModeTest. [flink] - posted by "RocMarshal (via GitHub)" <gi...@apache.org> on 2024/12/16 06:13:10 UTC, 10 replies.
- [jira] [Updated] (FLINK-36160) Support hive advanced configuration - posted by "zhuanshenbsj1 (Jira)" <ji...@apache.org> on 2024/12/16 06:46:00 UTC, 0 replies.
- Re: [PR] [FLINK-36160] Support hive advanced configuration [flink] - posted by "zhuanshenbsj1 (via GitHub)" <gi...@apache.org> on 2024/12/16 06:48:10 UTC, 5 replies.
- [PR] [FLINK-36887][hive] Bumping to 1.20.0 [flink-connector-hive] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/16 06:53:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/16 06:54:00 UTC, 1 replies.
- [PR] [BP-1.19][FLINK-35887][core] Fix NPE in TypeExtractor where getSuperclass from an interface returns null [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2024/12/16 08:13:51 UTC, 2 replies.
- [jira] [Resolved] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/16 08:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/16 08:46:00 UTC, 0 replies.
- [PR] [FLINK-35904][test] Test harness for async state processing operators [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/16 08:53:51 UTC, 2 replies.
- [jira] [Updated] (FLINK-35904) Test harness for async state processing operators - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/16 08:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36397) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics. - posted by "Zhongmin Qiao (Jira)" <ji...@apache.org> on 2024/12/16 09:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-35141][Connectors/Pulsar] Drop support for Flink 1.17 [flink-connector-pulsar] - posted by "dannycranmer (via GitHub)" <gi...@apache.org> on 2024/12/16 09:07:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36904) Fix document error on how to programmatically configure serialization - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/16 09:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/12/16 09:20:00 UTC, 0 replies.
- [PR] Reduce Number of Streams Fetched in StreamPatternSubscriber [flink-connector-kafka] - posted by "xiaochen-zhou (via GitHub)" <gi...@apache.org> on 2024/12/16 09:26:27 UTC, 1 replies.
- [PR] [BP-1.20][FLINK-35887][core] Fix NPE in TypeExtractor where getSuperclass from an interface returns null [flink] - posted by "dylanhz (via GitHub)" <gi...@apache.org> on 2024/12/16 09:37:10 UTC, 2 replies.
- [jira] [Created] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/16 09:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/12/16 09:44:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/16 10:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36908) All builds are failing - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36908) All builds are failing - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/12/16 10:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36908) All builds are failing when writing to S3 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 10:18:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36908) All builds are failing - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 10:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36908) All builds are failing when writing to S3 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 10:19:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/16 11:13:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36908) All builds are failing when writing to S3 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 12:36:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36908) All builds are failing when writing to S3 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/16 12:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/16 13:11:00 UTC, 1 replies.
- [PR] [FLINK-36070][flink-runtime-web] Modifying web UI to adapt to Incremental JobGraph Generation [flink] - posted by "yuchen-ecnu (via GitHub)" <gi...@apache.org> on 2024/12/16 16:43:24 UTC, 2 replies.
- [jira] [Updated] (FLINK-36070) Modifying web UI to adapt to Incremental JobGraph Generation - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/16 16:44:00 UTC, 0 replies.
- [PR] [FLINK-36706] Refactor TypeInferenceExtractor for PTFs [flink] - posted by "twalthr (via GitHub)" <gi...@apache.org> on 2024/12/16 20:49:41 UTC, 13 replies.
- [jira] [Updated] (FLINK-36706) Update TypeInferenceExtractor for PTFs - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/16 20:50:00 UTC, 0 replies.
- Re: [PR] [FLINK-36558] Fix column metadata parsing compatibility with MySQL 8.0.17 / 8.0.18 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/17 00:04:40 UTC, 1 replies.
- Re: [PR] Use Schema#newBuilder instead of TableSchema#fromResolvedSchema [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/17 00:05:16 UTC, 1 replies.
- [jira] [Updated] (FLINK-36909) Reduce Stream Creation in StreamPatternSubscriber - posted by "xiaochen.zhou (Jira)" <ji...@apache.org> on 2024/12/17 00:14:00 UTC, 3 replies.
- [jira] [Created] (FLINK-36909) Reduce Stream Creation in StreamPatternSubscriber - posted by "xiaochen.zhou (Jira)" <ji...@apache.org> on 2024/12/17 00:14:00 UTC, 0 replies.
- [PR] [FLINK-36909] Reduce Stream Creation in StreamPatternSubscriber [flink-connector-kafka] - posted by "xiaochen-zhou (via GitHub)" <gi...@apache.org> on 2024/12/17 00:15:37 UTC, 1 replies.
- [jira] [Created] (FLINK-36910) Support calling time-related dynamic functions with parenthesis - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/17 00:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36910) Support calling time-related dynamic functions with parenthesis - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/17 01:00:29 UTC, 1 replies.
- [PR] [FLINK-36910][table] Add function call syntax support to time-related dynamic functions [flink] - posted by "gustavodemorais (via GitHub)" <gi...@apache.org> on 2024/12/17 01:24:42 UTC, 8 replies.
- [jira] [Created] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/17 02:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory: - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:12:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/17 02:12:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory: - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:18:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:19:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/17 02:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/12/17 02:38:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-34688) CDC framework split snapshot chunks asynchronously - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/17 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/17 03:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name. - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36914) Sources with watermark alignment should wait for watermark generation - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/12/17 05:11:00 UTC, 0 replies.
- Re: [PR] [FLINK-36895]The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. [flink-cdc] - posted by "ruanhang1993 (via GitHub)" <gi...@apache.org> on 2024/12/17 05:47:30 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/17 05:48:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/17 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36915) flink-oracle-cdc supports user-defined conditions or time updates - posted by "twan1588 (Jira)" <ji...@apache.org> on 2024/12/17 06:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 06:37:03 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 06:37:03 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 06:38:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36854) Column comments and default expressions gone after being transformed - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/17 07:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/17 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36917) Add OceanBase DataSource to Flink CDC - posted by "ChaomingZhang (Jira)" <ji...@apache.org> on 2024/12/17 07:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36917) Add OceanBase DataSource to Flink CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 07:31:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36918) Introduce ProcTimeSortOperator in TemporalSort with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/17 07:43:00 UTC, 0 replies.
- [PR] [FLINK-36918][table] Introduce ProcTimeSortOperator in TemporalSort with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/17 07:51:24 UTC, 7 replies.
- [jira] [Created] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/17 08:01:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/17 08:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/17 08:38:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/17 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36920) Update org.quartz-schedule:quartz - posted by "Anupam Aggarwal (Jira)" <ji...@apache.org> on 2024/12/17 08:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36740) Update frontend dependencies to address vulnerabilities - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/17 08:57:00 UTC, 0 replies.
- [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 "dependabot[bot] (via GitHub)" <gi...@apache.org> on 2024/12/17 08:58:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36917) Add OceanBase DataSource to Flink CDC - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 09:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36920) Update org.quartz-schedule:quartz in flink-autoscaler module from 2.3.2 to 2.4.0 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/17 10:47:00 UTC, 1 replies.
- [PR] [FLINK-28897] [TABLE-SQL] Backport fix for fail to use udf in added jar when enabling checkpoint to 1.19.2 [flink] - posted by "ammu20-dev (via GitHub)" <gi...@apache.org> on 2024/12/17 11:09:39 UTC, 5 replies.
- [PR] [FLINK-36919][table] Add missing dropTable/dropView methods to TableEnvironment [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/17 11:12:40 UTC, 60 replies.
- [jira] [Updated] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/17 11:13:00 UTC, 1 replies.
- [PR] [FLINK-36873][runtime] Adapting batch job progress recovery to Apache Celeborn. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/17 12:31:23 UTC, 2 replies.
- [jira] [Resolved] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist' - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/17 12:54:00 UTC, 0 replies.
- [PR] [FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name. [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/17 13:16:48 UTC, 6 replies.
- [jira] [Updated] (FLINK-36913) Add an option in Kafka Sink to manual map table to topic name. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/17 13:17:00 UTC, 0 replies.
- [PR] [FLINK-36236] JdbcSourceBuilder overrides set connection provider [flink-connector-jdbc] - posted by "coopstah13 (via GitHub)" <gi...@apache.org> on 2024/12/17 13:21:24 UTC, 1 replies.
- [jira] [Updated] (FLINK-36236) JdbcSourceBuilder overrides set connection provider - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/17 13:22:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/17 13:24:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/17 13:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/17 13:40:00 UTC, 3 replies.
- [jira] [Created] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/17 14:58:00 UTC, 0 replies.
- Re: [PR] [FLINK-36496][table]Remove deprecated method `CatalogFunction#isGeneric` [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/17 15:34:49 UTC, 4 replies.
- [jira] [Commented] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 15:40:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 15:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36865) Provide UNIX_TIMESTAMP series functions in YAML pipeline - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/17 16:02:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-36841) Incorrect error message for functions without parenthesis - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/17 17:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36841) Incorrect error message for functions without parenthesis - posted by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2024/12/17 17:00:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-35229) join An error occurred when the table was empty - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 17:23:00 UTC, 0 replies.
- [PR] Flink 33117 [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2024/12/17 18:27:16 UTC, 1 replies.
- Re: [PR] [FLINK-33117][table][docs] Fix scala example in udfs page [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2024/12/17 18:53:29 UTC, 6 replies.
- [jira] [Updated] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 19:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 19:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36609) Protobuf Format not support proto3 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 19:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36609) Protobuf Format not support proto3 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 19:12:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-33571) Bump json-path from 2.7.0 to 2.9.0 - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2024/12/17 19:19:00 UTC, 0 replies.
- [PR] [FLINK-36227] Restore compatibility with Logback 1.2 [flink] - posted by "piotrp (via GitHub)" <gi...@apache.org> on 2024/12/17 21:20:40 UTC, 19 replies.
- [jira] [Updated] (FLINK-36227) NullPointerException when starting flink with logback logger - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/17 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36922) Add warning when creating KryoSerializer for generic type - posted by "LEONID ILYEVSKY (Jira)" <ji...@apache.org> on 2024/12/17 22:28:00 UTC, 0 replies.
- Re: [PR] upgrade-tikv-client [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/18 00:04:29 UTC, 0 replies.
- Re: [PR] [FLINK-36564][ci] Running CI in random timezone to expose more time related bugs. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/18 00:04:30 UTC, 0 replies.
- Re: [PR] [FLINK-36741][cdc][transform] Fix the precision of decimal has been lost when use transform [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/18 01:27:32 UTC, 1 replies.
- [jira] [Closed] (FLINK-33921) Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/12/18 01:38:00 UTC, 0 replies.
- Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/18 02:02:34 UTC, 1 replies.
- [jira] [Updated] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 02:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36641) Support and Release Connectors for Flink 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 02:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36658) Support and Release Connectors for Flink 2.0 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 02:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 03:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 03:01:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 03:44:00 UTC, 0 replies.
- [PR] [FLINK-FLINK-36923] Bump flink version to 1.19.1, adapt CI workflow [flink-connector-hbase] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/18 03:51:30 UTC, 1 replies.
- Re: [PR] [FLINK-36923] Bump flink version to 1.19.1, adapt CI workflow [flink-connector-hbase] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/18 03:56:32 UTC, 1 replies.
- [jira] [Created] (FLINK-36924) cannot initialize module JavadocMethod - Property 'allowUndeclaredRTE' does not exist, please check the documentation - posted by "luoyuxia (Jira)" <ji...@apache.org> on 2024/12/18 04:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36923) Bump flink-connector-hbase to Flink 1.19 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/18 04:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc] - posted by "ChaomingZhangCN (via GitHub)" <gi...@apache.org> on 2024/12/18 04:15:41 UTC, 0 replies.
- [jira] [Created] (FLINK-36925) Introduce SemiAntiJoinOperator in Join with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/18 05:50:00 UTC, 0 replies.
- [PR] [FLINK-36925][table] Introduce SemiAntiJoinOperator in Join with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/18 05:53:45 UTC, 6 replies.
- Re: [PR] [hotfix] Fix Java 11 target compatibility & add tests [flink-cdc] - posted by "GOODBOY008 (via GitHub)" <gi...@apache.org> on 2024/12/18 06:05:46 UTC, 3 replies.
- [jira] [Created] (FLINK-36926) Introduce Window Join Operator with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/18 06:31:00 UTC, 0 replies.
- [PR] [FLINK-36926][table] Introduce window join operator with async state api [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/18 06:55:30 UTC, 7 replies.
- [jira] [Updated] (FLINK-36926) Introduce Window Join Operator with Async State API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/18 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/18 07:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/18 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36928) Split the action of Epoch into two parts (trigger & final) - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/18 07:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36928) Split the action of Epoch into two parts (trigger & final) - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/18 07:56:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-35904) Test harness for async state processing operators - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/18 08:44:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-35904) Test harness for async state processing operators - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/18 08:44:00 UTC, 0 replies.
- [PR] [FLINK-36928] Split the action of Epoch into two parts (trigger & final) [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/18 08:58:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-36928) Split the action of Epoch into two parts (trigger & final) - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/18 08:59:00 UTC, 0 replies.
- Re: [PR] [FLINK-36928][Runtime] Split the action of Epoch into two parts (trigger & final) [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/18 09:11:42 UTC, 4 replies.
- [jira] [Assigned] (FLINK-36929) SQL connector for keyed state data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/18 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36929) SQL connector for keyed state data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/18 09:21:00 UTC, 0 replies.
- [PR] [FLINK-36920][Kubernetes Operator] Bump quartz-scheduler from 2.3.2 to 2.4.0 [flink-kubernetes-operator] - posted by "anupamaggarwal (via GitHub)" <gi...@apache.org> on 2024/12/18 09:22:12 UTC, 3 replies.
- [jira] [Reopened] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/18 09:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/12/18 10:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36914) Sources with watermark alignment should wait for watermark generation - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/18 11:39:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-36914) Sources with watermark alignment should wait for watermark generation - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/18 11:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36907) Bump flink-connector-aws to 1.20 - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/18 11:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36898) Support SQL FLOOR and CEIL functions with NanoSecond for TIMESTAMP_TLZ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/18 12:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36839) Update Kudu version to 1.17.1 - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/12/18 13:14:00 UTC, 0 replies.
- Re: [PR] [FLINK-36161][docs]Update Integration Test Example with Sink API. [flink] - posted by "davidradl (via GitHub)" <gi...@apache.org> on 2024/12/18 14:16:14 UTC, 0 replies.
- [jira] [Created] (FLINK-36930) Lookup join with JDBC connector fails when join condition does not include fields from the probe/left table - posted by "Lilo (Jira)" <ji...@apache.org> on 2024/12/18 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/12/18 15:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/12/18 15:10:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/12/18 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36932) Add resource-level metrics for different status/states to flink-kubernetes-operator - posted by "Philippe Gref-Viau (Jira)" <ji...@apache.org> on 2024/12/18 18:45:00 UTC, 0 replies.
- Re: [PR] Support mysql pipline rate [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 00:04:39 UTC, 1 replies.
- Re: [PR] [FLINK-35360] support Flink cdc pipeline Yarn application mode. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 00:04:40 UTC, 1 replies.
- Re: [PR] [Kafka]Kafka sink numRecordsOutByIncremental metrics [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/19 00:04:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL - posted by "Hao Li (Jira)" <ji...@apache.org> on 2024/12/19 00:42:00 UTC, 0 replies.
- [PR] [hotfix] Fix building status badge in README as workflow files have been refactored [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/19 05:05:49 UTC, 3 replies.
- [jira] [Resolved] (FLINK-36879) CDC yaml transform supports to convert delete as insert - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/19 05:46:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36864) YAML Pipeline could not write number literals that exceeds Int32 range - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/19 05:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36873) Adapting batch job progress recovery to Apache Celeborn - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/19 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36933) Error using QUALIFY in rank - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/19 07:04:00 UTC, 0 replies.
- [PR] [hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr… [flink-cdc] - posted by "hql0312 (via GitHub)" <gi...@apache.org> on 2024/12/19 07:17:57 UTC, 10 replies.
- [jira] [Assigned] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/19 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/19 07:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/19 07:25:00 UTC, 4 replies.
- [PR] [FLINK-36934][network] Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/19 07:28:20 UTC, 2 replies.
- [jira] [Created] (FLINK-36935) Implement fast link for ForStFileSystem - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/19 08:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36935) Implement fast link for ForStFileSystem - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/19 08:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36936) Introduce UpdatableTopNFunction in Rank with Async State API - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/19 08:05:00 UTC, 0 replies.
- [PR] [FLINK-36935][state/forst] Implement fast link for ForStFileSystem [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/19 08:07:39 UTC, 14 replies.
- [jira] [Updated] (FLINK-36935) Implement fast link for ForStFileSystem - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/19 08:08:00 UTC, 1 replies.
- [PR] [FLINK-36936][table] Introduce UpdatableTopNFunction in Rank with Async State API [flink] - posted by "Au-Miner (via GitHub)" <gi...@apache.org> on 2024/12/19 08:29:34 UTC, 1 replies.
- [PR] [hotfix] [docs] Fix typo in Flink Overview [flink] - posted by "philhofftw (via GitHub)" <gi...@apache.org> on 2024/12/19 08:29:59 UTC, 2 replies.
- [jira] [Closed] (FLINK-36706) Update TypeInferenceExtractor for PTFs - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/12/19 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36937) Integrate PTF TypeInference into Table API - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/12/19 08:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2024/12/19 08:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36920) Update org.quartz-schedule:quartz in flink-autoscaler module from 2.3.2 to 2.4.0 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/19 08:57:00 UTC, 0 replies.
- [PR] [hotfix][tests] Use scala's instanceOf in DataTypeExtractorScalaTest [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/19 09:26:03 UTC, 6 replies.
- [jira] [Resolved] (FLINK-36928) Split the action of Epoch into two parts (trigger & final) - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/19 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36938) Provide hooks before and after the watermark processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/19 10:21:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36929) SQL connector for keyed savepoint data - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/12/19 10:45:00 UTC, 0 replies.
- [PR] [FLINK-36608][table-runtime] Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2024/12/19 13:39:20 UTC, 2 replies.
- [jira] [Updated] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/19 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2024/12/19 14:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2024/12/19 14:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-20625] Implement V2 Google Cloud PubSub Source in accordance with FLIP-27 [flink-connector-gcp-pubsub] - posted by "clmccart (via GitHub)" <gi...@apache.org> on 2024/12/19 19:04:44 UTC, 0 replies.
- Re: [PR] [FLINK-34598][table] Migrate RemoveRedundantLocalRankRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/19 23:26:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-34598) Migrate RemoveRedundantLocalRankRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/19 23:28:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/19 23:43:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/19 23:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-36276] Fix the description of MySqlDataSourceOptions.`scan.sta… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/20 00:04:27 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36508) Remove all deprecated methods in `SymbolType ` - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/20 00:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36508) Remove all deprecated methods in `SymbolType ` - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/20 00:21:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/20 01:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/20 01:54:00 UTC, 0 replies.
- [PR] [FLINK-xx][table] Remove RelBuilder [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/20 02:44:28 UTC, 1 replies.
- [jira] [Resolved] (FLINK-36784) Support to add metadata columns for data in the meta fields of DataChangeEvent at transform - posted by "Ruan Hang (Jira)" <ji...@apache.org> on 2024/12/20 03:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36884) GCS 503 Error Codes for `flink-checkpoints//shared/` file after upload complete - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/20 03:28:00 UTC, 0 replies.
- [PR] [FLINK-36938] Provide hooks before and after the watermark processing [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/20 03:57:56 UTC, 2 replies.
- [jira] [Updated] (FLINK-36938) Provide hooks before and after the watermark processing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36940) Why does autoscaler Math.round the TargetProcessingCapacity - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/20 05:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36940) Why does autoscaler Math.round the TargetProcessingCapacity - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/20 05:24:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-36940) Why does autoscaler Math.round the TargetProcessingCapacity - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/20 05:55:00 UTC, 2 replies.
- [PR] [FLINK-36911][table] Add more Calcite Reduce Expression Rules [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/20 06:39:13 UTC, 1 replies.
- [PR] [hotfix] Fix unstable `testInitialStartupModeWithOpTs` case [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/20 06:45:33 UTC, 2 replies.
- [PR] [FLINK-xx][table] Add more Calcite PruneEmptyRules [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/20 06:48:21 UTC, 1 replies.
- [jira] [Created] (FLINK-36941) Fix Doc for DATE_FORMAT - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/20 07:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36941) Fix Doc for DATE_FORMAT - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/20 07:28:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36941) Fix Doc for DATE_FORMAT - posted by "Yiyu Tian (Jira)" <ji...@apache.org> on 2024/12/20 07:29:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-36923) Bump flink-connector-hbase to Flink 1.20 - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/20 07:45:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-36940) Why does autoscaler Math.round the TargetProcessingCapacity - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/12/20 08:41:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-35921) Flink SQL physical operator replacement support - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/20 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimestamportOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/20 09:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimestamportOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/20 09:13:00 UTC, 4 replies.
- [PR] [BP-1.20][FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2024/12/20 09:20:09 UTC, 1 replies.
- [PR] [FLINK-36941][hotfix] Update DATE_FORMAT Doc and Python Tests [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/20 09:39:40 UTC, 13 replies.
- [jira] [Updated] (FLINK-36941) Fix Doc for DATE_FORMAT - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36944) Introduce 'enableAsycState' in DataStream v1 interfaces - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 09:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 09:58:00 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18 [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2024/12/20 09:58:22 UTC, 1 replies.
- [PR] [BP-1.20][FLINK-36740] [WebFrontend] Update frontend dependencies to address vulnerabilities [flink] - posted by "mehdid93 (via GitHub)" <gi...@apache.org> on 2024/12/20 10:07:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimestamportOperator - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 10:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36920) Update org.quartz-schedule:quartz in flink-autoscaler module from 2.3.2 to 2.4.0 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/12/20 10:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Yohei Yoshimuta (Jira)" <ji...@apache.org> on 2024/12/20 10:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Yohei Yoshimuta (Jira)" <ji...@apache.org> on 2024/12/20 10:35:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job - posted by "Yohei Yoshimuta (Jira)" <ji...@apache.org> on 2024/12/20 10:55:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 11:04:00 UTC, 1 replies.
- [PR] [FLINK-36944][DataStream/API] Introduce 'enableAsycState' in KeyedStream interfaces and implement reduce operator [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/20 11:07:21 UTC, 6 replies.
- [PR] [FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency [flink-cdc] - posted by "MOBIN-F (via GitHub)" <gi...@apache.org> on 2024/12/20 11:11:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-36580) Using debezium.column.exclude.list causes job failure - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 11:12:00 UTC, 0 replies.
- Re: [PR] [FLINK-34505][table] Migrate WindowGroupReorderRule to java. [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/20 11:52:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-36938) Provide hooks before and after the watermark processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 12:07:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36938) Provide hooks before and after the watermark processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/20 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36946) optimize sink operator name truncate - posted by "tartarus (Jira)" <ji...@apache.org> on 2024/12/20 12:08:00 UTC, 0 replies.
- [PR] [FLINK-36946][Metrics] Optimize sink operator name truncate [flink] - posted by "Tartarus0zm (via GitHub)" <gi...@apache.org> on 2024/12/20 12:12:30 UTC, 7 replies.
- [jira] [Updated] (FLINK-36946) optimize sink operator name truncate - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 12:13:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36946) optimize sink operator name truncate - posted by "tartarus (Jira)" <ji...@apache.org> on 2024/12/20 12:14:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36946) optimize sink operator name truncate - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/12/20 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36947) Rate limiting the GetRecord call frequency - posted by "Burak Ozakinci (Jira)" <ji...@apache.org> on 2024/12/20 13:20:00 UTC, 0 replies.
- Re: [PR] [FLINK-36634][table] Introduce AdaptiveJoinOperator to support dynamic generate join operator at runtime. [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2024/12/20 13:21:13 UTC, 5 replies.
- Re: [PR] [FLINK-36607][table-planner] Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join. [flink] - posted by "SinBex (via GitHub)" <gi...@apache.org> on 2024/12/20 13:21:20 UTC, 6 replies.
- [PR] [FLINK-36770-] make AWS sink writers use ResultHandler, move flink version to 1.20 [flink-connector-aws] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2024/12/20 13:39:48 UTC, 0 replies.
- [jira] [Updated] (FLINK-36770) Support Request Timeout for AWS sinks - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 13:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/20 16:03:00 UTC, 0 replies.
- [PR] [FLINK-35014] SqlNode to operation conversion for models [flink] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2024/12/20 18:55:41 UTC, 3 replies.
- [jira] [Updated] (FLINK-35014) SqlNode to operation conversion for models - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/20 18:56:00 UTC, 0 replies.
- Re: [PR] [FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/21 00:41:26 UTC, 3 replies.
- [PR] [MINOR] Deprecated StreamSink and SinkOperator [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2024/12/21 02:17:56 UTC, 1 replies.
- [PR] [MINOR] Rename PunctuatedWatermarkStrategyWrapper with PunctuatedWatermarkAssignerWrapper [flink] - posted by "beliefer (via GitHub)" <gi...@apache.org> on 2024/12/21 04:34:28 UTC, 1 replies.
- Re: [PR] [FLINK-36579][cdc] Fix mysql cdc charset collation sort not equals ja… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:31 UTC, 0 replies.
- Re: [PR] [FLINK-36345][feature][cdc-connector][oracle] Oracle cdc support partition table [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:34 UTC, 1 replies.
- Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:36 UTC, 0 replies.
- Re: [PR] [cdc-runtime]SchemaRegistry Log output is repeated [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:38 UTC, 1 replies.
- Re: [PR] [minor][cdc-connector][mysql] catch all exceptions to display the table info [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:40 UTC, 1 replies.
- Re: [PR] [minor][cdc-runtime]The processedTableIds add is executed twice [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/22 00:04:41 UTC, 1 replies.
- [PR] [FLINK-34558][state] Support tracking state size [flink] - posted by "hejufang (via GitHub)" <gi...@apache.org> on 2024/12/22 09:22:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-34558) Add RocksDB key/value size metrics - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/22 09:23:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimeSortOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/22 09:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimeSortOperator - posted by "Wang Qilong (Jira)" <ji...@apache.org> on 2024/12/22 10:03:00 UTC, 1 replies.
- [PR] [FLINK-36429] [runtime-web] Enhancing Flink History Server File Storage and Retrieval with RocksDB [flink] - posted by "Shawnsuun (via GitHub)" <gi...@apache.org> on 2024/12/22 10:26:08 UTC, 3 replies.
- [jira] [Updated] (FLINK-36429) Enhancing Flink History Server File Storage and Retrieval with RocksDB - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/22 10:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36429) Enhancing Flink History Server File Storage and Retrieval with RocksDB - posted by "Xiaowen Sun (Jira)" <ji...@apache.org> on 2024/12/22 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36948) Drop deprecated FlinkMatchers - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/22 11:13:00 UTC, 0 replies.
- [PR] [FLINK-36948][tests] Remove deprecated FlinkMatchers [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/22 11:16:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-36948) Drop deprecated FlinkMatchers - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/22 11:17:00 UTC, 0 replies.
- [PR] [FLINK-33117][docs] Fix scala example for `NamedParameterClass` [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/22 14:00:40 UTC, 3 replies.
- [jira] [Resolved] (FLINK-36919) Add missing dropTable/dropView methods to TableEnvironment - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/22 20:29:00 UTC, 0 replies.
- Re: [PR] Fix an exception:java.lang.NoClassDefFoundError: [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/23 00:04:32 UTC, 0 replies.
- [jira] [Closed] (FLINK-36930) Lookup join with JDBC connector fails when join condition does not include fields from the probe/left table - posted by "Lilo (Jira)" <ji...@apache.org> on 2024/12/23 01:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/23 03:15:00 UTC, 0 replies.
- [PR] [FLINK-36949] Make getCurrentKey of async state operators return the ground truth [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/23 03:15:09 UTC, 4 replies.
- [jira] [Updated] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/23 03:16:00 UTC, 0 replies.
- [PR] Updates the slack invitation link [flink-web] - posted by "Myasuka (via GitHub)" <gi...@apache.org> on 2024/12/23 03:32:24 UTC, 1 replies.
- [PR] [FLINK-36880][network] Hybrid shuffle supports job master failover if only external tier used [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/23 04:08:29 UTC, 3 replies.
- [jira] [Updated] (FLINK-36880) Hybrid Shuffle support batch job recovery - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/23 04:09:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36950) Migrate WindowPropertiesRules - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/23 04:16:00 UTC, 0 replies.
- [PR] [FLINK-36950][table] Migrate WindowPropertiesRules to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/23 04:19:26 UTC, 3 replies.
- [jira] [Updated] (FLINK-36950) Migrate WindowPropertiesRules - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/23 04:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/23 07:36:00 UTC, 0 replies.
- [PR] [FLINK-36951][table] Migrate ProjectSemiAntiJoinTransposeRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/23 07:37:02 UTC, 3 replies.
- [jira] [Updated] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/23 07:38:00 UTC, 0 replies.
- Re: [PR] [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/23 07:45:01 UTC, 1 replies.
- Re: [PR] [FLINK-34676][table] Migrate ConvertToNotInOrInRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/23 07:47:21 UTC, 0 replies.
- Re: [PR] [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/23 07:48:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-34558) Add RocksDB key/value size metrics - posted by "Jufang He (Jira)" <ji...@apache.org> on 2024/12/23 07:54:00 UTC, 0 replies.
- [PR] fix DynamicKafkaRecordSerializationSchema, add serialVersionUID [flink-connector-kafka] - posted by "lwjhn (via GitHub)" <gi...@apache.org> on 2024/12/23 09:03:39 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-34558) Add RocksDB key/value size metrics - posted by "Jufang He (Jira)" <ji...@apache.org> on 2024/12/23 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36952) fix mongodb chinese doc - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/23 09:39:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36952) fix mongodb chinese doc - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/23 09:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36952) Fix mongodb chinese doc - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/23 09:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36952) Fix mongodb connector chinese doc - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/23 09:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36952) Fix MongoDB connector Chinese documentation - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/12/23 09:55:00 UTC, 1 replies.
- [PR] [FLINK-36952][hotfix][mongodb]Fix MongoDB connector Chinese documentation [flink-cdc] - posted by "Thorne-coder (via GitHub)" <gi...@apache.org> on 2024/12/23 09:57:19 UTC, 4 replies.
- [jira] [Commented] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/23 12:11:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36944) Introduce 'enableAsycState' in KeyedStream interfaces - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/23 12:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/23 12:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/23 12:28:00 UTC, 0 replies.
- [PR] Update NFA.java [flink] - posted by "melodylx666 (via GitHub)" <gi...@apache.org> on 2024/12/23 13:44:53 UTC, 2 replies.
- [PR] [FLINK-36931][cdc] FlinkCDC YAML supports batch mode [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/23 15:57:30 UTC, 3 replies.
- Re: [PR] [FLINK-36770] make AWS sink writers use ResultHandler, move flink version to 1.20 [flink-connector-aws] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2024/12/23 18:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2024/12/23 18:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join - posted by "Weiqing Yang (Jira)" <ji...@apache.org> on 2024/12/23 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36954) Migrate CalcRankTransposeRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/24 02:20:00 UTC, 0 replies.
- [PR] [FLINK-36954][table] Migrate CalcRankTransposeRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/24 02:22:27 UTC, 4 replies.
- [jira] [Updated] (FLINK-36954) Migrate CalcRankTransposeRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/24 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36955) Migrate RewriteIntersectAllRule - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/12/24 03:22:00 UTC, 0 replies.
- [PR] [FLINK-36955][table] Migrate RewriteIntersectAllRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/24 03:25:48 UTC, 3 replies.
- [jira] [Updated] (FLINK-36955) Migrate RewriteIntersectAllRule - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/24 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36956) Pipeline transform should deduce PK column types to be NOT NULL - posted by "yux (Jira)" <ji...@apache.org> on 2024/12/24 04:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36957) Implement async StreamFlatMap - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/24 06:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36957) Implement async StreamFlatMap - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/24 06:03:00 UTC, 0 replies.
- [PR] [FLINK-36957][Datastream] Implement asyc stream flatmap [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/24 06:13:20 UTC, 1 replies.
- [jira] [Updated] (FLINK-36957) Implement async StreamFlatMap - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/24 06:14:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36922) Add warning when creating KryoSerializer for generic type - posted by "ZhiyuanLiu (Jira)" <ji...@apache.org> on 2024/12/24 09:55:00 UTC, 1 replies.
- [PR] [hotfix][docs] Fix Apache Avro Specification Link [flink] - posted by "donPain (via GitHub)" <gi...@apache.org> on 2024/12/24 11:28:23 UTC, 3 replies.
- [jira] [Created] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/24 12:11:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/24 12:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/12/24 12:14:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/24 16:19:00 UTC, 0 replies.
- [PR] [FLINK-36921][runtime] Fix unstable AdaptiveExecutionPlanSchedulingContextTest [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/24 16:22:18 UTC, 2 replies.
- [jira] [Updated] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/24 16:23:00 UTC, 1 replies.
- [PR] [hotfix] Fix the logic for computing readable buffer offsets and sizes when including empty buffers. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/24 16:26:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/24 16:34:00 UTC, 2 replies.
- [jira] [Created] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/24 16:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:18 UTC, 0 replies.
- Re: [PR] [FLINK-36351][pipeline-connector/doris] support the conversion of Flink TIME type to Doris String typeAdd the conversion from Flink TIME type to Doris. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:21 UTC, 1 replies.
- Re: [PR] [FLINK-35421]fixed schema operator blocking when restart [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:28 UTC, 1 replies.
- Re: [PR] [FLINK-35309][cdc] Fix license and NOTICE files and add CI check in Flink CDC [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:29 UTC, 1 replies.
- Re: [PR] [FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:31 UTC, 1 replies.
- Re: [PR] [cdc-cli][cdc-composer] Applying 'flink-config' for pipeline yaml [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:32 UTC, 1 replies.
- Re: [PR] Add benodes configuration to mysql2doris in case some users can't fin… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:34 UTC, 1 replies.
- Re: [PR] [enhancement] add param which contain column comments of source table field [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:36 UTC, 1 replies.
- Re: [PR] add ignore no primary key table param [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:37 UTC, 1 replies.
- Re: [PR] [cdc-connector][mysql][hotfix] Fix NullPointerException when currentReader is null. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:38 UTC, 1 replies.
- Re: [PR] [cdc-connector][mysql][hotfix] Avoid mysql source to read data after high_watermark in backfill phase [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:40 UTC, 1 replies.
- Re: [PR] [pipeline-connector][starrocks] Add the binary column type support [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:42 UTC, 1 replies.
- Re: [PR] [cdc-composer][tests] Refactor newline handling for cross-platform compatibility [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:43 UTC, 1 replies.
- Re: [PR] [mysql] Error message more cautious [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:45 UTC, 1 replies.
- Re: [PR] [pipeline-connector][doris] Extract type mapping logic [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:46 UTC, 1 replies.
- Re: [PR] [cdc-common] Add default value of pipeline parallelism. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:48 UTC, 1 replies.
- Re: [PR] [mysql-cdc] Current binlog offset add serverId, fix incremental-snapshot scan data lose [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:49 UTC, 1 replies.
- Re: [PR] [db] When modifying the time zone connection parameters in the datab… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:50 UTC, 1 replies.
- Re: [PR] Refactoring code. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:52 UTC, 1 replies.
- Re: [PR] Reorder dependency flink-table-runtime in pom.xml to avoid dependency conflict. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:54 UTC, 2 replies.
- Re: [PR] [mongodb] Add lookup option to IncrementalSource for mongodb [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:55 UTC, 1 replies.
- Re: [PR] The uniqueidentifier type in SQL Server cannot be compared using ObjectUtils.compare. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:57 UTC, 1 replies.
- Re: [PR] [base][minor] Code Cleanup, remove redundant code [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:04:58 UTC, 1 replies.
- Re: [PR] [oracle][fix] support multiple chunkKeys [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:01 UTC, 1 replies.
- Re: [PR] [tidb]fix the tidb checkpoints to exactly once. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:02 UTC, 1 replies.
- Re: [PR] [oracle-cdc]Optimized slow oracle real-time synchronization [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:03 UTC, 1 replies.
- Re: [PR] [mysql-cdc] Fix MySqlSplitSerializer ConcurrentModificationException [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:05 UTC, 1 replies.
- Re: [PR] [oracle-cdc] fix oracle scn huge increment, can not catch up new record in time #1940 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:07 UTC, 1 replies.
- Re: [PR] [oracle-cdc] Fix read one record in the incremental snapshot [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:08 UTC, 1 replies.
- Re: [PR] [mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:10 UTC, 1 replies.
- Re: [PR] [FLINK-35313][mysql-cdc] Add upsert changelog mode to avoid UPDATE_BEFORE records … [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:12 UTC, 1 replies.
- Re: [PR] [oracle][fix]fix oracle maximum number of processes exceeded [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:14 UTC, 1 replies.
- Re: [PR] [postgresql] Fix debezium-postgresql data loss [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:15 UTC, 1 replies.
- Re: [PR] [tidb-cdc]fix too many fields cause the value to be NULL [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:16 UTC, 1 replies.
- Re: [PR] [mysql][Improvement] Use debezium SPI way converter data types output. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:18 UTC, 1 replies.
- Re: [PR] [build] Add maven wrapper [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:20 UTC, 1 replies.
- Re: [PR] [oceanBase] add metrics for oceanbase cdc connector [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:21 UTC, 1 replies.
- Re: [PR] [Fix a Bug] add supported for Oracle CDB mode at OracleIncrementalSource [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:22 UTC, 1 replies.
- Re: [PR] [common] Improve implementation of offset backing store [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:24 UTC, 1 replies.
- Re: [PR] fix bug 'mysql primary key of binary data type is compared incorrectly' [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:25 UTC, 1 replies.
- Re: [PR] [DOC] When type is number,update doc [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:27 UTC, 1 replies.
- Re: [PR] [oracle]Error when TIMESTAMP_LTZ type is encoded in string type [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:29 UTC, 1 replies.
- Re: [PR] [oracle] The STRUCT type processing exception [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:30 UTC, 1 replies.
- Re: [PR] [#1770] fix NumberFormatException when mysql server_id is larger than INT_MAX [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:31 UTC, 1 replies.
- Re: [PR] [tidb-cdc]When the task runs for a period of time, there are only Resolved Events [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:33 UTC, 1 replies.
- Re: [PR] [WIP] tidb netty worker leak [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:35 UTC, 1 replies.
- Re: [PR] [mysql] Use cursor fetch by default when snapshot. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:36 UTC, 1 replies.
- Re: [PR] support table splitting process control when read table snapshot [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:37 UTC, 1 replies.
- Re: [PR] [mysql] Support the rate limit when Mysql parallel read data output [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:39 UTC, 1 replies.
- Re: [PR] [mysql] Fix the binlogSplit state incompatibility when upgrading from 2.2.0 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:40 UTC, 1 replies.
- Re: [PR] [mysql] expose meta_ts field in the metadata through flink sql [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:42 UTC, 1 replies.
- Re: [PR] [mysql] keep order of each split by replacing HashMap with LinkedHashMap [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:44 UTC, 1 replies.
- Re: [PR] [mysql] support for transaction metadata events [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:45 UTC, 1 replies.
- Re: [PR] Added option for MysqlSource to dispatch watermark event at the begin… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:46 UTC, 1 replies.
- Re: [PR] fix: fix mysql-cdc case sensitive [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:47 UTC, 1 replies.
- Re: [PR] [mysql] Add schema validation for table schema #493 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:49 UTC, 1 replies.
- Re: [PR] optimize the update operation in binlog events [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/25 00:05:51 UTC, 1 replies.
- Re: [PR] [FLINK-36952][source-connector/mongodb] Fix MongoDB connector Chinese documentation [flink-cdc] - posted by "Jiabao-Sun (via GitHub)" <gi...@apache.org> on 2024/12/25 01:29:08 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36952) Fix MongoDB connector Chinese documentation - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/12/25 01:31:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36952) Fix MongoDB connector Chinese documentation - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/12/25 01:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36921) AdaptiveExecutionPlanSchedulingContextTest.testGetParallelismAndMaxParallelism fails - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/25 02:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/25 02:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2024/12/25 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2 - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/12/25 03:31:00 UTC, 0 replies.
- [PR] [FLINK-36956][transform] Append NOT NULL attribute to PK columns [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/25 03:52:23 UTC, 1 replies.
- [jira] [Updated] (FLINK-36956) Pipeline transform should deduce PK column types to be NOT NULL - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/25 03:53:00 UTC, 0 replies.
- [PR] [FLINK-36120][Runtime] Internal APIs for declaring the record processing and variables [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/25 07:01:12 UTC, 3 replies.
- [jira] [Updated] (FLINK-36120) Internal APIs for declaring and defining the record processing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/25 07:02:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2024/12/25 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36961) Wait ForSt state excutor shutdown when disposing - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/25 07:54:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36961) Wait ForSt state excutor shutdown when disposing - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/12/25 07:54:00 UTC, 0 replies.
- Re: [PR] [FLINK-35555] Make ListSerializer allow null values [flink] - posted by "pltbkd (via GitHub)" <gi...@apache.org> on 2024/12/25 08:02:05 UTC, 0 replies.
- [jira] (FLINK-36922) Add warning when creating KryoSerializer for generic type - posted by "ZhiyuanLiu (Jira)" <ji...@apache.org> on 2024/12/25 08:13:00 UTC, 1 replies.
- [PR] [FLINK-36961][state/forst] Wait for the ForSt state executor to shutdown when disposing [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/25 08:24:23 UTC, 4 replies.
- [jira] [Updated] (FLINK-36961) Wait ForSt state excutor shutdown when disposing - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/25 08:25:00 UTC, 0 replies.
- Re: [PR] [FLINK-36959][runtime] Fix the logic for computing readable buffer offsets and sizes when including empty buffers. [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/25 08:29:56 UTC, 2 replies.
- [jira] [Created] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2024/12/25 08:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "Shuai Xu (Jira)" <ji...@apache.org> on 2024/12/25 08:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2024/12/25 08:57:00 UTC, 0 replies.
- Re: [PR] [FLINK-36923] Bump flink version to 1.20.0, adapt CI workflow [flink-connector-hbase] - posted by "ferenc-csaky (via GitHub)" <gi...@apache.org> on 2024/12/25 11:15:25 UTC, 1 replies.
- [jira] [Created] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/25 11:54:00 UTC, 0 replies.
- [PR] [FLINK-36963][Runtime] Fix wrong context maintain around `asyncProcessWithKey` [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/25 11:57:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey` - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/25 11:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36933) Error using QUALIFY in rank - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/25 12:00:00 UTC, 0 replies.
- [PR] [FLINK-35904][test] Make async test harnesses extend existing harnesses [flink] - posted by "fredia (via GitHub)" <gi...@apache.org> on 2024/12/25 12:50:26 UTC, 2 replies.
- [jira] [Closed] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/25 12:52:00 UTC, 0 replies.
- [PR] [hotfix][docs] Fix typo in Amazon S3 Access Credential [flink] - posted by "gudfhr95 (via GitHub)" <gi...@apache.org> on 2024/12/25 13:28:56 UTC, 2 replies.
- Re: [PR] [WIP][mysql] Add ExternalSystemListener to notify user about the status of connector. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:28 UTC, 1 replies.
- Re: [PR] [mysql] Add custom configurations for ConnectionPool which starts with `hikari.` [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:30 UTC, 1 replies.
- Re: [PR] Fix during the snapshot phase, projection is not being performed according to the user defined schema. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:32 UTC, 1 replies.
- Re: [PR] [oracle] Support partitioned table [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:33 UTC, 1 replies.
- Re: [PR] [postgres] Add lsn as metadata [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:35 UTC, 1 replies.
- Re: [PR] [mysql] Add a module to periodically check ip on DNS (for DB Switching) [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:37 UTC, 1 replies.
- Re: [PR] [mysql] Add notification after snapshot phase ends, before binlog stream starts with GTIDs via Slack [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:38 UTC, 1 replies.
- Re: [PR] [postgres] PostgresSql snapshot sql [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:40 UTC, 1 replies.
- Re: [PR] [Bug][Oracle] oracle 单表全量阶段根据ROWID 字段 split chunk存在BUG [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:41 UTC, 1 replies.
- Re: [PR] Support split snapshot asynchronously [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:43 UTC, 1 replies.
- Re: [PR] Update OracleSourceBuilder's constructor to private [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:44 UTC, 1 replies.
- Re: [PR] [Oracle]修复oracle数据库表主键是NUMBER类型且不指定p,s长度时报校验异常:org.apache.flink.table.api.Val… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:46 UTC, 1 replies.
- Re: [PR] [Oracle]修复oracle数据库scan.incremental.snapshot.chunk.key-column设置不生效的问题 [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:47 UTC, 1 replies.
- Re: [PR] [hotfix] Modify the schema and table name snapshot data reading probl… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:49 UTC, 1 replies.
- Re: [PR] [Mysql] Mysql connector can't handle the case sensitive of rename/change column statement (#2144) [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:50 UTC, 1 replies.
- Re: [PR] Add a AbstractJdbcSourceChunkSplitter to handle common logic [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:52 UTC, 1 replies.
- Re: [PR] [Bug][issues-2187] if splitTable method execute fast than getNext, job will be blocked [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:53 UTC, 1 replies.
- Re: [PR] Update mysql binlog connector & changes for transaction payload events [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:55 UTC, 1 replies.
- Re: [PR] [core] make ObjectUtils can not be instantiated [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:56 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-36942) Unable to trigger onEventTime() when using the async state API in RowTimeSortOperator - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/26 01:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/26 01:40:00 UTC, 0 replies.
- [PR] [hotfix] Allow pinning issues & PRs that never decay [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/26 02:01:50 UTC, 2 replies.
- [PR] [FLINK-35904][test] Enhance test harness for async state processing with fast fail [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/26 04:53:19 UTC, 2 replies.
- [jira] [Updated] (FLINK-36850) Disable streamGraph adaptive optimization when enable batch job progress recovery - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/26 05:41:00 UTC, 2 replies.
- Re: [PR] [FLINK-35888][cdc-connector][paimon] Add e2e test for PaimonDataSink. [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/26 05:45:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 06:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 06:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 06:19:00 UTC, 0 replies.
- Re: [PR] [DRAFT][FLINK-35186][Runtime/State] Create State V2 from new StateDescriptor [flink] - posted by "Zakelly (via GitHub)" <gi...@apache.org> on 2024/12/26 06:19:08 UTC, 1 replies.
- [jira] [Created] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink. - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/26 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36965) Enable to allow re-create the pod watch with many retries on k8s cluster failure - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/12/26 06:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36965) Enable to allow re-create the pod watch with many retries on k8s cluster failure - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2024/12/26 06:40:00 UTC, 0 replies.
- [PR] [FLINK-36629][table-planner] Introducing the AdaptiveSkewedJoinOptimizationStrategy [flink] - posted by "noorall (via GitHub)" <gi...@apache.org> on 2024/12/26 06:55:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/26 06:56:00 UTC, 0 replies.
- [PR] Release 1.19.1 [flink] - posted by "Camellia-lili (via GitHub)" <gi...@apache.org> on 2024/12/26 07:11:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-35116) Upgrade JOSDK dependency to 4.8.3 - posted by "Fei Feng (Jira)" <ji...@apache.org> on 2024/12/26 07:23:00 UTC, 0 replies.
- [PR] [FLINK-36964] Fix potential exception when SchemaChange in parallel w… [flink-cdc] - posted by "lvyanquan (via GitHub)" <gi...@apache.org> on 2024/12/26 10:45:21 UTC, 2 replies.
- [jira] [Updated] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/26 10:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-35904) Test harness for async state processing operators - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 11:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 11:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/12/26 11:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-36067) Support optimize stream graph based on input info. - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/26 12:05:00 UTC, 0 replies.
- [PR] [FLINK-36865][cdc] Provide UNIX_TIMESTAMP series functions in YAML pipeline [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/26 12:48:58 UTC, 1 replies.
- [PR] [FLINK-36927][table] Introduce slicing & one stage Window Aggregate with Async State API [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/26 12:50:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/26 12:51:00 UTC, 0 replies.
- Re: [PR] [FLINK-36683][cdc-connector][mongo] Support metadata 'row_kind' virtual column [flink-cdc] - posted by "herunkang2018 (via GitHub)" <gi...@apache.org> on 2024/12/26 14:28:43 UTC, 0 replies.
- Re: [PR] [FLINK-34874][cdc-connector][mongodb] Support initial.snapshotting.pipeline related configs in table api [flink-cdc] - posted by "herunkang2018 (via GitHub)" <gi...@apache.org> on 2024/12/26 14:30:14 UTC, 0 replies.
- Re: [PR] [FLINK-36573][cdc-connector][mysql] Add table information of binlog offsets when checkpointing [flink-cdc] - posted by "herunkang2018 (via GitHub)" <gi...@apache.org> on 2024/12/26 14:34:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-36948) Drop deprecated FlinkMatchers - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/26 19:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36966) Bump mockito to 5.x - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/26 20:04:00 UTC, 0 replies.
- [PR] [FLINK-36966][tests] Bump mockito to 5.14.2 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/26 20:10:34 UTC, 5 replies.
- [jira] [Updated] (FLINK-36966) Bump mockito to 5.x - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/26 20:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-34505) Migrate WindowGroupReorderRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/26 22:15:00 UTC, 0 replies.
- Re: [PR] [minor][cdc-connector][mongodb] Add `op_type` metadata column [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/27 00:04:28 UTC, 1 replies.
- Re: [PR] [mysql] Support mysql primary keys using encoding types different fro… [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/27 00:04:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table - posted by "hql0312 (Jira)" <ji...@apache.org> on 2024/12/27 00:59:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-36141) [mysql]Set the scanNewlyAddedTableEnabled is true, but does not support automatic capture new added table - posted by "hql0312 (Jira)" <ji...@apache.org> on 2024/12/27 00:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36880) Hybrid Shuffle support batch job recovery - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/27 03:05:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/12/27 03:27:00 UTC, 0 replies.
- [PR] [FLINK-36850][runtime] Disable adaptive batch execution when batch job progress recovery is enabled [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/27 03:36:21 UTC, 1 replies.
- [jira] [Created] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2024/12/27 05:05:00 UTC, 0 replies.
- [PR] [FLINK-36967] [cdc-connector] [paimon] Bump dependency of Paimon Pipeline connector to 0.9.0 [flink-cdc] - posted by "yangjf2019 (via GitHub)" <gi...@apache.org> on 2024/12/27 05:24:25 UTC, 1 replies.
- [jira] [Updated] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/27 05:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36968) The "values" lookup table used for testing does not deduplicate data with the same key. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/27 07:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36968) The "values" lookup table used for testing does not deduplicate data with the same pk. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/12/27 07:46:00 UTC, 1 replies.
- [PR] [FLINK-36968][table-planner] Deduplicate data with the same pk in values lookup table used for testing [flink] - posted by "xuyangzhong (via GitHub)" <gi...@apache.org> on 2024/12/27 07:49:01 UTC, 1 replies.
- Re: [PR] [FLINK-36960] Introduce Generalized Watermark for DataStream V2 [flink] - posted by "reswqa (via GitHub)" <gi...@apache.org> on 2024/12/27 08:14:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/27 08:15:00 UTC, 0 replies.
- Re: [PR] [FLINK-36576][runtime] Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider [flink] - posted by "JunRuiLee (via GitHub)" <gi...@apache.org> on 2024/12/27 08:15:41 UTC, 7 replies.
- [jira] [Created] (FLINK-36969) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/12/27 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36970) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/12/27 08:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36970) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/12/27 08:37:00 UTC, 1 replies.
- [PR] [FLINK-36970][runtime] merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING [flink-cdc] - posted by "Shawn-Hx (via GitHub)" <gi...@apache.org> on 2024/12/27 09:21:19 UTC, 0 replies.
- Re: [PR] [FLINK-36970][runtime] Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/27 11:51:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-36971) Add Sqs Sink SQL connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/12/27 16:50:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36971) Add Sqs Sink SQL connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/12/27 16:50:00 UTC, 0 replies.
- [PR] [FLINK-36971] Add Sqs SQL connector [flink-connector-aws] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2024/12/27 17:26:54 UTC, 0 replies.
- [jira] [Created] (FLINK-36972) Unify AWS sink implementation - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/12/27 17:45:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36966) Bump mockito to 5.x - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 18:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36966) Bump mockito to 5.x - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 18:37:00 UTC, 0 replies.
- Re: [PR] [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/27 18:41:23 UTC, 0 replies.
- [jira] [Resolved] (FLINK-34675) Migrate AggregateReduceGroupingRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 18:43:00 UTC, 0 replies.
- Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink] - posted by "kimgr (via GitHub)" <gi...@apache.org> on 2024/12/27 19:01:23 UTC, 0 replies.
- Re: [PR] [FLINK-35282][python] Upgrade Apache Beam > 2.54 [flink] - posted by "franciscojavierarceo (via GitHub)" <gi...@apache.org> on 2024/12/27 19:30:25 UTC, 0 replies.
- [jira] [Commented] (FLINK-36955) Migrate RewriteIntersectAllRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 19:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36955) Migrate RewriteIntersectAllRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 19:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36954) Migrate CalcRankTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 20:01:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36954) Migrate CalcRankTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 20:01:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 20:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/27 20:03:00 UTC, 0 replies.
- Re: [PR] [FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/28 00:04:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-36069) Extending job detail rest API to adapt to Incremental JobGraph Generation - posted by "Junrui Lee (Jira)" <ji...@apache.org> on 2024/12/28 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36973) udf dateformat support LocalZonedTimestampData - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2024/12/28 04:33:00 UTC, 0 replies.
- [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 04:40:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-36973) udf dateformat support LocalZonedTimestampData - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/28 04:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2024/12/28 04:42:00 UTC, 0 replies.
- [PR] support overwrite flink config by command line [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 05:24:13 UTC, 0 replies.
- [jira] [Created] (FLINK-36974) support overwrite flink config by command line - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2024/12/28 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions - posted by "Mohsen Rezaei (Jira)" <ji...@apache.org> on 2024/12/28 05:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36976) Bump jackson to 2.18.2 - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/12/28 08:31:00 UTC, 0 replies.
- [PR] [FLINK-36976] Upgrade jackson from 2.15.3 to 2.18.2 [flink] - posted by "snuyanzin (via GitHub)" <gi...@apache.org> on 2024/12/28 08:38:22 UTC, 1 replies.
- [jira] [Updated] (FLINK-36976) Bump jackson to 2.18.2 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/28 08:39:00 UTC, 0 replies.
- [PR] [FLINK-36977]paimon apply default value options when apply add_column schema change [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 14:07:35 UTC, 0 replies.
- [jira] [Created] (FLINK-36977) paimon apply default value options when apply add column_schema change - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2024/12/28 14:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36977) paimon apply default value options when apply add column_schema change - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/28 14:08:00 UTC, 1 replies.
- Re: [PR] [UDF]udf dateformat support LocalZonedTimestampData [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 14:10:33 UTC, 0 replies.
- Re: [PR] [CliFrontend]support overwrite flink config by command line [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 14:10:47 UTC, 0 replies.
- [PR] [FLINK-36978]Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. [flink-cdc] - posted by "hiliuxg (via GitHub)" <gi...@apache.org> on 2024/12/28 14:27:57 UTC, 0 replies.
- [jira] [Updated] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/28 14:28:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2024/12/28 14:28:00 UTC, 0 replies.
- Re: [PR] [FLINK-36510][rpc] bump pekko to 1.1.2, remove netty 3 (backport to release-1.20) [flink] - posted by "He-Pin (via GitHub)" <gi...@apache.org> on 2024/12/28 14:47:55 UTC, 0 replies.
- Re: [PR] [FLINK-36065][runtime] Support submit stream graph. [flink] - posted by "afedulov (via GitHub)" <gi...@apache.org> on 2024/12/28 15:05:06 UTC, 0 replies.
- Re: [PR] [FLINK-36971][Connectors/Sqs] Add Sqs SQL connector [flink-connector-aws] - posted by "vahmed-hamdy (via GitHub)" <gi...@apache.org> on 2024/12/28 21:29:22 UTC, 0 replies.
- Re: [PR] add updateBinlogStartPoint function [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/29 00:04:35 UTC, 0 replies.
- Re: [PR] [FLINK-36397][cdc-connector][mysql] Obtain the high watermark offset and table data in the same transaction during the Snapshot phase [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/29 00:04:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36979) Revert netty bump for 1.20 and 1.19 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/29 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36979) Revert netty bump for 1.20 and 1.19 - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/12/29 13:40:00 UTC, 0 replies.
- [PR] [FLINK-36979][rpc] Reverting pekko version bump [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/29 13:51:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-36979) Revert netty bump for 1.20 and 1.19 - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/29 13:52:00 UTC, 0 replies.
- Re: [PR] [FLINK-36979][rpc] Reverting pekko version bump in Flink 1.20 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/29 13:55:40 UTC, 3 replies.
- Re: [PR] [FLINK-36979][rpc] Reverting pekko version bump in Flink 1.19 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/29 13:55:46 UTC, 0 replies.
- [PR] [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension [flink] - posted by "XComp (via GitHub)" <gi...@apache.org> on 2024/12/29 16:20:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-28091) Thread leak in CheckpointResourcesCleanupRunnerTest#testCancellationAfterStart - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/29 16:21:00 UTC, 0 replies.
- Re: [PR] Fixed an issue where the write to decimal type in starrocks sink in pipeline was null. [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/30 00:04:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/30 02:12:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/12/30 02:23:00 UTC, 9 replies.
- [PR] [WIP][FLINK-36310] Remove per-job mode [flink] - posted by "codenohup (via GitHub)" <gi...@apache.org> on 2024/12/30 03:06:44 UTC, 1 replies.
- Re: [PR] [FLINK-36741][cdc][transform] Fix the precision of decimal has been lost when use transform and support DecimalData [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/30 03:19:18 UTC, 0 replies.
- [PR] [FLINK-36746] Fix the deadlock bug when initializing SerializedThrowable object. [flink] - posted by "raoraoxiong (via GitHub)" <gi...@apache.org> on 2024/12/30 06:46:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-36746) Found deadlock in SerializedThrowable - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/30 06:47:00 UTC, 0 replies.
- Re: [PR] [FLINK-34597][table] Migrate SimplifyFilterConditionRule to java [flink] - posted by "liuyongvs (via GitHub)" <gi...@apache.org> on 2024/12/30 06:59:28 UTC, 0 replies.
- [PR] 1.19/flink 36941 [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/30 07:53:18 UTC, 3 replies.
- [PR] [FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests in Release 1.19 [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/30 08:17:23 UTC, 2 replies.
- [PR] fix db2 Db2Dialect error [flink-connector-jdbc] - posted by "andyphone (via GitHub)" <gi...@apache.org> on 2024/12/30 08:18:47 UTC, 0 replies.
- [jira] [Created] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" - posted by "sukang (Jira)" <ji...@apache.org> on 2024/12/30 08:34:00 UTC, 0 replies.
- Re: [PR] [FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests in 1.19 [flink] - posted by "flinkbot (via GitHub)" <gi...@apache.org> on 2024/12/30 08:35:37 UTC, 0 replies.
- [jira] [Created] (FLINK-36981) The bug of transform merging with route in YAML task - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/12/30 08:37:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" - posted by "sukang (Jira)" <ji...@apache.org> on 2024/12/30 08:38:00 UTC, 0 replies.
- [PR] [FLINK-36941][docs] Update DATE_FORMAT Doc and Python Tests in 1.20 [flink] - posted by "yiyutian1 (via GitHub)" <gi...@apache.org> on 2024/12/30 08:38:52 UTC, 1 replies.
- [jira] [Assigned] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" - posted by "dalongliu (Jira)" <ji...@apache.org> on 2024/12/30 09:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36981) The bug of transform merging with route in YAML task - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/12/30 11:06:00 UTC, 4 replies.
- [jira] [Assigned] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/12/30 12:09:00 UTC, 0 replies.
- [PR] [BP-1.20][FLINK-35241][table]Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ [flink] - posted by "hanyuzheng7 (via GitHub)" <gi...@apache.org> on 2024/12/30 16:44:09 UTC, 5 replies.
- [PR] [FLINK-36981][cdc] Fix the bug of transform merging with route in YAML task [flink-cdc] - posted by "aiwenmo (via GitHub)" <gi...@apache.org> on 2024/12/30 17:35:02 UTC, 1 replies.
- [jira] [Created] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/31 04:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/31 04:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(CURRENT_TIMESTAMP, 'yyyy-MM-dd') as datetime` in - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/31 04:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(CURRENT_TIMESTAMP, 'yyyy-MM-dd') as datetime` in transform - posted by "Yanquan Lv (Jira)" <ji...@apache.org> on 2024/12/31 04:29:00 UTC, 0 replies.
- Re: [PR] [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform [flink-cdc] - posted by "yuxiqian (via GitHub)" <gi...@apache.org> on 2024/12/31 06:18:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-22091) env.java.home option didn't take effect in resource negotiator - posted by "Zhanghao Chen (Jira)" <ji...@apache.org> on 2024/12/31 08:55:00 UTC, 1 replies.
- [PR] [FLINK-22091][yarn] Make Flink on YARN honor env.java.home [flink] - posted by "X-czh (via GitHub)" <gi...@apache.org> on 2024/12/31 15:21:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-22091) env.java.home option didn't take effect in resource negotiator - posted by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/12/31 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36983) Observing unreliable IO metrics - posted by "Anurag Kyal (Jira)" <ji...@apache.org> on 2024/12/31 20:19:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version - posted by "Nick Nezis (Jira)" <ji...@apache.org> on 2024/12/31 21:01:00 UTC, 0 replies.