[flink] branch master updated (13c8d4d -> a612d99)

This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 13c8d4d [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink add a

[flink-table-store] branch master updated (e7eed4d -> 29f1521)

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git. from e7eed4d [hotfix] Make Predicates Serializable add 29f1521 [hotfix] Move SinkRecord to core fr

[flink] branch master updated (a543e65 -> 13c8d4d)

This is an automated email from the ASF dual-hosted git repository. hxb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a543e65 [FLINK-25312][hive] HiveCatalog supports Flink's managed table add 13c8d4d [FLINK-25836][python] Fix the u

[flink] branch master updated (51eb386 -> a543e65)

This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 51eb386 [FLINK-25719][python] Support General Python UDF in Thread Mode add a543e65 [FLINK-25312][hive]

[flink] branch master updated (fef375e -> ca519f6)

This is an automated email from the ASF dual-hosted git repository. tangyun pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from fef375e [FLINK-24038] Disable leadership tests when using multiple component leadership ha services add d34653

[flink] branch master updated (25ecc0b -> fef375e)

This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 25ecc0b [FLINK-24041][connectors] Removed public setter for elementConverter in Async Sink. Concrete implementati

[flink] branch master updated: [FLINK-24041][connectors] Removed public setter for elementConverter in Async Sink. Concrete implementations must now construct this elementConverter

This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 25ecc0b [FLINK-24041][connectors] Removed

[flink-statefun] annotated tag statefun-sdk-go/v3.2.0-rc1 updated (70daa3a -> 816fa75)

This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a change to annotated tag statefun-sdk-go/v3.2.0-rc1 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. *** WARNING: tag statefun-sdk-go/v3.2.0-rc1 was modified! *** from 70daa3a (commit

[flink] branch master updated (8c3f241 -> 674bc96)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 8c3f241 [hotfix][tests] Add missing '=' add 674bc96 [FLINK-25754][elsaticsearch] Remove unused private class

[flink-statefun] branch release-3.0 updated: [hotfix][docs] Fix typo

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-3.0 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/release-3.0 by this push: new 8ca76a0 [hotfix][docs] Fix t

[flink] branch master updated: [hotfix][tests] Add missing '='

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 8c3f241 [hotfix][tests] Add missing '=' 8c3f241

[flink] branch master updated (0f701b5 -> d7bc8e2)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0f701b5 [FLINK-25818][Docs][Kafka] Add explanation how Kafka Source deals with idleness when parallelism is higher

[flink] branch master updated (9412c99 -> 0f701b5)

This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9412c99 [FLINK-25811][connector/base] changing failed requests handler to accept list in AsyncSinkWriter add 0f7

[flink-web] branch asf-site updated: Add libenchao to the committer list

This is an automated email from the ASF dual-hosted git repository. libenchao pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 9f3e4ee Add libenchao to the committe

[flink] branch master updated: [FLINK-25811][connector/base] changing failed requests handler to accept list in AsyncSinkWriter

This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 9412c99 [FLINK-25811][connector/base] chan

[flink] branch master updated (cfe5e9a -> d9bb8d7)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from cfe5e9a fixup! [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100% ad

[flink] branch master updated (928d656 -> cfe5e9a)

This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 928d656 [hotfix] fix a typo in KafkaTestBase add dea617c [FLINK-25590][metrics] Introduce RequestedMemoryUsa

[flink] branch master updated (873c481 -> 928d656)

This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 873c481 [hotfix][filesystem] Fix the typo in InProgressFileWriter new c6f14ca [FLINK-25368][connectors/kafka] Su

[flink] 02/02: [hotfix] fix a typo in KafkaTestBase

This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 928d6569de10732bb7f5f84009d88d3daf643f43 Author: dengziming AuthorDate: Fri Dec 24 10:53:32 2021 +0800 [hotfix] fix a

[flink] 01/02: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient in OffsetsInitializer

This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c6f14ca5b10d30232966bce2f52e9f9128346473 Author: dengziming AuthorDate: Sat Dec 18 10:21:29 2021 +0800 [FLINK-25368][