Commits

Branch selector

 e77dc91

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 14, 2023

• [FLINK-33076][network] Reduce serialization overhead of broadcast emit from ChannelSelectorRecordWriter.

  reswqa

  committed
  e77dc91

• [hotfix] Parameterlize RecordWriterTest and migrate it to junit5

  reswqa

  committed
  e198c09

• [FLINK-32863][runtime-web] Improve Flink UI's time precision from second level to millisecond level

  

  hejufang

  authored and

  KarmaGYZ

  committed
  2d74260

• [FLINK-32775][yarn] Add parent dir of files to classpath using yarn.provided.lib.dirs

  Show description for 1f96218
  architgyl

  authored
  1f96218

Commits on Sep 13, 2023

• [FLINK-33029][python] Drop python 3.7 support

  gaborgsomogyi

  authored
  50cb4ee

• [FLINK-30906][task] TwoInputStreamTask and MultipleInputStreamTask passes wrong configuration when create input processor

  reswqa

  committed
  70f4c40

• [FLINK-14032][state] Make the cache size of RocksDBPriorityQueueSetFactory configurable

  

  ljz2051

  authored and

  masteryhx

  committed
  3671960

• [FLINK-33064][table-planner] Improve the error message when the lookup source is used as the scan source (apache#23377)

  Show description for be509e6
  

  swuferhong

  and

  zhengyunhong.zyh

  authored
  be509e6

• [FLINK-33034][runtime] Fix incorrect StateBackendTestBase#testGetKeysAndNamespaces

  

  ldadima

  authored and

  masteryhx

  committed
  36b9da5

Commits on Sep 12, 2023

• [FLINK-32885 ] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink remote execution

  

  Elkhan Dadashov

  authored and

  tweise

  committed
  e7eeea0

• [hotfix][docs] Misprints in security-ssl.md (apache#23400)

  snuyanzin

  authored
  45f26c7

• [FLINK-33065][client] Add possible root cause to the exception message when the program plan could not be fetched (apache#23379)

  1996fanrui

  authored
  d5b2cdb

• [FLINK-32978][flink-core] Migrate the usage of RichFunction#open(Configuration parameters) to RichFunction#open(OpenContext openContext)

  Show description for e935331
  

  WencongLiu

  authored and

  xintongsong

  committed
  e935331

• [FLINK-32978][flink-core] Deprecate RichFunction#open(Configuration parameters)

  

  WencongLiu

  authored and

  xintongsong

  committed
  798a20a

• [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

  Show description for ade583c
  

  TanYuxin-tyx

  authored and

  xintongsong

  committed
  ade583c

• [hotfix][network] Fix the close method for the tiered producer client

  

  TanYuxin-tyx

  authored and

  xintongsong

  committed
  e41b0b2

• [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3

  Show description for 649b7fe
  fsk119

  committed
  649b7fe

Commits on Sep 11, 2023

• [FLINK-32854][flink-runtime][JUnit5 Migration] The state package of flink-runtime module (apache#23218)

  Jiabao-Sun

  authored
  554810a

• [FLINK-32396][jdbc-driver] Support timestamp and timestamp_ltz for jdbc driver and sql gateway (apache#22832)

  Show description for c33a652
  FangYongs

  authored
  c33a652

• [FLINK-32979] Migrate the usage of getDefaultTrigger(StreamExecutionEnvironment env) to getDefaultTrigger()

  Show description for 831cb8e
  

  WencongLiu

  authored and

  xintongsong

  committed
  831cb8e

• [FLINK-32979] Add getDefaultTrigger() to WindowAssigner

  

  WencongLiu

  authored and

  xintongsong

  committed
  29a6e06

• [FLINK-31889][docs] Add documentation for implementing/loading enrichers

  

  pgaref

  authored and

  zentol

  committed
  484da99

• [FLINK-33054][datastream] Align the execution result fetching timeout in CollectResultFetcher with akka ask timeout

  KarmaGYZ

  committed
  9c91ea3

Commits on Sep 10, 2023

• [FLINK-32796][docs] Extend catalog store documentation (apache#23367)

  ferenc-csaky

  authored
  034a60a

• [FLINK-32796][table] Try to create catalog store path if not exists (apache#23366)

  ferenc-csaky

  authored
  9a94891

• [FLINK-33010][table] GREATEST/LEAST should work with other functions as input (apache#23345)

  snuyanzin

  authored
  5775fbb

Commits on Sep 9, 2023

• [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

  1996fanrui

  committed
  5370273

• [FLINK-33042][refactor] Refactor the method name of ExecutionState from Recovering to Initializing

  1996fanrui

  committed
  242b3e5

• [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser (apache#23374)

  swuferhong

  authored
  01cb6ef

Commits on Sep 8, 2023

• [FLINK-33038][table-planner] remove getMinRetentionTime in StreamExecDeduplicate (apache#23360)

  Show description for e4deaf4
  

  zhougit86

  and

  xiaogang

  authored
  e4deaf4

• [FLINK-32999][connectors/hbase] Remove HBase connector code from main repo (apache#23342)

  Show description for 62e41ac
  

  ferenc-csaky

  and

  snuyanzin

  authored
  62e41ac

• [FLINK-33031][table-planner][JUnit5 Migration] Module: flink-table-planner (AggFunctionTestBase) (apache#23354)

  Jiabao-Sun

  authored
  da69cc7

• [FLINK-30025][doc] improve the option description with more precise content

  JingGe

  committed
  3b9fcb5

• [FLINK-33055][doc]Correct the error value about 'state.backend.type' in the document (apache#23378)

  ljz2051

  authored
  53ccb93

• [FLINK-32620][sink] Fix the bug that sinkv2 does not set coLocationGroupKey for writer.

  reswqa

  committed
  c4a76e2

Pagination

PreviousNext