[flink] branch master updated (09386f2 -> 64b9665)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09386f2 [FLINK-19644][hive] Support read latest partition of Hive table in temporal join add fe9313e [hotfix]

[flink] branch master updated (09386f2 -> 64b9665)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09386f2 [FLINK-19644][hive] Support read latest partition of Hive table in temporal join add fe9313e [hotfix]

[flink] branch master updated (09386f2 -> 64b9665)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09386f2 [FLINK-19644][hive] Support read latest partition of Hive table in temporal join add fe9313e [hotfix]

[flink] branch master updated (09386f2 -> 64b9665)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09386f2 [FLINK-19644][hive] Support read latest partition of Hive table in temporal join add fe9313e [hotfix]

[flink] branch master updated (09386f2 -> 64b9665)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09386f2 [FLINK-19644][hive] Support read latest partition of Hive table in temporal join add fe9313e [hotfix]

[flink] branch master updated (64b9665 -> f850f55)

2020-11-07 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 64b9665 [FLINK-19276][json][connector-kafka] Support reading Debezium metadata add f850f55 [FLINK-19823]

[flink] branch master updated (64b9665 -> f850f55)

2020-11-07 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 64b9665 [FLINK-19276][json][connector-kafka] Support reading Debezium metadata add f850f55 [FLINK-19823]

[flink] branch master updated (64b9665 -> f850f55)

2020-11-07 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 64b9665 [FLINK-19276][json][connector-kafka] Support reading Debezium metadata add f850f55 [FLINK-19823]

[flink] branch master updated (64b9665 -> f850f55)

2020-11-07 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 64b9665 [FLINK-19276][json][connector-kafka] Support reading Debezium metadata add f850f55 [FLINK-19823]

[flink] branch master updated (f850f55 -> 0ccea43)

