Commits

Branch selector

 6ad365c

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 28, 2020

• [FLINK-20651] Move checkstyle ignores to suppressions.xml

  Show description for 6ad365c
  

  aljoscha

  authored and

  zentol

  committed
  6ad365c

  Copy full SHA for 6ad365c

• [refactor] Use tabs in checkstyle.xml to conform to our other XML files

  

  aljoscha

  authored and

  zentol

  committed
  7ed6cbe

  Copy full SHA for 7ed6cbe

• [hotfix] Fix incorrect license headers

  

  aljoscha

  authored and

  zentol

  committed
  d7dae84

  Copy full SHA for d7dae84

• [hotfix][docs][checkpointing] Fix and sync example code

  atealxt

  authored
  8fc6eae

  Copy full SHA for 8fc6eae

• [hotfix][docs] Fix typo

  sv3ndk

  authored
  441fc5d

  Copy full SHA for 441fc5d

• [hotfix][docs] Fix typo

  Sunt-ing

  authored
  fdb6b98

  Copy full SHA for fdb6b98

• [FLINK-20259][web] Add explanation to Effective Configuration in JM/TM

  

  vthinkxie

  authored and

  zentol

  committed
  a914581

  Copy full SHA for a914581

• [FLINK-20756][python] Fix the bug that it doesn't support field access of expression containing Python UDF in the condition of Calc

  Show description for 7d6715c
  

  HuangXingBo

  authored and

  dianfu

  committed
  7d6715c

  Copy full SHA for 7d6715c

• [FLINK-20540][jdbc] Fix JdbcCatalog connection exception when baseUrl doesn't end with slash

  Show description for 8da64d7
  

  kougazhang

  and

  zhao.zhang

  authored
  8da64d7

  Copy full SHA for 8da64d7

• [FLINK-20620][table-planner-blink][python] Port BatchExecPythonCalc and StreamExecPythonCalc to Java

  Show description for 2848d4d
  

  HuangXingBo

  authored and

  dianfu

  committed
  2848d4d

  Copy full SHA for 2848d4d

