[flink-statefun-docker] branch master updated: [FLINK-21904] Sync standalone-job.sh with recent Flink 1.12.x changes

This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun-docker.git The following commit(s) were added to refs/heads/master by this push: new 9bf8e25 [FLINK-21904] Sync sta

[flink] branch master updated: [FLINK-21306] Ensure fatal errors always stop the JVM process

This is an automated email from the ASF dual-hosted git repository. rmetzger 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 4b21391 [FLINK-21306] Ensure fatal errors alwa

[flink] branch master updated (b3b8abb -> 5045ac1)

This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b3b8abb [FLINK-21590][build] Avoid hive logs in the SQL client console (#15384) add 4bc2873 [FLINK-21998][hive]

[flink] branch master updated (21157d5 -> b3b8abb)

This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 21157d5 [hotfix][docs] Add missing AggregatingStateDescriptor in State page (#15208) add b3b8abb [FLINK-21590][b

[flink] branch master updated (8d2fa1b -> 21157d5)

This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 8d2fa1b [FLINK-20114][connector/kafka] Remove duplicated warning and remove redundant default value for partition.disc

[flink] 03/12: [hotfix][connector/kafka] Reduce the offset commit logging verbosity from INFO to DEBUG.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b5b9682827f0698d9b4d24215b4dd2daaf25ec30 Author: Dong Lin AuthorDate: Sat Mar 6 12:51:52 2021 +0800 [hotfix][connector

[flink] 08/12: [FLINK-20114][connector/kafka] SourceOperatorStreamTask should check the committed offset first before using OffsetResetStrategy.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8de17841d144c780a46389f5ef69b8c484c0747b Author: Dong Lin AuthorDate: Sun Mar 7 19:33:58 2021 +0800 [FLINK-20114][conn

[flink] 06/12: [hotfix][connector/kafka] Remove the unused close.timeout.ms config.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b3471f2a55df9d10248c41c6d4efedec188b93d6 Author: Dong Lin AuthorDate: Sun Mar 7 17:44:59 2021 +0800 [hotfix][connector

[flink] 12/12: [FLINK-20114][connector/kafka] Remove duplicated warning and remove redundant default value for partition.discovery.interval.ms

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8d2fa1bb81eff790bdc21a69d15a17aa074010ae Author: Dong Lin AuthorDate: Wed Mar 24 15:26:23 2021 +0800 [FLINK-20114][con

[flink] 11/12: [hotfix][examples] Update StateMachineExample to use KafkaSource

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e079aef0efcd544322a028cc15a24bdaa456af4f Author: Dong Lin AuthorDate: Sun Mar 21 17:33:39 2021 +0800 [hotfix][examples

[flink] 10/12: [FLINK-20114][connector/kafka] Add IT cases for KafkaSource by migrating IT cases from FlinkKafkaConsumer.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 3abf5550a11ac4733799187bf49122417a177b6a Author: Dong Lin AuthorDate: Mon Mar 8 09:35:30 2021 +0800 [FLINK-20114][conn

[flink] 07/12: [FLINK-20114][connector/kafka] PartitionOffsetsRetrieverImpl.committedOffsets() should handle the case without committed offsets.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b831b853b908d26a2b7890478fc9f8446b2eb724 Author: Dong Lin AuthorDate: Sun Mar 7 17:53:27 2021 +0800 [FLINK-20114][conn

[flink] 01/12: [FLINK-20114][connector/kafka] KafkaSourceReader should not commit offsets for partitions whose offsets have not been initialized.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7a36623dc081a555d4e6e9d2b1f7bfb908640fee Author: Dong Lin AuthorDate: Wed Mar 3 22:37:25 2021 +0800 [FLINK-20114][conn

[flink] 04/12: [FLINK-20114][connector/common] SourceOperatorStreamTask should update the numRecordsOutCount metric

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b23f65f17b4de16cf0fd91b225c3c3c61c849450 Author: Dong Lin AuthorDate: Sat Mar 6 13:07:31 2021 +0800 [FLINK-20114][conn

[flink] branch master updated (5f0c76f -> 8d2fa1b)

This is an automated email from the ASF dual-hosted git repository. jqin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 5f0c76f [FLINK-21330] Optimize the performance of PipelinedRegionSchedulingStrategy new 7a36623 [FLINK-20114][co

[flink] 09/12: [FLINK-20114][connector/kafka] Auto offset commit should be disabled by default.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit a4360c7f4128eb7ec97c9707b184ab121e829312 Author: Dong Lin AuthorDate: Sun Mar 7 23:05:02 2021 +0800 [FLINK-20114][conn

[flink] 05/12: [FLINK-20114][connector/kafka] KafkaSourceEnumerator should close the admin client early if periodic partition discovery is disabled.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4c6c42392e7d116dee572fefb2e4e0e02abacefb Author: Dong Lin AuthorDate: Sun Mar 7 13:10:08 2021 +0800 [FLINK-20114][conn

[flink] 02/12: [FLINK-20114][connector/common] SourceCoordinatorContext should not log and fail job again if it receives InterruptedException after it is closed.

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b0077c4a4a0f867069e428b1fa13ee87fc5a5556 Author: Dong Lin AuthorDate: Sat Mar 6 12:45:23 2021 +0800 [FLINK-20114][conn

[flink] branch master updated (2c19d3f -> 5f0c76f)

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2c19d3f [FLINK-19607][table-runtime-blink] Implement streaming window TopN operator add 5f0c76f [FLINK-21330] O

[flink] branch master updated (083d022 -> 2c19d3f)

This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 083d022 [hotfix][formats][parquet] Fix argument references add 2c19d3f [FLINK-19607][table-runtime-blink] Impleme

[flink-ml] 05/05: [FLINK-21976] Update README.md to include overview, build, contributing and license sections

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git commit 08d058046f34b711128e0646ffbdc7e384c22064 Author: Dong Lin AuthorDate: Mon Mar 29 17:00:54 2021 +0800 [FLINK-21976]

[flink-ml] 02/05: [FLINK-21976] Add CODE_OF_CONDUCT.md, LICENSE and .gitignore

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git commit f8b84cc202ecbe7de2ca26651191b3991319 Author: Dong Lin AuthorDate: Sun Mar 28 19:28:53 2021 +0800 [FLINK-21976]

[flink-ml] 04/05: [FLINK-21976] Update pom.xml

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git commit 8e2415bfb2ddb00074dc5a44ffd9c828d63af9c7 Author: Dong Lin AuthorDate: Sun Mar 28 16:51:46 2021 +0800 [FLINK-21976]

[flink-ml] 03/05: [FLINK-21976] Add files needed for checkstyle under tools/maven

This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git commit bdb1b93130254dcdb868cc48b3873db825312c72 Author: Dong Lin AuthorDate: Sun Mar 28 22:07:10 2021 +0800 [FLINK-21976]

[flink-ml] branch master updated (ea541d7 -> 08d0580)

This is an automated email from the ASF dual-hosted git repository. jqin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git. from ea541d7 Initialize repository. new 8f86ecf [FLINK-21976] Move files under flink/flink-ml-parent to flink-ml r

[flink] branch master updated (5b3a8f3 -> 083d022)

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 5b3a8f3 [FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTime

[flink] branch master updated (f1e69bb -> 5b3a8f3)

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 f1e69bb [FLINK-19938][network] Implement shuffle data read scheduling for sort-merge blocking shuffle add 5b3a8f3

[flink] branch master updated (71122fd -> f1e69bb)

This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 71122fd [FLINK-21989][table] Add a SupportsSourceWatermark ability interface add f1e69bb [FLINK-19938][network]