dev  

Messages by Thread

• [jira] [Created] (FLINK-36059) SqlClientITCase failed due to could not create/start container Weijie Guo (Jira)
• [jira] [Created] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery Rodrigo Meneses (Jira)
• [SUMMARY] Flink 2.0 Release Sync 08/14/2024 Xintong Song
• [jira] [Created] (FLINK-36057) Allow specifying ARN for AWS connector resources Elphas Toringepi (Jira)
• [jira] [Created] (FLINK-36056) change flink.connector.elasticsearch.version to a release version in branch release-3.2 wuzexian (Jira)
• [jira] [Created] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version wuzexian (Jira)
• [jira] [Created] (FLINK-36054) Cleanup Flink CDC pom and release scripts Qingsheng Ren (Jira)
• [jira] [Created] (FLINK-36053) Support multi-version integration test in mongodb connector Jiabao Sun (Jira)
• [jira] [Created] (FLINK-36052) add elasticsearch.md for elasticsearch pipeline connector wuzexian (Jira)
• [jira] [Created] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements Sergei Morozov (Jira)
• [jira] [Created] (FLINK-36049) Add CompiledPlan annotations to BatchExecSortLimit Jim Hughes (Jira)
• [jira] [Created] (FLINK-36048) Add CompiledPlan annotations to BatchExecRank Jim Hughes (Jira)
• [jira] [Created] (FLINK-36047) Add CompiledPlan annotations to BatchExecOverAggregate Jim Hughes (Jira)
• [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 Min Zhao (Jira)
• [jira] [Created] (FLINK-36045) Add support for SharePlex JSON format to Flink Formats. Will-Hyde (Jira)
• [jira] [Created] (FLINK-36044) In Flinkcdc-connect-mysql2.4 version, scan.snapshot.fetch.size does not take effect zhanghuaibei (Jira)
• [jira] [Created] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields Yuan Kui (Jira)
• [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
  • Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yanfei Lei
  • Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yuepeng Pan
  • Re:Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Xuyang
  • Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Ahmed Hamdy
  • Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Hangxiang Yu
  • Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
  • Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Yuan Mei
  • Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests Zakelly Lan
• [jira] [Created] (FLINK-36042) newly added tables capture xuhaiLong (Jira)
• [jira] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime yux (Jira)
• [jira] [Created] (FLINK-36040) mysql cdc pipeline recover error from ck xuhaiLong (Jira)
• [jira] [Created] (FLINK-36039) Support clean historical event handler records in autoscaler jdbc plugin RocMarshal (Jira)
• [jira] [Created] (FLINK-36038) SHOW CREATE VIEW returns invalid query Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery Mate Czagany (Jira)
• [ANNOUNCE] Flink CDC release-3.2 branch cut Qingsheng Ren
  • Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Leonard Xu
  • Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Qingsheng Ren
  • Re: [ANNOUNCE] Flink CDC release-3.2 branch cut Leonard Xu
• [jira] [Created] (FLINK-36036) CDC remove unused dependency jar from calcite-core Hongshun Wang (Jira)
• [jira] [Created] (FLINK-36035) Remove zipped dependency files from flink-python Grace Grimwood (Jira)
• [jira] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module yux (Jira)
• [jira] [Created] (FLINK-36033) FLIP-469: Supports Adaptive Optimization of StreamGraph Junrui Li (Jira)
• [jira] [Created] (FLINK-36032) FLIP-468: Introducing StreamGraph-Based Job Submission Junrui Li (Jira)
• [VOTE] FLIP-470: Support Adaptive Broadcast Join Xia Sun
  • Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Lincoln Lee
  • Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Zhu Zhu
  • Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join Ron Liu
• [jira] [Created] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API Sam Barker (Jira)
• [jira] [Created] (FLINK-36030) Don't use negative values for changelog recovery tests Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-36029) Add @Nullable Annotation to ValueState's Value Method Return Type LEE SOMANG (Jira)
• [jira] [Created] (FLINK-36028) Doc: kafka source additional properties Rich (Jira)
• [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink Rich C.
  • Re: [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink Ahmed Hamdy
• [jira] [Created] (FLINK-36027) [cdc-connector][MySQL] added metrics numRecordsOut for each OperationType(update, delete, insert) Lee SeungMin (Jira)
• Rebuilding flink Dan Plyukhin
  • Re: Rebuilding flink Gabor Somogyi
  • Re: Rebuilding flink Ferenc Csaky
• [jira] [Created] (FLINK-36026) Options from OPTIONS hint are not present in compile plan Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36025) Add TO_NUMBER function Dylan He (Jira)
• [jira] [Created] (FLINK-36024) Handle BinaryLogClient exceptions when searching for the starting binlog offset He Wang (Jira)
• [jira] [Created] (FLINK-36023) Flink K8S Native Application Mode add wrong jar url. Hongshun Wang (Jira)
• [RESULT][VOTE] FLIP-469: Supports Adaptive Optimization of StreamGraph Junrui Lee
• [RESULT][VOTE] FLIP-468: Introducing StreamGraph-Based Job Submission Junrui Lee
• [jira] [Created] (FLINK-36022) When scaling.enabled =false, adjust the values ​​​​of some parameters to provide bette recommendation values. yuanfenghu (Jira)
• [jira] [Created] (FLINK-36021) Give the responsibility of compression to tier itself Weijie Guo (Jira)
• [jira] [Created] (FLINK-36020) exception: Time should be non negative siyuan zheng (Jira)
• [jira] [Created] (FLINK-36019) flink_ha目录下的文件，可以通过配置自定义权限 yanggang (Jira)
• [jira] [Created] (FLINK-36018) Support lazy scale down to avoid frequent rescaling Rui Fan (Jira)
• [jira] [Created] (FLINK-36017) Support Passing Metadata to Formats in KafkaDynamicSink Kevin Lam (Jira)
• [jira] [Created] (FLINK-36016) Synchronize initialization time and clock usage Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36015) Align rescale parameters Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36014) Align the desired and sufficient resources definiton in Executing and WaitForResources states Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36013) Introduce the transition from Restarting to CreatingExecutionGraph state Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36012) Integrate StateTransitionManager into WaitingForResources state Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager Zdenek Tison (Jira)
• [jira] [Created] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED Ahmed Hamdy (Jira)
• [RESULT][VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states Zdenek Tison
• [jira] [Created] (FLINK-36009) Change configs to use CondigOptions Jira
• Flink Jackson Exception when using JsonDeserialisationSchema Taher Koitawala
• [jira] [Created] (FLINK-36008) Guidance for connector docs contributions Lorenzo Nicora (Jira)
• [DISCUSS] Release flink-connector-mongodb 2.0.0 Jiabao Sun
  • Re: [DISCUSS] Release flink-connector-mongodb 2.0.0 Leonard Xu
  • Re: [DISCUSS] Release flink-connector-mongodb 2.0.0 Ahmed Hamdy
  • [DISCUSS] Release flink-connector-mongodb 2.0.0 Jiabao Sun
  • Re: [DISCUSS] Release flink-connector-mongodb 2.0.0 Leonard Xu
• [jira] [Created] (FLINK-36007) cdc load and register factory in once search Hongshun Wang (Jira)
• [DISCUSS] Release flink-connector-pulsar 2.0.0 Jiabao Sun
  • Re: [DISCUSS] Release flink-connector-pulsar 2.0.0 Jiabao Sun
• [jira] [Created] (FLINK-36006) Add documentations for Flink CDC CLI yux (Jira)
• [jira] [Created] (FLINK-36005) Specify to get part of the potgresql field Jira
• [jira] [Created] (FLINK-36004) Flink SQL returns wrong results for Paimon tables with complex schemas Xingcan Cui (Jira)
• [jira] [Created] (FLINK-36003) Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate Jim Hughes (Jira)
• [jira] [Created] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch Jim Hughes (Jira)
• [Flink SQL Format] How to Process Metadata Columns in KafkaDynamicSink compatible EncodingFormat Kevin Lam
• [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Márton Balassi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata David Morávek
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Gabor Somogyi
  • Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata Zakelly Lan
• [jira] [Created] (FLINK-36001) Store operator name and UID in state metadata Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-36000) DynamicTableSink#Context's getTargetColumns should not return an array of zero length lincoln lee (Jira)
• [jira] [Created] (FLINK-35999) Remove log4j internal dependency Siddharth R (Jira)
• [jira] [Created] (FLINK-35998) Duplicate common type search in type inference Dylan He (Jira)
• [jira] [Created] (FLINK-35997) Incomplete Table API & Python API of built-in function LTRIM & RTRIM Dylan He (Jira)
• [jira] [Created] (FLINK-35996) Add end-to-end tests for MySQL to Elasticsearch pipeline wuzexian (Jira)
• [jira] [Created] (FLINK-35995) postgresql有字段限制了，全量期间需要select * 的权限 Jira
• [jira] [Created] (FLINK-35994) CDC pipeline use SavepointRestoreSettings in flink config flile as a fallback strategy. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-35993) Add UNHEX function Dylan He (Jira)
• [jira] [Created] (FLINK-35992) NettyShuffleMaster not close tiered-storage resources xuhuang (Jira)
• [jira] [Created] (FLINK-35991) Resolve conflicting definitions in transform SqlFunctionTable definition yux (Jira)
• [jira] [Created] (FLINK-35990) Lingering Transactions with FlinkKafkaProducer after failures & scale-down Peter Larsen (Jira)
• Stateful AsyncIO operator Taher Koitawala
  • Re: Stateful AsyncIO operator Eric Xiao
