{"payload":{"feedbackUrl":"https://github.com/orgs/community/discussions/53140","repo":{"id":20587599,"defaultBranch":"master","name":"flink","ownerLogin":"apache","currentUserCanPush":false,"isFork":false,"isEmpty":false,"createdAt":"2014-06-07T07:00:10.000Z","ownerAvatar":"https://avatars.githubusercontent.com/u/47359?v=4","public":true,"private":false,"isOrgOwned":true},"refInfo":{"name":"","listCacheKey":"v0:1715770237.0","currentOid":""},"activityList":{"items":[{"before":"3d40bd7dd197b12b7b156bd758b4129148e885d1","after":"467f94f9ecef91b671ebbdc4774f2b690f4fa713","ref":"refs/heads/master","pushedAt":"2024-05-24T15:43:29.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-35355][State] Internal async aggregating state and corresponding state descriptor\n\nThis closes #24810","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35355\">FLINK-35355</a>][State] Internal async aggregating state and correspondi…"}},{"before":"54f037f9b2f08bd958d02eac2ffd018919b3f43e","after":"3d40bd7dd197b12b7b156bd758b4129148e885d1","ref":"refs/heads/master","pushedAt":"2024-05-24T08:25:35.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dawidwys","name":"Dawid Wysakowicz","path":"/dawidwys","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6242259?s=80&v=4"},"commit":{"message":"[FLINK-35437] Rewrite BlockStatementGrouper so that it uses less memory (#24834)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35437\">FLINK-35437</a>] Rewrite BlockStatementGrouper so that it uses less memo…"}},{"before":"71e6746727aaa57a6082f91576365807fa51b478","after":"54f037f9b2f08bd958d02eac2ffd018919b3f43e","ref":"refs/heads/master","pushedAt":"2024-05-24T05:22:24.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all task attempts finished\n\nThis closes #24817","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35400\">FLINK-35400</a>][checkpoint] Release FileMergingSnapshotManager if all t…"}},{"before":"0737220959fe52ee22535e7db55b015a46a6294e","after":"71e6746727aaa57a6082f91576365807fa51b478","ref":"refs/heads/master","pushedAt":"2024-05-24T03:25:00.000Z","pushType":"pr_merge","commitsCount":3,"pusher":{"login":"lsyldliu","name":"Ron","path":"/lsyldliu","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/17698589?s=80&v=4"},"commit":{"message":"[FLINK-35347][table] Introduce EmbeddedWorkflowScheduler plugin based on embedded scheduler","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35347\">FLINK-35347</a>][table] Introduce EmbeddedWorkflowScheduler plugin based…"}},{"before":"4f1427cabffe0a2609b54b3349db300636977811","after":"0737220959fe52ee22535e7db55b015a46a6294e","ref":"refs/heads/master","pushedAt":"2024-05-23T14:12:15.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dawidwys","name":"Dawid Wysakowicz","path":"/dawidwys","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6242259?s=80&v=4"},"commit":{"message":"[FLINK-35216] Support for RETURNING clause of JSON_QUERY","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35216\">FLINK-35216</a>] Support for RETURNING clause of JSON_QUERY"}},{"before":"a5efed2c06c42186e376dd2ede18dc09986c0387","after":"a450980de65eaead734349ed44452f572e5e329d","ref":"refs/heads/release-1.19","pushedAt":"2024-05-23T12:10:55.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-35429][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35429\">FLINK-35429</a>][sqlgateway] Do not introduce new method in SqlGatewayEn…"}},{"before":"9ccfb6588762acfd3be8b3772af5559291e8ffb2","after":"4f1427cabffe0a2609b54b3349db300636977811","ref":"refs/heads/master","pushedAt":"2024-05-23T08:10:18.000Z","pushType":"push","commitsCount":8,"pusher":{"login":"xintongsong","name":"Xintong Song","path":"/xintongsong","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6509172?s=80&v=4"},"commit":{"message":"[FLINK-35359][config] Make yarn.application-attempts Int type\n\nThis closes #24815","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35359\">FLINK-35359</a>][config] Make yarn.application-attempts Int type"}},{"before":"77111f7d33d64005a583dce4fbb72ab8e19f7a99","after":"9ccfb6588762acfd3be8b3772af5559291e8ffb2","ref":"refs/heads/master","pushedAt":"2024-05-23T07:13:15.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"pnowojski","name":"Piotr Nowojski","path":"/pnowojski","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8957547?s=80&v=4"},"commit":{"message":"[FLINK-35420][hadoop-compatibility][test] Workaround some strange scala compilation issue\n\nWithout this fix a couple of people did experience compilation error in the IntelliJ:\n\nWordCountMapredITCase.scala:42:8\nvalue isFalse is not a member of ?0\npossible cause: maybe a semicolon is missing before `value isFalse'?\n      .isFalse()","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35420\">FLINK-35420</a>][hadoop-compatibility][test] Workaround some strange sca…"}},{"before":"d43aeafa5a59a53887526a7464fd3ba2d2802895","after":"77111f7d33d64005a583dce4fbb72ab8e19f7a99","ref":"refs/heads/master","pushedAt":"2024-05-23T07:04:23.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-35410][state] Avoid sync waiting in coordinator thread of ForSt executor (#24819)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35410\">FLINK-35410</a>][state] Avoid sync waiting in coordinator thread of ForS…"}},{"before":"5ba0141e3b9d0bd956bd48b33a4b92c586e160aa","after":"d43aeafa5a59a53887526a7464fd3ba2d2802895","ref":"refs/heads/master","pushedAt":"2024-05-23T04:11:21.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"masteryhx","name":"yhx","path":"/masteryhx","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38719192?s=80&v=4"},"commit":{"message":"[FLINK-35047][state] Shutdown StateExecutors when ForStKeyedStateBackend is disposed (#24768)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35047\">FLINK-35047</a>][state] Shutdown StateExecutors when ForStKeyedStateBack…"}},{"before":"ddccfb62dcb214d437e97d87016244cefa3589bf","after":"a5efed2c06c42186e376dd2ede18dc09986c0387","ref":"refs/heads/release-1.19","pushedAt":"2024-05-23T02:15:22.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest\n\nSigned-off-by: David Radley <david_radley@uk.ibm.com>","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35246\">FLINK-35246</a>][test] Fix incorrect address construction in SqlClientSS…"}},{"before":"c4af0c388d07316282819dc2741fa7bc758fa767","after":"ddccfb62dcb214d437e97d87016244cefa3589bf","ref":"refs/heads/release-1.19","pushedAt":"2024-05-23T02:02:42.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"1996fanrui","name":"Rui Fan","path":"/1996fanrui","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38427477?s=80&v=4"},"commit":{"message":"[hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily","shortMessageHtmlLink":"[hotfix][rest] Add getter methods for SubtasksTimesInfo to get all va…"}},{"before":"4c6571d075b1d1ff5e7b9d7ec3bf625329155fbf","after":"5ba0141e3b9d0bd956bd48b33a4b92c586e160aa","ref":"refs/heads/master","pushedAt":"2024-05-23T02:02:25.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"1996fanrui","name":"Rui Fan","path":"/1996fanrui","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38427477?s=80&v=4"},"commit":{"message":"[hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily","shortMessageHtmlLink":"[hotfix][rest] Add getter methods for SubtasksTimesInfo to get all va…"}},{"before":"e502d2371ffea52ebfa6b8a1b9d2b4a23bc9bbaa","after":"4c6571d075b1d1ff5e7b9d7ec3bf625329155fbf","ref":"refs/heads/master","pushedAt":"2024-05-22T14:01:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dawidwys","name":"Dawid Wysakowicz","path":"/dawidwys","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6242259?s=80&v=4"},"commit":{"message":"[FLINK-32706][table] Add built-in SPLIT_STRING function (#24365)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-32706\">FLINK-32706</a>][table] Add built-in SPLIT_STRING function (<a class=\"issue-link js-issue-link\" data-error-text=\"Failed to load title\" data-id=\"2148128546\" data-permission-text=\"Title is private\" data-url=\"https://github.com/apache/flink/issues/24365\" data-hovercard-type=\"pull_request\" data-hovercard-url=\"/apache/flink/pull/24365/hovercard\" href=\"https://github.com/apache/flink/pull/24365\">#24365</a>)"}},{"before":"c1baf07d7601a683f42997dc35dfaef4e41bc928","after":"e502d2371ffea52ebfa6b8a1b9d2b4a23bc9bbaa","ref":"refs/heads/master","pushedAt":"2024-05-22T04:04:28.000Z","pushType":"pr_merge","commitsCount":11,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-34549\">FLINK-34549</a>][API] Implement applyToAllPartitions for non-partitioned…"}},{"before":"8b73ca955bcd796916597046dd8aa80407d0aa07","after":"c1baf07d7601a683f42997dc35dfaef4e41bc928","ref":"refs/heads/master","pushedAt":"2024-05-22T01:55:27.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"1996fanrui","name":"Rui Fan","path":"/1996fanrui","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38427477?s=80&v=4"},"commit":{"message":"[FLINK-35215][core] Fix the bug when Kryo serialize length is 0\n\nRe-implement to avoid the performance regression","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35215\">FLINK-35215</a>][core] Fix the bug when Kryo serialize length is 0"}},{"before":"a160f8db1f76e672ac163ff251aea3413853c442","after":"c4af0c388d07316282819dc2741fa7bc758fa767","ref":"refs/heads/release-1.19","pushedAt":"2024-05-21T15:10:46.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"hlteoh37","name":"Hong Liang Teoh","path":"/hlteoh37","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/35062175?s=80&v=4"},"commit":{"message":"[FLINK-35383][docs] Update compatibility matrix for 1.19 release","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35383\">FLINK-35383</a>][docs] Update compatibility matrix for 1.19 release"}},{"before":"5a2c1e071946de5e20be9f73324c35dc996f3ed6","after":"8b73ca955bcd796916597046dd8aa80407d0aa07","ref":"refs/heads/master","pushedAt":"2024-05-21T15:10:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"hlteoh37","name":"Hong Liang Teoh","path":"/hlteoh37","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/35062175?s=80&v=4"},"commit":{"message":"[FLINK-35383][docs] Update compatibility matrix for 1.19 release","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35383\">FLINK-35383</a>][docs] Update compatibility matrix for 1.19 release"}},{"before":"11bd030aca8bc7134c6ff6893919a2cb0eaf86bf","after":"5a2c1e071946de5e20be9f73324c35dc996f3ed6","ref":"refs/heads/master","pushedAt":"2024-05-21T10:13:05.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"masteryhx","name":"yhx","path":"/masteryhx","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38719192?s=80&v=4"},"commit":{"message":"[hotfix][state] Create new copy for each SerializedCompositeKeyBuilder in ForStStateBackend (#24816)","shortMessageHtmlLink":"[hotfix][state] Create new copy for each SerializedCompositeKeyBuilde…"}},{"before":"46aaea8083047fc86c35491336d795ddcd565128","after":"11bd030aca8bc7134c6ff6893919a2cb0eaf86bf","ref":"refs/heads/master","pushedAt":"2024-05-21T09:31:11.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"pnowojski","name":"Piotr Nowojski","path":"/pnowojski","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8957547?s=80&v=4"},"commit":{"message":"[hotfix] [streaming] Correct copying StreamPartitioner in rescale case","shortMessageHtmlLink":"[hotfix] [streaming] Correct copying StreamPartitioner in rescale case"}},{"before":"5f5722fe916bafc00ec05539d6c19ac28ac1c5c4","after":"46aaea8083047fc86c35491336d795ddcd565128","ref":"refs/heads/master","pushedAt":"2024-05-21T09:18:22.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35130\">FLINK-35130</a>][runtime] Simplify AvailabilityNotifierImpl to support s…"}},{"before":"26b149a1664ca8ea395badbb02e1e245a623ee90","after":"5f5722fe916bafc00ec05539d6c19ac28ac1c5c4","ref":"refs/heads/master","pushedAt":"2024-05-21T05:18:13.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-35395][core] Fix the example code of KeyedStateStore#getState","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35395\">FLINK-35395</a>][core] Fix the example code of KeyedStateStore#getState"}},{"before":"2bcc308d3600b429416b01e95159c360dafcb0ab","after":"26b149a1664ca8ea395badbb02e1e245a623ee90","ref":"refs/heads/master","pushedAt":"2024-05-21T02:30:53.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"fredia","name":"Yanfei Lei","path":"/fredia","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18653940?s=80&v=4"},"commit":{"message":"[FLINK-35382][test] Disable snapshot-file-merging in ChangelogCompatibilityITCase (#24813)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35382\">FLINK-35382</a>][test] Disable snapshot-file-merging in ChangelogCompati…"}},{"before":"e5398e1025ec4312bac74a8b32b98d03cb254667","after":"2bcc308d3600b429416b01e95159c360dafcb0ab","ref":"refs/heads/master","pushedAt":"2024-05-21T02:16:24.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-35379][Checkpoint] Fix incorrect checkpoint notification handling in file merging (#24806)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-35379\">FLINK-35379</a>][Checkpoint] Fix incorrect checkpoint notification handl…"}},{"before":"c7c1d78752836b96591e31422c65b85eca38bd50","after":"e5398e1025ec4312bac74a8b32b98d03cb254667","ref":"refs/heads/master","pushedAt":"2024-05-21T01:29:08.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"1996fanrui","name":"Rui Fan","path":"/1996fanrui","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38427477?s=80&v=4"},"commit":{"message":"[FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: types (#24613)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-25537\">FLINK-25537</a>][JUnit5 Migration] Module: flink-core with,Package: types ("}},{"before":"f5a8edbcb911c2247c83dae104bbe82adf4910e6","after":"c7c1d78752836b96591e31422c65b85eca38bd50","ref":"refs/heads/master","pushedAt":"2024-05-19T10:06:18.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"zhuzhurk","name":"Zhu Zhu","path":"/zhuzhurk","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5869249?s=80&v=4"},"commit":{"message":"[FLINK-33983][runtime] Introduce JobEvent and JobEventStore","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-33983\">FLINK-33983</a>][runtime] Introduce JobEvent and JobEventStore"}},{"before":"4848a50d73563d14d479437d64854e1da7f06b47","after":"08ba6497e3ec7106021043612118df77330f9797","ref":"refs/heads/release-1.18","pushedAt":"2024-05-17T11:17:53.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"snuyanzin","name":"Sergey Nuyanzin","path":"/snuyanzin","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/403174?s=80&v=4"},"commit":{"message":"[FLINK-20539][table-planner] Fix type mismatch when using ROW in computed column\n\n(cherry picked from commit db934bfe3772cc44263d42e875a5957ea00c15c1)","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-20539\">FLINK-20539</a>][table-planner] Fix type mismatch when using ROW in comp…"}},{"before":"1e1a7f16b6f272334d9f9a1053b657148151a789","after":"4848a50d73563d14d479437d64854e1da7f06b47","ref":"refs/heads/release-1.18","pushedAt":"2024-05-17T08:07:49.000Z","pushType":"pr_merge","commitsCount":4,"pusher":{"login":"pnowojski","name":"Piotr Nowojski","path":"/pnowojski","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8957547?s=80&v=4"},"commit":{"message":"[FLINKCC-1283] Properly initialize initial splits in WatermarkOutputMultiplexer\n\nWithout this fix, initial splits were registered in the multiplexer only\nwhen first record from that split has been emitted. This was leading to\nincorrectly emitted watermarks, as resulting watermark was not properly\ncombined from the initial splits, but only from the splits that have\nalready emitted at least one record.","shortMessageHtmlLink":"[FLINKCC-1283] Properly initialize initial splits in WatermarkOutputM…"}},{"before":"190522c2c051e0ec05213be71fb7a59a517353b1","after":"a160f8db1f76e672ac163ff251aea3413853c442","ref":"refs/heads/release-1.19","pushedAt":"2024-05-17T08:07:38.000Z","pushType":"pr_merge","commitsCount":4,"pusher":{"login":"pnowojski","name":"Piotr Nowojski","path":"/pnowojski","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8957547?s=80&v=4"},"commit":{"message":"[FLINK-32828] Properly initialize initial splits in WatermarkOutputMultiplexer\n\nWithout this fix, initial splits were registered in the multiplexer only\nwhen first record from that split has been emitted. This was leading to\nincorrectly emitted watermarks, as resulting watermark was not properly\ncombined from the initial splits, but only from the splits that have\nalready emitted at least one record.","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-32828\">FLINK-32828</a>] Properly initialize initial splits in WatermarkOutputMu…"}},{"before":"f1ecb9e4701d612050da54589a8f561857debf34","after":"f5a8edbcb911c2247c83dae104bbe82adf4910e6","ref":"refs/heads/master","pushedAt":"2024-05-17T07:23:53.000Z","pushType":"push","commitsCount":3,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-34615]Create a new class `ExternalizedCheckpointRetention` in python and replace the original class `ExternalizedCheckpointCleanup`.\n\nThis closes #24461","shortMessageHtmlLink":"[<a class=\"issue-link js-issue-link notranslate\" rel=\"noopener noreferrer nofollow\" href=\"https://issues.apache.org/jira/browse/FLINK-34615\">FLINK-34615</a>]Create a new class <code>ExternalizedCheckpointRetention</code> in …"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEUzIGBAA","startCursor":null,"endCursor":null}},"title":"Activity · apache/flink"}