Commits

Branch selector

 master

User selector

echauchot

Datepicker

All time

Commit History

Commits on Nov 29, 2023

• [hotfix][doc] improve comments in archunit.properties

  echauchot

  committed
  667d3a4

Commits on Nov 10, 2023

• [FLINK-33059][connectors][doc] Update website docs

  echauchot

  committed
  4ccb2f6

• [FLINK-33059][connectors][format][filesystem] Some FileInputFormats don't use FileInputFormat#createSplits. If input files are compressed, ensure that the size of the split is not the compressed fi…

  Show description for e9bf48f
  echauchot

  committed
  e9bf48f

• [FLINK-33059][connectors][format][filesystem] Generalize compression test to all compression formats

  echauchot

  committed
  b75338e

• [FLINK-33059][connectors][format][filesystem] Set FileInputSplit length based on splittability

  echauchot

  committed
  5125263

Commits on Oct 26, 2023

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

  

  echauchot

  authored and

  1996fanrui

  committed
  3ff225c

Commits on Jun 12, 2023

• [FLINK-31806] Fix public API rule for connectors and update the violations

  echauchot

  committed
  28abe81

• [hotfix] Update archunit violations

  echauchot

  committed
  0225714

Commits on May 12, 2023

• [FLINK-31749][hotfix][doc] Fix HadoopInputFormat example code for DataStream

  echauchot

  committed
  b7154f2

• [FLINK-31749][hotfix][doc] Remove unavailable HadoopOutputFormat for DataStream

  echauchot

  committed
  ab5f25f

Commits on May 11, 2023

• [FLINK-32014][doc][hotfix] Add Cassandra source documentation to website (apache#22569)

  echauchot

  authored
  5310760

Commits on Mar 14, 2023

• [FLINK-30802][connectors] Document that SplitReader#fetch() may interrupt&resume

  echauchot

  authored
  17b805b

Commits on Mar 8, 2023

• [FLINK-30113] Implement state compression for broadcast and regular operator states (apache#21636)

  Show description for d04d727
  echauchot

  authored
  d04d727

Commits on Jul 18, 2022

• [FLINK-28198][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (apache#20184)

  Show description for 7cdf0e6
  echauchot

  authored
  7cdf0e6

Commits on Jul 13, 2022

• [FLINK-27884][connectors] Move OutputFormatBase to flink-core

  echauchot

  authored
  85a5e1d

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

  committed
  729da7d

Commits on Jun 16, 2022

• [FLINK-26824][cassandra] Upgrade driver to 3.11.2

  echauchot

  authored
  15f18db

Commits on Jun 8, 2022

• [FLINK-27457][cassandra] Implement flush() logic in output formats

  echauchot

  authored
  5b6394b

Commits on Mar 15, 2022

• [FLINK-25771][cassandra][tests] Remove keyspace drop

  Show description for 3bb6fa3
  echauchot

  authored
  3bb6fa3

Commits on Mar 9, 2022

• [FLINK-25771][cassandra][tests] Raise client timeouts

  echauchot

  authored
  d0d97cb

Commits on Mar 7, 2022

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

  Show description for ccbb05e
  

  echauchot

  authored and

  XComp

  committed
  ccbb05e

Commits on Feb 21, 2022

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

  

  echauchot

  authored and

  zentol

  committed
  8488368

• [FLINK-25851][build][tests] Bump bytebuddy to 1.8.22

  

  echauchot

  authored and

  zentol

  committed
  bbd5682

Commits on Feb 14, 2022

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

  

  echauchot

  authored and

  fapaul

  committed
  bfd3fde

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

  committed
  3144fae

• [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts

  

  echauchot

  authored and

  fapaul

  committed
  9d44bc0

• [FLINK-25147][connectors][Cassandra][test] Use parent test containers version

  

  echauchot

  authored and

  fapaul

  committed
  c5483c6

Commits on Jan 21, 2022

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

  

  echauchot

  authored and

  zentol

  committed
  6c84a5b

• [FLINK-25674][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test

  

  echauchot

  authored and

  zentol

  committed
  153bb9b

Commits on Dec 29, 2021

• [FLINK-25415] Add retries to CasandraConnectorITCase

  Show description for 3071f5c
  

  echauchot

  authored and

  tillrohrmann

  committed
  3071f5c

• [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests.

  

  echauchot

  authored and

  tillrohrmann

  committed
  cb73172

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

Commits on Dec 17, 2021

• [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers

  echauchot

  authored
  c4b10ca

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

  committed
  a9c139a

Commits on Dec 2, 2021

• Address review comments

  

  echauchot

  authored and

  AHeise

  committed
  b2f1207

Pagination

PreviousNext