Commits

Branch selector

 5493a38

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 2, 2022

• [FLINK-27630][table-planner] Add maven-source-plugin for table planner testing connectors (apache#19746)

  liuyongvs

  authored
  5493a38

Commits on Jun 1, 2022

• [FLINK-27797][python] Fix the issue that PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

  Show description for 586715f
  

  jaydonzhou

  authored and

  HuangXingBo

  committed
  586715f

• [hotfix][doc] fix typo and enlarge image

  

  JingGe

  authored and

  wangyang0918

  committed
  4f58359

Commits on May 31, 2022

• [FLINK-27527][test-utils] Create a file-based upsert sink connector for testing internal components

  

  alpreu

  authored and

  XComp

  committed
  d0b7a03

• [hotfix][streaming] Remove flink-tests dependency

  

  alpreu

  authored and

  XComp

  committed
  829d08b

• [FLINK-27522][network] Ignore max buffers per channel when allocate buffer

  

  1996fanrui

  authored and

  pnowojski

  committed
  9146220

Commits on May 30, 2022

• [FLINK-27779][connectors/aws-kinesis] Remove flink-table-planner in favor of flink-table-test-utils

  

  alpreu

  authored and

  MartijnVisser

  committed
  3081528

• [FLINK-27779][connectors/kinesis] Remove flink-table-planner in favor of flink-table-test-utils

  

  alpreu

  authored and

  MartijnVisser

  committed
  c924b29

• [FLINK-27779][connectors/kafka] Remove flink-table-planner in favor of flink-table-test-utils

  

  alpreu

  authored and

  MartijnVisser

  committed
  a65941d

• [FLINK-27779][connectors/cassandra] Remove flink-table-planner in favor of flink-table-test-utils

  

  alpreu

  authored and

  MartijnVisser

  committed
  ac90927

• [FLINK-27657][python] Implement remote operator state backend in PyFlink

  Show description for 9be49ff
  

  vancior98

  authored and

  HuangXingBo

  committed
  9be49ff

• [FLINK-27825][docs] Update the doc of aligned checkpoint timeout

  

  1996fanrui

  authored and

  pnowojski

  committed
  317b230

Commits on May 27, 2022

• [FLINK-27818][rest][docs] Model enums as references

  zentol

  committed
  e7834d8

• [hotfix][python] Fix flake8 check E302 error for blank lines (apache#19821)

  a49a

  authored
  d92ef4f

• [hotfix][python] Fix flake8 check E523 error for format method has unused arguments (apache#19822)

  a49a

  authored
  5ae21e7

Commits on May 26, 2022

• [hotfix][tests] Raise logging level in TestJobExecutor

  rkhachatryan

  committed
  0b139a1

• [FLINK-27169][tests] Set timeout for operator lifecycle tests

  rkhachatryan

  committed
  9bf10eb

• [FLINK-27169][tests] Increase changelog upload timeout in tests

  rkhachatryan

  committed
  f0ec84a

• [FLINK-27776][python] Throw meaningful exceptions when UDAF doesn't override method 'merge' is used in cases where 'merge' is used

  Show description for 51eb02e
  

  HuangXingBo

  authored and

  dianfu

  committed
  51eb02e

• [FLINK-27760][python] Fix the issue that NPE is thrown when executing PyFlink Table API jobs in batch mode

  Show description for 1348dee
  dianfu

  committed
  1348dee

Commits on May 25, 2022

• [FLINK-27740][tests] Migrate flink-test-utils-junit to JUnit5

  

  snuyanzin

  authored and

  zentol

  committed
  e631111

• [FLINK-26074] Improve FlameGraphs scalability for high parallelism jobs

  

  afedulov

  authored and

  MartijnVisser

  committed
  b39d842

• [hotfix][docs-zh] Fix the formatting errors of some Chinese documents.

  

  liuzhuang2017

  authored and

  MartijnVisser

  committed
  b51084d

• [FLINK-27763][kinesis][tests] Remove netty bundling&relocation

  zentol

  committed
  ffca99d

• [FLINK-27532][build][clients] Drop flink-clients test-jar

  zentol

  committed
  391f5f3

• [FLINK-27757][Connector][Elasticsearch] Elasticsearch connector should not use flink-table-planner but flink-table-planner-loader. We also need to add flink-table-runtime to avoid ClassNotFou…

  Show description for d9df7e7
  MartijnVisser

  committed
  d9df7e7

• [FLINK-27251][checkpoint] Refactor the close() and cancel() of SubtaskCheckpointCoordinator

  

  1996fanrui

  authored and

  pnowojski

  committed
  e68d679

• [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

  

  1996fanrui

  authored and

  pnowojski

  committed
  dd8f4e2

• [FLINK-27251][checkpoint] Refactor the barrier alignment timer and default priority sequence number

  

  1996fanrui

  authored and

  pnowojski

  committed
  10b7afa

• [FLINK-27690][python][connector/pulsar][docs] Add pulsar example and documentation

  Show description for 8a2a396
  

  a49a

  authored and

  dianfu

  committed
  8a2a396

Commits on May 24, 2022

• [FLINK-27754][shell] Add stderr when singular flink-dist*.jar cannot be resolved for config.sh.

  

  rudikershaw

  authored and

  dannycranmer

  committed
  d891509

• [FLINK-27751][build] Disable jboss repository

  zentol

  committed
  8cbb42a

• [FLINK-27219][sql-client] Print exception stack when get errors

  Show description for 3c5d3ba
  

  fsk119

  authored and

  HuangXingBo

  committed
  3c5d3ba

• [FLINK-27733][python] Rework on_timer output behind watermark bug fix

  Show description for a0ef9eb
  

  vancior98

  authored and

  HuangXingBo

  committed
  a0ef9eb

• Revert "[FLINK-25188][python][build] Support m1 chip."

  Show description for 99c74d5
  HuangXingBo

  committed
  99c74d5

Pagination

PreviousNext