提交 · 679c974a24de55d5a12d1fa58cb679dd242098ba · doujutun3207 / flink

29 12月, 2020 1 次提交
- H
  [FLINK-20793][core] Fix the NamesTest and JarSubmissionITCase due to code style refactor · 679c974a
  由 huangxingbo 提交于 12月 29, 2020
```
This closes #14514.
```
  679c974a
28 12月, 2020 20 次提交
- P
  
  [hotfix] Update .git-blame-ignore-revs · 479d95f0
  由 Piotr Nowojski 提交于 12月 28, 2020
  
  479d95f0
- A
  
  [FLINK-20651] Add IDE instructions for google-java-format · 97bfd049
  由 Aljoscha Krettek 提交于 12月 16, 2020
  
  97bfd049
- A
  
  [FLINK-20651] Update .editorconfig to match google-java-format · 164e6d8e
  由 Aljoscha Krettek 提交于 12月 16, 2020
  
  164e6d8e
- A
  [FLINK-20651] Add .git-blame-ignore-revs for ignoring refactor commit · b8a17369
  由 Aljoscha Krettek 提交于 10月 09, 2020
```
This file can be used via:

$ git config blame.ignoreRevsFile .git-blame-ignore-revs
```
  b8a17369
- R
  
  [FLINK-20651] Format code with Spotless/google-java-format · c6997c97
  由 Rufus Refactor 提交于 12月 28, 2020
  
  c6997c97
- A
  
  [FLINK-20651] Add Spotless plugin with Google AOSP style · 2f78a2a9
  由 Aljoscha Krettek 提交于 10月 06, 2020
  
  2f78a2a9
- A
  
  [FLINK-20651] Fix formatting that doesn't work with google-java-format/checkstyle · ce427e7e
  由 Aljoscha Krettek 提交于 12月 15, 2020
  
  ce427e7e
- A
  [FLINK-20651] Add suppressions for breakage after google-java-format formatting · 640ddd6d
  由 Aljoscha Krettek 提交于 10月 28, 2020
```
The reformatting increases file length for some files.
```
  640ddd6d
- A
  
  [FLINK-20651] Remove checkstyle checks that don't work/are not needed with google-java-format · acccb1a1
  由 Aljoscha Krettek 提交于 12月 15, 2020
  
  acccb1a1
- A
  [FLINK-20651] Move checkstyle ignores to suppressions.xml · 6ad365c2
  由 Aljoscha Krettek 提交于 10月 28, 2020
```
Keeping them inline does not work with google-java-format.
```
  6ad365c2
- A
  
  [refactor] Use tabs in checkstyle.xml to conform to our other XML files · 7ed6cbed
  由 Aljoscha Krettek 提交于 12月 16, 2020
  
  7ed6cbed
- A
  
  [hotfix] Fix incorrect license headers · d7dae840
  由 Aljoscha Krettek 提交于 12月 15, 2020
  
  d7dae840
- S
  
  [hotfix][docs][checkpointing] Fix and sync example code · 8fc6eaea
  由 Suo Lu 提交于 12月 28, 2020
  
  8fc6eaea
- S
  
  [hotfix][docs] Fix typo · 441fc5dd
  由 Svend Vanderveken 提交于 12月 28, 2020
  
  441fc5dd
- T
  
  [hotfix][docs] Fix typo · fdb6b984
  由 Ting Sun 提交于 12月 28, 2020
  
  fdb6b984
- V
  
  [FLINK-20259][web] Add explanation to Effective Configuration in JM/TM · a9145813
  由 vthinkxie 提交于 12月 21, 2020
  
  a9145813
- H
  [FLINK-20756][python] Fix the bug that it doesn't support field access of... · 7d6715c2
  由 huangxingbo 提交于 12月 25, 2020
```
[FLINK-20756][python] Fix the bug that it doesn't support field access of expression containing Python UDF in the condition of Calc

This closes #14492.
```
  7d6715c2
- K
  [FLINK-20540][jdbc] Fix JdbcCatalog connection exception when baseUrl doesn't end with slash · 8da64d79
  由 kougazhang 提交于 12月 28, 2020
```
This closes #14362
Co-authored-by: Nzhao.zhang <zhao.zhang@upai.com>
```
  8da64d79
- H
  [FLINK-20620][table-planner-blink][python] Port BatchExecPythonCalc and... · 2848d4d4
  由 huangxingbo 提交于 12月 25, 2020
```
[FLINK-20620][table-planner-blink][python] Port BatchExecPythonCalc and StreamExecPythonCalc to Java

This closes #14496.
```
  2848d4d4
