You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-35945) Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka - posted by "任铭睿 (Jira)" <ji...@apache.org> on 2024/08/01 02:28:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-470: Support Adaptive Broadcast Join - posted by Xia Sun <xi...@gmail.com> on 2024/08/01 03:15:02 UTC, 2 replies.
- [jira] [Created] (FLINK-35946) Finalize release 1.20.0 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35950) CLONE - Publish the Dockerfiles for the new release - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35947) CLONE - Deploy Python artifacts to PyPI - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35948) CLONE - Deploy artifacts to Maven Central Repository - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35949) CLONE - Create Git tag and mark version as released in Jira - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35951) Flink CDC startup exception using jar package - posted by "huxx (Jira)" <ji...@apache.org> on 2024/08/01 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35960) CLONE - Start End of Life discussion thread for now outdated Flink minor version - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35954) CLONE - Merge website pull request - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35961) CLONE - Build 1.19 docs in GitHub Action and mark 1.19 as stable in docs - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35957) CLONE - Other announcements - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35958) CLONE - Update reference data for Migration Tests - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35953) CLONE - Update japicmp configuration - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35955) CLONE - Remove outdated versions - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35952) Promote release 1.20 - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35959) CLONE - Updates the docs stable version - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35956) CLONE - Apache mailing lists announcements - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/01 07:59:00 UTC, 0 replies.
- Re: [DISCUSS] Remove deprecated dataset based API from State Processor API - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/08/01 10:54:46 UTC, 2 replies.
- [jira] [Created] (FLINK-35962) Add REGEXP_INSTR function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/01 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35963) Add REGEXP_SUBSTR function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/01 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35964) Add STARTSWITH function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/01 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35965) Add ENDSWITH function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/01 13:00:00 UTC, 0 replies.
- Re:[DISCUSS] FLIP-455: Declare async state processing and checkpoint the in-flight requests - posted by Xuyang <xy...@163.com> on 2024/08/02 03:43:17 UTC, 8 replies.
- [jira] [Created] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/08/02 06:05:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.20.0 released - posted by weijie guo <gu...@gmail.com> on 2024/08/02 09:04:34 UTC, 12 replies.
- [jira] [Created] (FLINK-35967) Shade other Flink connectors in CDC Pipeline connectors - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/02 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/02 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35969) Remove deprecated dataset based API from State Processor API - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/08/02 11:48:00 UTC, 0 replies.
- Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting - posted by Roman Khachatryan <ro...@apache.org> on 2024/08/02 12:56:33 UTC, 1 replies.
- [jira] [Created] (FLINK-35970) Update documentation about FLINK-26050 (small file compaction) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/08/02 14:28:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states - posted by Matthias Pohl <mp...@confluent.io.INVALID> on 2024/08/02 16:18:33 UTC, 5 replies.
- Re: [DISCUSS]: Flink code generation porting to Calcite - posted by James Duong <Ja...@improving.com.INVALID> on 2024/08/02 22:51:30 UTC, 0 replies.
- [jira] [Created] (FLINK-35971) Lose precision in PostgresParallelSource - posted by "wuzhenhua (Jira)" <ji...@apache.org> on 2024/08/04 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35972) Directly specify key and process runnable in async state execution model - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/08/04 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35973) HeartbeatManagerTest.testHeartbeatTimeout failed - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/05 01:52:00 UTC, 0 replies.
- [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs - posted by Xuyang <xy...@163.com> on 2024/08/05 02:40:01 UTC, 9 replies.
- [jira] [Created] (FLINK-35974) PyFlink YARN per-job on Docker test failed because docker-compose command not found - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/05 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35975) MongoFilterPushDownVisitorTest fails - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/08/05 03:05:00 UTC, 0 replies.
- Re: Discussion on Vertica-Flink Connector - posted by Vikas Garg <vg...@opentext.com.INVALID> on 2024/08/05 06:16:48 UTC, 1 replies.
- [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states - posted by Zdenek Tison <zt...@confluent.io.INVALID> on 2024/08/05 07:11:04 UTC, 5 replies.
- [jira] [Created] (FLINK-35976) StreamPhysicalOverAggregate should handle column name confliction - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/08/05 07:20:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-471: Fixing watermark idleness timeout accounting - posted by Piotr Nowojski <pn...@apache.org> on 2024/08/05 08:34:33 UTC, 0 replies.
- [jira] [Created] (FLINK-35977) Missing an import in datastream.md - posted by "guluo (Jira)" <ji...@apache.org> on 2024/08/05 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35978) adapt labelling of boring cyborg - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/08/05 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35979) Add flink version 2.0-SNAPSHOT to ci - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/08/05 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35980) Add transform test coverage in Integrated / E2e tests - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 01:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35981) Transform rule doesn't support referencing one column more than once - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 02:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35982) Transform metadata config doesn't work if no projection block was provided - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35983) Job crashes when using wildcard (*) match with metadata column - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35984) Job crashes when metadata column names present in transform rules - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35985) SUBSTRING function not available in transform rules - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35986) NULL literal is not supported in Transform rules - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/06 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35987) Add ELT function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/06 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction. - posted by "luolei (Jira)" <ji...@apache.org> on 2024/08/06 07:49:00 UTC, 0 replies.
- [DISCUSS] Flink 2.0 Release Plan - posted by Xintong Song <to...@gmail.com> on 2024/08/06 07:53:34 UTC, 1 replies.
- [jira] [Created] (FLINK-35989) Document and log error on partially failed requests for AWS sinks - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/08/06 09:35:00 UTC, 0 replies.
- Stateful AsyncIO operator - posted by Taher Koitawala <ta...@gmail.com> on 2024/08/06 10:47:16 UTC, 1 replies.
- Re: [VOTE] FLIP-468: Introducing StreamGraph-Based Job Submission - posted by Junrui Lee <jr...@gmail.com> on 2024/08/06 14:02:38 UTC, 3 replies.
- Re: [DISCUSS] FLIP-468: Introducing StreamGraph-Based Job Submission. - posted by Junrui Lee <jr...@gmail.com> on 2024/08/06 14:05:14 UTC, 1 replies.
- [jira] [Created] (FLINK-35990) Lingering Transactions with FlinkKafkaProducer after failures & scale-down - posted by "Peter Larsen (Jira)" <ji...@apache.org> on 2024/08/07 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35991) Resolve conflicting definitions in transform SqlFunctionTable definition - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/07 04:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35992) NettyShuffleMaster not close tiered-storage resources - posted by "xuhuang (Jira)" <ji...@apache.org> on 2024/08/07 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35993) Add UNHEX function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/07 07:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35994) CDC pipeline use SavepointRestoreSettings in flink config flile as a fallback strategy. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/07 07:40:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector - posted by Ahmed Hamdy <ha...@gmail.com> on 2024/08/07 08:48:10 UTC, 3 replies.
- [jira] [Created] (FLINK-35995) postgresql有字段限制了，全量期间需要select * 的权限 - posted by "宇宙先生 (Jira)" <ji...@apache.org> on 2024/08/07 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35996) Add end-to-end tests for MySQL to Elasticsearch pipeline - posted by "wuzexian (Jira)" <ji...@apache.org> on 2024/08/07 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35997) Incomplete Table API & Python API of built-in function LTRIM & RTRIM - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/07 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35998) Duplicate common type search in type inference - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/07 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-35999) Remove log4j internal dependency - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/08/07 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36000) DynamicTableSink#Context's getTargetColumns should not return an array of zero length - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/08/07 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36001) Store operator name and UID in state metadata - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/08/07 14:05:00 UTC, 0 replies.
- [DISCUSS] FLIP-474: Store operator name and UID in state metadata - posted by Gabor Somogyi <ga...@gmail.com> on 2024/08/07 14:07:14 UTC, 11 replies.
- [Flink SQL Format] How to Process Metadata Columns in KafkaDynamicSink compatible EncodingFormat - posted by Kevin Lam <ke...@shopify.com.INVALID> on 2024/08/07 18:13:54 UTC, 0 replies.
- [jira] [Created] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/08/07 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36003) Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/08/07 20:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36004) Flink SQL returns wrong results for Paimon tables with complex schemas - posted by "Xingcan Cui (Jira)" <ji...@apache.org> on 2024/08/08 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36005) Specify to get part of the potgresql field - posted by "宇宙先生 (Jira)" <ji...@apache.org> on 2024/08/08 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36006) Add documentations for Flink CDC CLI - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/08 07:35:00 UTC, 0 replies.
- [DISCUSS] Release flink-connector-pulsar 2.0.0 - posted by Jiabao Sun <ji...@apache.org> on 2024/08/08 08:54:19 UTC, 1 replies.
- [jira] [Created] (FLINK-36007) cdc load and register factory in once search - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/08 09:04:00 UTC, 0 replies.
- [DISCUSS] Release flink-connector-mongodb 2.0.0 - posted by Jiabao Sun <ji...@apache.org> on 2024/08/08 09:04:15 UTC, 2 replies.
- [jira] [Created] (FLINK-36008) Guidance for connector docs contributions - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2024/08/08 09:57:00 UTC, 0 replies.
- Flink Jackson Exception when using JsonDeserialisationSchema - posted by Taher Koitawala <ta...@gmail.com> on 2024/08/08 10:04:11 UTC, 0 replies.
- [jira] [Created] (FLINK-36009) Change configs to use CondigOptions - posted by "João Boto (Jira)" <ji...@apache.org> on 2024/08/08 13:36:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states - posted by Zdenek Tison <zt...@confluent.io.INVALID> on 2024/08/08 13:41:39 UTC, 0 replies.
- [jira] [Created] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/08/08 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36012) Integrate StateTransitionManager into WaitingForResources state - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36013) Introduce the transition from Restarting to CreatingExecutionGraph state - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36014) Align the desired and sufficient resources definiton in Executing and WaitForResources states - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36015) Align rescale parameters - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36016) Synchronize initialization time and clock usage - posted by "Zdenek Tison (Jira)" <ji...@apache.org> on 2024/08/08 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36017) Support Passing Metadata to Formats in KafkaDynamicSink - posted by "Kevin Lam (Jira)" <ji...@apache.org> on 2024/08/08 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36018) Support lazy scale down to avoid frequent rescaling - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/08/09 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36019) flink_ha目录下的文件，可以通过配置自定义权限 - posted by "yanggang (Jira)" <ji...@apache.org> on 2024/08/09 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36020) exception: Time should be non negative - posted by "siyuan zheng (Jira)" <ji...@apache.org> on 2024/08/09 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36021) Give the responsibility of compression to tier itself - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/09 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36022) When scaling.enabled =false, adjust the values of some parameters to provide bette recommendation values. - posted by "yuanfenghu (Jira)" <ji...@apache.org> on 2024/08/09 07:22:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-468: Introducing StreamGraph-Based Job Submission - posted by Junrui Lee <jr...@gmail.com> on 2024/08/09 08:22:16 UTC, 0 replies.
- [RESULT][VOTE] FLIP-469: Supports Adaptive Optimization of StreamGraph - posted by Junrui Lee <jr...@gmail.com> on 2024/08/09 08:25:52 UTC, 0 replies.
- [jira] [Created] (FLINK-36023) Flink K8S Native Application Mode add wrong jar url. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/09 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36024) Handle BinaryLogClient exceptions when searching for the starting binlog offset - posted by "He Wang (Jira)" <ji...@apache.org> on 2024/08/09 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36025) Add TO_NUMBER function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/09 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36026) Options from OPTIONS hint are not present in compile plan - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/09 11:57:00 UTC, 0 replies.
- Rebuilding flink - posted by Dan Plyukhin <dp...@gmail.com> on 2024/08/09 22:17:22 UTC, 2 replies.
- [jira] [Created] (FLINK-36027) [cdc-connector][MySQL] added metrics numRecordsOut for each OperationType(update, delete, insert) - posted by "Lee SeungMin (Jira)" <ji...@apache.org> on 2024/08/10 18:48:00 UTC, 0 replies.
- [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink - posted by "Rich C." <ch...@gmail.com> on 2024/08/11 03:25:19 UTC, 1 replies.
- [jira] [Created] (FLINK-36028) Doc: kafka source additional properties - posted by "Rich (Jira)" <ji...@apache.org> on 2024/08/11 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36029) Add @Nullable Annotation to ValueState's Value Method Return Type - posted by "LEE SOMANG (Jira)" <ji...@apache.org> on 2024/08/11 05:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36030) Don't use negative values for changelog recovery tests - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2024/08/11 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API - posted by "Sam Barker (Jira)" <ji...@apache.org> on 2024/08/12 01:07:00 UTC, 0 replies.
- [VOTE] FLIP-470: Support Adaptive Broadcast Join - posted by Xia Sun <xi...@gmail.com> on 2024/08/12 01:57:19 UTC, 3 replies.
- [jira] [Created] (FLINK-36032) FLIP-468: Introducing StreamGraph-Based Job Submission - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/12 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36033) FLIP-469: Supports Adaptive Optimization of StreamGraph - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/12 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/12 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36035) Remove zipped dependency files from flink-python - posted by "Grace Grimwood (Jira)" <ji...@apache.org> on 2024/08/12 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36036) CDC remove unused dependency jar from calcite-core - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/12 08:48:00 UTC, 0 replies.
- [ANNOUNCE] Flink CDC release-3.2 branch cut - posted by Qingsheng Ren <re...@apache.org> on 2024/08/12 13:11:34 UTC, 3 replies.
- [jira] [Created] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery - posted by "Mate Czagany (Jira)" <ji...@apache.org> on 2024/08/12 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36038) SHOW CREATE VIEW returns invalid query - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/12 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36039) Support clean historical event handler records in autoscaler jdbc plugin - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2024/08/13 02:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36040) mysql cdc pipeline recover error from ck - posted by "xuhaiLong (Jira)" <ji...@apache.org> on 2024/08/13 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/13 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36042) newly added tables capture - posted by "xuhaiLong (Jira)" <ji...@apache.org> on 2024/08/13 03:41:00 UTC, 0 replies.
- [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests - posted by Zakelly Lan <za...@gmail.com> on 2024/08/13 05:42:03 UTC, 8 replies.
- [jira] [Created] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields - posted by "Yuan Kui (Jira)" <ji...@apache.org> on 2024/08/13 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36044) In Flinkcdc-connect-mysql2.4 version, scan.snapshot.fetch.size does not take effect - posted by "zhanghuaibei (Jira)" <ji...@apache.org> on 2024/08/13 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36045) Add support for SharePlex JSON format to Flink Formats. - posted by "Will-Hyde (Jira)" <ji...@apache.org> on 2024/08/13 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36046) Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces - posted by "Min Zhao (Jira)" <ji...@apache.org> on 2024/08/13 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36047) Add CompiledPlan annotations to BatchExecOverAggregate - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/08/13 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36048) Add CompiledPlan annotations to BatchExecRank - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/08/13 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36049) Add CompiledPlan annotations to BatchExecSortLimit - posted by "Jim Hughes (Jira)" <ji...@apache.org> on 2024/08/13 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36050) Support enhanced `show views` statement - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/13 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2024/08/14 00:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36052) add elasticsearch.md for elasticsearch pipeline connector - posted by "wuzexian (Jira)" <ji...@apache.org> on 2024/08/14 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36053) Support multi-version integration test in mongodb connector - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/08/14 03:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36054) Cleanup Flink CDC pom and release scripts - posted by "Qingsheng Ren (Jira)" <ji...@apache.org> on 2024/08/14 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version - posted by "wuzexian (Jira)" <ji...@apache.org> on 2024/08/14 06:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36056) change flink.connector.elasticsearch.version to a release version in branch release-3.2 - posted by "wuzexian (Jira)" <ji...@apache.org> on 2024/08/14 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36057) Allow specifying ARN for AWS connector resources - posted by "Elphas Toringepi (Jira)" <ji...@apache.org> on 2024/08/14 08:08:00 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 08/14/2024 - posted by Xintong Song <to...@gmail.com> on 2024/08/14 09:09:46 UTC, 0 replies.
- Re: [DISCUSS] CLI action deprecation process - posted by Ferenc Csaky <fe...@pm.me.INVALID> on 2024/08/14 11:30:29 UTC, 0 replies.
- RE: [DISCUSS] FLIP-XXX Apicurio-avro format - posted by David Radley <da...@uk.ibm.com> on 2024/08/14 16:18:22 UTC, 0 replies.
- [jira] [Created] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery - posted by "Rodrigo Meneses (Jira)" <ji...@apache.org> on 2024/08/14 19:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36059) SqlClientITCase failed due to could not create/start container - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/15 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36060) Transform built-in functions could not handle NULL values as arguments - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/15 05:57:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-470: Support Adaptive Broadcast Join - posted by Xia Sun <xi...@gmail.com> on 2024/08/15 06:08:59 UTC, 0 replies.
- [jira] [Created] (FLINK-36061) Support Apache iceberg for pipeline connector - posted by "ZhengYu Chen (Jira)" <ji...@apache.org> on 2024/08/15 06:44:00 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0 - posted by Qingsheng Ren <re...@apache.org> on 2024/08/15 07:13:17 UTC, 6 replies.
- [jira] [Created] (FLINK-36062) Only the first one in the delayed data will trigger,and it will only be restored when the transition is made to the current day window - posted by "Darren_Han (Jira)" <ji...@apache.org> on 2024/08/15 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36063) Migrate StreamGraph and its related classes to flink-runtime - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36064) Refactor CollectResultIterator to eliminate dependency on OperatorID - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36065) Support for submitting StreamGraph - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36066) Introducing the AdaptiveGraphGenerator component - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36067) Introducing the StreamGraphOptimizer component - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36068) Support for adaptive job scheduling based on StreamGraph - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36069) Extending job detail rest API to adapt to Incremental JobGraph Generation - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/08/15 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36070) Modifying web UI to adapt to Incremental JobGraph Generation - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36072) Optimizing the Overhead of the Network Layer in Adaptive Execution Scenarios - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/15 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2024/08/15 15:36:00 UTC, 0 replies.
- SinkV2 framework operators - posted by Rodrigo Meneses <rm...@gmail.com> on 2024/08/15 16:24:11 UTC, 0 replies.
- [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization. - posted by Lei Yang <le...@gmail.com> on 2024/08/16 03:17:19 UTC, 3 replies.
- 退订 - posted by 995626544 <99...@qq.com.INVALID> on 2024/08/16 03:27:13 UTC, 2 replies.
- [jira] [Created] (FLINK-36074) Supprt insert overwrite semantics for mongodb table sink. - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/08/16 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36075) Add paginate partition strategy for mongodb connector - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/08/16 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/16 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36077) Implement Table API support for PubSubSink V2 - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/08/16 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36078) Add Documentation for PubSubSink Table API connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/08/16 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36079) Add Documentation for SQS Table API connector - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/08/17 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36080) Add SQL Connector for SQS - posted by "Ahmed Hamdy (Jira)" <ji...@apache.org> on 2024/08/17 10:12:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Xuannan Su - posted by Xintong Song <xt...@apache.org> on 2024/08/17 12:42:51 UTC, 16 replies.
- [jira] [Created] (FLINK-36081) Flink CDC MySQL source connector missing some columns data of newly added tables - posted by "Mingya Wang (Jira)" <ji...@apache.org> on 2024/08/18 02:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36082) Fix NotSerializableException for KafkaDataSink - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/18 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36083) Fix kafka table api doc's Connector Options table broken - posted by "Zhongqiang Gong (Jira)" <ji...@apache.org> on 2024/08/18 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36084) Optimze parquet binary getBytes with getBytesUnsafe to avoid copy cost - posted by "xy (Jira)" <ji...@apache.org> on 2024/08/18 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36085) Refeactor operation with LIKE/ILIKE - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/18 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36086) SQL Server source connector skips changes if restarted mid transaction - posted by "Sergei Morozov (Jira)" <ji...@apache.org> on 2024/08/18 20:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36087) Fix - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/19 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36088) Fix NopointException in PaimonDataSink. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/19 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36089) clean codegen print function - posted by "Jacky Lau (Jira)" <ji...@apache.org> on 2024/08/19 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36090) Bug with IngestDB restore operation for priority queue state in backend - posted by "Maxim Vershinin (Jira)" <ji...@apache.org> on 2024/08/19 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36091) Config passed in via the environment variable FLINK_PROPERTIES which has space not getting processed - posted by "lajith (Jira)" <ji...@apache.org> on 2024/08/19 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36092) Transform doesn't fully support with schema evolution - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/19 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/19 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/19 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36095) KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering - posted by "lincoln lee (Jira)" <ji...@apache.org> on 2024/08/19 10:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36096) Support sync interface in state v2 api. - posted by "wang qian (Jira)" <ji...@apache.org> on 2024/08/19 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36097) Add timeseries support for SampleSplitter - posted by "Jiabao Sun (Jira)" <ji...@apache.org> on 2024/08/19 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36098) Add support for Table Comments in Flink SQL ALTER TABLE statements - posted by "Steffen Hoellinger (Jira)" <ji...@apache.org> on 2024/08/19 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/08/19 15:42:00 UTC, 0 replies.
- [FLINK-35177] Fix DataGen Connector documentation - posted by Sergei Morozov <mo...@gmail.com> on 2024/08/19 18:16:51 UTC, 0 replies.
- [jira] [Created] (FLINK-36100) Support ESCAPE in built-in function LIKE formally - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/20 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36102) Support ESCAPE in built-in function LIKE formally - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/20 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36101) Support ESCAPE in built-in function LIKE formally - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/20 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36103) Support ESCAPE in built-in function LIKE formally - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/20 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36104) flink 1.20 not suport logback - posted by "xuhaiLong (Jira)" <ji...@apache.org> on 2024/08/20 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20 - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/20 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36106) t_flink_autoscaler_event_handler is not cleaned after each testing - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/08/20 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36107) schema event support custom callback - posted by "melin (Jira)" <ji...@apache.org> on 2024/08/20 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36108) Wait for state download on cancellation to enforce cleanup - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2024/08/20 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/08/20 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36110) Periodic save points trigger continuously - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/08/20 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/08/20 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36112) Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes - posted by "liang yu (Jira)" <ji...@apache.org> on 2024/08/20 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false' - posted by "tiancx (Jira)" <ji...@apache.org> on 2024/08/20 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36114) Schema registry should block when handling existing requests - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/21 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36115) Allow to scan newly table DDL during incremental reading stage. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/21 02:07:00 UTC, 0 replies.
- [VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs - posted by Xuyang <xy...@163.com> on 2024/08/21 02:33:03 UTC, 6 replies.
- [jira] [Created] (FLINK-36116) Javadocs aren't visible anymore for Flink 1.17 and above - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/08/21 07:47:00 UTC, 0 replies.
- [VOTE] FLIP-477: Amazon SQS Source Connector - posted by Abhisagar Khatri <kh...@gmail.com> on 2024/08/21 08:09:55 UTC, 2 replies.
- [jira] [Created] (FLINK-36117) Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend. - posted by "wang qian (Jira)" <ji...@apache.org> on 2024/08/21 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36118) FLIP-455: Declare async state processing and checkpoint the in-flight requests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/08/21 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36119) Conditional branchings APIs under `StateFuture` - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/08/21 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36121) Snapshot the in-flight async state requests - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/08/21 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36120) Internal APIs for declaring and defining the record processing - posted by "Zakelly Lan (Jira)" <ji...@apache.org> on 2024/08/21 09:08:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests - posted by Zakelly Lan <za...@gmail.com> on 2024/08/21 09:24:22 UTC, 0 replies.
- [jira] [Created] (FLINK-36122) Redundant cast in outer layer when comparing Row Types for equality - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/21 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36123) Add PERCENTILE function - posted by "Dylan He (Jira)" <ji...@apache.org> on 2024/08/21 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/08/21 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36125) File not found exception on restoring state handles with file merging - posted by "Burak Ozakinci (Jira)" <ji...@apache.org> on 2024/08/21 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36126) Qualification of current catalog and current database should happen during execution, not parsing - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/21 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36127) Support sorting watermark on flink web - posted by "Yu Chen (Jira)" <ji...@apache.org> on 2024/08/21 15:06:00 UTC, 0 replies.
- Flink CDC insert-only changelog mode - posted by Daniel Henneberger <me...@danielhenneberger.com> on 2024/08/22 01:29:00 UTC, 3 replies.
- [jira] [Created] (FLINK-36128) Promote LENIENT mode as the default schema evolution behavior - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/22 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36129) Autoscaler is compatible with Flink 1.20 - posted by "Rui Fan (Jira)" <ji...@apache.org> on 2024/08/22 05:28:00 UTC, 0 replies.
- Issue with table.optimizer.join-reorder-enabled and lookup join - posted by Tamas Sule <ta...@cloudera.com.INVALID> on 2024/08/22 07:38:07 UTC, 0 replies.
- [jira](FLINK-35444) Apply for a jira account and repair bug - posted by 郑恺原 <ky...@gmail.com> on 2024/08/22 08:05:39 UTC, 3 replies.
- [jira] [Created] (FLINK-36130) flink cdc submit yaml task - posted by "zzm (Jira)" <ji...@apache.org> on 2024/08/22 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data - posted by "mumu (Jira)" <ji...@apache.org> on 2024/08/22 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/22 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/22 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/22 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/22 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc. - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/22 10:16:00 UTC, 0 replies.
- [jira](FLINK-36127) Apply for a jira account and repair bug - posted by Yunming Tang <yu...@gmail.com> on 2024/08/22 12:01:11 UTC, 2 replies.
- [jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/08/22 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36138) KinesisStreamsSource.buil() should have helpful null errors - posted by "Jörn Kottmann (Jira)" <ji...@apache.org> on 2024/08/22 17:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36139) ClassCastException when checkpointing AggregateFunction - posted by "Vladislav Keda (Jira)" <ji...@apache.org> on 2024/08/22 19:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36140) Log a warning when pods are terminated by kubernetes - posted by "Clara Xiong (Jira)" <ji...@apache.org> on 2024/08/22 21:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36141) Set the scanNewlyAddedTableEnabled is true, but does not support automatic identification new table - posted by "zhongyuandong (Jira)" <ji...@apache.org> on 2024/08/23 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/23 04:04:00 UTC, 0 replies.
- Re: [EXTERNAL] - Re: Discussion on Vertica-Flink Connector - posted by Vikas Garg <vg...@opentext.com.INVALID> on 2024/08/23 06:01:17 UTC, 0 replies.
- [jira] [Created] (FLINK-36143) Sink ES occurred "version conflict" - posted by "sanqingleo (Jira)" <ji...@apache.org> on 2024/08/23 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36144) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data - posted by "mumu (Jira)" <ji...@apache.org> on 2024/08/23 08:29:00 UTC, 0 replies.
- [DISCUSS] FLIP-319: Integrating with Kafka’s proper support for 2PC participation (KIP-939). - posted by David Radley <da...@uk.ibm.com> on 2024/08/23 15:15:20 UTC, 0 replies.
- [jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/08/23 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager - posted by "Kim Gräsman (Jira)" <ji...@apache.org> on 2024/08/23 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36147) Removes deprecated location field - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/08/23 20:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36148) Support parsing DDL to new CreateTableEvent in binlog reading phase. - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/24 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states. - posted by "luolei (Jira)" <ji...@apache.org> on 2024/08/24 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36150) tables.exclude is not valid if scan.binlog.newly-added-table.enabled is true. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/25 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36151) Add documentations for Schema Evolution related options - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/25 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36152) Traverse through the superclass hierarchy to extract generic type. - posted by "Xinglong Wang (Jira)" <ji...@apache.org> on 2024/08/25 23:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36153) MySQL fails to handle schema change events In Timestamp or Earliest Offset startup mode - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/26 01:32:00 UTC, 0 replies.
- [VOTE] FLIP-474: Store operator name and UID in state metadata - posted by Gabor Somogyi <ga...@gmail.com> on 2024/08/26 08:00:03 UTC, 9 replies.
- [jira] [Created] (FLINK-36154) Support parse json ignore field key case - posted by "KevinyhZou (Jira)" <ji...@apache.org> on 2024/08/26 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected - posted by "Keith Lee (Jira)" <ji...@apache.org> on 2024/08/26 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36156) SinkV2: Provide the ability to set Committer Operator parallelism - posted by "Rodrigo Meneses (Jira)" <ji...@apache.org> on 2024/08/26 19:34:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs - posted by Xuyang <xy...@163.com> on 2024/08/27 02:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-36157) FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/27 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36158) Support for StreamGraph store - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/27 02:50:00 UTC, 0 replies.
- [KINDLY REMINDER] Flink 2.0 Release Sync 08/28/2024 - posted by Xintong Song <to...@gmail.com> on 2024/08/27 05:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-36159) FLIP-470: Support Adaptive Broadcast Join - posted by "xingbe (Jira)" <ji...@apache.org> on 2024/08/27 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36160) Support hive advanced configuration - posted by "zhuanshenbsj1 (Jira)" <ji...@apache.org> on 2024/08/27 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36161) Integration Test Example uses deprecated SinkFunction - posted by "Wolff Bock von Wuelfingen (Jira)" <ji...@apache.org> on 2024/08/27 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2024/08/27 16:05:00 UTC, 0 replies.
- PostCommitTopology question - posted by Péter Váry <pe...@gmail.com> on 2024/08/27 19:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-36163) Kafka cdc pipeline source supports protobuf format. - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/28 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36164) JdbcIncrementalSource CheckPoint Timeout Due to Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned PostgreSQL Table - posted by "tchivs (Jira)" <ji...@apache.org> on 2024/08/28 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36165) Support obtaining snapshot data of the scope - posted by "Thorne (Jira)" <ji...@apache.org> on 2024/08/28 06:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36166) testJoinDisorderChangeLog failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/28 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36167) testSinkDisorderChangeLog failed on AZP - posted by "Weijie Guo (Jira)" <ji...@apache.org> on 2024/08/28 07:23:00 UTC, 0 replies.
- [SUMMARY] Flink 2.0 Release Sync 08/28/2024 - posted by Xintong Song <to...@gmail.com> on 2024/08/28 07:53:37 UTC, 0 replies.
- [jira] [Created] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle - posted by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/08/28 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2024/08/28 16:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36170) Bump assertj-core version - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/08/28 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36171) Remove APIs about ManagedTable - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/29 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/29 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36173) Invalid link in checkpoint documentation - posted by "Gabor Somogyi (Jira)" <ji...@apache.org> on 2024/08/29 07:52:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-474: Store operator name and UID in state metadata - posted by Gabor Somogyi <ga...@gmail.com> on 2024/08/29 08:11:21 UTC, 0 replies.
- [jira] [Created] (FLINK-36174) CDC yaml without pipeline will throw NullPointException - posted by "Hongshun Wang (Jira)" <ji...@apache.org> on 2024/08/29 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36175) Remove `register_table_source` and `register_table_sink` in python module - posted by "xuyang (Jira)" <ji...@apache.org> on 2024/08/29 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36176) Remove support for ancient Kafka versions - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/08/29 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36177) Deprecating KafkaShuffle - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/08/29 09:39:00 UTC, 0 replies.
- [DISCUSSION] Disabling japicmp plugin in master for 2.0 - posted by Matthias Pohl <ma...@apache.org> on 2024/08/29 09:39:14 UTC, 1 replies.
- [jira] [Created] (FLINK-36178) Parse CREATE TABLE LIKE to CreateTableEvent - posted by "LvYanquan (Jira)" <ji...@apache.org> on 2024/08/29 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36179) Bump log4j version - posted by "Siddharth R (Jira)" <ji...@apache.org> on 2024/08/29 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36180) Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost - posted by "Wenbing Shen (Jira)" <ji...@apache.org> on 2024/08/29 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36181) Drop support for Java 8 and use Java 17 by default - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/08/29 19:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36182) PyFlink SQL Job Got IllegalStateException During Task Manager Shutdown - posted by "EMERSON WANG (Jira)" <ji...@apache.org> on 2024/08/29 20:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36183) Lenient mode doesn't work with route blocks - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/30 01:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36184) Transform Operator swallows schema changes from tables not present in transform rules - posted by "yux (Jira)" <ji...@apache.org> on 2024/08/30 02:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-36185) Remove RuntimeContext#getExecutionConfig - posted by "Junrui Li (Jira)" <ji...@apache.org> on 2024/08/30 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36186) Speed up RocksDB close during manual compaction - posted by "Yue Ma (Jira)" <ji...@apache.org> on 2024/08/30 04:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36187) Reimplement UniformShardAssigner using Kinesis shard hashes - posted by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/08/30 08:41:00 UTC, 0 replies.
- [VOTE] Apache Flink CDC Release 3.2.0, release candidate #1 - posted by Qingsheng Ren <re...@apache.org> on 2024/08/30 09:24:48 UTC, 0 replies.
- [jira] [Created] (FLINK-36188) HBase disable buffer flush lose efficacy - posted by "MOBIN (Jira)" <ji...@apache.org> on 2024/08/30 10:11:00 UTC, 0 replies.
- Flink aggregation docs - posted by David Radley <da...@uk.ibm.com> on 2024/08/30 11:22:24 UTC, 2 replies.
- [jira] [Created] (FLINK-36189) Documentation build is failing with NPM installation problem - posted by "Martijn Visser (Jira)" <ji...@apache.org> on 2024/08/30 13:27:00 UTC, 0 replies.
- Match recognize references old type system in docs. - posted by David Radley <da...@uk.ibm.com> on 2024/08/30 13:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues - posted by "Alexis Sarda-Espinosa (Jira)" <ji...@apache.org> on 2024/08/31 15:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-36191) FsMergingCheckpointStorageLocationTest generates test data not in tmp folder - posted by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2024/08/31 19:15:00 UTC, 0 replies.