{"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:1718112945.0","currentOid":""},"activityList":{"items":[{"before":"77cd1cd72fbfa369d6f298d09b72dea8613774aa","after":"fb5fd483f91f524c81130c0fc4125d3382a7ffdc","ref":"refs/heads/master","pushedAt":"2024-06-12T13:20:30.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-35570][Checkpoint] Consider PlaceholderStreamStateHandle in file merging\n\nThis fixes #24924","shortMessageHtmlLink":"[FLINK-35570][Checkpoint] Consider PlaceholderStreamStateHandle in fi…"}},{"before":"986d06d2cd7046afbbb3311ccc5eddf5f6792606","after":"77cd1cd72fbfa369d6f298d09b72dea8613774aa","ref":"refs/heads/master","pushedAt":"2024-06-12T12:20:21.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-35528][task] Skip execution of interruptible mails when yielding\n\nWhen operators are yielding, for example waiting for async state access to complete before a checkpoint, it would be beneficial to not execute interruptible mails. Otherwise continuation mail for firing timers would be continuously re-enqeueed. To achieve that MailboxExecutor must be aware which mails are interruptible.\n\nThe easiest way to achieve this is to set MIN_PRIORITY for interruptible mails.","shortMessageHtmlLink":"[FLINK-35528][task] Skip execution of interruptible mails when yielding"}},{"before":"23fa2aeb01861a6f8b85f911c5a3f989a1f75898","after":"986d06d2cd7046afbbb3311ccc5eddf5f6792606","ref":"refs/heads/master","pushedAt":"2024-06-12T12:18:55.000Z","pushType":"pr_merge","commitsCount":7,"pusher":{"login":"pnowojski","name":"Piotr Nowojski","path":"/pnowojski","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/8957547?s=80&v=4"},"commit":{"message":"[FLINK-20217][docs] Regenerate docs","shortMessageHtmlLink":"[FLINK-20217][docs] Regenerate docs"}},{"before":"894feed5f3eb4fb38c53001a7cc8727d7fe46bb5","after":"23fa2aeb01861a6f8b85f911c5a3f989a1f75898","ref":"refs/heads/master","pushedAt":"2024-06-12T10:07:20.000Z","pushType":"pr_merge","commitsCount":4,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"[FLINK-35533][runtime] Add a option to config the external remote tier factory class","shortMessageHtmlLink":"[FLINK-35533][runtime] Add a option to config the external remote tie…"}},{"before":"526f9b034763fd022a52fe84b2c3227c59a78df1","after":"894feed5f3eb4fb38c53001a7cc8727d7fe46bb5","ref":"refs/heads/master","pushedAt":"2024-06-12T09:41:54.000Z","pushType":"pr_merge","commitsCount":3,"pusher":{"login":"reswqa","name":"Weijie Guo","path":"/reswqa","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/19502505?s=80&v=4"},"commit":{"message":"Revert \"[FLINK-34123][core][type] Introduce built-in serialization support for Map, List, and Collection\"\n\nThis reverts commit 73676da59584f360c02d139a916033e8967583b3.","shortMessageHtmlLink":"Revert \"[FLINK-34123][core][type] Introduce built-in serialization su…"}},{"before":"f33808c0f02c12488d4de2f4d517da8b8b100224","after":"526f9b034763fd022a52fe84b2c3227c59a78df1","ref":"refs/heads/master","pushedAt":"2024-06-11T14:07:51.000Z","pushType":"push","commitsCount":6,"pusher":{"login":"LadyForest","name":"Jane Chan","path":"/LadyForest","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/55568005?s=80&v=4"},"commit":{"message":"[FLINK-35473][sql-client] Add missing annotation for ResultMode and SqlClientOptions\n\nThis closes #24889","shortMessageHtmlLink":"[FLINK-35473][sql-client] Add missing annotation for ResultMode and S…"}},{"before":null,"after":"04e7179738b5dfea6a6929ce74b08306e1f6e438","ref":"refs/heads/FLINK-35550","pushedAt":"2024-06-11T13:35:45.000Z","pushType":"branch_creation","commitsCount":0,"pusher":{"login":"XComp","name":"Matthias Pohl","path":"/XComp","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/1101012?s=80&v=4"},"commit":{"message":"JavaDoc fix","shortMessageHtmlLink":"JavaDoc fix"}},{"before":"e1b45684394541ee290a3d81cc59a85623396c42","after":"f33808c0f02c12488d4de2f4d517da8b8b100224","ref":"refs/heads/master","pushedAt":"2024-06-11T09:15:05.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"Zakelly","name":"Zakelly","path":"/Zakelly","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/2986149?s=80&v=4"},"commit":{"message":"[FLINK-32081][test] Add Compatibility IT case for fileMerging\n\nThis fixes #24873","shortMessageHtmlLink":"[FLINK-32081][test] Add Compatibility IT case for fileMerging"}},{"before":"b72ce532fdd77bca86a030be1b9878be4c097546","after":"e1b45684394541ee290a3d81cc59a85623396c42","ref":"refs/heads/master","pushedAt":"2024-06-11T08:17:34.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-35068][core][type] Introduce built-in serialization support for java.util.Set","shortMessageHtmlLink":"[FLINK-35068][core][type] Introduce built-in serialization support fo…"}},{"before":"8ae7986e1dca80a686b678feb4ea3bdfff4a19bb","after":"bae1ca48907c4473ba7fcef009b2ceb60bf971fe","ref":"refs/heads/release-1.18","pushedAt":"2024-06-11T06:31:06.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"xintongsong","name":"Xintong Song","path":"/xintongsong","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6509172?s=80&v=4"},"commit":{"message":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream\n\nThis closes #24896","shortMessageHtmlLink":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsReco…"}},{"before":"72267c47fa98b9110133328a44cbd49cfee827e9","after":"cdbc14be949548f9a0418a326b9bb791ab8fb124","ref":"refs/heads/release-1.19","pushedAt":"2024-06-11T06:30:13.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"xintongsong","name":"Xintong Song","path":"/xintongsong","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6509172?s=80&v=4"},"commit":{"message":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream\n\nThis closes #24896","shortMessageHtmlLink":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsReco…"}},{"before":"c9def98128f0b948d98a11d57da9ea69d326c227","after":"b72ce532fdd77bca86a030be1b9878be4c097546","ref":"refs/heads/master","pushedAt":"2024-06-11T06:29:30.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"xintongsong","name":"Xintong Song","path":"/xintongsong","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/6509172?s=80&v=4"},"commit":{"message":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream\n\nThis closes #24896","shortMessageHtmlLink":"[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsReco…"}},{"before":"74b100bcba33ce18b21a44b26db7e162507f7830","after":"c9def98128f0b948d98a11d57da9ea69d326c227","ref":"refs/heads/master","pushedAt":"2024-06-10T15:33:05.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"dannycranmer","name":"Danny Cranmer","path":"/dannycranmer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4950503?s=80&v=4"},"commit":{"message":"[FLINK-35435][Connectors/base] Add timeout Configuration to Async Sink (#24839)","shortMessageHtmlLink":"[FLINK-35435][Connectors/base] Add timeout Configuration to Async Sink ("}},{"before":"57869c11687e0053a242c90623779c0c7336cd33","after":"74b100bcba33ce18b21a44b26db7e162507f7830","ref":"refs/heads/master","pushedAt":"2024-06-10T12:50:14.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"gaborgsomogyi","name":"Gabor Somogyi","path":"/gaborgsomogyi","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/18561820?s=80&v=4"},"commit":{"message":"[FLINK-35525][yarn] Add a token services configuration to allow obtained token to be passed to Yarn AM","shortMessageHtmlLink":"[FLINK-35525][yarn] Add a token services configuration to allow obtai…"}},{"before":"20816c906a2eb726d5feb67eb59fe0ea0709c575","after":"57869c11687e0053a242c90623779c0c7336cd33","ref":"refs/heads/master","pushedAt":"2024-06-07T10:04:07.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-34239][core,table] Add copy() in SerializerConfig","shortMessageHtmlLink":"[FLINK-34239][core,table] Add copy() in SerializerConfig"}},{"before":"7afa6eaae3218f273c7971434ea88a2cfd966ced","after":"72267c47fa98b9110133328a44cbd49cfee827e9","ref":"refs/heads/release-1.19","pushedAt":"2024-06-07T09:58:54.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-35537] Fix exception when setting 'state.backend.rocksdb.compression.per.level' in yaml","shortMessageHtmlLink":"[FLINK-35537] Fix exception when setting 'state.backend.rocksdb.compr…"}},{"before":"030511111a38a4e50e52c71a489bd4e3d021da3b","after":"20816c906a2eb726d5feb67eb59fe0ea0709c575","ref":"refs/heads/master","pushedAt":"2024-06-07T09:58:45.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-35537] Fix exception when setting 'state.backend.rocksdb.compression.per.level' in yaml","shortMessageHtmlLink":"[FLINK-35537] Fix exception when setting 'state.backend.rocksdb.compr…"}},{"before":"4b0a39590b9159e5904290a06684c7b677e489ba","after":"030511111a38a4e50e52c71a489bd4e3d021da3b","ref":"refs/heads/master","pushedAt":"2024-06-07T09:14:03.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-35423][table] ARRAY_EXCEPT should follow set semantics","shortMessageHtmlLink":"[FLINK-35423][table] ARRAY_EXCEPT should follow set semantics"}},{"before":"0c4f6416ad4f8d4c7a249ffa59c23aba89e09946","after":"8ae7986e1dca80a686b678feb4ea3bdfff4a19bb","ref":"refs/heads/release-1.18","pushedAt":"2024-06-07T01:56:50.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-35522][runtime] Fix the issue that the source task may get stuck in speculative execution mode.","shortMessageHtmlLink":"[FLINK-35522][runtime] Fix the issue that the source task may get stu…"}},{"before":"175ed72e15c6228dbc36cf42105eccccf9f5a03b","after":"7afa6eaae3218f273c7971434ea88a2cfd966ced","ref":"refs/heads/release-1.19","pushedAt":"2024-06-07T01:56:43.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-35522][runtime] Fix the issue that the source task may get stuck in speculative execution mode.","shortMessageHtmlLink":"[FLINK-35522][runtime] Fix the issue that the source task may get stu…"}},{"before":"09673354bf6b23ef6e80ba580dbc904d541efa84","after":"4b0a39590b9159e5904290a06684c7b677e489ba","ref":"refs/heads/master","pushedAt":"2024-06-06T21:49:52.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-31664][table] Implement ARRAY_INTERSECT function","shortMessageHtmlLink":"[FLINK-31664][table] Implement ARRAY_INTERSECT function"}},{"before":"f462926ad9c1d9a42ebd7aedbd67ebce2b1519a5","after":"09673354bf6b23ef6e80ba580dbc904d541efa84","ref":"refs/heads/master","pushedAt":"2024-06-06T18:54:13.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"JingGe","name":"Jing Ge","path":"/JingGe","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4742354?s=80&v=4"},"commit":{"message":"[hotfix][table] refactoring to template method to separate concerns","shortMessageHtmlLink":"[hotfix][table] refactoring to template method to separate concerns"}},{"before":"9a69067ec01ebd4aa08be4a2b8b142faab47789c","after":"5edb5a93061c36e183899415beaf0dab2495b984","ref":"refs/heads/release-1.19.1-rc1","pushedAt":"2024-06-06T12:45:37.000Z","pushType":"push","commitsCount":4,"pusher":{"login":"hlteoh37","name":"Hong Liang Teoh","path":"/hlteoh37","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/35062175?s=80&v=4"},"commit":{"message":"[FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard","shortMessageHtmlLink":"[FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication…"}},{"before":"9708f9fd65751296b3b0377c964207b630958259","after":"f462926ad9c1d9a42ebd7aedbd67ebce2b1519a5","ref":"refs/heads/master","pushedAt":"2024-06-06T12:34:24.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-35201][table] Remove unnecessary logs in MaterializedTableManager","shortMessageHtmlLink":"[FLINK-35201][table] Remove unnecessary logs in MaterializedTableManager"}},{"before":"ceb4db4d88a91546a179cc9fe1bc86ea1d7bb42a","after":"9708f9fd65751296b3b0377c964207b630958259","ref":"refs/heads/master","pushedAt":"2024-06-06T12:18:41.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"rkhachatryan","name":"Roman","path":"/rkhachatryan","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/3939322?s=80&v=4"},"commit":{"message":"[FLINK-35501] Use common IO thread pool for RocksDB data transfer\n\nCurrently, each RocksDB state backend creates an executor backed by a\nthread pool.\n\nThis makes it difficult to control the total number of threads per TM\nbecause it might have at least one task per slot and theoretically, many\nstate backends per task (because of chaining).\n\nAdditionally, using a common thread pool allows to indirectly control\nthe load on the underlying DFS (e.g. the total number of requests to S3\nfrom a TM).\n\nThis change allows to control the total number of data transfers per TM.","shortMessageHtmlLink":"[FLINK-35501] Use common IO thread pool for RocksDB data transfer"}},{"before":"de5793a3803cc550c6f76e872f05b699cd0fbb16","after":"175ed72e15c6228dbc36cf42105eccccf9f5a03b","ref":"refs/heads/release-1.19","pushedAt":"2024-06-06T10:37:44.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-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard","shortMessageHtmlLink":"[FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication…"}},{"before":"5b228cdab2b8000bcae8ae276e081ef5be442949","after":"ceb4db4d88a91546a179cc9fe1bc86ea1d7bb42a","ref":"refs/heads/master","pushedAt":"2024-06-06T10:31:17.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-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard","shortMessageHtmlLink":"[FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication…"}},{"before":"b51dc716ce48862269fdd409ea85036d61ee7b57","after":"0c4f6416ad4f8d4c7a249ffa59c23aba89e09946","ref":"refs/heads/release-1.18","pushedAt":"2024-06-06T10:08:16.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dannycranmer","name":"Danny Cranmer","path":"/dannycranmer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4950503?s=80&v=4"},"commit":{"message":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release","shortMessageHtmlLink":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release"}},{"before":"b9c666e6a51702c35101af2d13277115f48be993","after":"de5793a3803cc550c6f76e872f05b699cd0fbb16","ref":"refs/heads/release-1.19","pushedAt":"2024-06-06T10:08:16.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dannycranmer","name":"Danny Cranmer","path":"/dannycranmer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4950503?s=80&v=4"},"commit":{"message":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release","shortMessageHtmlLink":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release"}},{"before":"aa4d312f65afd2fd5942a6e1cc6423450b4cc855","after":"5b228cdab2b8000bcae8ae276e081ef5be442949","ref":"refs/heads/master","pushedAt":"2024-06-06T10:06:06.000Z","pushType":"push","commitsCount":1,"pusher":{"login":"dannycranmer","name":"Danny Cranmer","path":"/dannycranmer","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/4950503?s=80&v=4"},"commit":{"message":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release","shortMessageHtmlLink":"[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEY1ei-AA","startCursor":null,"endCursor":null}},"title":"Activity · apache/flink"}