Commits

History for

Commits on Oct 18, 2022

[FLINK-28405][Connector/Kafka] Update Confluent Platform images used for testing to v7.2.2. This closes apache#20170
MartijnVisser
committedOct 18, 2022

Commits on Oct 6, 2022

[FLINK-29513][Connector/Kafka] Update Kafka to version 3.2.3 which contains certain security fixes
MartijnVisser
committedOct 6, 2022

Commits on Sep 5, 2022

Update version to 1.17-SNAPSHOT
HuangXingBo
committedSep 5, 2022

Commits on Aug 10, 2022

[FLINK-28060][kafka] Bump Kafka to 3.2.1
zentol
committedAug 10, 2022

Commits on Jun 18, 2022

[FLINK-28060][Connector/Kafka] Updated Kafka Clients to 3.1.1 to resolve the issue where Flink is unable to commit its offset back to Kafka in case of Kafka Broker becoming unavailable. This should…
MartijnVisser
committedJun 18, 2022

Commits on Apr 7, 2022

[FLINK-26011][avro-confluent-registry][test] add ArchUnit tests for the test code

JingGe
authored and
MartijnVisser
committedApr 7, 2022

Commits on Mar 25, 2022

[FLINK-26736][tests] Migrate flink-avro-confluent-registry to JUnit5
RyanSkraba
committedMar 25, 2022

Commits on Mar 14, 2022

Update version to 1.16-SNAPSHOT
gaoyunhaii
committedMar 14, 2022

Commits on Jan 25, 2022

[FLINK-25391][format-avro] Forward catalog table options

slinkydeveloper
authored and
twalthr
committedJan 25, 2022

Commits on Jan 14, 2022

[FLINK-25504][Kafka] Upgrade Confluent to v6.2.2 and Kafka-Client to 2.8.1

MartijnVisser
authored and
fapaul
committedJan 14, 2022

Commits on Dec 7, 2021

[FLINK-25114][table-runtime] Remove flink-scala dependency and scala suffix

slinkydeveloper
authored and
twalthr
committedDec 7, 2021

Commits on Dec 3, 2021

[FLINK-24687][table][connectors] Move FileSystemTableSink, FileSystemTableSource to flink-connector-files and columnar support to flink-table-common

slinkydeveloper
authored and
twalthr
committedDec 3, 2021

Commits on Dec 1, 2021

[FLINK-25060][table-common] Replace projection methods of FLINK-24399 with the new Projection util

slinkydeveloper
authored and
twalthr
committedDec 1, 2021

Commits on Nov 17, 2021

[FLINK-24776][table] Clarify DecodingFormat and introduce ProjectableDecodingFormat

slinkydeveloper
authored and
twalthr
committedNov 17, 2021

Commits on Aug 28, 2021

Update version to 1.15-SNAPSHOT
xintongsong
committedAug 28, 2021

Commits on Aug 10, 2021

[FLINK-23192][table] Move connector & format options to consistent packages

Airblader
authored and
twalthr
committedAug 10, 2021

Commits on Aug 2, 2021

[FLINK-23450][avro-confluent-registry] Set properties map for DebeziumAvroFormat
twalthr
committedAug 2, 2021

Commits on Jul 12, 2021

[FLINK-23064][format-avro][format-avro-confluent-registry] Expose config options as PublicEvolving

Airblader
authored and
twalthr
committedJul 12, 2021

Commits on Jul 6, 2021

[FLINK-22879][table] Rename flink-table-runtime-blink to flink-table-runtime
twalthr
committedJul 6, 2021

Commits on Jun 24, 2021

[FLINK-21229][docs] Update avro-confluent docs
twalthr
committedJun 24, 2021
[FLINK-21229][avro-confluent-registry] Add Confluent schema registry SSL support

Lars Bachmann
authored and
twalthr
committedJun 24, 2021
[FLINK-21229][avro-confluent-registry] Shorten RegistryAvroOptions
twalthr
committedJun 24, 2021

Commits on Apr 18, 2021

Update version to 1.14-SNAPSHOT
guoweiM
committedApr 18, 2021

Commits on Mar 23, 2021

[FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable
twalthr
committedMar 23, 2021

Commits on Jan 8, 2021

[FLINK-20321][formats] Fix NPE when using Avro/Json/Csv formats to deserialize null input (apache#14539 )

xuewang
and
Alex Wang
committedJan 8, 2021

Commits on Dec 28, 2020

[FLINK-20651] Format code with Spotless/google-java-format

Rufus Refactor
authored and
zentol
committedDec 28, 2020

Commits on Nov 26, 2020

Update version to 1.13-SNAPSHOT
dianfu
committedNov 26, 2020

Commits on Nov 8, 2020

[FLINK-18774][debezium-avro] Improve debezium-avro format implementation
wuchong
committedNov 8, 2020
[FLINK-18774][debezium-avro] Support debezium avro format

caozhen1937
authored and
wuchong
committedNov 8, 2020

Commits on Nov 6, 2020

[FLINK-18546] Upgrade to Kafka Schema Registry Client 5.5.2
dawidwys
committedNov 6, 2020

Commits on Nov 4, 2020

[FLINK-19849] Fix NOTICE files for 1.12 release
rmetzger
committedNov 4, 2020

Commits on Oct 29, 2020

[FLINK-19786][avro] Fix the nullability and precision for Avro format deserialization

danny0405
authored and
dawidwys
committedOct 29, 2020
[FLINK-19779][avro] Remove the "record_" field name prefix for Avro format deserialization

danny0405
authored and
dawidwys
committedOct 29, 2020

Commits on Oct 23, 2020

[hotfix][table-common] Avoid unnecessary casting when creating type information in sources and sinks
twalthr
committedOct 23, 2020

Commits on Oct 14, 2020

[FLINK-18999][table-common][table-planner-blink] Add isTemporary flag to table factory context

lirui-apache
authored and
JingsongLi
committedOct 14, 2020