[flink] branch master updated (a2eb2c1 -> 2145610)

2020-11-03 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 a2eb2c1 [FLINK-19891][table-planner-blink] ScalarOperatorGens should generate a not-null type for IS NULL and IS

[flink] branch release-1.11 updated: [FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark 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 be1aea7 [FLINK-19258][docs] Fix the

[flink] branch release-1.11 updated (4bf1f02 -> 0a38f73)

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4bf1f02 [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

[flink] branch release-1.11 updated (4bf1f02 -> 0a38f73)

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4bf1f02 [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

[flink] branch release-1.11 updated (4bf1f02 -> 0a38f73)

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4bf1f02 [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

[flink] branch release-1.11 updated (4bf1f02 -> 0a38f73)

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4bf1f02 [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

[flink] branch release-1.11 updated (4bf1f02 -> 0a38f73)

2020-11-03 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 4bf1f02 [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

[flink-statefun] branch master updated: [FLINK-19866] Move intialization logic to open() instead initializeState

2020-11-03 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 315718c [FLINK-19866] Move

[flink-statefun] branch release-2.2 updated: [FLINK-19866] Move intialization logic to open() instead initializeState

2020-11-03 Thread tzulitai
This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch release-2.2 in repository https://gitbox.apache.org/repos/asf/flink-statefun.git The following commit(s) were added to refs/heads/release-2.2 by this push: new 653393f [FLINK-19866] Move

[flink] branch master updated (9652b6d -> a2eb2c1)

2020-11-03 Thread lzljs3620320
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 9652b6d [FLINK-18325][table-sql-parser] Check null when calling SqlDataTypeSpec#getNullable add a2eb2c1

[flink] branch master updated (9652b6d -> a2eb2c1)

2020-11-03 Thread lzljs3620320
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 9652b6d [FLINK-18325][table-sql-parser] Check null when calling SqlDataTypeSpec#getNullable add a2eb2c1

[flink] branch master updated (9652b6d -> a2eb2c1)

2020-11-03 Thread lzljs3620320
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 9652b6d [FLINK-18325][table-sql-parser] Check null when calling SqlDataTypeSpec#getNullable add a2eb2c1

[flink] branch master updated (9652b6d -> a2eb2c1)

2020-11-03 Thread lzljs3620320
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 9652b6d [FLINK-18325][table-sql-parser] Check null when calling SqlDataTypeSpec#getNullable add a2eb2c1

[flink] branch master updated (9652b6d -> a2eb2c1)

2020-11-03 Thread lzljs3620320
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 9652b6d [FLINK-18325][table-sql-parser] Check null when calling SqlDataTypeSpec#getNullable add a2eb2c1

[flink] branch master updated (25701e1 -> 9652b6d)

2020-11-03 Thread jark
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 25701e1 [FLINK-19873][canal-json] Skip DDL change events for Canal data add 9652b6d

[flink] branch master updated (25701e1 -> 9652b6d)

2020-11-03 Thread jark
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 25701e1 [FLINK-19873][canal-json] Skip DDL change events for Canal data add 9652b6d

[flink] branch master updated (25701e1 -> 9652b6d)

2020-11-03 Thread jark
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 25701e1 [FLINK-19873][canal-json] Skip DDL change events for Canal data add 9652b6d

[flink] branch master updated (6c1b3b6 -> 25701e1)

2020-11-03 Thread jark
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 6c1b3b6 [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception add 25701e1

[flink] branch master updated (25701e1 -> 9652b6d)

2020-11-03 Thread jark
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 25701e1 [FLINK-19873][canal-json] Skip DDL change events for Canal data add 9652b6d

[flink] branch master updated (6c1b3b6 -> 25701e1)

2020-11-03 Thread jark
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 6c1b3b6 [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception add 25701e1

[flink] branch master updated (a5bb18a -> 6c1b3b6)

2020-11-03 Thread jark
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 a5bb18a [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW add

[flink] branch master updated (25701e1 -> 9652b6d)

2020-11-03 Thread jark
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 25701e1 [FLINK-19873][canal-json] Skip DDL change events for Canal data add 9652b6d

[flink] branch master updated (6c1b3b6 -> 25701e1)

2020-11-03 Thread jark
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 6c1b3b6 [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception add 25701e1

[flink] branch master updated (a5bb18a -> 6c1b3b6)

2020-11-03 Thread jark
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 a5bb18a [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW add

[flink] branch master updated (6c1b3b6 -> 25701e1)

2020-11-03 Thread jark
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 6c1b3b6 [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception add 25701e1

[flink] branch master updated (a5bb18a -> 6c1b3b6)

2020-11-03 Thread jark
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 a5bb18a [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW add

[flink] branch master updated (6c1b3b6 -> 25701e1)

2020-11-03 Thread jark
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 6c1b3b6 [FLINK-19948][table-planner-blink] Fix calling NOW() function throws compile exception add 25701e1

[flink] branch master updated (a5bb18a -> 6c1b3b6)

2020-11-03 Thread jark
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 a5bb18a [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW add

[flink] branch master updated (a5bb18a -> 6c1b3b6)

2020-11-03 Thread jark
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 a5bb18a [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW add

[flink] branch release-1.11 updated: [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

2020-11-03 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 4bf1f02 [FLINK-19138][python]

[flink] branch release-1.11 updated: [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

2020-11-03 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 4bf1f02 [FLINK-19138][python]

[flink] branch master updated (b868639 -> a5bb18a)

2020-11-03 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 b868639 [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

[flink] branch master updated (b868639 -> a5bb18a)

2020-11-03 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 b868639 [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

[flink] branch master updated (b868639 -> a5bb18a)

2020-11-03 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 b868639 [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

[flink] branch master updated: [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

2020-11-03 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 b868639 [FLINK-18716][python][docs] Remove the

[flink] branch master updated: [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

2020-11-03 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 b868639 [FLINK-18716][python][docs] Remove the

[flink] branch master updated (5b4a370 -> 3c613dd)

2020-11-03 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 5b4a370 [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode add 3c613dd

[flink] branch master updated (5b4a370 -> 3c613dd)

2020-11-03 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 5b4a370 [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode add 3c613dd

[flink] branch master updated (5b4a370 -> 3c613dd)

2020-11-03 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 5b4a370 [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode add 3c613dd

[flink] branch master updated (5b4a370 -> 3c613dd)

2020-11-03 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 5b4a370 [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode add 3c613dd

[flink] branch master updated (5b4a370 -> 3c613dd)

2020-11-03 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 5b4a370 [FLINK-19931] Do not emit intermediate results for reduce operation BATCH execution mode add 3c613dd

[flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 85fc5c1 [FLINK-19901][metrics] Fix

[flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 85fc5c1 [FLINK-19901][metrics] Fix

[flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 85fc5c1 [FLINK-19901][metrics] Fix

[flink] branch master updated (477d37d -> 5b4a370)

2020-11-03 Thread dwysakowicz
This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 477d37d [FLINK-19901][metrics] Fix caching offset for variables add 5468fab [hotfix] Add Operator suffix

[flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 85fc5c1 [FLINK-19901][metrics] Fix

[flink] branch master updated (477d37d -> 5b4a370)

2020-11-03 Thread dwysakowicz
This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 477d37d [FLINK-19901][metrics] Fix caching offset for variables add 5468fab [hotfix] Add Operator suffix

[flink] branch release-1.11 updated (8addf89 -> cdd537c)

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 8addf89 [FLINK-19907][network] Recover channel state before initializing operators chain add cdd537c

[flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 85fc5c1 [FLINK-19901][metrics] Fix

[flink] branch master updated (477d37d -> 5b4a370)

2020-11-03 Thread dwysakowicz
This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 477d37d [FLINK-19901][metrics] Fix caching offset for variables add 5468fab [hotfix] Add Operator suffix

[flink] branch release-1.11 updated (8addf89 -> cdd537c)

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 8addf89 [FLINK-19907][network] Recover channel state before initializing operators chain add cdd537c

[flink] branch master updated (477d37d -> 5b4a370)

2020-11-03 Thread dwysakowicz
This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 477d37d [FLINK-19901][metrics] Fix caching offset for variables add 5468fab [hotfix] Add Operator suffix

[flink] branch release-1.11 updated (8addf89 -> cdd537c)

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git. from 8addf89 [FLINK-19907][network] Recover channel state before initializing operators chain add cdd537c

[flink] branch master updated (477d37d -> 5b4a370)

2020-11-03 Thread dwysakowicz
This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 477d37d [FLINK-19901][metrics] Fix caching offset for variables add 5468fab [hotfix] Add Operator suffix

[flink] branch release-1.11 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 cdd537c [FLINK-19901][metrics] Fix

[flink] branch release-1.11 updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
This is an automated email from the ASF dual-hosted git repository. chesnay 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 cdd537c [FLINK-19901][metrics] Fix

[flink] branch master updated (6ed81d9 -> 477d37d)

2020-11-03 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 6ed81d9 [FLINK-19603][network] Introduce shuffle data compression to sort-merge based blocking shuffle add

[flink] branch master updated (6ed81d9 -> 477d37d)

2020-11-03 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 6ed81d9 [FLINK-19603][network] Introduce shuffle data compression to sort-merge based blocking shuffle add

[flink] branch master updated: [FLINK-19901][metrics] Fix caching offset for variables

2020-11-03 Thread chesnay
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 477d37d [FLINK-19901][metrics] Fix caching

[flink] 06/10: [FLINK-19597][network] Introduce SortBuffer and PartitionSortedBuffer for sort-merge based blocking shuffle

2020-11-03 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 7ea1168efa70470602f735a8c2d81ccf7aa14ba7 Author: kevin.cyj AuthorDate: Mon Oct 12 19:52:36 2020 +0800

[flink] 05/10: [FLINK-19804][connector files] Make FileSource class generic with respect to split types

2020-11-03 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 cb406d6a4c605fdccd7a44e80b2199cded4c9193 Author: Stephan Ewen AuthorDate: Sun Oct 25 23:12:55 2020 +0100

[flink] 10/10: [FLINK-19603][network] Introduce shuffle data compression to sort-merge based blocking shuffle

2020-11-03 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 6ed81d93d1972a6e76b5d7fe57595f20ae28d3bc Author: kevin.cyj AuthorDate: Mon Oct 12 21:01:58 2020 +0800

[flink] 07/10: [FLINK-19600][network] Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle

2020-11-03 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 1076da9c45a0cecdb8a95d51d03f1500b8a2dc90 Author: kevin.cyj AuthorDate: Mon Oct 12 20:13:34 2020 +0800

[flink] 09/10: [FLINK-19602][network] Introduce new config options to enable sort-merge based blocking shuffle

2020-11-03 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 11ba5b3b26e146d80e1319d77d1ee5ef2dd261d1 Author: kevin.cyj AuthorDate: Mon Oct 12 20:45:49 2020 +0800

[flink] 08/10: [FLINK-19601][network] Introduce sort-merge based blocking result partition SortMergeResultPartition and the corresponding subpartition reader

2020-11-03 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 99726825cf5f11989496f60647030a474ac5d233 Author: kevin.cyj AuthorDate: Mon Oct 12 20:35:18 2020 +0800

[flink] 03/10: [FLINK-19802][connector files] Let BulkFormat createReader and restoreReader methods accept Splits directly

2020-11-03 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 a2849b327635233d34686a9ab95cf3486ac08ae5 Author: Stephan Ewen AuthorDate: Sun Oct 25 20:00:26 2020 +0100

[flink] 04/10: [FLINK-19803][connector files] Make PendingSplitCheckpoint and its Serializer generic to support sub-classes of FileSourceSplit

2020-11-03 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 59055b55a0d384b92b7beb09f96c4ba08e9920b7 Author: Stephan Ewen AuthorDate: Sun Oct 25 21:47:16 2020 +0100

[flink] 02/10: [FLINK-19800][connector file] Make FileSourceSplit / FileSourceSplitState interaction extensible

2020-11-03 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 0e72b550a97df91ee7731f79df6051adb7d12a1f Author: Stephan Ewen AuthorDate: Sun Oct 25 15:09:11 2020 +0100

[flink] 01/10: [hotfix] Minor JavaDocs fixes for File Source classes.

2020-11-03 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 e2e14b2b1fe4ca31e975f3d9ef9e02f42326030c Author: Stephan Ewen AuthorDate: Sun Oct 25 19:23:58 2020 +0100 [hotfix]

[flink] branch master updated (a4d70ae -> 6ed81d9)

2020-11-03 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 a4d70ae [hotfix][coordination] Remove confusing 'Bulk' from test names in PhysicalSlotProviderImplTest new

[flink] branch master updated (1f40502 -> a4d70ae)

2020-11-03 Thread azagrebin
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 1f40502 [FLINK-19924][config] Add StreamConfig.isGraphContainingLoops add 86b3c71

[flink] branch master updated (1f40502 -> a4d70ae)

2020-11-03 Thread azagrebin
This is an automated email from the ASF dual-hosted git repository. azagrebin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 1f40502 [FLINK-19924][config] Add StreamConfig.isGraphContainingLoops add 86b3c71

[flink] branch master updated (d0458aa -> 1f40502)

2020-11-03 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 d0458aa [FLINK-19874][table-planner] Apply JoinDeriveNullFilterRule after join reorder add 13576c5

[flink] branch master updated (d0458aa -> 1f40502)

2020-11-03 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 d0458aa [FLINK-19874][table-planner] Apply JoinDeriveNullFilterRule after join reorder add 13576c5

[flink] branch master updated (d0458aa -> 1f40502)

2020-11-03 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 d0458aa [FLINK-19874][table-planner] Apply JoinDeriveNullFilterRule after join reorder add 13576c5

[flink] branch master updated (d0458aa -> 1f40502)

2020-11-03 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 d0458aa [FLINK-19874][table-planner] Apply JoinDeriveNullFilterRule after join reorder add 13576c5

[flink] branch release-1.11 updated: [FLINK-19907][network] Recover channel state before initializing operators chain

2020-11-03 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid 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 8addf89 [FLINK-19907][network]

[flink] branch release-1.11 updated: [FLINK-19907][network] Recover channel state before initializing operators chain

2020-11-03 Thread arvid
This is an automated email from the ASF dual-hosted git repository. arvid 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 8addf89 [FLINK-19907][network]

[flink] branch master updated (4d7c89fd -> d0458aa)

2020-11-03 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 4d7c89fd [FLINK-16522][python] Add support of type hints add d0458aa [FLINK-19874][table-planner] Apply

[flink] branch master updated (4d7c89fd -> d0458aa)

2020-11-03 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 4d7c89fd [FLINK-16522][python] Add support of type hints add d0458aa [FLINK-19874][table-planner] Apply

[flink] branch master updated (4d7c89fd -> d0458aa)

2020-11-03 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 4d7c89fd [FLINK-16522][python] Add support of type hints add d0458aa [FLINK-19874][table-planner] Apply

[flink] branch master updated (4d7c89fd -> d0458aa)

2020-11-03 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 4d7c89fd [FLINK-16522][python] Add support of type hints add d0458aa [FLINK-19874][table-planner] Apply

[flink] branch master updated (4d7c89fd -> d0458aa)

2020-11-03 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 4d7c89fd [FLINK-16522][python] Add support of type hints add d0458aa [FLINK-19874][table-planner] Apply

[flink] branch master updated (c715421 -> 4d7c89fd)

2020-11-03 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 c715421 [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner add 4d7c89fd

[flink] branch master updated (c715421 -> 4d7c89fd)

2020-11-03 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 c715421 [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner add 4d7c89fd

[flink] branch master updated (c715421 -> 4d7c89fd)

2020-11-03 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 c715421 [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner add 4d7c89fd

[flink] branch release-1.11 updated: [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner (#13899)

2020-11-03 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 5333fbf [FLINK-19740][python] Fix

[flink] branch master updated (c715421 -> 4d7c89fd)

2020-11-03 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 c715421 [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner add 4d7c89fd

[flink] branch release-1.11 updated: [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner (#13899)

2020-11-03 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 5333fbf [FLINK-19740][python] Fix

[flink] branch master updated (c715421 -> 4d7c89fd)

2020-11-03 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 c715421 [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner add 4d7c89fd

[flink] branch release-1.11 updated: [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner (#13899)

2020-11-03 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 5333fbf [FLINK-19740][python] Fix

[flink] branch release-1.11 updated: [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner (#13899)

2020-11-03 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 5333fbf [FLINK-19740][python] Fix

[flink] branch master updated (b45ee1f -> c715421)

2020-11-03 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 b45ee1f [FLINK-19831][coordination] Implement SlotManager#setFailUnfulfillableRequest add c715421

[flink] branch master updated (b45ee1f -> c715421)

2020-11-03 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 b45ee1f [FLINK-19831][coordination] Implement SlotManager#setFailUnfulfillableRequest add c715421

[flink] branch master updated (091c7fa -> b45ee1f)

2020-11-03 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 091c7fa [FLINK-15408][table-planner-blink] Interval join supports non-equal condition add b45ee1f

[flink] branch master updated (091c7fa -> b45ee1f)

2020-11-03 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 091c7fa [FLINK-15408][table-planner-blink] Interval join supports non-equal condition add b45ee1f

[flink] branch master updated (091c7fa -> b45ee1f)

2020-11-03 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 091c7fa [FLINK-15408][table-planner-blink] Interval join supports non-equal condition add b45ee1f

[flink] branch master updated (091c7fa -> b45ee1f)

2020-11-03 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 091c7fa [FLINK-15408][table-planner-blink] Interval join supports non-equal condition add b45ee1f

[flink] branch master updated (091c7fa -> b45ee1f)

2020-11-03 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 091c7fa [FLINK-15408][table-planner-blink] Interval join supports non-equal condition add b45ee1f

[flink-benchmarks] 02/02: [FLINK-19884] Add benchmarks for batch-style execution for bounded keyed streams

2020-11-03 Thread pnowojski
This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git commit 2df81781c55f145deb815591bec922a735e7dfa6 Author: Dawid Wysakowicz AuthorDate: Thu Oct 29 15:12:45 2020

  1   2   >