Commits

Branch selector

 main

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 3, 2024

• [FLINK-36780] Kafka source disable partition discovery unexpectedly (#136)

  liuml07

  authored
  f6a077a

Commits on Nov 25, 2024

• [FLINK-35109] Update weekly CI to verify 3.4 release branch

  AHeise

  committed
  59baacc

Commits on Nov 14, 2024

• [FLINK-34466] Lineage interfaces for kafka connector (#130)

  Show description for 727327d
  pawel-big-lebowski

  authored
  727327d

Commits on Oct 14, 2024

• [FLINK-35109] Updating build configurations for v3.3

  AHeise

  committed
  0fed445

• [FLINK-34467] bump flink version to 1.20.0 (#111)

  HuangZhenQiu

  authored
  2dfdae6

Commits on Oct 11, 2024

• [FLINK-35109] Update version to 3.4-SNAPSHOT

  AHeise

  committed
  c2e11a6

Commits on Oct 10, 2024

• Addressing Chesnay's feedback

  AHeise

  committed
  6dc74db

• [hotfix] Add maven wrapper

  AHeise

  committed
  7f1ac6d

• [FLINK-35109] Bump to Flink 1.19 and support Flink 1.20

  Show description for aedc790
  AHeise

  committed
  aedc790

• [FLINK-35109] Fix SmokeKafkaITCase for later java versions

  Show description for 429fe0c
  AHeise

  committed
  429fe0c

Commits on Oct 9, 2024

• [FLINK-36441] Fix KafkaWriterITCase#testIncreasingRecordBasedCounters

  Show description for 5eeafd6
  AHeise

  committed
  5eeafd6

• [FLINK-36441] Ensure producers are not leaked in tests

  Show description for 28836c6
  AHeise

  committed
  28836c6

• [FLINK-36441] Fix leak for non-transactional FlinkKafkaProducer.

  Show description for 8472d03
  AHeise

  committed
  8472d03

• [FLINK-36441] Ignore exceptions during test cleanup

  Show description for ab333a4
  AHeise

  committed
  ab333a4

• [FLINK-36441] Show full stacktraces in tests for failures

  Show description for a738104
  AHeise

  committed
  a738104

• [hotfix] Copy Flink .editorconfig

  Show description for 264ce8c
  AHeise

  committed
  264ce8c

Commits on Oct 3, 2024

• [FLINK-36420][Connectors/Kafka] Bump avro from 1.11.3 to 1.11.4

  dannycranmer

  committed
  3fbb68d

• [FLINK-36422][docs] Fix PyFlink jar download link

  

  z3d1k

  authored and

  dannycranmer

  committed
  ac8fa12

• [FLINK-35138][Connectors/Kafka] Drop support for Flink 1.17

  dannycranmer

  committed
  a87bf72

Commits on Sep 27, 2024

• [FLINK-36177] Introduce KafkaPartitioner to replace FlinkKafkaPartitioner

  Show description for 157813e
  AHeise

  committed
  157813e

• [FLINK-36177] Deprecate KafkaShuffle and more

  Show description for 21d07b7
  AHeise

  committed
  21d07b7

Commits on Sep 23, 2024

• [hotfix] Fix FlinkKafkaConsumerBaseTest.testClosePartitionDiscovererWithCancellation

  Show description for 9b97c51
  AHeise

  committed
  9b97c51

• [hotfix] Remove unused test dependencies

  AHeise

  committed
  2ee9b9a

• [FLINK-36278] Reduce Flink log levels

  Show description for 1b02ce8
  AHeise

  committed
  1b02ce8

• [FLINK-36278] Reduce Kafka log level

  Show description for ec8d7c2
  AHeise

  committed
  ec8d7c2

• [FLINK-36278] Decrease log levels for hotpath logs

  Show description for 2f86484
  AHeise

  committed
  2f86484

• [FLINK-36278] Reduce log size by avoiding container logs by default

  Show description for c0be7d5
  AHeise

  committed
  c0be7d5

Commits on Sep 19, 2024

• [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState (#116)

  Show description for 52e7e58
  xiaochen-zhou

  authored
  52e7e58

Commits on Sep 17, 2024

• [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition on split reader (#100)

  Show description for 122a743
  dongwoo6kim

  authored
  122a743

Commits on Sep 12, 2024

• [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode (#117)

  Show description for 7929b16
  xiaochen-zhou

  authored
  7929b16

Commits on Sep 6, 2024

• [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks (#109)

  Show description for 3730005
  klam-shop

  authored
  3730005

Commits on Aug 30, 2024

• [FLINK-36176] Remove support for Kafka 0.1 (#115)

  Show description for 268f6b5
  AHeise

  authored
  268f6b5

• [FLINK-35886] Leave a note for future Flink 2.0 upgrade

  Show description for 020bc33
  pnowojski

  committed
  020bc33

Commits on Aug 22, 2024

• [FLINK-33201][Connectors/Kafka] Fix memory leak in CachingTopicSelector

  

  qbx2

  authored and

  AHeise

  committed
  ea3a641

Commits on Aug 21, 2024

• [FLINK-36083][docs] Fix kafka table api doc's Connector Options table broken. (#112)

  GOODBOY008

  authored
  b5b8076

Pagination

PreviousNext