You are viewing a plain text version of this content. The canonical link for it is here.
- (flink-connector-mongodb) branch main updated: [FLINK-36075][Connectors/MongoDB] Add pagination partitioning strategy (#45) - posted by ji...@apache.org on 2024/12/02 01:23:12 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36194][Runtime] Handle the Graceful close of ExecutionGraphInfoStore from ClusterEntrypoint - posted by ma...@apache.org on 2024/12/02 07:27:57 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36803][cdc-connector][base & mysql] Use the same format `tableId:chunkId` for splitId in SnapshotSplit (#3763) - posted by ru...@apache.org on 2024/12/02 08:37:09 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][tests][oceanbase] Fix oceanbase test failure, possibly caused by some interactions among cases (#3712) - posted by ru...@apache.org on 2024/12/02 08:38:35 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36739][Web UI] Update NodeJS to v22.11.0 (LTS). This closes #25670 - posted by ma...@apache.org on 2024/12/02 09:49:52 UTC, 0 replies.
- (flink) branch master updated (1ba5631ac8f -> e383400ef20) - posted by sn...@apache.org on 2024/12/02 13:31:26 UTC, 0 replies.
- (flink) branch master updated (e383400ef20 -> dbd21cf56af) - posted by gu...@apache.org on 2024/12/03 02:18:20 UTC, 0 replies.
- (flink) 01/04: [FLINK-36815][API] Make ExecutionEnvironment#fromSource return ProcessConfigurableAndNonKeyedPartitionStream - posted by gu...@apache.org on 2024/12/03 02:18:21 UTC, 0 replies.
- (flink) 02/04: [FLINK-36815][API] Introduce subtask index and attempt id in TaskInfo for DSv2 - posted by gu...@apache.org on 2024/12/03 02:18:22 UTC, 0 replies.
- (flink) 03/04: [FLINK-36815][API] Open and close user function in DSv2 ProcessOperators - posted by gu...@apache.org on 2024/12/03 02:18:23 UTC, 0 replies.
- (flink) 04/04: [FLINK-36815][API] Introduce a NonPartitionedContext parameter in Open method of UserFunction for DSv2 - posted by gu...@apache.org on 2024/12/03 02:18:24 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36535][autoscaler] Optimize the scale down logic based on historical parallelism to reduce the rescale frequency - posted by fa...@apache.org on 2024/12/03 02:33:50 UTC, 0 replies.
- (flink) branch master updated (dbd21cf56af -> 82031921de0) - posted by za...@apache.org on 2024/12/03 03:22:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36756][sql-gateway] Bump up the sql gateway rest version (#25705) - posted by sh...@apache.org on 2024/12/03 05:49:27 UTC, 0 replies.
- [I] INFO org.apache.doris.flink.sink.writer.serializer.jsondebezium.JsonDebeziumSchemaChangeImplV2 [] - ddl can not do schema change:{"source":{"version":"1.9.7.Final","connector":"mysql","name":"mysql_binlog_source","ts_ms": [flink-cdc] - posted by "wangwenzhao1 (via GitHub)" <gi...@apache.org> on 2024/12/03 07:15:42 UTC, 4 replies.
- (flink) branch master updated: [FLINK-36783][table-planner] Use validated SqlNode in `asQuery` while converting `SqlCreateTableAS` to `CreateTableASOperation` - posted by sn...@apache.org on 2024/12/03 08:06:11 UTC, 0 replies.
- (flink) branch release-1.20 updated (71fd38037cd -> 504c866b347) - posted by ar...@apache.org on 2024/12/03 09:16:21 UTC, 0 replies.
- (flink) 01/04: [FLINK-36379] Refactor sink test assertions - posted by ar...@apache.org on 2024/12/03 09:16:22 UTC, 1 replies.
- (flink) 02/04: [FLINK-36379] Optimize global committers - posted by ar...@apache.org on 2024/12/03 09:16:23 UTC, 1 replies.
- (flink) 03/04: [FLINK-36379] Optimize committers with UC disabled - posted by ar...@apache.org on 2024/12/03 09:16:24 UTC, 1 replies.
- (flink) 04/04: [FLINK-36788] Fix GlobalCommitter expansion - posted by ar...@apache.org on 2024/12/03 09:16:25 UTC, 1 replies.
- (flink) branch master updated (f5c44b683cd -> 22cc255ad99) - posted by za...@apache.org on 2024/12/03 11:45:31 UTC, 0 replies.
- (flink-connector-kafka) branch main updated: [FLINK-36780] Kafka source disable partition discovery unexpectedly (#136) - posted by ar...@apache.org on 2024/12/03 13:11:24 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-35114] Remove old Table API implementations, update Table API and Schema stack - posted by fc...@apache.org on 2024/12/03 16:17:04 UTC, 0 replies.
- (flink) branch master updated (22cc255ad99 -> 7d95fe8ba92) - posted by za...@apache.org on 2024/12/04 02:39:25 UTC, 0 replies.
- (flink) 01/02: [FLINK-36838][state] Join background threads when ForSt state backend quit - posted by za...@apache.org on 2024/12/04 02:39:26 UTC, 0 replies.
- (flink) 02/02: [hotfix] Use `FlinkEnv` in tests for ForStStateBackend - posted by za...@apache.org on 2024/12/04 02:39:27 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36840][table] Add correct call syntax for functions without `()` - posted by sn...@apache.org on 2024/12/04 12:57:45 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779 - posted by sn...@apache.org on 2024/12/04 22:00:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36688][table-planner] Sort metadata keys when reusing source - posted by sn...@apache.org on 2024/12/04 22:03:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18. This closes #25713 - posted by ma...@apache.org on 2024/12/04 22:09:46 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-207dd53bcd created (now 7b37646fbf4) - posted by gi...@apache.org on 2024/12/04 22:12:48 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-be7a34ed94 created (now a4233686687) - posted by gi...@apache.org on 2024/12/04 22:16:08 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36792][table] Remove FlinkJoinPushExpressionsRule - posted by sn...@apache.org on 2024/12/04 22:30:52 UTC, 0 replies.
- (flink) branch master updated: [hotfix][config] Do not use deprecated configs in example config.yaml (#25736) - posted by ju...@apache.org on 2024/12/05 05:59:06 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36593][runtime] Backport io.airlift:aircompressor upgrade to 0.27 - posted by sn...@apache.org on 2024/12/05 07:48:34 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-36368] Do not prematurely merge CommittableManager (#25405) - posted by ar...@apache.org on 2024/12/05 14:19:48 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36537] Bump snappy-java from 1.1.10.4 to 1.1.10.7 - posted by sn...@apache.org on 2024/12/05 21:18:19 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-connectors/flink-connector-hive/org.apache.avro-avro-1.11.4 created (now a8118e94fe1) - posted by gi...@apache.org on 2024/12/05 21:19:29 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-hive/io.netty-netty-common-4.1.115.Final created (now 5d2a8f40649) - posted by gi...@apache.org on 2024/12/05 21:19:45 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-2299424a7d created (now 651e1b49983) - posted by gi...@apache.org on 2024/12/05 21:20:07 UTC, 0 replies.
- (flink) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 26fc668b0cd) - posted by gi...@apache.org on 2024/12/05 21:37:16 UTC, 0 replies.
- (flink) branch dependabot/maven/org.apache.zookeeper-zookeeper-3.7.2 deleted (was cd034a133f7) - posted by gi...@apache.org on 2024/12/05 21:40:23 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36315][cdc-connector][base&pg&mongodb]The flink-cdc-base module supports source metric statistics (#3619) - posted by ru...@apache.org on 2024/12/06 03:06:17 UTC, 0 replies.
- (flink) branch release-1.19 updated (ba410bc80ea -> 91137a3394f) - posted by ar...@apache.org on 2024/12/06 08:59:07 UTC, 0 replies.
- (flink) branch release-1.20 updated (4e5ef6695ce -> 958ba8c5cfb) - posted by ar...@apache.org on 2024/12/06 09:01:40 UTC, 0 replies.
- (flink) 01/02: [FLINK-36455] Sinks retry synchronously - posted by ar...@apache.org on 2024/12/06 09:01:41 UTC, 1 replies.
- (flink) 02/02: [FLINK-36455] Fix PendingCommittable metric in sink - posted by ar...@apache.org on 2024/12/06 09:01:42 UTC, 1 replies.
- (flink-web) branch asf-site updated: Add blogpost for new Prometheus connector Addressed comments by @dannycranmer Addressed comments by @hlteoh37 Update publication date to 2024-12-05T18:00:00.000Z - posted by ho...@apache.org on 2024/12/06 13:24:29 UTC, 0 replies.
- (flink-web) branch asf-site updated: Rebuild website - posted by ho...@apache.org on 2024/12/06 13:32:30 UTC, 1 replies.
- (flink) branch master updated (b25ef726b32 -> f7d280ec1de) - posted by zh...@apache.org on 2024/12/06 13:58:11 UTC, 0 replies.
- (flink) 01/04: [FLINK-36066][runtime] Further Improve Method Reusability in StreamingJobGraphGenerator - posted by zh...@apache.org on 2024/12/06 13:58:12 UTC, 0 replies.
- (flink) 02/04: [FLINK-36066][runtime] Introduce ImmutableStreamGraph to provide a read-only view of StreamGraph - posted by zh...@apache.org on 2024/12/06 13:58:13 UTC, 0 replies.
- (flink) 03/04: [FLINK-36066][runtime] Introduce StreamGraphContext to provide the ability to modify the StreamGraph - posted by zh...@apache.org on 2024/12/06 13:58:14 UTC, 0 replies.
- (flink) 04/04: [FLINK-36066][runtime] Introduce the AdaptiveGraphManager component - posted by zh...@apache.org on 2024/12/06 13:58:15 UTC, 0 replies.
- (flink) branch release-1.19 updated (91137a3394f -> 5222a25540d) - posted by ar...@apache.org on 2024/12/06 14:05:47 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36840][table] Add correct call syntax for functions without `()` (#25756) - posted by dw...@apache.org on 2024/12/06 16:44:18 UTC, 0 replies.
- (flink) branch master updated (f7d280ec1de -> 0feefe9a40b) - posted by sn...@apache.org on 2024/12/06 20:37:58 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34674][table] Migrate CalcSnapshotTransposeRule to java - posted by sn...@apache.org on 2024/12/06 21:20:42 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36830][table] Bump json-path to 2.9.0 - posted by sn...@apache.org on 2024/12/06 22:06:25 UTC, 0 replies.
- (flink-cdc) branch release-3.2 updated: [BP-3.2][docs] Update download links to up-to-date cdc version (#3765) - posted by go...@apache.org on 2024/12/07 01:19:08 UTC, 0 replies.
- Re: [I] oracle no primary key table Data is lost in full phase [flink-cdc] - posted by "CabbageDu (via GitHub)" <gi...@apache.org> on 2024/12/07 06:12:50 UTC, 1 replies.
- (flink-cdc) branch master updated: [docs] Update download links to up-to-date cdc version (#3766) - posted by go...@apache.org on 2024/12/07 10:14:55 UTC, 0 replies.
- Re: [I] [Bug] Caused by: java.lang.NumberFormatException: For input string: "UTF8MB4'0" mysql -> doris [flink-cdc] - posted by "tuoluzhe8521 (via GitHub)" <gi...@apache.org> on 2024/12/09 02:32:42 UTC, 1 replies.
- (flink) branch master updated: [FLINK-36859][Runtime] Fix wrong epoch/watermark firing in async state processing (#25761) - posted by za...@apache.org on 2024/12/09 03:13:42 UTC, 0 replies.
- (flink) branch master updated (d62dc68c383 -> cfaa00e215e) - posted by gu...@apache.org on 2024/12/09 07:27:38 UTC, 0 replies.
- (flink) 01/03: [FLINK-35652][table] Expose taskinfo in FunctionContext - posted by gu...@apache.org on 2024/12/09 07:27:39 UTC, 0 replies.
- (flink) 02/03: [FLINK-35652][table] Introduce SupportsLookupCustomShuffle interface - posted by gu...@apache.org on 2024/12/09 07:27:40 UTC, 0 replies.
- (flink) 03/03: [FLINK-35652][table] Shuffle input stream of lookup join based on LOOKUP hint - posted by gu...@apache.org on 2024/12/09 07:27:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36612][core] Fix TypeSerializer to detect lombok boolean with is prefix - posted by ga...@apache.org on 2024/12/09 08:31:39 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36856][runtime] CollectSinkOperatorFactory batch size and socket timeout config fix - posted by ga...@apache.org on 2024/12/09 08:33:37 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36856][runtime] CollectSinkOperatorFactory batch size and socket timeout config fix - posted by ga...@apache.org on 2024/12/09 13:14:10 UTC, 0 replies.
- (flink) branch master updated (fa9d9099bf3 -> 158786282b1) - posted by ju...@apache.org on 2024/12/09 13:28:41 UTC, 0 replies.
- (flink-connector-elasticsearch) branch v3.1 updated: [hotfix][Connector/Elasticsearch] Update version to 3.1-SNAPSHOT - posted by da...@apache.org on 2024/12/09 15:20:35 UTC, 0 replies.
- (flink) branch master updated: [hotfix] [docs] Sync google-java-format version in docs with one in pom.xml - posted by sn...@apache.org on 2024/12/09 16:18:05 UTC, 0 replies.
- (flink) branch master updated (fc1809678d1 -> b32181bb95d) - posted by ma...@apache.org on 2024/12/09 16:22:53 UTC, 0 replies.
- (flink) 01/05: [hotfix][runtime] Adds missing @GuardedBy annotation - posted by ma...@apache.org on 2024/12/09 16:22:54 UTC, 0 replies.
- (flink) 02/05: [hotfix][runtime] Removes unused FlinkException in signature - posted by ma...@apache.org on 2024/12/09 16:22:55 UTC, 0 replies.
- (flink) 03/05: [hotfix][runtime] hasLeadership does not need to be called to protect the confirmLeadership call because the check happens internally - posted by ma...@apache.org on 2024/12/09 16:22:56 UTC, 0 replies.
- (flink) 04/05: [hotfix][runtime] JobResultStore#hasJobResultEntryAsync does not need to be triggered as a leader since it's read access only - posted by ma...@apache.org on 2024/12/09 16:22:57 UTC, 0 replies.
- (flink) 05/05: [FLINK-36451][runtime] Makes hasLeadership and confirmLeadership work asynchronously - posted by ma...@apache.org on 2024/12/09 16:22:58 UTC, 0 replies.
- (flink) branch master updated (b32181bb95d -> e016051e2c1) - posted by za...@apache.org on 2024/12/10 03:28:48 UTC, 0 replies.
- (flink) 01/02: [hotfix][state] Make state iterator adaptor tolerate null iterable input - posted by za...@apache.org on 2024/12/10 03:28:49 UTC, 0 replies.
- (flink) 02/02: [FLINK-36860][State/v2] Make internal list state inherit the internal merging state - posted by za...@apache.org on 2024/12/10 03:28:50 UTC, 0 replies.
- (flink) branch release-1.20 updated (a1abb6a155f -> 09a7e7e2ac1) - posted by ma...@apache.org on 2024/12/10 08:15:05 UTC, 0 replies.
- (flink) 01/03: [hotfix][runtime] hasLeadership does not need to be called to protect the confirmLeadership call because the check happens internally - posted by ma...@apache.org on 2024/12/10 08:15:06 UTC, 1 replies.
- (flink) 02/03: [hotfix][runtime] JobResultStore#hasJobResultEntryAsync does not need to be triggered as a leader since it's read access only - posted by ma...@apache.org on 2024/12/10 08:15:07 UTC, 1 replies.
- (flink) 03/03: [FLINK-36451][runtime] Makes hasLeadership and confirmLeadership work asynchronously - posted by ma...@apache.org on 2024/12/10 08:15:08 UTC, 1 replies.
- (flink-cdc) branch flink36879 created (now 2e595cb1f) - posted by ru...@apache.org on 2024/12/10 09:30:21 UTC, 0 replies.
- (flink-cdc) 01/01: [FLINK-36879][runtime] Support to convert delete as insert in transform - posted by ru...@apache.org on 2024/12/10 09:30:22 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36745][docs] Make FixedSizeSplitFetcherManager and FixedFetcherSizeSourceReader examples match Flink 2.0-preview API (#25667) - posted by rm...@apache.org on 2024/12/10 10:48:40 UTC, 0 replies.
- (flink-cdc) branch flink36879 updated (2e595cb1f -> de01742b6) - posted by ru...@apache.org on 2024/12/10 11:16:30 UTC, 0 replies.
- [I] 使用Flink OacaleCDC 3.1.1版本，在k8s上运行，会报Caused by: java.sql.SQLException: ORA-18716: {0} not in any time zone.DATE，在本地运行是正常的 [flink-cdc] - posted by "lovezhangxialang (via GitHub)" <gi...@apache.org> on 2024/12/11 01:21:31 UTC, 2 replies.
- (flink) branch master updated: [FLINK-34974][state] Support getOrCreateKeyedState for AsyncKeyedStateBackend (#25745) - posted by le...@apache.org on 2024/12/11 02:14:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36757][sql-gateway] Introduce ScripExecutor to run the script (#25700) - posted by sh...@apache.org on 2024/12/11 03:03:21 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36878][pipeline-connector][kafka] Shade org.apache.kafka with org.apache.flink.kafka.shaded.org.apache.kafka instead of cdc path - posted by le...@apache.org on 2024/12/11 03:40:16 UTC, 0 replies.
- (flink-connector-mongodb) branch main updated: [FLINK-36738][Connectors/MongoDB][test] Fix Weekly CI for MongoDB connector fails on jdk21 (#47) - posted by go...@apache.org on 2024/12/11 03:58:19 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][build] Add missed third-party OSS NOTICE - posted by le...@apache.org on 2024/12/11 04:02:25 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36868][State] Provide file system methods with string parameters for ForSt JNI (#25772) - posted by za...@apache.org on 2024/12/11 06:08:00 UTC, 0 replies.
- (flink) branch master updated (31d6ce89c19 -> 4d4cb34fd19) - posted by sx...@apache.org on 2024/12/11 06:46:54 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36883] Adapt time attributes from the VIEWs query (#25779) - posted by dw...@apache.org on 2024/12/11 08:41:11 UTC, 0 replies.
- (flink-connector-elasticsearch) branch main updated: [FLINK-35472] Improve tests for Elasticsearch 8 connector - posted by gu...@apache.org on 2024/12/11 08:47:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36861][table-planner] CREATE TABLE AS with METADATA columns doesn't work - posted by dw...@apache.org on 2024/12/11 09:12:25 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Remove requiremenet for java 8 in docs (#25785) - posted by sn...@apache.org on 2024/12/11 10:00:41 UTC, 0 replies.
- (flink) branch release-1.19 updated (5222a25540d -> 61b1c337c90) - posted by ma...@apache.org on 2024/12/11 15:39:39 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36890] Update observedGeneration on NOOP reconciliation (#923) - posted by mx...@apache.org on 2024/12/11 17:04:16 UTC, 0 replies.
- (flink-connector-hbase) branch main updated: [hotfix] Update weekly CI to v4.0 - posted by fc...@apache.org on 2024/12/11 20:07:55 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36875][runtime] Complete timer before emiting watermark (#25773) - posted by le...@apache.org on 2024/12/12 02:35:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][mysql] Remove deprecated MySQL incremental sources used in tests - posted by le...@apache.org on 2024/12/12 03:08:53 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-36883] Adapt time attributes from the VIEWs query (#25779) - posted by dw...@apache.org on 2024/12/12 08:34:16 UTC, 0 replies.
- (flink) branch master updated (43c50b91418 -> 1580b4dd53c) - posted by ju...@apache.org on 2024/12/12 10:52:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36896][table] Table API `trim()` expression incorrectly translated to SQL - posted by sn...@apache.org on 2024/12/12 12:17:21 UTC, 0 replies.
- (flink) branch master updated: [hotfix] ignore vscode folder in .gitignore (#25774) - posted by rm...@apache.org on 2024/12/12 17:22:44 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34602][table] Migrate StreamPhysicalWindowJoinRule to java - posted by sn...@apache.org on 2024/12/12 19:59:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36848][table] Remove FlinkLimit0RemoveRule - posted by sn...@apache.org on 2024/12/12 20:00:50 UTC, 0 replies.
- (flink) branch master updated (22398b48607 -> 2d9fb799ed6) - posted by ju...@apache.org on 2024/12/13 02:13:09 UTC, 0 replies.
- (flink) 01/02: [FLINK-36072][runtime] Enable netty shuffle to support a single input channel consuming multiple subpartitions. - posted by ju...@apache.org on 2024/12/13 02:13:10 UTC, 0 replies.
- (flink) 02/02: [FLINK-36072][runtime] Support sort-merge shuffle by accumulating small buffers to reduce network overhead. - posted by ju...@apache.org on 2024/12/13 02:13:11 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36771][cdc-connector][base&mysql] Fix UT trigger error: Invalid assigner status {} [NEWLY_ADDED_ASSIGNING_FINISHED] (#3755) - posted by ru...@apache.org on 2024/12/13 07:12:16 UTC, 0 replies.
- [I] java.lang.IllegalStateException: Unable to get latest schema [flink-cdc] - posted by "najsword (via GitHub)" <gi...@apache.org> on 2024/12/13 09:13:10 UTC, 6 replies.
- [I] Failed to apply schema change. [flink-cdc] - posted by "najsword (via GitHub)" <gi...@apache.org> on 2024/12/13 09:25:18 UTC, 10 replies.
- (flink-cdc) branch master updated: [FLINK-36891[[source-connector][mysql] Fix corrupted state in case of serialization failure in MySQL CDC Source - posted by le...@apache.org on 2024/12/14 03:42:45 UTC, 0 replies.
- (flink) branch master updated (2d9fb799ed6 -> 8aeb2ff8dae) - posted by za...@apache.org on 2024/12/16 02:47:53 UTC, 0 replies.
- (flink) branch master updated (8aeb2ff8dae -> d541997954e) - posted by gu...@apache.org on 2024/12/16 03:30:36 UTC, 0 replies.
- (flink) branch master updated (d541997954e -> 96773507be2) - posted by le...@apache.org on 2024/12/16 08:42:54 UTC, 0 replies.
- (flink) branch release-1.20 updated: [FLINK-35887][core] Fix NPE in TypeExtractor where getSuperclass from an interface returns null - posted by li...@apache.org on 2024/12/16 14:23:34 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-35887][core] Fix NPE in TypeExtractor where getSuperclass from an interface returns null - posted by li...@apache.org on 2024/12/16 14:23:56 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-34688][cdc-connector][base] CDC framework split snapshot chunks asynchronously (#3510) - posted by ru...@apache.org on 2024/12/17 02:48:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36895][cdc-connector][base] The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. (#3797) - posted by ru...@apache.org on 2024/12/17 05:47:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36558][source-connector/mysql] Fix column metadata parsing compatibility with MySQL 8.0.17&8.0.18 - posted by le...@apache.org on 2024/12/17 06:37:18 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36854][transform] Add missed comment and default value after transform - posted by le...@apache.org on 2024/12/17 06:46:30 UTC, 0 replies.
- (flink-cdc) branch flink36879 deleted (was de01742b6) - posted by ru...@apache.org on 2024/12/17 07:34:31 UTC, 0 replies.
- Re: [I] [mysql-cdc、DataStreamApi] FlinkCDC_2.3.0 Use 'scan.startup.mode' = 'timestamp' will get errors when restart job from checkpoint/savepoint [flink-cdc] - posted by "Yoona-wzw (via GitHub)" <gi...@apache.org> on 2024/12/17 08:39:08 UTC, 0 replies.
- (flink) branch master updated (96773507be2 -> 1c2ec0664fc) - posted by rm...@apache.org on 2024/12/17 08:56:30 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-be7a34ed94 deleted (was a4233686687) - posted by gi...@apache.org on 2024/12/17 08:58:21 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-2299424a7d deleted (was 651e1b49983) - posted by gi...@apache.org on 2024/12/17 08:58:27 UTC, 0 replies.
- (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-207dd53bcd deleted (was 7b37646fbf4) - posted by gi...@apache.org on 2024/12/17 08:58:38 UTC, 0 replies.
- (flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-sql/com.nimbusds-nimbus-jose-jwt-9.37.2 created (now 6cd0e581df8) - posted by gi...@apache.org on 2024/12/17 08:58:56 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36889] Mention locking down a Flink cluster in the 'Production Readiness Checklist' (#25793) - posted by rm...@apache.org on 2024/12/17 12:53:39 UTC, 0 replies.
- (flink) branch master updated (473a3e8a7b3 -> c7d8515c028) - posted by sn...@apache.org on 2024/12/17 13:23:45 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36866][transform] Fix unable to narrow casting on numeric values - posted by le...@apache.org on 2024/12/17 16:00:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33117][table][docs] Fix scala example in udfs page (#23439) - posted by af...@apache.org on 2024/12/17 18:53:34 UTC, 0 replies.
- (flink) branch master updated: [FLINK-33921][table] Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig - posted by li...@apache.org on 2024/12/18 01:36:44 UTC, 0 replies.
- [I] How to add SSL properties to db2-cdc like sslConnection, sslTrustStoreLocation, sslTrustStorePassword, Security,SSLClientKeystoredb,SSLClientKeystash [flink-cdc] - posted by "SateehTeppala (via GitHub)" <gi...@apache.org> on 2024/12/18 06:32:06 UTC, 4 replies.
- (flink) branch master updated (6248fd4fd61 -> 12ee2993707) - posted by le...@apache.org on 2024/12/18 07:19:33 UTC, 0 replies.
- (flink-connector-kudu) branch main updated: [FLINK-36839] Update Kudu version to 1.17.1 - posted by fc...@apache.org on 2024/12/18 13:13:03 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix] Fix Java 11 target compatibility & add tests (#3633) - posted by go...@apache.org on 2024/12/19 03:05:42 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36864][cdc-runtime] Fix unable to use numeric literals that goes beyond Int32 range (#3785) - posted by ru...@apache.org on 2024/12/19 04:02:12 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36879][runtime] Support to convert delete as insert in transform (#3804) - posted by ru...@apache.org on 2024/12/19 05:45:03 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36706][table] Refactor TypeInferenceExtractor for PTFs - posted by tw...@apache.org on 2024/12/19 08:28:50 UTC, 0 replies.
- (flink) branch master updated (ab8286e8b5c -> 9e38f32889e) - posted by za...@apache.org on 2024/12/19 09:51:53 UTC, 0 replies.
- Re: [I] Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.doris.flink.cfg.DorisOptions to field org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier.dorisOptions of type org.apache.doris.flink.cfg.DorisOptions in instance of org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier [flink-cdc] - posted by "wuzhaoyu (via GitHub)" <gi...@apache.org> on 2024/12/19 13:24:46 UTC, 3 replies.
- (flink-cdc) branch master updated: [hotfix] Fix building status badge in README as workflow files have been refactored (#3807) - posted by go...@apache.org on 2024/12/19 13:55:38 UTC, 0 replies.
- (flink) branch master updated (9e38f32889e -> 7109fe04068) - posted by sn...@apache.org on 2024/12/19 17:57:33 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34598][table] Migrate RemoveRedundantLocalRankRule to java - posted by sn...@apache.org on 2024/12/19 23:26:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36791][table] Remove FlinkPruneEmptyRules - posted by sn...@apache.org on 2024/12/19 23:41:45 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36508][table] Remove deprecated methods - posted by sn...@apache.org on 2024/12/20 00:19:41 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36934][network] Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor - posted by gu...@apache.org on 2024/12/20 01:48:32 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36784][common] Support to add metadata columns for data in the meta fields of DataChangeEvent at transform (#3758) - posted by ru...@apache.org on 2024/12/20 03:09:34 UTC, 0 replies.
- (flink-kubernetes-operator) branch main updated: [FLINK-36920] Bump quartz-scheduler from 2.3.2 to 2.4.0 (#924) - posted by rm...@apache.org on 2024/12/20 10:26:44 UTC, 0 replies.
- (flink) branch release-1.20 updated: [hotfix][docs] Fix broken url in avro docs. (#25769) - posted by rm...@apache.org on 2024/12/20 10:35:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36938][Runtime] Provide hooks before and after the watermark processing (#25824) - posted by za...@apache.org on 2024/12/20 12:06:30 UTC, 0 replies.
- (flink) branch release-1.19 updated: [FLINK-33117][table][docs] Fix scala example in udfs page (#23439) - posted by af...@apache.org on 2024/12/20 13:41:30 UTC, 0 replies.
- (flink-web) branch Myasuka-patch-1 created (now 2fec48633) - posted by ta...@apache.org on 2024/12/23 03:32:00 UTC, 0 replies.
- (flink-web) 01/01: Updates the slack invitation link - posted by ta...@apache.org on 2024/12/23 03:32:01 UTC, 0 replies.
- (flink-web) branch asf-site updated: Updates the slack invitation link - posted by ta...@apache.org on 2024/12/23 03:49:53 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][docs] Fix ToC to include H1 - posted by le...@apache.org on 2024/12/23 09:24:18 UTC, 0 replies.
- (flink) branch master updated (37e25f2697e -> 5b6553997c1) - posted by za...@apache.org on 2024/12/23 11:52:12 UTC, 0 replies.
- (flink) 01/04: [FLINK-36944][API] Introduce `enableAsyncState` API - posted by za...@apache.org on 2024/12/23 11:52:13 UTC, 0 replies.
- (flink) 02/04: [FLINK-36944][State] Introduce serializer based state descriptor constructors - posted by za...@apache.org on 2024/12/23 11:52:14 UTC, 0 replies.
- (flink) 03/04: [FLINK-36944][Datastream] Implement async reduce operator - posted by za...@apache.org on 2024/12/23 11:52:15 UTC, 0 replies.
- (flink) 04/04: [FLINK-36944][Example] Introduce async state version of wordcount - posted by za...@apache.org on 2024/12/23 11:52:16 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36949][Runtime] Make getCurrentKey of async state operators return the ground truth (#25841) - posted by za...@apache.org on 2024/12/23 12:26:46 UTC, 0 replies.
- (flink-cdc) branch master updated (dfa6de919 -> 842446723) - posted by le...@apache.org on 2024/12/24 06:11:49 UTC, 0 replies.
- (flink-cdc) 01/04: [tests][build] Update migration test matrix to 3.2.0 and later - posted by le...@apache.org on 2024/12/24 06:11:50 UTC, 0 replies.
- (flink-cdc) 02/04: [cdc-common] Extract column / schema type merging utility methods to `SchemaMergingUtils` - posted by le...@apache.org on 2024/12/24 06:11:51 UTC, 0 replies.
- (flink-cdc) 03/04: [FLINK-36763][cdc-runtime] Introduce distributed schema evolution topology for sources with parallelized metadata - posted by le...@apache.org on 2024/12/24 06:11:52 UTC, 0 replies.
- (flink-cdc) 04/04: [FLINK-36690][cdc-runtime] Fix schema operator hanging under extreme parallelized pressure This closes #3680 - posted by le...@apache.org on 2024/12/24 06:11:53 UTC, 0 replies.
- (flink-cdc) branch master updated: [hotfix][tests] Fix unstable `testInitialStartupModeWithOpTs` case (#3809) - posted by ru...@apache.org on 2024/12/24 11:37:18 UTC, 0 replies.
- (flink-cdc) branch master updated: [FLINK-36952][source-connector/mongodb] Fix typos in MongoDB connector Chinese documentation (#3811) - posted by ji...@apache.org on 2024/12/25 01:29:11 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36921][runtime] Fix unstable AdaptiveExecutionPlanSchedulingContextTest - posted by ju...@apache.org on 2024/12/25 02:00:53 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36575][runtime] ExecutionVertexInputInfo supports consuming subpartition groups - posted by ju...@apache.org on 2024/12/25 02:07:56 UTC, 0 replies.
- [I] Flink CDC has moved to Apache Jira for managing issues（Flink CDC 不再使用Github 管理issue） [flink-cdc] - posted by "leonardBang (via GitHub)" <gi...@apache.org> on 2024/12/25 02:31:44 UTC, 0 replies.
- (flink) branch master updated (72240726a93 -> 56ba88bf0b4) - posted by zh...@apache.org on 2024/12/25 02:53:36 UTC, 0 replies.
- (flink) 01/02: [FLINK-36634][table] Move the PlannerModule to the flink-table-api-java module so that the planner code can be accessed by the runtime. - posted by zh...@apache.org on 2024/12/25 02:53:37 UTC, 0 replies.
- (flink) 02/02: [FLINK-36634][table] Introduce AdaptiveJoin to support dynamic generate join operator at runtime. - posted by zh...@apache.org on 2024/12/25 02:53:38 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36959][runtime] Fix the logic for computing readable buffer offsets and sizes when including empty buffers. - posted by ju...@apache.org on 2024/12/25 12:50:58 UTC, 0 replies.
- Re: [I] Flink CDC Issue Management（Flink CDC Issue 管理指南） [flink-cdc] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/12/26 00:04:18 UTC, 9 replies.
- (flink) branch master updated: [FLINK-35904][test] Make async test harness extend exsit test harness (#25856) - posted by le...@apache.org on 2024/12/26 02:27:53 UTC, 0 replies.
- (flink) branch master updated: [hotfix] Remove unused noinspection comment in NettyShuffleMetricFactory - posted by gu...@apache.org on 2024/12/26 03:52:23 UTC, 0 replies.
- (flink) branch hs_jm_fo created (now 7735f359ffa) - posted by gu...@apache.org on 2024/12/26 08:00:16 UTC, 0 replies.
- (flink) 01/01: [FLINK-36880][network] Hybrid shuffle supports job master failover if only external tier used. - posted by gu...@apache.org on 2024/12/26 08:00:17 UTC, 0 replies.
- (flink) branch hs_jm_fo deleted (was 7735f359ffa) - posted by gu...@apache.org on 2024/12/26 08:00:54 UTC, 0 replies.
- [I] Why test taskContext.getSourceConfig().isScanNewlyAddedTableEnabled() in IncrementalSourceStreamFetcher‘s method shouldEmit [flink-cdc] - posted by "hql0312 (via GitHub)" <gi...@apache.org> on 2024/12/26 08:19:01 UTC, 3 replies.
- (flink) branch master updated: [FLINK-35904][test] Enhance test harness for async state processing with fast fail (#25858) - posted by za...@apache.org on 2024/12/26 11:36:53 UTC, 0 replies.
- (flink) branch master updated (3165f942bad -> 19bc0b3721e) - posted by za...@apache.org on 2024/12/26 11:37:30 UTC, 0 replies.
- (flink) branch master updated (19bc0b3721e -> 95f9a160532) - posted by ju...@apache.org on 2024/12/26 12:01:23 UTC, 0 replies.
- (flink) 01/03: [FLINK-36067][runtime] Introduce StreamGraphOptimizer and StreamGraphOptimizationStrategy - posted by ju...@apache.org on 2024/12/26 12:01:24 UTC, 0 replies.
- (flink) 02/03: [FLINK-36067][runtime] Manually trigger aggregate all-to-all result partition info when all consumers created and initialized. - posted by ju...@apache.org on 2024/12/26 12:01:25 UTC, 0 replies.
- (flink) 03/03: [FLINK-36067][runtime] Support optimize stream graph based on input info. - posted by ju...@apache.org on 2024/12/26 12:01:26 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36948][tests] Remove deprecated FlinkMatchers - posted by sn...@apache.org on 2024/12/26 19:34:02 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34505][table] Migrate WindowGroupReorderRule to java - posted by sn...@apache.org on 2024/12/26 22:14:02 UTC, 0 replies.
- (flink) branch master updated (dacb848f84f -> 3f247042fa8) - posted by gu...@apache.org on 2024/12/27 03:03:44 UTC, 0 replies.
- (flink) 01/02: [FLINK-36880][network] Handle the finished vertex in InputConsumableDecider - posted by gu...@apache.org on 2024/12/27 03:03:45 UTC, 0 replies.
- (flink) 02/02: [FLINK-36880][network] Hybrid shuffle supports job master failover if only external tier used. - posted by gu...@apache.org on 2024/12/27 03:03:46 UTC, 0 replies.
- (flink-cdc) branch master updated: [build][hotfix] Allow pinning issues & PRs that never decay - posted by le...@apache.org on 2024/12/27 09:36:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36966][tests] Bump mockito to 5.14.2 - posted by sn...@apache.org on 2024/12/27 18:36:14 UTC, 0 replies.
- (flink) branch master updated: [hotfix][docs] Fix typo in Amazon S3 Access Credential - posted by sn...@apache.org on 2024/12/27 18:39:47 UTC, 0 replies.
- (flink) branch master updated: [FLINK-34675][table] Migrate AggregateReduceGroupingRule to java - posted by sn...@apache.org on 2024/12/27 18:41:28 UTC, 0 replies.
- (flink) branch master updated (60b23d11cb9 -> 9b12ec0fbde) - posted by sn...@apache.org on 2024/12/27 18:43:49 UTC, 0 replies.
- (flink) branch master updated (9b12ec0fbde -> 59ef8d6af85) - posted by sn...@apache.org on 2024/12/27 19:55:29 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36954][table] Migrate CalcRankTransposeRule to java - posted by sn...@apache.org on 2024/12/27 19:59:36 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36951][table] Migrate ProjectSemiAntiJoinTransposeRule to java - posted by sn...@apache.org on 2024/12/27 20:01:32 UTC, 0 replies.
- (flink) branch master updated: [FLINK-36069][runtime/rest] Extending job detail rest API to expose json stream graph - posted by ju...@apache.org on 2024/12/28 04:16:17 UTC, 0 replies.
- [I] There is a bug in non-standard timestamp values [flink-cdc] - posted by "WuChongYong (via GitHub)" <gi...@apache.org> on 2024/12/31 06:26:06 UTC, 2 replies.