[flink] branch release-1.14 updated: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm

2021-09-09 Thread hxb
This is an automated email from the ASF dual-hosted git repository. hxb pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new d9e6abf [FLINK-24123][python] Optimize

[flink] branch master updated: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm

2021-09-09 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 fb5d1b8 [FLINK-24123][python] Optimize the python o

[flink] 01/02: [FLINK-24213][qs] Introduce factory for established connection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git commit fa2ab610c1c20ff828db0fc928b6328c2f440e9d Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:34:26 2021 +0200 [

[flink] 02/02: [FLINK-24213][qs] Use single lock in ServerConnection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git commit de69c3e3e7a4c29e99acd91129937db24afaefb2 Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:40:20 2021 +0200 [

[flink] branch release-1.12 updated (07a3f66 -> de69c3e)

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 07a3f66 [FLINK-23345][python] Limits the version requests to 2.26.0 or above new fa2ab61 [FLINK-24213][

[flink] 02/02: [FLINK-24213][qs] Use single lock in ServerConnection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4db7f4c502ba6428bf4f3f7d52b00a8cbada29fa Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:40:20 2021 +0200 [

[flink] branch release-1.13 updated (53f79ea -> 4db7f4c)

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 53f79ea [FLINK-23345][python] Limits the version requests to 2.26.0 or above new 640797f [FLINK-24213][

[flink] 01/02: [FLINK-24213][qs] Introduce factory for established connection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 640797f39454223503c097f4762ae4f8d5d2e768 Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:34:26 2021 +0200 [

[flink] branch master updated (412c45f -> d93682c)

2021-09-09 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 412c45f [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was f

[flink] branch release-1.14 updated: [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was fixed.

2021-09-09 Thread xtsong
This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 4e68c45 [FLINK-23944][connector/puls

[flink] branch release-1.14 updated (3621b00 -> 4e732ad)

2021-09-09 Thread xtsong
This is an automated email from the ASF dual-hosted git repository. xtsong pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 3621b00 [FLINK-23345][python] Limits the version requests to 2.26.0 or above add 1a7bc49 [FLINK-23848][c

[flink] branch master updated (0cecdca -> 412c45f)

2021-09-09 Thread xtsong
This is an automated email from the ASF dual-hosted git repository. xtsong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0cecdca [FLINK-23345][python] Limits the version requests to 2.26.0 or above add 412c45f [FLINK-23944][connect

[flink] branch release-1.10 updated: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.10 by this push: new 3d95391 [FLINK-24137][python] Fix th

[flink] branch release-1.11 updated: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.11 by this push: new aae0f91 [FLINK-24137][python] Fix th

[flink] branch release-1.12 updated (afcba03 -> 07a3f66)

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from afcba03 Revert "[FLINK-23949][checkpoint] Fix first incremental checkpoint after a savepoint degenerate into a

[flink] branch release-1.13 updated: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 53f79ea [FLINK-23345][python] Limits

[flink] branch release-1.14 updated: [FLINK-23345][python] Limits the version requests to 2.26.0 or above

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 3621b00 [FLINK-23345][python] Limits

[flink] branch master updated (713f066 -> 0cecdca)

2021-09-09 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 713f066 [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue. add 0cecdca [FLINK-2

[flink] branch release-1.13 updated: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery

2021-09-09 Thread lzljs3620320
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 3b4f230 [FLINK-22901][table-pl

[flink] 08/08: [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions.

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit c56ecf3e0acb917f3e302eda7c5f92b73a881c76 Author: Stephan Ewen AuthorDate: Tue Aug 24 16:06:04 2021 +0200 [FLINK

[flink] 05/08: [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 814f2780c855b6e3b3b1d26cc42c9979ba3abc53 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:22:56 2021 +0200 [hotfi

[flink] 06/08: [hotfix] Deduplicate JavaDocs in SourceFunction

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 18e94e44d1ebda41ad8595eac03393ebb17bdfbf Author: Stephan Ewen AuthorDate: Tue Aug 24 15:36:12 2021 +0200 [hotfi

[flink] 07/08: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange.

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9a26fe9c4e325a9c44bdcc9be3c99aef0a8e1e34 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:37:09 2021 +0200 [hotfi

[flink] branch release-1.14 updated (2459a3c -> c56ecf3)

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 2459a3c [FLINK-24213][qs] Use single lock in ServerConnection new 4aa457d [FLINK-22357][core] Upgrades API

[flink] 02/08: [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext class.

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2a13b241b95434e2fd26271cf98a47af936b93e5 Author: Stephan Ewen AuthorDate: Thu Sep 9 15:48:19 2021 +0200 [hotfix

[flink] 04/08: [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue.

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2af65df0127db5890cfc3d3f382e2ba7eca44771 Author: Stephan Ewen AuthorDate: Thu Sep 9 16:14:54 2021 +0200 [hotfix

[flink] 03/08: [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources.

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit a76854f535f4af4251b038c5c87bfb73e36fdf0f Author: Stephan Ewen AuthorDate: Mon Apr 19 18:22:07 2021 +0200 [FLINK

[flink] 01/08: [FLINK-22357][core] Upgrades API stability of unified source API to @Public (= stable).

2021-09-09 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4aa457d75a83f929104ea1a4f7526ce13b06c475 Author: Stephan Ewen AuthorDate: Mon Apr 19 18:05:01 2021 +0200 [FLINK

[flink] branch master updated (76ee66f -> 713f066)

2021-09-09 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 76ee66f [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified Sink API, Increase robustness for flush,

[flink] branch master updated: [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments, added unit and

2021-09-09 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 76ee66f [FLINK-24041][connectors] First dr

[flink] branch master updated: [FLINK-23836][doc-zh] Translate "Execution Configuration" page into Chinese (#16865)

2021-09-09 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 ff713a8 [FLINK-23836][doc-zh] Translate "Execution

[flink] 01/02: [FLINK-24213][qs] Introduce factory for established connection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit a2185c0f9bef64b103a4e1ae2c33619d83d54921 Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:34:26 2021 +0200 [

[flink] 02/02: [FLINK-24213][qs] Use single lock in ServerConnection

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2459a3c3001c2ef263536276b7d7109752f93286 Author: Chesnay Schepler AuthorDate: Thu Sep 9 09:40:20 2021 +0200 [

[flink] branch release-1.14 updated (2db50d6 -> 2459a3c)

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 2db50d6 [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed i

[flink] branch master updated (0b4855f -> 2e721ab)

2021-09-09 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 0b4855f [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loop

[flink] 01/02: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4d131d547fd510a08d15557995edc19078cd26e7 Author: Dian Fu AuthorDate: Thu Sep 9 15:34:17 2021 +0800 [FLINK-2413

[flink] 02/02: [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2db50d63a5e4a97868ef2c6d05163e78c85db21c Author: Dian Fu AuthorDate: Thu Sep 9 17:27:07 2021 +0800 [FLINK-2413

[flink] branch release-1.14 updated (e859af6 -> 2db50d6)

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from e859af6 [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest new 4d131d5 [FLINK-24137][p

[flink] branch master updated (60046b1 -> 0b4855f)

2021-09-09 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 60046b1 [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API add 7a1b2b3 [FLINK-241

[flink] branch master updated: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API

2021-09-09 Thread dianfu
This is an automated email from the ASF dual-hosted git repository. dianfu 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 60046b1 [FLINK-24199][python] Expose StreamExec

[flink] branch release-1.14 updated: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

2021-09-09 Thread roman
This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new e859af6 [FLINK-22889][tests] Increase

[flink] branch release-1.14 updated (adc9d43 -> 8e982b7)

2021-09-09 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from adc9d43 [hotfix] Add .eslintcache to .gitignore add 8e982b7 [FLINK-23462] [docs-zh] Translate the abfs doc

[flink] branch master updated (c69193b -> 1980481)

2021-09-09 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 c69193b [FLINK-24031] Extend vcs.xml add 1980481 [FLINK-23462] [docs-zh] Translate the abfs documentation to ch

[flink] branch release-1.13 updated: [hotfix] Add .eslintcache to .gitignore

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new c89b172 [hotfix] Add .eslintcache t

[flink] branch release-1.14 updated: [hotfix] Add .eslintcache to .gitignore

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new adc9d43 [hotfix] Add .eslintcache t

[flink] branch release-1.14 updated: [FLINK-24031] Extend vcs.xml

2021-09-09 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new e7766f7 [FLINK-24031] Extend vcs.xm

[flink] branch master updated (a1a645a -> c69193b)

2021-09-09 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 a1a645a [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (#

[flink] branch master updated (69fefdd -> a1a645a)

2021-09-09 Thread yuanmei
This is an automated email from the ASF dual-hosted git repository. yuanmei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 69fefdd [hotfix][rest][tests] Cleanup add a1a645a [FLINK-24155][documentation] Sync Chinese version of docume