Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 2, 2021

• [FLINK-20942][table] Digest of FLOAT literals throws UnsupportedOperationException

  Show description for 017bb12
  

  danny0405

  authored and

  twalthr

  committed
  017bb12

  Copy full SHA for 017bb12

• [FLINK-20345][table-planner-blink] SplitAggregateRule: Adds an Expand node only if there are multiple distinct aggregate functions

  Show description for a334b92
  beyond1920

  authored
  a334b92

  Copy full SHA for a334b92

Commits on Feb 1, 2021

• [FLINK-21150][table-planner-blink] Introduce ExecEdge to connect two ExecNodes

  Show description for 52c540a
  godfreyhe

  authored
  52c540a

  Copy full SHA for 52c540a

• [FLINK-21226][table-common] Reintroduce TableColumn.of for backwards compatibility

  twalthr

  committed
  a92c264

  Copy full SHA for a92c264

Commits on Jan 29, 2021

• [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

  rmetzger

  committed
  95f8b61

  Copy full SHA for 95f8b61

Commits on Jan 27, 2021

• [FLINK-21105][table-planner-blink] Rename ExecEdge to InputProperty and rename RequiredShuffle to RequiredDistribution

  Show description for f083c67
  godfreyhe

  authored
  f083c67

  Copy full SHA for f083c67

Commits on Jan 26, 2021

• [minor][table-planner-blink] Minor code cleanup for some exec nodes and physical nodes

  Show description for cacfef2
  godfreyhe

  committed
  cacfef2

  Copy full SHA for cacfef2

• [minor][table-planner-blink] Move CommonPhysicalJoin and CommonPhysicalLookupJoin to nodes.physical.common package

  Show description for 40c3068
  godfreyhe

  committed
  40c3068

  Copy full SHA for 40c3068

• [FLINK-20968][table-planner-blink] Rename ExecNode#getDesc to ExecNode#getDescription

  Show description for e6e9c7a
  godfreyhe

  committed
  e6e9c7a

  Copy full SHA for e6e9c7a

• [FLINK-20968][table-planner-blink] Remove legacy exec nodes

  Show description for 5ed569f
  godfreyhe

  committed
  5ed569f

  Copy full SHA for 5ed569f

• [FLINK-21026][flink-sql-parser] Align column list specification syntax with hive in INSERT statement

  Show description for 35247bb
  docete

  authored
  35247bb

  Copy full SHA for 35247bb

Commits on Jan 25, 2021

• [FLINK-19465][runtime / statebackends] Wire checkpoint storage through the runtime

  sjwiesman

  committed
  947a02c

  Copy full SHA for 947a02c

• [FLINK-20961][table-planner-blink] Fix NPE when no assigned timestamp defined in DataStream

  Show description for e78eca4
  YuvalItzchakov

  authored
  e78eca4

  Copy full SHA for e78eca4

• [FLINK-21069][table-planner-blink] Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

  Show description for 0d3c785
  SteNicholas

  authored
  0d3c785

  Copy full SHA for 0d3c785

• [FLINK-21020][build] Bump Jackson to 2.12.1

  

  HuangXingBo

  authored and

  zentol

  committed
  273899a

  Copy full SHA for 273899a

• [FLINK-20680][table-planner-blink] Add additional var-arg tests

  Show description for 59454b8
  twalthr

  committed
  59454b8

  Copy full SHA for 59454b8

• [FLINK-20680][table-common] Fix invalid validation of var-arg function with no parameters

  

  lirui-apache

  authored and

  twalthr

  committed
  1ee13f2

  Copy full SHA for 1ee13f2

• [FLINK-21054][table-runtime-blink] Implement mini-batch optimized slicing window aggregate operator

  Show description for c4bfa9f
  wuchong

  committed
  c4bfa9f

  Copy full SHA for c4bfa9f

• [hotfix][table-runtime-blink] Rename StateTtlConfigUtil to StateConfigUtil

  wuchong

  committed
  f3db422

  Copy full SHA for f3db422

• [hotfix][table-runtime-blink] Make MemoryManager not null in LazyMemorySegmentPool

  wuchong

  committed
  d16393f

  Copy full SHA for d16393f

Commits on Jan 22, 2021

• [FLINK-21070][table-runtime-blink] Fix invalid reuse of generated code

  Show description for d20867a
  twalthr

  committed
  d20867a

  Copy full SHA for d20867a

• [FLINK-20947][planner] Fix idle source doesn't work when pushing watermark into the source

  Show description for 90e680c
  fsk119

  authored
  90e680c

  Copy full SHA for 90e680c

• [FLINK-17868][table-planner-blink] Fix proctime in DDL can not work in batch mode

  Show description for c5bb490
  LadyForest

  authored
  c5bb490

  Copy full SHA for c5bb490

• [FLINK-21011][table-planner-blink] Fix missed renaming for BatchExecJoinRuleBase, BatchExecNestedLoopJoinRuleBase and BatchExecSingleRowJoinRule

  Show description for 5b477d3
  

  龙三

  authored and

  godfreyhe

  committed
  5b477d3

  Copy full SHA for 5b477d3

• [FLINK-21011][table-planner-blink] Introduce StreamPhysicalIntervalJoin, and make SteamExecIntervalJoin only extended from ExecNode

  Show description for 05faac1
  

  龙三

  authored and

  godfreyhe

  committed
  05faac1

  Copy full SHA for 05faac1

Commits on Jan 21, 2021

• [FLINK-21041][table-planner-blink] Introduce ExecNodeGraph to wrap the ExecNode topology

  Show description for 842f5cd
  godfreyhe

  authored
  842f5cd

  Copy full SHA for 842f5cd

Commits on Jan 20, 2021

• [hotfix][javadoc] Correct the wrong spelling 'perserves' to 'preserves'.

  

  RocMarshal

  authored and

  alpinegizmo

  committed
  d24eafb

  Copy full SHA for d24eafb

Commits on Jan 19, 2021

• [FLINK-20949][table-planner-blink] BatchCommonSubGraphBasedOptimizer should also consider Sink node

  Show description for 53ab259
  godfreyhe

  committed
  53ab259

  Copy full SHA for 53ab259

• [FLINK-20949][table-planner-blink] Introduce BatchPhysicalLegacySink, and make BatchExecLegacySink only extended from ExecNode

  Show description for 45bf1b2
  godfreyhe

  committed
  45bf1b2

  Copy full SHA for 45bf1b2

• [FLINK-20949][table-planner-blink] Introduce StreamPhysicalLegacySink, and make StreamExecLegacySink only extended from ExecNode

  Show description for e99b6e1
  godfreyhe

  committed
  e99b6e1

  Copy full SHA for e99b6e1

• [FLINK-20949][table-planner-blink] Introduce BatchPhysicalSink, and make BatchExecSink only extended from ExecNode

  Show description for 4d9a763
  godfreyhe

  committed
  4d9a763

  Copy full SHA for 4d9a763

• [FLINK-20949][table-planner-blink] Introduce StreamPhysicalSink, and make StreamExecSink only extended from ExecNode

  Show description for 95257a2
  godfreyhe

  committed
  95257a2

  Copy full SHA for 95257a2

• [FLINK-21010][table-planner-blink] Introduce StreamPhysicalJoin, and make StreamExecJoin only extended from ExecNode

  Show description for df851de
  

  龙三

  authored and

  godfreyhe

  committed
  df851de

  Copy full SHA for df851de

• [FLINK-20971][table-api-java] Support calling SQL expressions in Table API

  Show description for ddc06e5
  twalthr

  committed
  ddc06e5

  Copy full SHA for ddc06e5

• [FLINK-20924][python][table-planner-blink] Port StreamExecPythonOverAggregate and BatchExecPythonOverAggregate to Java (apache#14690)

  HuangXingBo

  authored
  d5bbc30

  Copy full SHA for d5bbc30

Pagination

Previous

Next