[flink] 03/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Add test coverage for watermarks with chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit f79a3a78b77dfe75063d58a49ea460a752c64b0d Author: Piotr Nowojski AuthorDate: Mon Sep 21 15:18:25 2020 +0200 [bac

[flink] 04/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Fix and add test coverage for watermarks gauges with chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit cd3ffa5365cfe9461533e7b047d458caf7040a08 Author: Piotr Nowojski AuthorDate: Mon Sep 21 18:17:20 2020 +0200 [bac

[flink] 01/21: [backport] Backport some core changes that were part of the FLIP-27 File Source commit

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 91903351ad1c8e13bbe2cfe5d8383ad915b5887f Author: Stephan Ewen AuthorDate: Mon Jun 29 11:00:59 2020 +0200 [backp

[flink] 06/21: [refactor][tests] Move some source test utils from flink-connector-base to flink-core

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 7916ad7680ee048353b58c37db263dfff3cb18bb Author: Stephan Ewen AuthorDate: Tue Sep 29 22:25:37 2020 +0200 [refac

[flink] 05/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Add stream status forwarding test for chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 242ced99de92b07cf433b5408acd08985e5d7499 Author: Piotr Nowojski AuthorDate: Tue Sep 22 14:14:52 2020 +0200 [bac

[flink] 11/21: [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext. (#12647)

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 5b2cc0e566150026f359af884dfa201145a1dea7 Author: fangliang <568693...@qq.com> AuthorDate: Wed Oct 28 09:08:38 2020 +0

[flink] 13/21: [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit b3ea6da49582af66a6182c27cfcfde772dc67dde Author: sxnan AuthorDate: Wed Aug 5 13:00:36 2020 +0800 [FLINK-18820]

[flink] 02/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Refactor MockSourceReader"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit ecc6a8aa30d761e0cf2174d8ef00f168b1d45d84 Author: Piotr Nowojski AuthorDate: Tue Sep 22 11:43:58 2020 +0200 [bac

[flink] branch release-1.11 updated (c24185d -> 1a8ff89)

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from c24185d [hotfix] Adjust japicmp exclusion to permit adding methods to SourceReaderContext and SplitEnumeratorCo

[flink] 09/21: [FLINK-19448][connector base] Explicitly check for un-expected condition that would leave an inconsistent state

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit cdc0721f6f4da04e5d08dd0f63a9c503b34410a7 Author: Stephan Ewen AuthorDate: Mon Oct 12 17:38:30 2020 +0200 [FLINK

[flink] 15/21: [hotfix] Only close the SourceReader and EventTimeLogic in the SourceOperator if they are not null.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 3463da5056da44c8fc99404306c8a42ba170ac63 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 18:12:34 2020 +0800

[flink] 08/21: [FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 301046ad36aeb2de0c97aeecc4fabc9dd2eb1520 Author: Stephan Ewen AuthorDate: Fri Oct 2 13:49:38 2020 +0200 [FLINK-

[flink] 14/21: [hotfix] Replace finally block with JUnit After method in SourceOperatorTest.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 8ad5da9be6c1af7c089081c328ef6f344900e077 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 18:04:19 2020 +0800

[flink] 12/21: [hotfix][runtime] Remove commented-out annotation in SourceOperator

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 1f823bd9facfe84f0ec079530b375ddbdaa0575a Author: Stephan Ewen AuthorDate: Mon Sep 21 18:09:43 2020 +0200 [hotfi

[flink] 10/21: [FLINK-19427][FLINK-19489][tests] Fix test conditions for 'SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent()'

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit dd2ac7af895ab117877a361fdafaeb19f8a65bd5 Author: Stephan Ewen AuthorDate: Mon Oct 12 13:43:57 2020 +0200 [FLINK

[flink] 16/21: [hotfix] Add a waitUntil() method to the CommonTestUtils.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 5787a70fcd54f3c23b6d26b5d48bc5d7e9c92239 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 20:02:35 2020 +0800

[flink] 19/21: [FLINK-19384][core] Add common permissive exception signatures to all methods of Source.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit abe4c4b6995cf5cefcc2384937d25f62dd6d492c Author: Stephan Ewen AuthorDate: Wed Nov 4 15:48:19 2020 +0100 [FLINK-

[flink] 17/21: Backport of "[FLINK-19698][connector/common] Let SplitEnumerator/SourceReader/SourceCoordinator implement CheckpointListener."

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 5f63e346d2bdb3f2d5de341e2de880c07ca81c16 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 10:07:16 2020 +0800

[flink] 07/21: [FLINK-19457][core] Add a number sequence generating source for the FLIP-27 source API.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 09ea814090eca8f0084b3a07add6cb3595705e47 Author: Stephan Ewen AuthorDate: Wed Sep 23 18:10:34 2020 +0200 [FLINK

[flink] 18/21: [FLINK-19698][connector/common] Add a close() method to the SplitReader.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2a775894dc2144af9b6d7361a06d15afedb5945f Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 11:07:27 2020 +0800

[flink] 21/21: [refactor][DataStream API] Make DataStreamUtils.collect() methods more flexible.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 1a8ff89466b1f13e1f624c4046ed7f5db8212e6d Author: Stephan Ewen AuthorDate: Wed Sep 2 15:23:27 2020 +0200 [refact

[flink] 20/21: [build] Add exclusions for added default methods in SourceReader and SplitEnumerator interfaces.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9cb241958e8c7f0e13ba856b0cbeb1419d296cd3 Author: Stephan Ewen AuthorDate: Sun Nov 15 23:22:38 2020 +0100 [build

[flink] branch release-1.11 updated: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable (#14072)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber 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 bc9f0fc [FLINK-16753][checkpointing

[flink] 04/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Fix and add test coverage for watermarks gauges with chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit c7d2b4f3d222d64edc36ddfdb5838ba9eeed23b7 Author: Piotr Nowojski AuthorDate: Mon Sep 21 18:17:20 2020 +0200 [bac

[flink] 06/21: [refactor][tests] Move some source test utils from flink-connector-base to flink-core

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9c558bc81109e4c1116b6f1ad44d2abc29e095bb Author: Stephan Ewen AuthorDate: Tue Sep 29 22:25:37 2020 +0200 [refac

[flink] 01/21: [backport] Backport some core changes that were part of the FLIP-27 File Source commit

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit c54b12ba3bd427e3597a4b81cf9dc3cc99342caa Author: Stephan Ewen AuthorDate: Mon Jun 29 11:00:59 2020 +0200 [backp

[flink] branch release-1.11 updated: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable (#14072)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber 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 bc9f0fc [FLINK-16753][checkpointing

[flink] 05/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Add stream status forwarding test for chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit bb234caa97eb49c341bb00831bb4e8e1e61b366a Author: Piotr Nowojski AuthorDate: Tue Sep 22 14:14:52 2020 +0200 [bac

[flink] branch release-1.11 updated (bc9f0fc -> ae23ab6)

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from bc9f0fc [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunn

[flink] 03/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Add test coverage for watermarks with chained sources"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 21283ee197d485352f1d9fcee0e889e6e0d3ecb2 Author: Piotr Nowojski AuthorDate: Mon Sep 21 15:18:25 2020 +0200 [bac

[flink] 11/21: [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext. (#12647)

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 1131e0582b5a50d48ae64cb2120e304b2aac9bcb Author: fangliang <568693...@qq.com> AuthorDate: Wed Oct 28 09:08:38 2020 +0

[flink] 08/21: [FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 99e9a90ba3c7cf54f3983f942ba8cc3edb2804d2 Author: Stephan Ewen AuthorDate: Fri Oct 2 13:49:38 2020 +0200 [FLINK-

[flink] 18/21: [FLINK-19698][connector/common] Add a close() method to the SplitReader.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2d074715a13a1a638ddd2a7dd138ae94d0ca04f8 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 11:07:27 2020 +0800

[flink] 10/21: [FLINK-19427][FLINK-19489][tests] Fix test conditions for 'SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent()'

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 253ffd2aaa1b91e9c840d58735d6f8b3c61cc19a Author: Stephan Ewen AuthorDate: Mon Oct 12 13:43:57 2020 +0200 [FLINK

[flink] 09/21: [FLINK-19448][connector base] Explicitly check for un-expected condition that would leave an inconsistent state

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit e4e0f2320489882d4445ebda40dd7c5638f2ca95 Author: Stephan Ewen AuthorDate: Mon Oct 12 17:38:30 2020 +0200 [FLINK

[flink] 13/21: [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 37ccdbe67ccb4e9d568f06214314a9afd9dae379 Author: sxnan AuthorDate: Wed Aug 5 13:00:36 2020 +0800 [FLINK-18820]

[flink] 17/21: Backport of "[FLINK-19698][connector/common] Let SplitEnumerator/SourceReader/SourceCoordinator implement CheckpointListener."

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9dce8f0dcf68492240933a74dbce760ae25ce07f Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 10:07:16 2020 +0800

[flink] 02/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Refactor MockSourceReader"

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit b0bfe8b044d3414138be784e710f68bc3f998f6e Author: Piotr Nowojski AuthorDate: Tue Sep 22 11:43:58 2020 +0200 [bac

[flink] 07/21: [FLINK-19457][core] Add a number sequence generating source for the FLIP-27 source API.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 0f7ff28c4109654e49cd11ab380bf5756e2bc497 Author: Stephan Ewen AuthorDate: Wed Sep 23 18:10:34 2020 +0200 [FLINK

[flink] 14/21: [hotfix] Replace finally block with JUnit After method in SourceOperatorTest.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 1be08c1401f5e9a94e3ee6b861d1d1e168b519a1 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 18:04:19 2020 +0800

[flink] 12/21: [hotfix][runtime] Remove commented-out annotation in SourceOperator

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit dffc12455a4f2a35265e8ca64634b3c16ee193e2 Author: Stephan Ewen AuthorDate: Mon Sep 21 18:09:43 2020 +0200 [hotfi

[flink] 19/21: [FLINK-19384][core] Add common permissive exception signatures to all methods of Source.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 216f469f821ee61fc48c2df86364c5e54d0aaa94 Author: Stephan Ewen AuthorDate: Wed Nov 4 15:48:19 2020 +0100 [FLINK-

[flink] 15/21: [hotfix] Only close the SourceReader and EventTimeLogic in the SourceOperator if they are not null.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 83e3613fdf85cb7b774724b68df9acd1ff392110 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 18:12:34 2020 +0800

[flink] 21/21: [refactor][DataStream API] Make DataStreamUtils.collect() methods more flexible.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit ae23ab6c9afa6707f8fe3472ac4caa286e875ef7 Author: Stephan Ewen AuthorDate: Wed Sep 2 15:23:27 2020 +0200 [refact

[flink] 16/21: [hotfix] Add a waitUntil() method to the CommonTestUtils.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4d413dffeae0fb4076c4305396e1c32629395e74 Author: Jiangjie (Becket) Qin AuthorDate: Sun Oct 25 20:02:35 2020 +0800

[flink] 20/21: [build] Add exclusions for added default methods in SourceReader and SplitEnumerator interfaces.

2020-11-16 Thread sewen
This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2b4d69d85971cb9e42a29427e1bcf0889c2cbbcb Author: Stephan Ewen AuthorDate: Sun Nov 15 23:22:38 2020 +0100 [build

[flink] branch release-1.10 updated (10f155e -> a14665d)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed

[flink] branch release-1.11 updated (c24185d -> bc9f0fc)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from c24185d [hotfix] Adjust japicmp exclusion to permit adding methods to SourceReaderContext and SplitEnumerator

[flink] branch release-1.10 updated (10f155e -> a14665d)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed

[flink] branch release-1.11 updated (c24185d -> bc9f0fc)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from c24185d [hotfix] Adjust japicmp exclusion to permit adding methods to SourceReaderContext and SplitEnumerator

[flink] branch release-1.10 updated (10f155e -> a14665d)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed

[flink] branch release-1.11 updated (c24185d -> bc9f0fc)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from c24185d [hotfix] Adjust japicmp exclusion to permit adding methods to SourceReaderContext and SplitEnumerator

[flink] branch release-1.10 updated (10f155e -> a14665d)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed

[flink] branch release-1.10 updated (10f155e -> a14665d)

2020-11-16 Thread nkruber
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git. from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed

[flink] branch master updated (f3f5e31 -> 432de2b)

2020-11-16 Thread trohrmann
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 f3f5e31 Revert "[FLINK-20098] Don't add flink-connector-files to flink-dist" add 432de2b [FLINK-20156] Corr

[flink] branch master updated (f3f5e31 -> 432de2b)

2020-11-16 Thread trohrmann
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 f3f5e31 Revert "[FLINK-20098] Don't add flink-connector-files to flink-dist" add 432de2b [FLINK-20156] Corr

[flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

2020-11-16 Thread trohrmann
This is an automated email from the ASF dual-hosted git repository. trohrmann 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 76564b7 [FLINK-20156] Correct Jav

[flink] branch master updated (f3f5e31 -> 432de2b)

2020-11-16 Thread trohrmann
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 f3f5e31 Revert "[FLINK-20098] Don't add flink-connector-files to flink-dist" add 432de2b [FLINK-20156] Corr

[flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

2020-11-16 Thread trohrmann
This is an automated email from the ASF dual-hosted git repository. trohrmann 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 76564b7 [FLINK-20156] Correct Jav

[flink] branch master updated (f3f5e31 -> 432de2b)

2020-11-16 Thread trohrmann
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 f3f5e31 Revert "[FLINK-20098] Don't add flink-connector-files to flink-dist" add 432de2b [FLINK-20156] Corr

[flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

2020-11-16 Thread trohrmann
This is an automated email from the ASF dual-hosted git repository. trohrmann 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 76564b7 [FLINK-20156] Correct Jav

[flink] branch master updated (f3f5e31 -> 432de2b)

2020-11-16 Thread trohrmann
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 f3f5e31 Revert "[FLINK-20098] Don't add flink-connector-files to flink-dist" add 432de2b [FLINK-20156] Corr

[flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

2020-11-16 Thread trohrmann
This is an automated email from the ASF dual-hosted git repository. trohrmann 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 76564b7 [FLINK-20156] Correct Jav

[flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner

2020-11-16 Thread trohrmann
This is an automated email from the ASF dual-hosted git repository. trohrmann 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 76564b7 [FLINK-20156] Correct Jav

[flink] branch master updated (432de2b -> 4a6ce27)

2020-11-16 Thread trohrmann
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 432de2b [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner add 4a6ce27 [

[flink] branch master updated (432de2b -> 4a6ce27)

2020-11-16 Thread trohrmann
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 432de2b [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner add 4a6ce27 [

[flink] branch master updated (432de2b -> 4a6ce27)

2020-11-16 Thread trohrmann
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 432de2b [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner add 4a6ce27 [

[flink] branch master updated (432de2b -> 4a6ce27)

2020-11-16 Thread trohrmann
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 432de2b [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner add 4a6ce27 [

[flink] branch master updated (432de2b -> 4a6ce27)

2020-11-16 Thread trohrmann
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 432de2b [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner add 4a6ce27 [

[flink] branch master updated (4a6ce27 -> 4e74e08)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4a6ce27 [FLINK-19546][doc] Add documentation for native Kubernetes HA add 4e74e08 [FLINK-20152] Document supp

[flink] branch master updated (4a6ce27 -> 4e74e08)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4a6ce27 [FLINK-19546][doc] Add documentation for native Kubernetes HA add 4e74e08 [FLINK-20152] Document supp

[flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas 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 a830791 [FLINK-20152] Document sup

[flink] branch master updated (4a6ce27 -> 4e74e08)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4a6ce27 [FLINK-19546][doc] Add documentation for native Kubernetes HA add 4e74e08 [FLINK-20152] Document supp

[flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas 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 a830791 [FLINK-20152] Document sup

[flink] branch master updated (4a6ce27 -> 4e74e08)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4a6ce27 [FLINK-19546][doc] Add documentation for native Kubernetes HA add 4e74e08 [FLINK-20152] Document supp

[flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas 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 a830791 [FLINK-20152] Document sup

[flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas 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 a830791 [FLINK-20152] Document sup

[flink] branch master updated (4a6ce27 -> 4e74e08)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4a6ce27 [FLINK-19546][doc] Add documentation for native Kubernetes HA add 4e74e08 [FLINK-20152] Document supp

[flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas 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 a830791 [FLINK-20152] Document sup

[flink] branch master updated (4e74e08 -> 30ae028)

2020-11-16 Thread rmetzger
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4e74e08 [FLINK-20152] Document supported execution.target values add 30ae028 [FLINK-17470] Send sigkill to ha

[flink] branch master updated (4e74e08 -> 30ae028)

2020-11-16 Thread rmetzger
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4e74e08 [FLINK-20152] Document supported execution.target values add 30ae028 [FLINK-17470] Send sigkill to ha

[flink] branch master updated (4e74e08 -> 30ae028)

2020-11-16 Thread rmetzger
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4e74e08 [FLINK-20152] Document supported execution.target values add 30ae028 [FLINK-17470] Send sigkill to ha

[flink] branch master updated (4e74e08 -> 30ae028)

2020-11-16 Thread rmetzger
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4e74e08 [FLINK-20152] Document supported execution.target values add 30ae028 [FLINK-17470] Send sigkill to ha

[flink] branch master updated (4e74e08 -> 30ae028)

2020-11-16 Thread rmetzger
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4e74e08 [FLINK-20152] Document supported execution.target values add 30ae028 [FLINK-17470] Send sigkill to ha

[flink] branch master updated (30ae028 -> d72866b)

2020-11-16 Thread trohrmann
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 30ae028 [FLINK-17470] Send sigkill to hanging processes in standalone scripts add d72866b [FLINK-20021][doc

[flink] branch master updated (30ae028 -> d72866b)

2020-11-16 Thread trohrmann
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 30ae028 [FLINK-17470] Send sigkill to hanging processes in standalone scripts add d72866b [FLINK-20021][doc

[flink] branch master updated (30ae028 -> d72866b)

2020-11-16 Thread trohrmann
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 30ae028 [FLINK-17470] Send sigkill to hanging processes in standalone scripts add d72866b [FLINK-20021][doc

[flink] branch master updated (30ae028 -> d72866b)

2020-11-16 Thread trohrmann
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 30ae028 [FLINK-17470] Send sigkill to hanging processes in standalone scripts add d72866b [FLINK-20021][doc

[flink] branch master updated (30ae028 -> d72866b)

2020-11-16 Thread trohrmann
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 30ae028 [FLINK-17470] Send sigkill to hanging processes in standalone scripts add d72866b [FLINK-20021][doc

[flink] branch master updated (d72866b -> e4f525e)

2020-11-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 d72866b [FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager add 230fab4 [hotfix][network] Remove redund

[flink] branch master updated (d72866b -> e4f525e)

2020-11-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 d72866b [FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager add 230fab4 [hotfix][network] Remove redund

[flink] branch master updated (d72866b -> e4f525e)

2020-11-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 d72866b [FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager add 230fab4 [hotfix][network] Remove redund

[flink] branch master updated (d72866b -> e4f525e)

2020-11-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 d72866b [FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager add 230fab4 [hotfix][network] Remove redund

[flink] branch master updated (d72866b -> e4f525e)

2020-11-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 d72866b [FLINK-20021][docs] Cleanup misuses of Dispatcher/JobManager add 230fab4 [hotfix][network] Remove redund

[flink] branch master updated (e4f525e -> 13e0648)

2020-11-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.git. from e4f525e [FLINK-19983][network] Release all buffers when releasing the SortMergeSubpartitionReader add 13e064

[flink] branch master updated (e4f525e -> 13e0648)

2020-11-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.git. from e4f525e [FLINK-19983][network] Release all buffers when releasing the SortMergeSubpartitionReader add 13e064

[flink] branch master updated (e4f525e -> 13e0648)

2020-11-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.git. from e4f525e [FLINK-19983][network] Release all buffers when releasing the SortMergeSubpartitionReader add 13e064

[flink] branch master updated (e4f525e -> 13e0648)

2020-11-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.git. from e4f525e [FLINK-19983][network] Release all buffers when releasing the SortMergeSubpartitionReader add 13e064

[flink] branch master updated (e4f525e -> 13e0648)

2020-11-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.git. from e4f525e [FLINK-19983][network] Release all buffers when releasing the SortMergeSubpartitionReader add 13e064

[flink] branch master updated (5f2942a -> 958fc80)

2020-11-16 Thread kkloudas
This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 5f2942a [FLINK-20022] Add link from production readiness checklist to state backends page add 2162fc2 [FLINK

  1   2   >