Commits

Commits on Nov 29, 2023

[hotfix][doc] improve comments in archunit.properties
echauchot
committedNov 29, 2023

Commits on Nov 10, 2023

Commits on Oct 26, 2023

[FLINK-21883 ][scheduler] Implement cooldown period for adaptive scheduler

echauchot
authored and
1996fanrui
committedOct 26, 2023

Commits on Jun 12, 2023

[FLINK-31806 ] Fix public API rule for connectors and update the violations
echauchot
committedJun 12, 2023
[hotfix] Update archunit violations
echauchot
committedJun 12, 2023

Commits on May 12, 2023

[FLINK-31749 ][hotfix][doc] Fix HadoopInputFormat example code for DataStream
echauchot
committedMay 12, 2023
[FLINK-31749 ][hotfix][doc] Remove unavailable HadoopOutputFormat for DataStream
echauchot
committedMay 12, 2023

Commits on May 11, 2023

[FLINK-32014 ][doc][hotfix] Add Cassandra source documentation to website (#22569 )
echauchot
committedMay 11, 2023

Commits on Mar 14, 2023

[FLINK-30802 ][connectors] Document that SplitReader#fetch() may interrupt&resume
echauchot
committedMar 14, 2023

Commits on Mar 8, 2023

[FLINK-30113 ] Implement state compression for broadcast and regular operator states (#21636 )
echauchot
committedMar 8, 2023

Commits on Jul 18, 2022

[FLINK-28198 ][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (#20184 )
echauchot
committedJul 18, 2022

Commits on Jul 13, 2022

[FLINK-27884 ][connectors] Move OutputFormatBase to flink-core
echauchot
committedJul 13, 2022

Commits on Jul 5, 2022

[FLINK-26793 ][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format.

echauchot
authored and
MartijnVisser
committedJul 5, 2022

Commits on Jun 16, 2022

[FLINK-26824 ][cassandra] Upgrade driver to 3.11.2
echauchot
committedJun 16, 2022

Commits on Jun 8, 2022

[FLINK-27457 ][cassandra] Implement flush() logic in output formats
echauchot
committedJun 8, 2022

Commits on Mar 15, 2022

[FLINK-25771 ][cassandra][tests] Remove keyspace drop
echauchot
committedMar 15, 2022

Commits on Mar 9, 2022

[FLINK-25771 ][cassandra][tests] Raise client timeouts
echauchot
committedMar 9, 2022

Commits on Mar 7, 2022

[FLINK-23843 ][runtime] Properly fail the job when SplitEnumeratorContext.runInCoordinatorThread() throws an exception.

echauchot
authored and
XComp
committedMar 7, 2022

Commits on Feb 21, 2022

[FLINK-25851 ][cassandra][tests] Inject dynamic table name into Pojos

echauchot
authored and
zentol
committedFeb 21, 2022
[FLINK-25851 ][build][tests] Bump bytebuddy to 1.8.22

echauchot
authored and
zentol
committedFeb 21, 2022

Commits on Feb 14, 2022

[FLINK-21407 ][docs][formats] Remove MongoDb connector as it is not supported on DataStream API.

echauchot
authored and
fapaul
committedFeb 14, 2022

Commits on Jan 31, 2022

[FLINK-25771 ][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container.

echauchot
authored and
fapaul
committedJan 31, 2022
[FLINK-25771 ][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

echauchot
authored and
fapaul
committedJan 31, 2022
[FLINK-25147 ][connectors][Cassandra][test] Use parent test containers version

echauchot
authored and
fapaul
committedJan 31, 2022

Commits on Jan 21, 2022

[FLINK-25674 ][connectors][cassandra][tests] use constants instead of string literals to avoid copy/paste

echauchot
authored and
zentol
committedJan 21, 2022
[FLINK-25674 ][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test

echauchot
authored and
zentol
committedJan 21, 2022

Commits on Dec 29, 2021

[FLINK-25415 ] Add retries to CasandraConnectorITCase

echauchot
authored and
tillrohrmann
committedDec 29, 2021
[FLINK-25147 ] add keyspace drop because the docker image is reused and modified by the tests.

echauchot
authored and
tillrohrmann
committedDec 29, 2021

Commits on Dec 27, 2021

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

echauchot
authored and
tillrohrmann
committedDec 27, 2021

Commits on Dec 17, 2021

[FLINK-25147 ][connectors][test] Migrate Cassandra connector tests to testContainers
echauchot
committedDec 17, 2021

Commits on Dec 8, 2021

[FLINK-24859 ][doc][formats] Make new formats name coherent: introduce previous names classes to indicate deprecation to the users

echauchot
authored and
AHeise
committedDec 8, 2021

Commits on Dec 2, 2021

Address review comments

echauchot
authored and
AHeise
committedDec 2, 2021