2020-11-07 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 f850f55 [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema add 0ccea43

[flink] branch master updated (f850f55 -> 0ccea43)

2020-11-07 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 f850f55 [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema add 0ccea43

[flink] branch master updated (0ccea43 -> efa4d18)

2020-11-07 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 0ccea43 [FLINK-19963] Allow SinkWriter use processing timer service. add efa4d18 [minor][python] Minor code cle

[flink] branch master updated (0ccea43 -> efa4d18)

2020-11-07 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 0ccea43 [FLINK-19963] Allow SinkWriter use processing timer service. add efa4d18 [minor][python] Minor code cle

[flink] branch master updated (0ccea43 -> efa4d18)

2020-11-07 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 0ccea43 [FLINK-19963] Allow SinkWriter use processing timer service. add efa4d18 [minor][python] Minor code cle

[flink] branch master updated (0ccea43 -> efa4d18)

2020-11-07 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 0ccea43 [FLINK-19963] Allow SinkWriter use processing timer service. add efa4d18 [minor][python] Minor code cle

[flink] branch master updated (efa4d18 -> c619a18)

2020-11-07 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 efa4d18 [minor][python] Minor code cleanup add c619a18 [FLINK-19510][sink][fs] Support processing time polici

[flink] branch master updated (efa4d18 -> c619a18)

2020-11-07 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 efa4d18 [minor][python] Minor code cleanup add c619a18 [FLINK-19510][sink][fs] Support processing time polici

[flink] branch master updated (efa4d18 -> c619a18)

2020-11-07 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 efa4d18 [minor][python] Minor code cleanup add c619a18 [FLINK-19510][sink][fs] Support processing time polici

[flink] branch master updated (efa4d18 -> c619a18)

2020-11-07 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 efa4d18 [minor][python] Minor code cleanup add c619a18 [FLINK-19510][sink][fs] Support processing time polici

[flink] branch master updated (efa4d18 -> c619a18)

2020-11-07 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 efa4d18 [minor][python] Minor code cleanup add c619a18 [FLINK-19510][sink][fs] Support processing time polici

[flink] branch master updated (c619a18 -> 9d435f4)

2020-11-07 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 c619a18 [FLINK-19510][sink][fs] Support processing time policicies in FileSink add 6dc5a13 [FLINK-20008] Cl

[flink] branch master updated (c619a18 -> 9d435f4)

2020-11-07 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 c619a18 [FLINK-19510][sink][fs] Support processing time policicies in FileSink add 6dc5a13 [FLINK-20008] Cl

[flink] branch master updated (c619a18 -> 9d435f4)

2020-11-07 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 c619a18 [FLINK-19510][sink][fs] Support processing time policicies in FileSink add 6dc5a13 [FLINK-20008] Cl

[flink] branch master updated (c619a18 -> 9d435f4)

2020-11-07 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 c619a18 [FLINK-19510][sink][fs] Support processing time policicies in FileSink add 6dc5a13 [FLINK-20008] Cl

[flink] branch master updated (c619a18 -> 9d435f4)

2020-11-07 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 c619a18 [FLINK-19510][sink][fs] Support processing time policicies in FileSink add 6dc5a13 [FLINK-20008] Cl

[flink] branch master updated (9d435f4 -> 23349b6)

2020-11-07 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 9d435f4 [FLINK-20008] Move leaderRetrievalDriver.close out of lock scope in DefaultLeaderRetrievalService.close

[flink] branch master updated (9d435f4 -> 23349b6)

2020-11-07 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 9d435f4 [FLINK-20008] Move leaderRetrievalDriver.close out of lock scope in DefaultLeaderRetrievalService.close

[flink] branch master updated (23349b6 -> 5f7e0dc)

2020-11-07 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 23349b6 [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions add d1f1865 [hotfi

[flink] branch master updated (23349b6 -> 5f7e0dc)

2020-11-07 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 23349b6 [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions add d1f1865 [hotfi

[flink] branch master updated (23349b6 -> 5f7e0dc)

2020-11-07 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 23349b6 [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions add d1f1865 [hotfi

[flink] branch master updated (23349b6 -> 5f7e0dc)

2020-11-07 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 23349b6 [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions add d1f1865 [hotfi

[flink] branch master updated (5f7e0dc -> dc56273)

2020-11-07 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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API add 653bc10 [hotfix

[flink] branch master updated (23349b6 -> 5f7e0dc)

2020-11-07 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 23349b6 [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions add d1f1865 [hotfi

[flink] branch master updated (5f7e0dc -> dc56273)

2020-11-07 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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API add 653bc10 [hotfix

[flink] branch master updated (5f7e0dc -> dc56273)

2020-11-07 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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API add 653bc10 [hotfix

[flink] branch master updated (5f7e0dc -> dc56273)

2020-11-07 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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API add 653bc10 [hotfix

[flink] branch master updated (5f7e0dc -> dc56273)

2020-11-07 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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry based Kubernetes API add 653bc10 [hotfix

[flink] branch master updated (dc56273 -> c037dcb)

2020-11-07 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 dc56273 [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API add c037dcb [FLINK

[flink] branch master updated (dc56273 -> c037dcb)

2020-11-07 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 dc56273 [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API add c037dcb [FLINK

[flink] branch master updated (c037dcb -> 05b56bd)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c037dcb [FLINK-20002] Add a StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method add 05b56

[flink] branch master updated (c037dcb -> 05b56bd)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c037dcb [FLINK-20002] Add a StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method add 05b56

[flink] branch master updated (c037dcb -> 05b56bd)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c037dcb [FLINK-20002] Add a StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method add 05b56

[flink] branch master updated: [minor] Rework Javadoc in Sink interface

2020-11-07 Thread aljoscha
This is an automated email from the ASF dual-hosted git repository. aljoscha 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 97eb584 [minor] Rework Javadoc in Sink interfa

[flink] branch master updated: [minor] Rework Javadoc in Sink interface

2020-11-07 Thread aljoscha
This is an automated email from the ASF dual-hosted git repository. aljoscha 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 97eb584 [minor] Rework Javadoc in Sink interfa

[flink] branch master updated (97eb584 -> 8efa521)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 97eb584 [minor] Rework Javadoc in Sink interface add eb96cb2 [hotfix][table-common] Improve SupportsPartitioni

[flink] branch master updated (97eb584 -> 8efa521)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 97eb584 [minor] Rework Javadoc in Sink interface add eb96cb2 [hotfix][table-common] Improve SupportsPartitioni

[flink] branch master updated (97eb584 -> 8efa521)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 97eb584 [minor] Rework Javadoc in Sink interface add eb96cb2 [hotfix][table-common] Improve SupportsPartitioni

[flink] branch master updated (97eb584 -> 8efa521)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 97eb584 [minor] Rework Javadoc in Sink interface add eb96cb2 [hotfix][table-common] Improve SupportsPartitioni

[flink] branch master updated (97eb584 -> 8efa521)

2020-11-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 97eb584 [minor] Rework Javadoc in Sink interface add eb96cb2 [hotfix][table-common] Improve SupportsPartitioni

[flink] branch master updated (8efa521 -> 24d612b)

2020-11-07 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 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage add 24d612b [FLINK-20041][kafka] Support watermark

[flink] branch master updated (8efa521 -> 24d612b)

2020-11-07 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 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage add 24d612b [FLINK-20041][kafka] Support watermark

[flink] branch master updated (8efa521 -> 24d612b)

2020-11-07 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 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage add 24d612b [FLINK-20041][kafka] Support watermark

[flink] branch master updated (8efa521 -> 24d612b)

2020-11-07 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 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage add 24d612b [FLINK-20041][kafka] Support watermark

[flink] branch master updated (24d612b -> eeb69fc)

2020-11-07 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 24d612b [FLINK-20041][kafka] Support watermark push down for kafka source add eeb69fc [FLINK-20037][table-api] F

[flink] branch master updated (24d612b -> eeb69fc)

2020-11-07 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 24d612b [FLINK-20041][kafka] Support watermark push down for kafka source add eeb69fc [FLINK-20037][table-api] F

[flink] branch master updated (24d612b -> eeb69fc)

2020-11-07 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 24d612b [FLINK-20041][kafka] Support watermark push down for kafka source add eeb69fc [FLINK-20037][table-api] F

[flink] branch master updated (eeb69fc -> 8317426)

2020-11-07 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 eeb69fc [FLINK-20037][table-api] Fix the Javadoc of TableEnvironment#fromValues(AbstractDataType, Object...)

[flink] branch master updated (eeb69fc -> 8317426)

2020-11-07 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 eeb69fc [FLINK-20037][table-api] Fix the Javadoc of TableEnvironment#fromValues(AbstractDataType, Object...)

[flink] branch master updated (eeb69fc -> 8317426)

2020-11-07 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 eeb69fc [FLINK-20037][table-api] Fix the Javadoc of TableEnvironment#fromValues(AbstractDataType, Object...)

[flink] branch master updated (eeb69fc -> 8317426)

2020-11-07 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 eeb69fc [FLINK-20037][table-api] Fix the Javadoc of TableEnvironment#fromValues(AbstractDataType, Object...)