• [jira] [Created] (FLINK-35989) Document and log error on partially failed requests for AWS sinks Hong Liang Teoh (Jira)
• [DISCUSS] Flink 2.0 Release Plan Xintong Song
  • Re: [DISCUSS] Flink 2.0 Release Plan Xintong Song
• [jira] [Created] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction. luolei (Jira)
• [jira] [Created] (FLINK-35987) Add ELT function Dylan He (Jira)
• [jira] [Created] (FLINK-35986) NULL literal is not supported in Transform rules yux (Jira)
• [jira] [Created] (FLINK-35985) SUBSTRING function not available in transform rules yux (Jira)
• [jira] [Created] (FLINK-35984) Job crashes when metadata column names present in transform rules yux (Jira)
• [jira] [Created] (FLINK-35983) Job crashes when using wildcard (*) match with metadata column yux (Jira)
• [jira] [Created] (FLINK-35982) Transform metadata config doesn't work if no projection block was provided yux (Jira)
• [jira] [Created] (FLINK-35981) Transform rule doesn't support referencing one column more than once yux (Jira)
• [jira] [Created] (FLINK-35980) Add transform test coverage in Integrated / E2e tests yux (Jira)
• [jira] [Created] (FLINK-35979) Add flink version 2.0-SNAPSHOT to ci Jira
• [jira] [Created] (FLINK-35978) adapt labelling of boring cyborg Jira
• [jira] [Created] (FLINK-35977) Missing an import in datastream.md guluo (Jira)
• [RESULT][VOTE] FLIP-471: Fixing watermark idleness timeout accounting Piotr Nowojski
• [jira] [Created] (FLINK-35976) StreamPhysicalOverAggregate should handle column name confliction lincoln lee (Jira)
• [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states Zdenek Tison
  • Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states Rui Fan
  • Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states yuanfeng hu
  • Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states David Morávek
  • Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states Matthias Pohl
  • Re:[VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states Yuepeng Pan
• [jira] [Created] (FLINK-35975) MongoFilterPushDownVisitorTest fails Jiabao Sun (Jira)
• [jira] [Created] (FLINK-35974) PyFlink YARN per-job on Docker test failed because docker-compose command not found Weijie Guo (Jira)
• [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
  • Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Zakelly Lan
  • Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
  • Re:Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
  • Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs David Morávek
  • Re:Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
  • Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Feng Jin
  • Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
  • Re: Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs ron
  • Re:Re: Re:Re: Re: Re:Re: [DISCUSS] FLIP-473: Introduce New SQL Operators Based on Asynchronous State APIs Xuyang
• [jira] [Created] (FLINK-35973) HeartbeatManagerTest.testHeartbeatTimeout failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-35972) Directly specify key and process runnable in async state execution model Zakelly Lan (Jira)
• [jira] [Created] (FLINK-35971) Lose precision in PostgresParallelSource wuzhenhua (Jira)
• [jira] [Created] (FLINK-35970) Update documentation about FLINK-26050 (small file compaction) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-35969) Remove deprecated dataset based API from State Processor API Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors Hongshun Wang (Jira)
• [jira] [Created] (FLINK-35967) Shade other Flink connectors in CDC Pipeline connectors yux (Jira)
• [ANNOUNCE] Apache Flink 1.20.0 released weijie guo
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Zakelly Lan
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Ahmed Hamdy
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Paul Lam
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Yubin Li
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Feng Jin
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Aleksandr Pilipenko
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Jiadong Lu
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Ferenc Csaky
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Jingsong Li
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released ConradJam
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Samrat Deb
  • Re: [ANNOUNCE] Apache Flink 1.20.0 released Yuan Mei
• [jira] [Created] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum RocMarshal (Jira)
• [jira] [Created] (FLINK-35965) Add ENDSWITH function Dylan He (Jira)
• [jira] [Created] (FLINK-35964) Add STARTSWITH function Dylan He (Jira)
• [jira] [Created] (FLINK-35963) Add REGEXP_SUBSTR function Dylan He (Jira)
• [jira] [Created] (FLINK-35962) Add REGEXP_INSTR function Dylan He (Jira)
• [jira] [Created] (FLINK-35959) CLONE - Updates the docs stable version Weijie Guo (Jira)
• [jira] [Created] (FLINK-35960) CLONE - Start End of Life discussion thread for now outdated Flink minor version Weijie Guo (Jira)
• [jira] [Created] (FLINK-35957) CLONE - Other announcements Weijie Guo (Jira)
• [jira] [Created] (FLINK-35958) CLONE - Update reference data for Migration Tests Weijie Guo (Jira)
• [jira] [Created] (FLINK-35954) CLONE - Merge website pull request Weijie Guo (Jira)
• [jira] [Created] (FLINK-35955) CLONE - Remove outdated versions Weijie Guo (Jira)
• [jira] [Created] (FLINK-35961) CLONE - Build 1.19 docs in GitHub Action and mark 1.19 as stable in docs Weijie Guo (Jira)
• [jira] [Created] (FLINK-35953) CLONE - Update japicmp configuration Weijie Guo (Jira)
• [jira] [Created] (FLINK-35956) CLONE - Apache mailing lists announcements Weijie Guo (Jira)
• [jira] [Created] (FLINK-35952) Promote release 1.20 Weijie Guo (Jira)
• [jira] [Created] (FLINK-35951) Flink CDC startup exception using jar package huxx (Jira)
• [jira] [Created] (FLINK-35950) CLONE - Publish the Dockerfiles for the new release Weijie Guo (Jira)
• [jira] [Created] (FLINK-35948) CLONE - Deploy artifacts to Maven Central Repository Weijie Guo (Jira)
• [jira] [Created] (FLINK-35949) CLONE - Create Git tag and mark version as released in Jira Weijie Guo (Jira)
• [jira] [Created] (FLINK-35947) CLONE - Deploy Python artifacts to PyPI Weijie Guo (Jira)
• [jira] [Created] (FLINK-35946) Finalize release 1.20.0 Weijie Guo (Jira)
• [jira] [Created] (FLINK-35945) Using Flink to dock with Kafka data sources without enabling checkpoints cannot browse consumer group information in Kafka Jira
• [jira] [Created] (FLINK-35944) Add CompiledPlan annotations to BatchExecUnion Jim Hughes (Jira)
• [jira] [Created] (FLINK-35943) Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin Jim Hughes (Jira)
• [jira] [Created] (FLINK-35942) Add CompiledPlan annotations to BatchExecSort Jim Hughes (Jira)
• [jira] [Created] (FLINK-35941) Add CompiledPlan annotations to BatchExecLimit Jim Hughes (Jira)
• [jira] [Created] (FLINK-35940) Upgrade log4j dependencies to 2.23.1 Daniel Burrell (Jira)

• Earlier messages
• Later messages