{"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":"6c417719972e203de44df9540c1875de0070949d","after":"49f22254a78d554ac49810058c209297331129cd","ref":"refs/heads/master","pushedAt":"2024-05-28T07:48:21.000Z","pushType":"pr_merge","commitsCount":2,"pusher":{"login":"lsyldliu","name":"Ron","path":"/lsyldliu","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/17698589?s=80&v=4"},"commit":{"message":"[FLINK-35425][table-common] Support convert freshness to cron expression in full refresh mode","shortMessageHtmlLink":"[FLINK-35425][table-common] Support convert freshness to cron express…"}},{"before":"1e996b8731bf2eabc83f1f7138ef37467c6b591d","after":"6c417719972e203de44df9540c1875de0070949d","ref":"refs/heads/master","pushedAt":"2024-05-28T03:12:09.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":"[hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359","shortMessageHtmlLink":"[hotfix] Fix modification conflict between FLINK-35465 and FLINK-35359"}},{"before":"9fbe9f30480311313ed02f7eed1fe87eb3f02b33","after":"1e996b8731bf2eabc83f1f7138ef37467c6b591d","ref":"refs/heads/master","pushedAt":"2024-05-28T03:04:33.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-35457][checkpoint] Hotfix! close physical file under the protection of lock (#24846)","shortMessageHtmlLink":"[FLINK-35457][checkpoint] Hotfix! close physical file under the prote…"}},{"before":"e964af392476e011147be73ae4dab8ff89512994","after":"9fbe9f30480311313ed02f7eed1fe87eb3f02b33","ref":"refs/heads/master","pushedAt":"2024-05-28T01:56:05.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-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt (#24847)","shortMessageHtmlLink":"[FLINK-35460][state] Adjust read size when ByteBuffer size is larger …"}},{"before":"57b20051a5aa6426d0a6ded71f5e0d550572428c","after":"e964af392476e011147be73ae4dab8ff89512994","ref":"refs/heads/master","pushedAt":"2024-05-28T01:43:34.000Z","pushType":"pr_merge","commitsCount":3,"pusher":{"login":"zhuzhurk","name":"Zhu Zhu","path":"/zhuzhurk","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5869249?s=80&v=4"},"commit":{"message":"[FLINK-35465][runtime] Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.","shortMessageHtmlLink":"[FLINK-35465][runtime] Introduce BatchJobRecoveryHandler for recovery…"}},{"before":"87b7193846090897b2feabf716ee5378bcd7585b","after":"57b20051a5aa6426d0a6ded71f5e0d550572428c","ref":"refs/heads/master","pushedAt":"2024-05-27T22:06:23.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":"FLINK-33759: add support for nested array with row/map type","shortMessageHtmlLink":"FLINK-33759: add support for nested array with row/map type"}},{"before":"2f7099e77e4eba45e2337e9afbaecb6eb7c62467","after":"87b7193846090897b2feabf716ee5378bcd7585b","ref":"refs/heads/master","pushedAt":"2024-05-27T13:50:11.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":"[FLINK-34379][table] Fix adding catalogtable logic","shortMessageHtmlLink":"[FLINK-34379][table] Fix adding catalogtable logic"}},{"before":"efcd146e0119cc7e67fea74cc46fbde08385de75","after":"2f7099e77e4eba45e2337e9afbaecb6eb7c62467","ref":"refs/heads/master","pushedAt":"2024-05-27T10:22:58.000Z","pushType":"push","commitsCount":2,"pusher":{"login":"masteryhx","name":"yhx","path":"/masteryhx","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/38719192?s=80&v=4"},"commit":{"message":"[FLINK-35434][statebackend] ForSt supports to pass db exception to runtime","shortMessageHtmlLink":"[FLINK-35434][statebackend] ForSt supports to pass db exception to ru…"}},{"before":"4d39738587e0f07a4776eebb83e2bcaf28eef604","after":"efcd146e0119cc7e67fea74cc46fbde08385de75","ref":"refs/heads/master","pushedAt":"2024-05-27T07:35:37.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"twalthr","name":"Timo Walther","path":"/twalthr","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5746567?s=80&v=4"},"commit":{"message":"[FLINK-35403][table] Allow skipping invocation of function calls while constant-folding","shortMessageHtmlLink":"[FLINK-35403][table] Allow skipping invocation of function calls whil…"}},{"before":"90e2d6cfeea44f6302b9d1f1ee4396c5a5c69b8f","after":"4d39738587e0f07a4776eebb83e2bcaf28eef604","ref":"refs/heads/master","pushedAt":"2024-05-27T07:13:33.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"twalthr","name":"Timo Walther","path":"/twalthr","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/5746567?s=80&v=4"},"commit":{"message":"[FLINK-34993][flink-sql-parser] Support MODEL syntax in parser","shortMessageHtmlLink":"[FLINK-34993][flink-sql-parser] Support MODEL syntax in parser"}},{"before":"4b342da6d149113dde821b370a136beef3430fff","after":"90e2d6cfeea44f6302b9d1f1ee4396c5a5c69b8f","ref":"refs/heads/master","pushedAt":"2024-05-27T05:53:55.000Z","pushType":"pr_merge","commitsCount":1,"pusher":{"login":"lsyldliu","name":"Ron","path":"/lsyldliu","primaryAvatarUrl":"https://avatars.githubusercontent.com/u/17698589?s=80&v=4"},"commit":{"message":"[FLINK-35342][table] Fix the unstable MaterializedTableStatementITCase test due to wrong job status check logic\n\nThis closes #24799","shortMessageHtmlLink":"[FLINK-35342][table] Fix the unstable MaterializedTableStatementITCas…"}},{"before":"f860631c523c1d446c0d01046f0fbe6055174dc6","after":"4b342da6d149113dde821b370a136beef3430fff","ref":"refs/heads/master","pushedAt":"2024-05-27T04:07: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-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast","shortMessageHtmlLink":"[FLINK-35426][table-planner] Change the distribution of DynamicFilter…"}},{"before":"c3221a649b9daa8374cc24ab039f6352fb2c6edf","after":"f860631c523c1d446c0d01046f0fbe6055174dc6","ref":"refs/heads/master","pushedAt":"2024-05-27T02:02:14.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-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection","shortMessageHtmlLink":"[FLINK-34123][docs][type] Add doc for built-in serialization support …"}},{"before":"096b4a6bef98ccff918ef3994c16b7361bca21b8","after":"c3221a649b9daa8374cc24ab039f6352fb2c6edf","ref":"refs/heads/master","pushedAt":"2024-05-27T01:41:56.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":"[hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpointFactory#Context","shortMessageHtmlLink":"[hotfix][sqlgateway] Do not introduce new method in SqlGatewayEndpoin…"}},{"before":"5b535e1410782a2d42127e00d77815d6ab7068ed","after":"096b4a6bef98ccff918ef3994c16b7361bca21b8","ref":"refs/heads/master","pushedAt":"2024-05-26T16:39:46.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-35446][checkpoint] Fix NPE when disabling file merging but restoring from merged files\n\nThis fixes #24840","shortMessageHtmlLink":"[FLINK-35446][checkpoint] Fix NPE when disabling file merging but res…"}},{"before":"467f94f9ecef91b671ebbdc4774f2b690f4fa713","after":"5b535e1410782a2d42127e00d77815d6ab7068ed","ref":"refs/heads/master","pushedAt":"2024-05-25T15:14:03.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-35215][core] Add a test for deserializing an object whose serialization result is an empty byte array","shortMessageHtmlLink":"[FLINK-35215][core] Add a test for deserializing an object whose seri…"}},{"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":"[FLINK-35355][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":"[FLINK-35437] 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":"[FLINK-35400][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":"[FLINK-35347][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":"[FLINK-35216] 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":"[FLINK-35429][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":"[FLINK-35359][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":"[FLINK-35420][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":"[FLINK-35410][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":"[FLINK-35047][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 ","shortMessageHtmlLink":"[FLINK-35246][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":"[FLINK-32706][table] Add built-in SPLIT_STRING function (#24365)"}}],"hasNextPage":true,"hasPreviousPage":false,"activityType":"all","actor":null,"timePeriod":"all","sort":"DESC","perPage":30,"cursor":"djE6ks8AAAAEVY-MkwA","startCursor":null,"endCursor":null}},"title":"Activity · apache/flink"}