You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-36413) Reenable the test case that related to Source/Sink APi deprecated. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/01 01:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36414) NoSuchMethodError while trying flink cdc - posted by "Yang Hua Jie (Jira)" <ji...@apache.org> on 2024/10/01 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36415) ProjectWatermarkAssignerTransposeRule can generate extra casts which do not make sense - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/10/01 08:52:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-477: Amazon SQS Source Connector - posted by Saurabh Singh <sa...@gmail.com> on 2024/10/01 11:06:29 UTC, 0 replies.
- [jira] [Created] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/10/01 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36417) STATE_TTL doesn't work with WatermarkAssigner - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/10/01 15:37:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) - posted by Jim Hughes <jh...@confluent.io.INVALID> on 2024/10/01 23:02:11 UTC, 7 replies.
- [jira] [Created] (FLINK-36418) Update Control Flow page with latest developments - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/10/02 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36419) Consider scaling in case of no input records on a source operator with long running job - posted by "Sergey Kononov (Jira)" <ji...@apache.org> on 2024/10/02 12:42:00 UTC, 0 replies.
- Flink Kubernetes Operator 1.10.0 release planning - posted by Gyula Fóra <gy...@gmail.com> on 2024/10/03 10:08:18 UTC, 3 replies.
- [jira] [Created] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4 - posted by "Danny Cranmer (Jira)" <ji...@apache.org> on 2024/10/03 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36421) Missing fsync in FsCheckpointStreamFactory - posted by "Marc Aurel Fritz (Jira)" <ji...@apache.org> on 2024/10/03 14:31:00 UTC, 0 replies.
- Slack access - posted by Tom Cooper <co...@tomcooper.dev> on 2024/10/03 16:07:09 UTC, 1 replies.
- Slack Access - posted by Justin Ngai <ju...@reddit.com.INVALID> on 2024/10/03 16:10:37 UTC, 0 replies.
- [jira] [Created] (FLINK-36422) Broken PyFlink jar download link for Kafka connector - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/10/03 17:32:00 UTC, 0 replies.
- 2.0 podcast - posted by Rich Bowen <rb...@apache.org> on 2024/10/03 19:38:54 UTC, 1 replies.
- [jira] [Created] (FLINK-36423) Support RichMapPartitionFunction on KyedPartitionWindowedStream - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/10/04 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36424) Update deprecated YARN RM/NM callback handlers - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/10/04 07:50:00 UTC, 0 replies.
- Flink Slack invite - posted by Ralph Bartley <ra...@flutteruki.com> on 2024/10/04 08:50:11 UTC, 3 replies.
- [jira] [Created] (FLINK-36425) Use JobStatus enum for status.job.state - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/10/04 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/10/04 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36427) Additional Integration Test cases for KDS source - posted by "Elphas Toringepi (Jira)" <ji...@apache.org> on 2024/10/04 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36428) DynamoDb Table API Sink fails when null value in the RowData - posted by "maoxingda (Jira)" <ji...@apache.org> on 2024/10/07 00:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36429) Enhancing Flink History Server File Storage and Retrieval with RocksDB - posted by "Xiaowen Sun (Jira)" <ji...@apache.org> on 2024/10/07 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36430) Enhancing Flink History Server File Storage and Retrieval with RocksDB - posted by "Xiaowen Sun (Jira)" <ji...@apache.org> on 2024/10/07 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36431) Enhancing Flink History Server File Storage and Retrieval with RocksDB - posted by "Xiaowen Sun (Jira)" <ji...@apache.org> on 2024/10/07 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36432) FLIP-438: Amazon SQS Source Connector - posted by "Saurabh (Jira)" <ji...@apache.org> on 2024/10/07 12:30:00 UTC, 0 replies.
- [VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package - posted by Zakelly Lan <za...@gmail.com> on 2024/10/07 16:20:26 UTC, 4 replies.
- [jira] [Created] (FLINK-36433) non-keyed fullWindowPartition#reduce may throw NPE - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/10/08 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36434) Revise threading model of (KafkaPartition)SplitReader - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/10/08 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36435) Shaded Hadoop S3A with credentials provider end-to-end test failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/10/08 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36436) Remove legacy APIs with `legacy` package in table modules - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/08 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36437) Hive connector failed to compile with JDK 11 - posted by "Xuannan Su (Jira)" <ji...@apache.org> on 2024/10/08 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36438) Bump assertj from 3.23.1 to 3.26.3 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/08 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36439) Documentation for Disaggregated State Storage and Management - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/10/08 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36440) Bump log4j from 2.17.1 to 2.23.1 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/08 10:45:00 UTC, 0 replies.
- [KINDELY REMINDER] Flink 2.0 Release Sync 10/09/2024 - posted by Xintong Song <to...@gmail.com> on 2024/10/08 11:14:07 UTC, 0 replies.
- [jira] [Created] (FLINK-36441) Resource leaks in Kafka Tests - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/10/08 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36442) Add option to handle insert-only changeless in Postgres CDC connector - posted by "Nandor Soma Abonyi (Jira)" <ji...@apache.org> on 2024/10/08 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36443) Flaky Test: assertEquals in PushPartitionIntoTableSourceScanRuleTest.testWithUdf - posted by "William Lin (Jira)" <ji...@apache.org> on 2024/10/08 16:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-478: Introduce Config Option Scope - posted by Junrui Lee <jr...@gmail.com> on 2024/10/09 02:44:00 UTC, 6 replies.
- Join to slack community - posted by Fabrizzio Chávez Tejada <co...@fabrizziochavez.com> on 2024/10/09 03:03:56 UTC, 0 replies.
- [jira] [Created] (FLINK-36444) unstable test case SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/10/09 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36445) Introducing an ExecutionPlan interface - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/10/09 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36446) Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/10/09 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36447) Add .java-version(generated by jenv) to git igonre - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/10/09 05:31:00 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 10/09/2024 - posted by Xintong Song <to...@gmail.com> on 2024/10/09 06:37:10 UTC, 0 replies.
- [jira] [Created] (FLINK-36448) Compilation fails in IntelliJ - posted by "Kumar Mallikarjuna (Jira)" <ji...@apache.org> on 2024/10/09 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36449) Bump apache-rat-plugin from 0.12 to 0.16.1 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/09 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36450) Exclude log4j from curator-test - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/09 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals - posted by "xiechenling (Jira)" <ji...@apache.org> on 2024/10/09 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36452) Avoid EOFException when reading binlog after a large table has just completed snapshot reading - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/09 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36453) Backport DBZ-6502 patch to fix Oracle 23.x JDBC driver compatbility - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/09 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36454) FlinkContainer always overwrites default config - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/10/09 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36455) Sink should commit everything on notifyCheckpointCompleted - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/10/09 13:22:00 UTC, 0 replies.
- Consequences of removing per-job mode in Flink 2.0 - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/10/09 13:54:56 UTC, 6 replies.
- [jira] [Created] (FLINK-36456) Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key - posted by "Raul Garcia (Jira)" <ji...@apache.org> on 2024/10/09 15:42:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Introduce CLI API compatibility guarantees - posted by Mate Czagany <cz...@gmail.com> on 2024/10/09 16:39:13 UTC, 0 replies.
- [jira] [Created] (FLINK-36457) Python DataStream API: calling add_jars or add_classpaths results in corrupted execution config - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/10/09 23:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36458) Use original 'OceanBaseCEContainer' of testcontainers in testing - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/10/10 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36459) Add document to guide user to configure debezium properties - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/10 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36460) Refactor Kubernetes Operator Edge to Edge test setup - posted by "Sam Barker (Jira)" <ji...@apache.org> on 2024/10/10 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36461) YAML job failed to schema evolve with unmatched transform tables - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/10 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36462) Revert "remove per-job" - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/10/10 05:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36463) Disable some debezium options which do not take effect - posted by "Xiao Huang (Jira)" <ji...@apache.org> on 2024/10/10 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36464) Local artifact fetcher should not require base directory - posted by "Fabian Paul (Jira)" <ji...@apache.org> on 2024/10/10 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36465) Bump okhttp from 3.14.9 to 4.12.0 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/10 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36466) Change default value of execution.runtime-mode from STREAMING to AUTOMATIC - posted by "Wenjun Ruan (Jira)" <ji...@apache.org> on 2024/10/10 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36467) Bump google-java-format and spotless - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/10/10 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36468) Use Flink Precondition utils instead of Parquet - posted by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/10/10 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36469) Bump commons-io from 2.11.0 to 2.17.0 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/10 19:16:00 UTC, 0 replies.
- Resource limits for the k8s - posted by Maksym Serhieiev <se...@gmail.com> on 2024/10/10 20:46:57 UTC, 2 replies.
- [jira] [Created] (FLINK-36470) Bump checkstyle to 10+ - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/10/10 20:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36471) Flink Operator uses out of date Docker actions. - posted by "Sam Barker (Jira)" <ji...@apache.org> on 2024/10/10 21:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36472) Correlates with UDTF don't handle right-side conditions or projections - posted by "Alan Sheinberg (Jira)" <ji...@apache.org> on 2024/10/10 23:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36473) Operator metrics tests fail intermittently - posted by "Sam Barker (Jira)" <ji...@apache.org> on 2024/10/11 02:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36474) YAML Table-merging route should accept more type widening cases - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/11 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36475) YAML Transform supports case-insensitive column names conversion - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/11 02:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:39:00 UTC, 1 replies.
- [jira] [Created] (FLINK-36477) Remove deprecated method `BaseExpressions#cast` in table-api-java - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36478) Remove deprecated methods `EnvironmentSettings#fromConfiguration` and `EnvironmentSettings#toConfiguration` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36480) Remove all deprecated methods in `TableConfig` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36481) Remove deprecated method `TableDescriptor#forManaged` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36482) Remove all deprecated methods in `TableEnvironment` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36484) Remove deprecated method `StreamTableEnvironment#registerFunction` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36483) Remove deprecated method `TableResult#getTableSchema` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36486) Remove deprecated method `StreamTableEnvironment#registerDataStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36491) Remove deprecated method `DataStreamSinkProvider#consumeDataStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36490) Remove deprecated method `DataStreamScanProvider#produceDataStream` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36492) Remove all deprecated methods in `ListView` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36493) Remove all deprecated methods in `MapView` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36494) Remove deprecated methods `Catalog#getTableFactory` and `Catalog#supportsManagedTable` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36496) Remove deprecated method `CatalogFunction#isGeneric ` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36497) Remove all deprecated methods in `CatalogTable` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36500) Remove all deprecated methods in `CallExpression` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36499) Remove deprecated method `SupportsProjectionPushDown#applyProjection` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36502) Remove all deprecated methods in `FactoryUtil` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36501) Remove all deprecated methods in `CatalogFactory` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36504) Remove all deprecated methods `ModuleFactory` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36506) Remove all deprecated methods in `ColumnStats` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36507) Remove deprecated method `LogicalTypeParser#parse` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36508) Remove all deprecated methods in `SymbolType ` - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/10/11 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/11 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2 - posted by "Grace Grimwood (Jira)" <ji...@apache.org> on 2024/10/11 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36511) FlinkSecurityManager#checkExit StackOverFlow if haltOnSystemExit is enabled - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2024/10/11 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/10/11 14:43:00 UTC, 0 replies.
- [VOTE] Release flink-connector-kafka v3.3.0, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2024/10/11 15:33:26 UTC, 12 replies.
- [jira] [Created] (FLINK-36513) A lot of CI failures are caused by Install cert-manager - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/10/12 02:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36514) Unable to override include/exclude schema types in lenient mode - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/12 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36515) Adds high-precision TIME type support in YAML pipeline - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/12 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/12 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36517) Duplicate commit the same datafile in Paimon Sink - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/10/12 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36518) Paimon Sink support per-table property configuration - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/10/12 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36519) Typo in PartitionKeyGenerator java doc - posted by "Jorick Caberio (Jira)" <ji...@apache.org> on 2024/10/12 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36520) Flink CDC doesn't support MySQL > 8.0 - posted by "Maciej Bryński (Jira)" <ji...@apache.org> on 2024/10/12 14:22:00 UTC, 0 replies.
- [VOTE] Release 2.0-preview1, release candidate #1 - posted by Xintong Song <to...@gmail.com> on 2024/10/12 16:46:18 UTC, 14 replies.
- [jira] [Created] (FLINK-36521) Introduce TtlAwareSerializer to resolve the compatibility check between ttlSerializer and original serializer - posted by "xiangyu feng (Jira)" <ji...@apache.org> on 2024/10/13 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36522) Bump mysql-connector-j version - posted by "Kartik Goyal (Jira)" <ji...@apache.org> on 2024/10/13 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases - posted by "Abhi Gupta (Jira)" <ji...@apache.org> on 2024/10/13 20:43:00 UTC, 0 replies.
- Fwd: Custom Windowing Strategies in SQL - posted by Justin Ngai <ju...@reddit.com.INVALID> on 2024/10/14 02:00:25 UTC, 1 replies.
- FLIP-202: Flink Clickhouse Connector to Flink Community - posted by ConradJam <cz...@apache.org> on 2024/10/14 02:47:05 UTC, 0 replies.
- [jira] [Created] (FLINK-36524) upgrade paimon 0.9.0 - posted by "melin (Jira)" <ji...@apache.org> on 2024/10/14 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36525) Support for AI Model Integration for Data Processing - posted by "wuzexian (Jira)" <ji...@apache.org> on 2024/10/14 06:40:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD - posted by Lajith Koova <la...@gmail.com> on 2024/10/14 07:52:07 UTC, 0 replies.
- [jira] [Created] (FLINK-36527) Introduce a parameter to support the autoscaler to adopt a more aggressive strategy when Source or upstream shuffle is keyBy - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/10/14 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36526) Optimize the overhead of writing with direct buffer in ForSt - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/10/14 07:54:00 UTC, 0 replies.
- [DISCUSS] Elasticsearch v3.1 release - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/10/14 09:21:09 UTC, 2 replies.
- [jira] [Created] (FLINK-36528) Update org.apache.avro : avro dependency - posted by "Kartik Goyal (Jira)" <ji...@apache.org> on 2024/10/14 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36529) Support greater or equals logic for operator flink version default configs - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/10/14 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36530) Not able to restore list state from S3 - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/10/14 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36531) AutoScaler needs to consider the lag from last checkpoint - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/10/14 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36532) Kafka group offsets are not committed on stop with savepoint - posted by "LEONID ILYEVSKY (Jira)" <ji...@apache.org> on 2024/10/14 21:16:00 UTC, 0 replies.
- [DISCUSS] FLINK-36510/PR 25494 Upgrade Pekko from 1.0.1 to 1.1.2 - posted by Grace Grimwood <gg...@redhat.com> on 2024/10/14 22:27:24 UTC, 0 replies.
- [jira] [Created] (FLINK-36533) An exception occurs when using the taskmanager.data.bind-port - posted by "five (Jira)" <ji...@apache.org> on 2024/10/15 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36534) Upgrade Flink Kubernetes operator to flink-1.20 - posted by "Shailesh Gupta (Jira)" <ji...@apache.org> on 2024/10/15 05:02:00 UTC, 0 replies.
- [DISCUSS] Flink external connector bump version - posted by Yanquan Lv <de...@gmail.com> on 2024/10/15 05:40:54 UTC, 2 replies.
- [jira] [Created] (FLINK-36535) Optimize the scale down logic based on historical parallelism - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/10/15 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36536) Bump commons-text from 1.10.0 to 1.12.0 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/15 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36537) Bump snappy-java from 1.1.10.4 to 1.1.10.7 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/15 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36538) Bump commons-codec from 1.15 to 1.17.1 - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/15 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36539) Add Support for Hadoop Caller Context when using Flink on yarn - posted by "liang yu (Jira)" <ji...@apache.org> on 2024/10/15 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36540) Add Support for Hadoop Caller Context when using Flink on yarn - posted by "liang yu (Jira)" <ji...@apache.org> on 2024/10/15 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36541) Occasional met commit conflict problem in PaimonSink. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/15 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36542) Speed up the spotless apply - posted by "Wenjun Ruan (Jira)" <ji...@apache.org> on 2024/10/15 13:50:00 UTC, 0 replies.
- Major performance degradation in case of list operator state restore from S3 - posted by Gabor Somogyi <ga...@gmail.com> on 2024/10/15 14:26:16 UTC, 1 replies.
- [jira] [Created] (FLINK-36543) Table API over windows cannot be string serialized - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/10/15 15:43:00 UTC, 0 replies.
- [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 - posted by Őrhidi Mátyás <ma...@gmail.com> on 2024/10/15 16:17:45 UTC, 8 replies.
- [jira] [Created] (FLINK-36544) Failing to generate OLM bundle (open manifests/flink-kubernetes-operator.clusterserviceversion.yaml: permission denied) - posted by "Keith Wall (Jira)" <ji...@apache.org> on 2024/10/15 16:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36545) generate-olm-bundle.sh switches uid/gid when runner OLM tool image - posted by "Keith Wall (Jira)" <ji...@apache.org> on 2024/10/15 17:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36546) Handle batch sources in DataSinkTranslator - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2024/10/16 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36547) Add option to retain `RowKind` sematics after serialization/deserialization - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2024/10/16 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36549) Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSON results in unexpected data loss. - posted by "jiangyu (Jira)" <ji...@apache.org> on 2024/10/16 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36548) ChangelogDelegateEmbeddedRocksDBStateBackendTest crashed due to exit code: 134 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/10/16 03:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36550) Use ‘Thread.currentThread().getContextClassLoader()’ instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader - posted by "原来你是 小幸运0 01 (Jira)" <ji...@apache.org> on 2024/10/16 08:43:00 UTC, 0 replies.
- [RESULT][VOTE] flink-connector-kafka 3.3.0, release candidate #1 - posted by Arvid Heise <ar...@apache.org> on 2024/10/16 09:36:28 UTC, 0 replies.
- [jira] [Created] (FLINK-36551) Generated OLM bundle fails to deploy with install strategy failed .. Duplicate value: "keystore" - posted by "Keith Wall (Jira)" <ji...@apache.org> on 2024/10/16 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36552) Fix Table API OVER window support in batch mode - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/10/16 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36553) Local Global aggregation in Datasream API - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2024/10/16 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36554) Support MapState in Operator State - posted by "Jacob Jona Fahlenkamp (Jira)" <ji...@apache.org> on 2024/10/16 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/10/16 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/10/16 14:49:00 UTC, 0 replies.
- [DISCUSS] FlinkCDC bump version to Flink 1.19 - posted by Yanquan Lv <de...@gmail.com> on 2024/10/16 17:18:31 UTC, 6 replies.
- [jira] [Created] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/10/16 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36558) MySQL CDC Fails to parse array-typed key index binlog created between 8.0.17 and 8.0.18 - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/17 01:33:00 UTC, 0 replies.
- [VOTE] FLIP-478: Introduce Config Option Scope - posted by Junrui Lee <jr...@gmail.com> on 2024/10/17 01:59:18 UTC, 3 replies.
- [jira] [Created] (FLINK-36559) [docs]Add elasticsearch sink to docs - posted by "JunboWang (Jira)" <ji...@apache.org> on 2024/10/17 08:11:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package - posted by Zakelly Lan <za...@gmail.com> on 2024/10/17 08:20:28 UTC, 0 replies.
- [jira] [Created] (FLINK-36560) Fix the issue of timestamp_ltz increasing by 8 hours in Paimon - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/17 09:19:00 UTC, 0 replies.
- [ANNOUNCE] Apache flink-connector-kafka 3.3.0 released - posted by Arvid Heise <ar...@apache.org> on 2024/10/17 16:06:46 UTC, 0 replies.
- [jira] [Created] (FLINK-36561) ResultSet.wasNull() does not reflect null values in Flink JDBC Driver - posted by "Ilya Soin (Jira)" <ji...@apache.org> on 2024/10/17 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36563) Running CI in random timezone to expose more time related bugs - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/18 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36562) Running CI in random timezone to expose more time related bugs - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/18 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36564) Running CI in random timezone to expose more time related bugs - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/18 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36565) Pipeline YAML should allow merging decimal with different precisions - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/18 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36566) Code optimization: always identify DataChangeEvent before SchemaChangeEvent in Operator - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/18 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36567) Planner module didn't use the setting from flink-conf.yaml - posted by "liting liu (Jira)" <ji...@apache.org> on 2024/10/18 05:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36568) IllegalStateException Causes Collect Sink to Fail to Collect Result - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/10/18 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success - posted by "Jake.zhang (Jira)" <ji...@apache.org> on 2024/10/18 07:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36570) Fatal error occurred in the cluster entrypoint - posted by "zyh (Jira)" <ji...@apache.org> on 2024/10/18 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36571) Flink dashboard does not show Busy / Backpressure - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/10/18 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36572) The local time zone is wrongly set in StarRocks pipeline sink - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/10/20 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36573) Add table information of binlog offsets when checkpointing - posted by "Runkang He (Jira)" <ji...@apache.org> on 2024/10/20 10:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36574) The file STDOUT is not available on the TaskExecutor - posted by "fangmin.yang (Jira)" <ji...@apache.org> on 2024/10/20 12:53:00 UTC, 0 replies.
- [RESULT][VOTE] Release 2.0-preview1, release candidate #1 - posted by Xintong Song <to...@gmail.com> on 2024/10/20 16:56:09 UTC, 0 replies.
- [jira] [Created] (FLINK-36575) ExecutionVertexInputInfo supports consuming subpartition groups - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2024/10/21 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36576) Improving amount-based data balancing distribution algorithm for DefaultVertexParallelismAndInputInfosDecider - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2024/10/21 07:45:00 UTC, 0 replies.
- Re: Request to work on FLINK-33926 - posted by Gantigmaa Selenge <gs...@redhat.com> on 2024/10/21 11:52:11 UTC, 0 replies.
- [jira] [Created] (FLINK-36577) Add compatibility check for FlinkStateSnapshot CRD - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/10/21 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36578) Fixed bug when converting json to string - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2024/10/22 02:36:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-478: Introduce Config Option Scope - posted by Junrui Lee <jr...@gmail.com> on 2024/10/22 03:05:15 UTC, 0 replies.
- [jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare. - posted by "LIU (Jira)" <ji...@apache.org> on 2024/10/22 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/10/22 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36581) Allow passing Flink configuration by yaml job file or command line parameters - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/22 09:02:00 UTC, 0 replies.
- [DISCUSS] Release HBase connector with partial JDK support - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/10/22 11:44:48 UTC, 8 replies.
- [jira] [Created] (FLINK-36582) sql client hang when querying a parquet table - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2024/10/22 17:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36583) Add Slow Request Kube Client Metrics - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2024/10/22 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36584) PostgresIncrementalSource is not exiting the flink execution when StartupOptions is snapshot and create multiple replication slots - posted by "Anil Dasari (Jira)" <ji...@apache.org> on 2024/10/22 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36585) The SplitFetcherManager.close() can chain the futures in a tight loop. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2024/10/23 01:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+ - posted by "ZhengYu Chen (Jira)" <ji...@apache.org> on 2024/10/23 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36587) Postgres-cdc: Add support to override connector.class - posted by "Anil Dasari (Jira)" <ji...@apache.org> on 2024/10/23 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36588) flink catalog is supported in cdc yaml - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2024/10/23 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36589) Decouple the initialization of sync and async keyed statebackend - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/10/23 03:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36590) Flink CDC does not Support MySQL > 8.0.x - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/23 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/10/23 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend - posted by "Yanfei Lei (Jira)" <ji...@apache.org> on 2024/10/23 07:10:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 2.0 Preview released - posted by Xintong Song <to...@gmail.com> on 2024/10/23 09:26:08 UTC, 1 replies.
- [jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/10/23 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back - posted by "slankka (Jira)" <ji...@apache.org> on 2024/10/23 13:34:00 UTC, 0 replies.
- Re: Backporting array_agg from 1.20 to 1.18 - posted by "Hanyu (Peter) Zheng" <pz...@confluent.io.INVALID> on 2024/10/23 22:14:59 UTC, 2 replies.
- RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw - posted by "Hanyu (Peter) Zheng" <pz...@confluent.io.INVALID> on 2024/10/23 22:36:22 UTC, 1 replies.
- [jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20 - posted by "Aleksandr Pilipenko (Jira)" <ji...@apache.org> on 2024/10/23 23:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36596) YAML Pipeline fails to schema change with no projection fields specified - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/24 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/10/24 08:13:00 UTC, 0 replies.
- [DISCUSS] FLIP-480: Support to deploy script in application mode - posted by Shengkai Fang <fs...@gmail.com> on 2024/10/24 08:26:02 UTC, 12 replies.
- [jira] [Created] (FLINK-36598) [state/forst] Refactor initialization of ForSt db core - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/10/24 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group - posted by "Alan Zhang (Jira)" <ji...@apache.org> on 2024/10/25 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36600) Implement java.sql.Wrapper interface. - posted by "Yi Cai (Jira)" <ji...@apache.org> on 2024/10/25 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36601) Add JobID property to FlinkResultSet - posted by "Yi Cai (Jira)" <ji...@apache.org> on 2024/10/25 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36602) Upgrade Calcite version to 1.38.0 - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/10/25 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36603) Inconsistent spelling of "behavior" across the API - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2024/10/25 14:01:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1 - posted by Őrhidi Mátyás <ma...@gmail.com> on 2024/10/25 15:13:29 UTC, 0 replies.
- [jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh - posted by "Mingliang Liu (Jira)" <ji...@apache.org> on 2024/10/26 00:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36605) Upgrade Debezium version to 2.7.x - posted by "Anil Dasari (Jira)" <ji...@apache.org> on 2024/10/27 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36606) TimestampITCase generates test artifacts outside of tmp folder - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/10/27 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36607) Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/10/28 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36608) Support dynamic StreamGraph optimization for AdaptiveBroadcastJoinOperator - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/10/28 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36609) Protobuf Format not support proto3 - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/10/28 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36610) MySQL CDC supports parsing gh-ost generated schema changes - posted by "yux (Jira)" <ji...@apache.org> on 2024/10/28 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36611) Add schema info to output of Kafka sink - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/28 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/10/28 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/10/28 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36614) mysql cdc will be stuck when the ChangeEventQueue is full at snapshot consume phase - posted by "Youle (Jira)" <ji...@apache.org> on 2024/10/28 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/10/28 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36616) Null pointer in PubSub's GcpPublisherConfig - posted by "Radosław Stankiewicz (Jira)" <ji...@apache.org> on 2024/10/28 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36617) Migrate kryo package - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/10/28 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36618) Improve PostgresDialect.discoverDataCollections to reduce the start time of Postgres CDC - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/10/29 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36619) Downstream lost the CreateTableEvent when tables were removed and then re-added - posted by "linqigeng (Jira)" <ji...@apache.org> on 2024/10/29 04:02:00 UTC, 0 replies.
- [DISCUSS] Optimize the processing logic of TopNFunction to avoid the expiration of downstream operator states when state TTL is set - posted by 李阳 <li...@gmail.com> on 2024/10/29 07:16:14 UTC, 0 replies.
- [jira] [Created] (FLINK-36620) Add support for the flink-home parameter to be set in both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats - posted by "zjjiang (Jira)" <ji...@apache.org> on 2024/10/29 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36621) Build failure: StatefulSink not found - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/10/29 10:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36622) Remove the dependency of StateBenchmark on RocksDBKeyedStateBackend APIs. - posted by "Han Yin (Jira)" <ji...@apache.org> on 2024/10/29 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36623) Improve logging in DefaultStateTransitionManager - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/10/29 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/10/29 16:26:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released - posted by Őrhidi Mátyás <ma...@gmail.com> on 2024/10/29 18:25:35 UTC, 0 replies.
- [jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/10/29 18:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36626) Flink SQL JOINs behavior change from Flink 1.15 to Flink 1.18+ - posted by "Eduardo Breijo (Jira)" <ji...@apache.org> on 2024/10/29 19:59:00 UTC, 0 replies.
- Micro batching with flink - posted by Anil Dasari <da...@myyahoo.com.INVALID> on 2024/10/29 20:22:08 UTC, 2 replies.
- kafka-connector random WakeupException after enabling watermark alignment - posted by Alberto Lago <tr...@gmail.com> on 2024/10/29 22:02:05 UTC, 0 replies.
- [jira] [Created] (FLINK-36627) Failure to process a CSV file in Flink due to a character encoding mismatch: the file is in ISO-8859 and the application expects UTF-8. - posted by "Hector Miuler Malpica Gallegos (Jira)" <ji...@apache.org> on 2024/10/29 23:03:00 UTC, 0 replies.
- [DISCUSS][FLINK-36547] Add option to retain `RowKind` sematics for cdc formats - posted by Yubin Li <ly...@gmail.com> on 2024/10/30 03:18:57 UTC, 0 replies.
- [jira] [Created] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/10/30 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy - posted by "Lei Yang (Jira)" <ji...@apache.org> on 2024/10/30 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment - posted by "Alberto Lago (Jira)" <ji...@apache.org> on 2024/10/30 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN - posted by "Di Wu (Jira)" <ji...@apache.org> on 2024/10/30 10:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/10/30 11:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36633) Add support for Flink 1.20 in Flink OpenSearch connector - posted by "Andriy Redko (Jira)" <ji...@apache.org> on 2024/10/30 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/10/31 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed - posted by "Yi Zhang (Jira)" <ji...@apache.org> on 2024/10/31 05:41:00 UTC, 0 replies.
- *TemporarySystemFunction API without ignoreIfExists option - posted by Venkatakrishnan Sowrirajan <vs...@asu.edu> on 2024/10/31 06:27:09 UTC, 0 replies.
- [jira] [Created] (FLINK-36636) Timestamp data can not be compared in cdc pipeline transform - posted by "Wenkai Qi (Jira)" <ji...@apache.org> on 2024/10/31 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36637) Fix ListShards for Kinesis streams with large number of shards - posted by "Elphas Toringepi (Jira)" <ji...@apache.org> on 2024/10/31 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36638) Remove legacy bounded blocking shuffle - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/10/31 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/10/31 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36640) Provide an easy way to reset autoscaling - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2024/10/31 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36641) Support and Release Connectors for Flink 1.20 - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/10/31 12:51:00 UTC, 0 replies.
- JSON-Path CVEs - posted by Tom Cooper <co...@tomcooper.dev> on 2024/10/31 14:37:13 UTC, 1 replies.
- [jira] [Created] (FLINK-36642) Table API expressions with several built-in functions are not correctly serialized to SQL - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2024/10/31 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36643) Upgrade aws-java-sdk-core to 1.12.773+ to fix vulnerability - posted by "Thomas Cooper (Jira)" <ji...@apache.org> on 2024/10/31 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2024/10/31 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler - posted by "Sai Sharath Dandi (Jira)" <ji...@apache.org> on 2024/10/31 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36646) Support Java 17+ job images more conveniently in the operator - posted by "Rob Young (Jira)" <ji...@apache.org> on 2024/10/31 21:11:00 UTC, 0 replies.