[flink] branch master updated: [FLINK-13092][docs-zh] Translate "kubernetes.md" page into Chinese

2021-08-16 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark 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 cad23b6 [FLINK-13092][docs-zh] Translate "kubernet

[flink] branch master updated: [FLINK-23680][streaming] Wait until all expected threads would be triggered in testOpenCloseAndTimestamps (#16797)

2021-08-16 Thread yuanmei
This is an automated email from the ASF dual-hosted git repository. yuanmei 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 ff416c6 [FLINK-23680][streaming] Wait until all

[flink] branch master updated (d57d9f8 -> ee74231)

2021-08-16 Thread tangyun
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 d57d9f8 [FLINK-23649][rocksdb] Add FRocksDB packages to parent-first classloading patterns add ee74231 [FLINK

[flink] branch master updated (8128c04 -> d57d9f8)

2021-08-16 Thread tangyun
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 8128c04 [FLINK-23765][python] Fix the NPE in Python UDTF add d57d9f8 [FLINK-23649][rocksdb] Add FRocksDB packa

[flink] branch master updated: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-16 Thread hxb
This is an automated email from the ASF dual-hosted git repository. hxb 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 8128c04 [FLINK-23765][python] Fix the NPE in Python

[flink] 02/02: [FLINK-23710][connectors/kafka] Deprecate FlinkKafkaProducer

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6c9818323b41a84137c52822d2993df788dbc9bb Author: Fabian Paul AuthorDate: Mon Aug 16 10:05:21 2021 +0200 [FLINK-23710]

[flink] 01/02: [FLINK-23710][connectors/kafka] Move FLIP-143 KafkaSink to org.apache.kafka.connector.kafka.sink

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 94da2b587c133621bbdf39d36d55070a64605f56 Author: Fabian Paul AuthorDate: Mon Aug 16 09:58:23 2021 +0200 [FLINK-23710]

[flink] branch master updated (c84ebe8 -> 6c98183)

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c84ebe8 [FLINK-23630][tests] Make EventTimeWindowCheckpointingITCase run on Windows. new 94da2b5 [FLINK-23710][

[flink] 01/02: [FLINK-23629][tests] Remove redundant file-async and mem-async test runs from EventTimeWindowCheckpointingITCase

2021-08-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 31b45fc6c48dc0503f1c91ce1b6b0b00c6439a02 Author: Stephan Ewen AuthorDate: Wed Aug 4 18:42:00 2021 +0200 [FLINK-23629]

[flink] 02/02: [FLINK-23630][tests] Make EventTimeWindowCheckpointingITCase run on Windows.

2021-08-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c84ebe839b3e1e936e68d2e67496cf7664b35287 Author: Stephan Ewen AuthorDate: Wed Aug 4 19:01:34 2021 +0200 [FLINK-23630]

[flink] branch master updated (c675f78 -> c84ebe8)

2021-08-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c675f78 [FLINK-20731] Introduce new pulsar source connector for flink. new 31b45fc [FLINK-23629][tests] Remove r

[flink] branch master updated (a86f8a5 -> c675f78)

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a86f8a5 [FLINK-23812][rocksdb] support configuring RocksDB logging (#16848) add c675f78 [FLINK-20731] Introduce

[flink] branch master updated (25bce2f -> a86f8a5)

2021-08-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 25bce2f [FLINK-21290][table-planner] Support project push down for window TVF add a86f8a5 [FLINK-23812][rocks

[flink] branch master updated: [FLINK-12141] [API/Type Serialization System] Allow @TypeInfo annotation on POJO field declarations (#8344)

2021-08-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber 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 d326b05 [FLINK-12141] [API/Type Serialization S

[flink] 04/04: [FLINK-23767][connectors] Revert going automatically idle when no partitions are (temporarily) available.

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit d6a8afd98dab90572472dd89fd398db34822647d Author: Arvid Heise AuthorDate: Fri Aug 13 15:29:06 2021 +0200 [FLINK-23767]

[flink] 01/04: [FLINK-23767][streaming] Update definition of StreamStatus.

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 379f28b60afb329c52ef0b0985825a0fd84882a5 Author: Arvid Heise AuthorDate: Thu Jul 8 16:45:50 2021 +0200 [FLINK-23767][

[flink] 03/04: [FLINK-23767][connectors] Add WatermarkOutput#markActive.

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7ef3c24cd752d1bcfd17c75d50d67ce897eb299f Author: Arvid Heise AuthorDate: Thu Jul 8 22:23:57 2021 +0200 [FLINK-23767][

[flink] branch master updated (ab7f541 -> d6a8afd)

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ab7f541 [FLINK-22519][python] Support tgz files as python archives new 379f28b [FLINK-23767][streaming] Update d

[flink] branch master updated (4c8f3a7 -> ab7f541)

2021-08-16 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4c8f3a7 [FLINK-22914][connector/kafka] Use FLIP-27 KafkaSource in table connector add ab7f541 [FLINK-22519][py

[flink] branch master updated (6451a1f -> 4c8f3a7)

2021-08-16 Thread lirui
This is an automated email from the ASF dual-hosted git repository. lirui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 6451a1f [FLINK-23111][runtime-web] Fix maven build node version, several dependencies, and NOTICE add 4c8f3a7 [

[flink] 05/05: [FLINK-23111][runtime-web] Fix maven build node version, several dependencies, and NOTICE

2021-08-16 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6451a1f445c52ee81122c3234f266c428aebb837 Author: 子扬 AuthorDate: Fri Jul 30 16:50:34 2021 +0800 [FLINK-23111][runtim

[flink] branch master updated (ac8c5a2 -> 6451a1f)

2021-08-16 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ac8c5a2 [FLINK-23802][kinesis][efo] Request next record from the Flink source thread rather than the AWS SDK respon

[flink] branch master updated: [FLINK-23802][kinesis][efo] Request next record from the Flink source thread rather than the AWS SDK response thread. Increase Read Timeout to 6m, higher than the maximu

2021-08-16 Thread dannycranmer
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 ac8c5a2 [FLINK-23802][kinesis][efo] Reques

[flink-statefun] 03/03: [FLINK-18810][sdk] Document Golang SDK

2021-08-16 Thread sjwiesman
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git commit 60c8b71f8a37f1ad28ebcb848ed2ec3be19ce8df Author: sjwiesman AuthorDate: Wed Aug 11 09:19:36 2021 -0500 [F

[flink-statefun] 02/03: [FLINK-18810][sdk] Golang remote functions smoke test

2021-08-16 Thread sjwiesman
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git commit a7dfca8bde7ae6bdd6d6e0d15df9eec435b88893 Author: sjwiesman AuthorDate: Wed Aug 11 09:18:19 2021 -0500 [F

[flink-statefun] branch master updated (33abb7b -> 60c8b71)

2021-08-16 Thread sjwiesman
This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git. from 33abb7b [FLINK-22752] More robust state configurations in base flink-conf.yaml new 1dfe226 [FLINK-

[flink] branch master updated (b3dea50 -> 3804cd3)

2021-08-16 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b3dea50 [FLINK-23247][table-planner] Materialize time attribute fields of regular join's inputs add 6e977ea [

[flink] branch master updated (cab4a98 -> b3dea50)

2021-08-16 Thread godfrey
This is an automated email from the ASF dual-hosted git repository. godfrey pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from cab4a98 [FLINK-23785][tests] Use unique operator names for metric tests. add b3dea50 [FLINK-23247][table-plan

[flink] branch master updated (a686982 -> cab4a98)

2021-08-16 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a686982 [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

[flink] 02/02: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-08-16 Thread hxb
This is an automated email from the ASF dual-hosted git repository. hxb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit a68698264ce1ebc37921ad6517eccd5c3700aeeb Author: huangxingbo AuthorDate: Fri Aug 6 11:32:26 2021 +0800 [FLINK-21222][py

[flink] 01/02: [FLINK-22871][python] Support to specify python client interpreter used to compile jobs

2021-08-16 Thread hxb
This is an automated email from the ASF dual-hosted git repository. hxb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5f99c42d27ad6b42df70c16810029ade365c9495 Author: huangxingbo AuthorDate: Mon Aug 16 10:35:58 2021 +0800 [FLINK-22871][p

[flink] branch master updated (6d0263f -> a686982)

2021-08-16 Thread hxb
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 6d0263f [FLINK-23720][table] Migrate ModuleFactory to the new stack new 5f99c42 [FLINK-22871][python] Support to s

[flink] branch master updated (6d89c1d -> 6d0263f)

2021-08-16 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 6d89c1d [FLINK-23560][runtime] Calculate absoluteTimeMillis only once for idle metric and throughput calculation. (

[flink-statefun-docker] branch master updated (a31a312 -> 0607844)

2021-08-16 Thread tzulitai
This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun-docker.git. from a31a312 [release] Update Dockerfiles for 3.0.0 release add 0607844 [FLINK-22752] More robust

[flink-statefun] branch master updated: [FLINK-22752] More robust state configurations in base flink-conf.yaml

2021-08-16 Thread tzulitai
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.git The following commit(s) were added to refs/heads/master by this push: new 33abb7b [FLINK-22752] More robust sta

[flink] branch master updated: [FLINK-23560][runtime] Calculate absoluteTimeMillis only once for idle metric and throughput calculation. (#16772)

2021-08-16 Thread yuanmei
This is an automated email from the ASF dual-hosted git repository. yuanmei 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 6d89c1d [FLINK-23560][runtime] Calculate absolu

[flink] branch master updated (cb273e5 -> 778fc42)

2021-08-16 Thread chesnay
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 cb273e5 [FLINK-23627][metrics] Migrate OperatorMG instantiations to factory method add 778fc42 [FLINK-23625][

[flink] branch master updated (7ff4cbd -> cb273e5)

2021-08-16 Thread chesnay
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 7ff4cbd [FLINK-18840][table-api] Add StreamStatementSet.attachAsDataStream() add cb273e5 [FLINK-23627][metric