Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 8, 2025

• [FLINK-36507][table-common] Remove the deprecated method LogicalTypeParser#parse (apache#25909)

  xuyangzhong

  authored
  4d57a12

  Copy full SHA for 4d57a12

• [FLINK-36968][table-planner] Deduplicate data with the same pk in values lookup table used for testing (apache#25864)

  xuyangzhong

  authored
  3ca52be

  Copy full SHA for 3ca52be

• [FLINK-36960][test] Add WatermarkITCase for Generalized Watermark

  Show description for 75c26e8
  

  2 peopleauthored and

  reswqa

  committed
  75c26e8

  Copy full SHA for 75c26e8

• [FLINK-36960][runtime] Combine Generalized Watermarks in StreamTaskNetworkInput for input channels

  Show description for 52ef4ea
  

  2 peopleauthored and

  reswqa

  committed
  52ef4ea

  Copy full SHA for 52ef4ea

• [FLINK-36960][runtime] Process Generalized Watermarks in ProcessOperators

  Show description for 75fca0d
  

  2 peopleauthored and

  reswqa

  committed
  75fca0d

  Copy full SHA for 75fca0d

• [FLINK-36960][runtime] Write and load the declared WatermarkDeclarations with StreamGraph and StreamConfig

  Show description for 84e86b2
  

  2 peopleauthored and

  reswqa

  committed
  84e86b2

  Copy full SHA for 84e86b2

• [FLINK-36960][API] Make Source is able to declare and output Generalized Watermarks

  Show description for c5031d7
  

  2 peopleauthored and

  reswqa

  committed
  c5031d7

  Copy full SHA for c5031d7

• [FLINK-36960][runtime] Introduce WatermarkEvent to propagate Generalized Watermarks within Stream

  Show description for 75d4230
  

  2 peopleauthored and

  reswqa

  committed
  75d4230

  Copy full SHA for 75d4230

• [FLINK-36960][API] Introduce WatermarkManager in NonPartitionedContext

  Show description for 472eca8
  

  2 peopleauthored and

  reswqa

  committed
  472eca8

  Copy full SHA for 472eca8

• [FLINK-36960][runtime] Introduce InternalWatermarkDeclaration, WatermarkCombiner and Alignable interface

  Show description for 3462cf3
  

  2 peopleauthored and

  reswqa

  committed
  3462cf3

  Copy full SHA for 3462cf3

• [FLINK-36960][API] Introduce WatermarkDeclaration and onWatermark callback in ProcessFunction

  Show description for 7915cb6
  

  2 peopleauthored and

  reswqa

  committed
  7915cb6

  Copy full SHA for 7915cb6

• [FLINK-36960][API] Enable PartitionedContext to access NonPartitionedContext

  Show description for 5c03fff
  

  2 peopleauthored and

  reswqa

  committed
  5c03fff

  Copy full SHA for 5c03fff

• [FLINK-36960][API] Introduce WatermarkDeclaration for Generalized Watermark in DSv2

  Show description for ad68d76
  

  2 peopleauthored and

  reswqa

  committed
  ad68d76

  Copy full SHA for ad68d76

• [FLINK-36960][API] Introduce Watermark and Combine Function for DSv2 Generalized Watermark

  Show description for 473aff1
  

  2 peopleauthored and

  reswqa

  committed
  473aff1

  Copy full SHA for 473aff1

• [FLINK-37010][Runtime] Unify KeyedProcessFunction and the async one (apache#25901)

  Zakelly

  authored
  9720dcc

  Copy full SHA for 9720dcc

• [FLINK-36950][table] Migrate WindowPropertiesRules to java

  liuyongvs

  authored
  63edfd6

  Copy full SHA for 63edfd6

Commits on Jan 7, 2025

• [FLINK-36976] Bump snakeyaml to 2.3

  snuyanzin

  committed
  58047a8

  Copy full SHA for 58047a8

• [FLINK-36976] Upgrade jackson from 2.15.3 to 2.18.2 and kubernetes.client to 6.13.4

  snuyanzin

  committed
  98a36a7

  Copy full SHA for 98a36a7

• [hotfix][docs] Add python docs for create_table/create_temporary_table

  snuyanzin

  committed
  503ad9b

  Copy full SHA for 503ad9b

• [FLINK-37007][table] Add missing createView methods to TableEnvironment

  Show description for d432dff
  snuyanzin

  committed
  d432dff

  Copy full SHA for d432dff

• [FLINK-36070][runtime/web] Show pending operators in overview page.

  

  yuchen-ecnu

  authored and

  JunRuiLee

  committed
  ae7184b

  Copy full SHA for ae7184b

• [FLINK-36070][runtime/web] Modifying web UI to adapt to Incremental JobGraph Generation

  

  yuchen-ecnu

  authored and

  JunRuiLee

  committed
  4c94d53

  Copy full SHA for 4c94d53

• [FLINK-36760][sql-client] Supports to deploy script via sql client (apache#25754)

  fsk119

  authored
  4a8b8c0

  Copy full SHA for 4a8b8c0

• [FLINK-36501][table-common] Remove all deprecated methods in CatalogFactory (apache#25579)

  hackergin

  authored
  7344916

  Copy full SHA for 7344916

• [FLINK-22091][yarn] Make Flink on YARN honor env.java.home (apache#25877)

  X-czh

  authored
  f0c8f18

  Copy full SHA for f0c8f18

Commits on Jan 6, 2025

• [FLINK-36935][state/forst] Implement fast link for ForStFileSystem (apache#25818)

  fredia

  authored
  9878e56

  Copy full SHA for 9878e56

• [FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension

  XComp

  committed
  c3d56df

  Copy full SHA for c3d56df

• [FLINK-36989][runtime] Fix scheduler benchmark regression caused by ConsumedSubpartitionContext

  

  noorall

  authored and

  zhuzhurk

  committed
  81f882b

  Copy full SHA for 81f882b

Commits on Jan 4, 2025

• [FLINK-36759][sql-gateway] Add REST API to deploy script in application mode (apache#25730)

  fsk119

  authored
  3084561

  Copy full SHA for 3084561

• [FLINK-36007][table] Apply changes from FLINK-36277 to AdaptiveJoin

  Show description for f08e5ec
  

  snuyanzin

  and

  xuyangzhong

  committed
  f08e5ec

  Copy full SHA for f08e5ec

Commits on Jan 3, 2025

• [hotfix][docs] In match_recognize docs, remove extracting time attributes from list of limitations

  alpinegizmo

  committed
  ec169a8

  Copy full SHA for ec169a8

• [FLINK-36277][table] Create a DynamicTableSource instead of registering a legacy TableSource in tests and remove TableEnvironmentInternal#registerTableSourceInternal

  

  xuyangzhong

  authored and

  lsyldliu

  committed
  bbbd160

  Copy full SHA for bbbd160

• [FLINK-36277][table] Remove all blocking subclasses of TableSource related to the removal of TableEnvironmentInternal#registerTableSourceInternal, except TestTableSource in tests.

  

  xuyangzhong

  authored and

  lsyldliu

  committed
  c7b6212

  Copy full SHA for c7b6212

• [FLINK-36277][table] Remove WithoutTimeAttributesTableSourceFactory, TestDataTypeTableSourceWithTimeFactory, TestDataTypeTableSourceFactory and TestTemporalTable(in LookupJoinTest) to prepare remov…

  Show description for 1a3fda6
  

  xuyangzhong

  authored and

  lsyldliu

  committed
  1a3fda6

  Copy full SHA for 1a3fda6

• [FLINK-36500][table-common] Remove all deprecated methods in CallExpression

  jbalchan

  authored
  ea10556

  Copy full SHA for ea10556

Pagination

Previous

Next