Commits

Branch selector

 5739196

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 29, 2021

• [FLINK-25465][state] Correct the logic of materizating wrapped changelog state

  Myasuka

  committed
  5739196

  Copy full SHA for 5739196

• [hotfix] Refactor type of states within ChangelogKeyedStateBackend

  Myasuka

  committed
  d40fc21

  Copy full SHA for d40fc21

• [FLINK-25372] Add thread dump feature for jobmanager on Web UI

  Show description for c915ccf
  

  X-czh

  authored and

  xintongsong

  committed
  c915ccf

  Copy full SHA for c915ccf

• [FLINK-25372] Add REST API for request JobManager thread-dump

  

  X-czh

  authored and

  xintongsong

  committed
  91cc35b

  Copy full SHA for 91cc35b

• [FLINK-25372] Move ThreadDumpInfo out from taskmanager-specific package

  

  X-czh

  authored and

  xintongsong

  committed
  72c451c

  Copy full SHA for 72c451c

• [hotfix][jdbc] Fix method name typo in Postgres test

  Show description for 9f49f10
  a49a

  authored
  9f49f10

  Copy full SHA for 9f49f10

Commits on Dec 28, 2021

• [FLINK-24912][state-processor-api] Update documentation for DataStream based API

  Show description for 3b54d27
  sjwiesman

  committed
  3b54d27

  Copy full SHA for 3b54d27

• [FLINK-24912][state-processor-api] Migrate savepoint reader to DataStream API

  Show description for 035ddf6
  

  sjwiesman

  and

  qinjunjerry

  committed
  035ddf6

  Copy full SHA for 035ddf6

• [FLINK-24912][state-processor-api] Migrate savepoint bootstrapping to DataStream API

  Show description for 15130b5
  

  sjwiesman

  and

  qinjunjerry

  committed
  15130b5

  Copy full SHA for 15130b5

• [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[])

  Myasuka

  committed
  c0f46ef

  Copy full SHA for c0f46ef

• [FLINK-24772][docs] Add documentation for individual window table-valued function (apache#17885)

  beyond1920

  authored
  0797708

  Copy full SHA for 0797708

• [FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable

  tillrohrmann

  committed
  fe3dfbc

  Copy full SHA for fe3dfbc

• [FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly

  tillrohrmann

  committed
  276570e

  Copy full SHA for 276570e

• [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

  Show description for cdef097
  

  SteNicholas

  authored and

  Myasuka

  committed
  cdef097

  Copy full SHA for cdef097

Commits on Dec 27, 2021

• [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.

  Show description for 509530b
  

  echauchot

  authored and

  tillrohrmann

  committed
  509530b

  Copy full SHA for 509530b

Commits on Dec 24, 2021

• [FLINK-25094][test] Correct the LatencyTrackingMapStateTest#verifyIterator

  Show description for d08a1d0
  

  ljz2051

  authored and

  Myasuka

  committed
  d08a1d0

  Copy full SHA for d08a1d0

• [FLINK-25429][state] Avoid to close output streams twice during uploading changelogs

  Myasuka

  committed
  804eb8d

  Copy full SHA for 804eb8d

Commits on Dec 23, 2021

• [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

  Show description for 11f74d8
  JingsongLi

  authored
  11f74d8

  Copy full SHA for 11f74d8

• [FLINK-24481][docs] Translate buffer debloat documenation to chinese

  Show description for e0c2676
  

  Myracle

  authored and

  xintongsong

  committed
  e0c2676

  Copy full SHA for e0c2676

• [hotfix][docs] Minor fixes in Network Memory Tuning Guide

  

  Myracle

  authored and

  xintongsong

  committed
  0eb3598

  Copy full SHA for 0eb3598

• [FLINK-25422][python] Specify requirements in dev-requirements.txt

  Show description for 8a3d033
  HuangXingBo

  committed
  8a3d033

  Copy full SHA for 8a3d033

Commits on Dec 22, 2021

• [FLINK-25085][runtime] Add a scheduled thread pool in MainThreadExecutor and close it when the endpoint is stopped

  Show description for 5580cd6
  

  shammon

  authored and

  KarmaGYZ

  committed
  5580cd6

  Copy full SHA for 5580cd6

• [FLINK-25365][python] Remove remaining references to planner from Python

  Show description for 74ed032
  

  slinkydeveloper

  authored and

  twalthr

  committed
  74ed032

  Copy full SHA for 74ed032

• [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

  

  PatrickRen

  authored and

  becketqin

  committed
  2b1a9de

  Copy full SHA for 2b1a9de

• [hotfix][checkpoint] Fix the wrong parameters due to base code change in StreamTaskFinalCheckpointsTest

  gaoyunhaii

  committed
  f191bec

  Copy full SHA for f191bec

• [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

  Show description for e8bd52b
  gaoyunhaii

  committed
  e8bd52b

  Copy full SHA for e8bd52b

Commits on Dec 21, 2021

• [FLINK-25399][tests] Disable changelog backend in tests

  Show description for 1d1e72f
  rkhachatryan

  committed
  1d1e72f

  Copy full SHA for 1d1e72f

• [FLINK-25375] Update log4j2 dependency to 2.17.0 to address

  Show description for fef7f46
  

  Bernard Joseph Jean Bruno

  authored and

  knaufk

  committed
  fef7f46

  Copy full SHA for fef7f46

• [FLINK-25363][python][table] Refactor shared group window classes for Python

  Show description for 6a96044
  

  slinkydeveloper

  authored and

  twalthr

  committed
  6a96044

  Copy full SHA for 6a96044

• [FLINK-25123][table-planner] Remove redundant info for the ExecNode's description

  Show description for d3b6a69
  

  龙三

  authored and

  godfreyhe

  committed
  d3b6a69

  Copy full SHA for d3b6a69

• [FLINK-25268][yarn] Support task manager node-label in Yarn deployment

  Show description for 71ed78d
  

  zuston

  authored and

  KarmaGYZ

  committed
  71ed78d

  Copy full SHA for 71ed78d

Commits on Dec 20, 2021

• [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

  Show description for 3822612
  

  snuyanzin

  authored and

  twalthr

  committed
  3822612

  Copy full SHA for 3822612

• [FLINK-25366][table-planner][table-runtime] Implement BINARY/VARBINARY length validation for sinks

  Show description for 19bc181
  

  matriv

  authored and

  twalthr

  committed
  19bc181

  Copy full SHA for 19bc181

• [FLINK-25364][python][table-planner] Remove dependency on planner for Python code generation

  Show description for 2e355d9
  

  slinkydeveloper

  authored and

  twalthr

  committed
  2e355d9

  Copy full SHA for 2e355d9

Commits on Dec 19, 2021

• [FLINK-21406][parquet] Add AvroParquetReaders to read parquet files into Avro types.

  Show description for cdf3d48
  

  JingGe

  authored and

  Arvid Heise

  committed
  cdf3d48

  Copy full SHA for cdf3d48

Pagination

Previous

Next