Commits

Branch selector

 20e6d63

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 28, 2024

• [FLINK-35773][docs] Document s5cmd

  pnowojski

  committed
  20e6d63

• [FLINK-35177] Fix DataGen Connector documentation (apache#24692)

  Show description for bc3afba
  morozov

  authored
  bc3afba

Commits on Aug 27, 2024

• [FLINK-35790][docs] Update docs for new schema definition in CTAS and RTAS

  spena

  authored
  8c116de

• [FLINK-35708][table-planner] Allow defining a schema in REPLACE TABLE AS (RTAS)

  spena

  authored
  c1fa29a

• [FLINK-36063][runtime] Migrate StreamGraph and its related classes from flink-streaming-java to flink-runtime.

  Show description for 51f1684
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  51f1684

• [FLINK-35965][table] Add the built-in function ENDSWITH

  

  dylanhz

  authored and

  lincoln-lil

  committed
  5bbdbb2

• [FLINK-35964][table] Add the built-in function STARTSWITH

  

  dylanhz

  authored and

  lincoln-lil

  committed
  4c14c76

Commits on Aug 26, 2024

• [FLINK-36100][table] Support ESCAPE in built-in function LIKE

  Show description for ae4eb7d
  dylanhz

  authored
  ae4eb7d

• [FLINK-36140] Log a warning when pods are terminated by kubernetes

  Show description for 9bcd8f4
  

  clarax

  and

  Clara Xiong

  authored
  9bcd8f4

• [FLINK-35771][s3] Limit the amount of work per s5cmd call

  Show description for 0daca7b
  

  rkhachatryan

  authored and

  pnowojski

  committed
  0daca7b

• [FLINK-36108][s3] Wait for state download on cancellation to enforce cleanup

  

  rkhachatryan

  authored and

  pnowojski

  committed
  576b308

• [FLINK-35770][s3] Make s5cmd copyFiles interruptable through CloseableRegistry to improve job cancellation behavior during restore.

  

  StefanRRichter

  authored and

  pnowojski

  committed
  9b67415

Commits on Aug 23, 2024

• [FLINK-35482][parquet][test] Fix timezone handling in ParquetInt64TimestampReaderTest

  xjmdoo

  authored
  4faf096

• [FLINK-36096] Add synchronous interfaces for State V2 API

  Show description for 825ed85
  

  wqshr12345

  authored and

  Zakelly

  committed
  825ed85

• [FLINK-27146][filesystems][tests] Migrate to Junit5

  Show description for a451edd
  

  kottmann

  and

  zentol

  authored
  a451edd

Commits on Aug 22, 2024

• [FLINK-36127][web] support sort watermark

  

  candaccc-tang

  authored and

  Myasuka

  committed
  9e6bcee

Commits on Aug 21, 2024

• [FLINK-33681][Runtime/Metrics] Reuse input/output metrics of SourceOperator/SinkWriterOperator for task (apache#23998)

  X-czh

  authored
  0309f13

• [FLINK-36126][table] Qualification of current catalog and current database should happen during execution, not parsing (apache#25230)

  snuyanzin

  authored
  e217fa1

• [FLINK-35716] Adds a rule which splits out async calls from join conditions

  AlanConfluent

  authored
  9ecf4cf

• [FLINK-35963][table] Add the built-in function REGEXP_SUBSTR

  

  dylanhz

  authored and

  lincoln-lil

  committed
  e8c1d1b

• [FLINK-35962][table] Add the built-in function REGEXP_INSTR

  

  dylanhz

  authored and

  lincoln-lil

  committed
  cbbb1cd

• [FLINK-35932][table] Add the built-in function REGEXP_COUNT

  

  dylanhz

  authored and

  lincoln-lil

  committed
  8189bba

• [FLINK-35931][table] Add the built-in function REGEXP_EXTRACT_ALL

  

  dylanhz

  authored and

  lincoln-lil

  committed
  7fa4eba

• [FLINK-35931][table-planner] Use a separate test class for the regexp family of functions

  

  dylanhz

  authored and

  lincoln-lil

  committed
  697b4b2

• [hotfix][API/DataStream] Log the right syncDurationMillis time

  

  Myracle

  authored and

  pnowojski

  committed
  9399e66

• [FLINK-35772][filesystem] Drop DuplicatingFileSystem in favour of the newer PathsCopyingFileSystem

  pnowojski

  committed
  56c8199

• [FLINK-36095][table-planner] KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering

  lincoln-lil

  committed
  624bc50

• [hotfix][table] Fix KeyedUpsertingSinkFunction's recovery logic and add restore test

  lincoln-lil

  committed
  f57ebac

Commits on Aug 20, 2024

• [FLINK-36085][table] Refactor SHOW operations with LIKE/ILIKE

  Show description for 36347e5
  snuyanzin

  committed
  36347e5

• [FLINK-36050][table] Enhance SHOW VIEW syntax

  snuyanzin

  committed
  04b385b

Commits on Aug 19, 2024

• [FLINK-35939] Do not set empty config values via ConfigUtils#encodeCollectionToConfig

  ferenc-csaky

  authored
  e4abd06

• [FLINK-36084] Optimize parquet binary getBytes with getBytesUnsafe to avoid copy cost (apache#25213)

  xuzifu666

  authored
  adb8368

Commits on Aug 17, 2024

• [FLINK-35886][source] Do not track already finished splits in watermark alignment

  pnowojski

  committed
  5f6200c

• [FLINK-35886][task] Hide backpressure from idleness detection in WatermarkAssignerOperator

  pnowojski

  committed
  6d100ab

• [FLINK-35886][task] Hide backpressure and watermark alignment from idleness detection in SourceOperator

  pnowojski

  committed
  02d89ca

Pagination

PreviousNext