• [FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept table function directly

  Show description for 7ea384b
  

  HuangXingBo

  authored and

  dianfu

  committed
  7ea384b

  Copy full SHA for 7ea384b

Commits on Dec 27, 2020

• [FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishment

  Show description for 0c36b66
  kezhuw

  authored
  0c36b66

  Copy full SHA for 0c36b66

• [FLINK-19650][jdbc][table] Support limit push down for the JDBC connector

  Show description for a859e2c
  fsk119

  authored
  a859e2c

  Copy full SHA for a859e2c

Commits on Dec 25, 2020

• [FLINK-20736][table-planner-blink] Introduce StreamPhysicalRank & StreamPhysicalLimit, and make StreamExecRank & StreamExeLimit only extended from ExecNode

  Show description for a25b9b8
  

  龙三

  authored and

  godfreyhe

  committed
  a25b9b8

  Copy full SHA for a25b9b8

• [FLINK-20736][table-planner-blink] Introduce BatchPhysicalLimit, and make BatchExecLimit only extended from ExecNode

  Show description for 677d392
  

  龙三

  authored and

  godfreyhe

  committed
  677d392

  Copy full SHA for 677d392

• [FLINK-20706][table-planner-blink] Introduce BatchPhysicalUnion, and make BatchExecUnion only extended from ExecNode

  Show description for f3d03eb
  godfreyhe

  committed
  f3d03eb

  Copy full SHA for f3d03eb

• [FLINK-20706][table-planner-blink] Introduce StreamPhysicalUnion, and make StreamExecUnion only extended from ExecNode

  Show description for 4f323ba
  godfreyhe

  committed
  4f323ba

  Copy full SHA for 4f323ba

• [FLINK-20702][python] Support map operation chained together in Python Table API

  Show description for febce35
  

  HuangXingBo

  authored and

  dianfu

  committed
  febce35

  Copy full SHA for febce35

• [FLINK-20764] In BatchGroupedReduceOperator, fix timer logic

  Show description for b474d28
  

  aljoscha

  authored and

  xintongsong

  committed
  b474d28

  Copy full SHA for b474d28

• [FLINK-20664][k8s][doc] Update RBAC section in native kubernetes document

  Show description for 4e5448c
  

  wangyang0918

  authored and

  xintongsong

  committed
  4e5448c

  Copy full SHA for 4e5448c

• [FLINK-20664][k8s] Support setting service account for TaskManager pod.

  

  blublinsky

  authored and

  xintongsong

  committed
  fb4286f

  Copy full SHA for fb4286f

• [FLINK-20642][python] Introduce InternalRow to optimize the performance of Python UDAF

  Show description for 3b8998d
  

  HuangXingBo

  authored and

  dianfu

  committed
  3b8998d

  Copy full SHA for 3b8998d

• [FLINK-20710][hive] Hive reading fail when splits on different FileSystem nameservices

  Show description for 5ffcfca
  JackWangCS

  authored
  5ffcfca

  Copy full SHA for 5ffcfca

• [FLINK-19691][jdbc] Support connection.max-retry-timeout configuration for JDBC connector

  Show description for f5e829c
  

  肖佳文

  authored and

  wuchong

  committed
  f5e829c

  Copy full SHA for f5e829c

• [FLINK-20552][jdbc] JdbcDynamicTableSink doesn't sink buffered data on checkpoint

  Show description for 21a08ea
  

  meijies

  authored and

  wuchong

  committed
  21a08ea

  Copy full SHA for 21a08ea

• [FLINK-20648][k8s] Add itcase for recovering from savepoint with Kubernetes HA enabled

  Show description for 2c92ea9
  

  wangyang0918

  authored and

  xintongsong

  committed
  2c92ea9

  Copy full SHA for 2c92ea9

Commits on Dec 24, 2020

• [hotfix][docs] Fix the broken link in Kafka SQL connector page

  wuchong

  committed
  fd8180a

  Copy full SHA for fd8180a

• [FLINK-18382][docs-zh] Translate Kafka SQL connector documentation into Chinese

  Show description for 52ddd9b
  PatrickRen

  authored
  52ddd9b

  Copy full SHA for 52ddd9b

• [FLINK-20709][table-planner-blink] Introduce StreamPhysicalMiniBatchAssigner, and make StreamExecMiniBatchAssigner only extended from ExecNode

  Show description for 8da6052
  godfreyhe

  authored
  8da6052

  Copy full SHA for 8da6052

• [FLINK-20708][table-planner-blink] Introduce StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only extended from ExecNode

  Show description for 2eb84aa
  godfreyhe

  authored
  2eb84aa

  Copy full SHA for 2eb84aa

• [FLINK-20707][table-planner-blink] Introduce BatchPhysicalExpand, and make BatchExecExpand only extended from ExecNode

  Show description for 4fbffb6
  godfreyhe

  committed
  4fbffb6

  Copy full SHA for 4fbffb6

• [FLINK-20707][table-planner-blink] Introduce StreamPhysicalExpand, and make StreamExecExpand only extended from ExecNode

  Show description for 0287560
  godfreyhe

  committed
  0287560

  Copy full SHA for 0287560

• [FLINK-20705][table-planner-blink] Introduce BatchPhysicalValues, and make BatchExecValues only extended from ExecNode

  Show description for f44b383
  godfreyhe

  committed
  f44b383

  Copy full SHA for f44b383

• [FLINK-20705][table-planner-blink] Introduce StreamPhysicalValues, and make StreamExecValues only extended from ExecNode

  Show description for acbda63
  godfreyhe

  committed
  acbda63

  Copy full SHA for acbda63

• [FLINK-20745][table] Clean useless codes: Never push calcProgram to correlate

  Show description for 110a044
  JingsongLi

  authored
  110a044

  Copy full SHA for 110a044

Pagination

Previous

Next