- H
  [FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept... · 7ea384b9
  由 huangxingbo 提交于 12月 27, 2020
```
[FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept table function directly

This closes #14500.
```
  7ea384b9
27 12月, 2020 2 次提交
- K
  [FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to... · 0c36b666
  由 Kezhu Wang 提交于 12月 27, 2020
```
[FLINK-20657][connectors/jdbc] Migrate jdbc InputFormat/LookupFunction to SimpleJdbcConnectionProvider for connection establishment

This closes #14466
```
  0c36b666
- S
  [FLINK-19650][jdbc][table] Support limit push down for the JDBC connector · a859e2cc
  由 Shengkai 提交于 12月 27, 2020
```
This closes #13800
```
  a859e2cc
25 12月, 2020 13 次提交
- 龙
  [FLINK-20736][table-planner-blink] Introduce StreamPhysicalRank &... · a25b9b84
  由龙三提交于 12月 23, 2020
```
[FLINK-20736][table-planner-blink] Introduce StreamPhysicalRank & StreamPhysicalLimit, and make StreamExecRank & StreamExeLimit only extended from ExecNode

This closes #14472
```
  a25b9b84
- 龙
  [FLINK-20736][table-planner-blink] Introduce BatchPhysicalLimit, and make... · 677d392a
  由龙三提交于 12月 23, 2020
```
[FLINK-20736][table-planner-blink] Introduce BatchPhysicalLimit, and make BatchExecLimit only extended from ExecNode

This closes #14472
```
  677d392a
- G
  [FLINK-20706][table-planner-blink] Introduce BatchPhysicalUnion, and make... · f3d03eb4
  由 godfreyhe 提交于 12月 22, 2020
```
[FLINK-20706][table-planner-blink] Introduce BatchPhysicalUnion, and make BatchExecUnion only extended from ExecNode

This closes #14455
```
  f3d03eb4
- G
  [FLINK-20706][table-planner-blink] Introduce StreamPhysicalUnion, and make... · 4f323bac
  由 godfreyhe 提交于 12月 22, 2020
```
[FLINK-20706][table-planner-blink] Introduce StreamPhysicalUnion, and make StreamExecUnion only extended from ExecNode

This closes #14455
```
  4f323bac
- H
  [FLINK-20702][python] Support map operation chained together in Python Table API · febce359
  由 huangxingbo 提交于 12月 23, 2020
```
This closes #14473.
```
  febce359
- A
  [FLINK-20764] In BatchGroupedReduceOperator, fix timer logic · b474d287
  由 Aljoscha Krettek 提交于 12月 24, 2020
```
This closes #14489
```
  b474d287
- W
  [FLINK-20664][k8s][doc] Update RBAC section in native kubernetes document · 4e5448cc
  由 wangyang0918 提交于 12月 25, 2020
```
This closes #14447
```
  4e5448cc
- B
  
  [FLINK-20664][k8s] Support setting service account for TaskManager pod. · fb4286f3
  由 blublinsky 提交于 12月 21, 2020
  
  fb4286f3
- H
  [FLINK-20642][python] Introduce InternalRow to optimize the performance of Python UDAF · 3b8998d5
  由 huangxingbo 提交于 12月 24, 2020
```
This closes #14487.
```
  3b8998d5
- J
  [FLINK-20710][hive] Hive reading fail when splits on different FileSystem nameservices · 5ffcfcaf
  由 Jack 提交于 12月 25, 2020
```
This closes #14452
```
  5ffcfcaf
- 肖
  [FLINK-19691][jdbc] Support connection.max-retry-timeout configuration for JDBC connector · f5e829c4
  由肖佳文提交于 12月 15, 2020
```
This closes #14387
```
  f5e829c4
- M
  [FLINK-20552][jdbc] JdbcDynamicTableSink doesn't sink buffered data on checkpoint · 21a08ea5
  由 meijie 提交于 12月 23, 2020
```
This closes #14387
```
  21a08ea5
- W
  [FLINK-20648][k8s] Add itcase for recovering from savepoint with Kubernetes HA enabled · 2c92ea9a
  由 wangyang0918 提交于 12月 24, 2020
```
This closes #14486
```
  2c92ea9a
24 12月, 2020 4 次提交
- J
  
  [hotfix][docs] Fix the broken link in Kafka SQL connector page · fd8180aa
  由 Jark Wu 提交于 12月 24, 2020
  
  fd8180aa
- Q
  [FLINK-18382][docs-zh] Translate Kafka SQL connector documentation into Chinese · 52ddd9b0
  由 Qingsheng Ren 提交于 12月 24, 2020
```
This closes #13876
```
  52ddd9b0
- G
  [FLINK-20709][table-planner-blink] Introduce StreamPhysicalMiniBatchAssigner,... · 8da60525
  由 godfrey he 提交于 12月 24, 2020
```
[FLINK-20709][table-planner-blink] Introduce StreamPhysicalMiniBatchAssigner, and make StreamExecMiniBatchAssigner only extended from ExecNode

This closes #14459
```
  8da60525
- G
  [FLINK-20708][table-planner-blink] Introduce StreamPhysicalDropUpdateBefore,... · 2eb84aaa
  由 godfrey he 提交于 12月 24, 2020
```
[FLINK-20708][table-planner-blink] Introduce StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only extended from ExecNode

This closes #14458
```
  2eb84aaa

doujutun3207 / flink 与 Fork 源项目一致

doujutun3207 / flink
与 Fork 源项目一致