Google Git
Sign in
apache/flink-connector-cassandra/HEAD
  1. bbc8019 [FLINK-38485] Make setup and teardown (test environment start/stop, tables creation, test data insertion) global for the whole test case instead of once per test to avoid too long test run. by Etienne Chauchot · 5 months ago main
  2. 1b94f6e [FLINK-38485] Upgrade testContainers to v1.20.2 which is compiled with a commons-compress version closer to the one flink uses and keep commons-compress transitive dep exclusion to favor flink's. by Etienne Chauchot · 5 months ago
  3. 84c3fa0 [FLINK-37937] Rebase on main and reference cassandraContainer1 instead of cassandraContainer by Etienne Chauchot · 6 months ago
  4. 191e50a [FLINK-37937] Deal with timeouts: put consistency level to ONE to be coherent between read and write request because CL=ANY in write requests could lead to hint writes that would be invisible to subsequent read requests. Raise write request timeout to the same timeout as read request. Put replication factor to 2 to deal with temporary down cassandra container. by Etienne Chauchot · 6 months ago
  5. e53d28a [FLINK-37937] Improve start/stop for the 2-container cluster. by Etienne Chauchot · 6 months ago
  6. eb10f9e [FLINK-37937] Make estimatedTableSize calculated during split preparation accessible to tests and not call estimate_size during tests. In refreshSizeEstimates wait until system.size_estimates has at least a row that has non-null mean_partition_size by Etienne Chauchot · 7 months ago
  7. c8dcb55 [FLINK-37937] upgrade to latest cassandra 4.x. reformat by Etienne Chauchot · 7 months ago
  8. df6a40b [FLINK-37937] change timeouts using cassandra.yaml instead of java options that are not interpreted by Cassandra cluster by Etienne Chauchot · 7 months ago
  9. 4441649 [FLINK-37937] Use nodetool refreshsizeestimates in addition to flush to update size estimates: flush updates the SSTables and refreshsizeestimates updates the size estimates based on them by Etienne Chauchot · 7 months ago
  10. ebbc218 [FLINK-37937] Add a node to Cassandra testContainers cluster by Etienne Chauchot · 7 months ago
  11. cc478e2 [FLINK-26823] [Connector] [Cassandra] Added Cassandra Table Source Implementation by Poorvank · 8 months ago
  12. dbb4ceb [FLINK-38034] Added WriteAheadSinkTestBase to Cassandra Repo by Poorvank · 8 months ago
  13. 19bca45 [FLINK-38042] Warn the user on full table scans: introduce QueryValidator and migrate unit test in integration test to use the cluster. by Etienne Chauchot · 8 months ago
  14. 7b03ece [FLINK-38048] Remove java 8 from ci workflows by Etienne Chauchot · 8 months ago
  15. 986fda5 [FLINK-37513] Test that fields and table names can contain prohibited string literals as we are validating queries regexp using function calls now. by Etienne Chauchot · 9 months ago
  16. 910e8f9 [FLINK-37513]. CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP fix by Maciej Bąk · 1 year, 1 month ago
  17. d9c2e0f [hotfix] split number is not calculated correctly as estimateTableSize is always zero by kan · 2 years, 2 months ago
  18. 997a12e [FLINK-35133][Connectors/Cassandra] Adding support for Flink 1.19 by Danny Cranmer · 1 year, 11 months ago
  19. 1f171fe [hotfix] exclude test containers from transitive deps for dependency convergence with Flink 1.17.2 by Etienne Chauchot · 2 years ago
  20. 506165b [hotfix] Improve archunit conf comments by Etienne Chauchot · 2 years ago
  21. 8881868 [FLINK-32353] Build on Flink 1.18.0 and refreeze archunit violations store. Test connector on 1.17.2 and 1.18.0. Skip archunit tests on 1.17.2 by Etienne Chauchot · 2 years ago
  22. 4d35e8b [hotfix] Fix: move back to weekly.yml naming by Etienne Chauchot · 2 years ago
  23. c541f70 [hotfix] Update copyright year to 2024 by Hang Ruan · 2 years, 1 month ago
  24. 20c5f50 [hotfix] Updated CQL_PROHIBITED_CLAUSES_REGEXP to match the "ORDER BY" keyword instead of just "ORDER" by Nathan · 2 years, 4 months ago
  25. b95690f [hotfix] Update NOTICE files to reflect year 2023 by Hang Ruan · 2 years, 6 months ago
  26. 1f47d20 [hotfix] fix naming of nightly workflow by Etienne Chauchot · 2 years, 8 months ago
  27. 83e0ed0 [hotfix] Build against latest flink versions (1.17.1 and 1.16.2) by Etienne Chauchot · 2 years, 8 months ago
  28. ac6cf71 [FLINK-31923] Run nightly builds against multiple branches and Flink versions by Martijn Visser · 2 years, 9 months ago
  29. 4f1cdfa [FLINK-32222] Automatically flush outputStreams in serializers by Etienne Chauchot · 2 years, 9 months ago
  30. 7919a75 [FLINK-32222] avoid using non-public DataInputDeserializer and DataOutputSerializer. Remove overkill ThreadLocal cache. Update archunit violations by Etienne Chauchot · 2 years, 9 months ago
  31. 26112ba [FLINK-32014][doc][hotfix] Add Cassandra source documentation to website (#15) by Etienne Chauchot · 2 years, 10 months ago
  32. 6088c45 [FLINK-32014][hotfix][javadoc] Fix incorrect javadoc regarding maxSplitMemorySize and add numSplits computation information (#14) by Etienne Chauchot · 2 years, 10 months ago
  33. f8ac343 [FLINK-31698] Support both Flink 1.16 and Flink 1.17 to resolve failing nightly builds by MartijnVisser · 2 years, 11 months ago
  34. bff8331 [FLINK-31749] Use default clusterBuilder reporting configuration in the tests by Etienne Chauchot · 2 years, 10 months ago
  35. 275804c [FLINK-31749] Disable cassandra driver metrics as they are not integrated with Flink metrics by Etienne Chauchot · 2 years, 10 months ago
  36. 7d8942b [FLINK-31807] Include all test code in architecture tests by Chesnay Schepler · 2 years, 11 months ago
  37. 1b87943 [FLINK-31805] Avoid non-public APIs by Chesnay Schepler · 2 years, 11 months ago
  38. 96482aa [FLINK-28198] Integrate tests with CassandraTestEnvironment which manages the cassandra cluster container, session, retrials and timeouts. Cleaning by Etienne Chauchot · 2 years, 11 months ago
  39. a63379d [FLINK-31722] use cassandra driver provided guava as it already surfaces in the cassandra driver API. shade provided guava. by Etienne Chauchot · 3 years ago
  40. d2b569c [FLINK-31722] remove unneeded flink-shaded-force-shading dependency by Etienne Chauchot · 3 years ago
  41. 764fa31 [FLINK-31698][Connector/Cassandra] Set `japicmp.referenceVersion` to latest released version of the Cassandra connector by Martijn Visser · 3 years ago
  42. f0249e8 [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies from Flink 1.16.0 to Flink 1.17.0 / Flink 1.17.0-SNAPSHOT by Martijn Visser · 3 years ago
  43. d92dc8d [hotfix] Add release workflow to build against final versions by Danny Cranmer · 3 years ago
  44. 59a4509 [hotfix] Disable nighty dependency convergence (#4) by Danny Cranmer · 3 years ago
  45. a250223 [hotfix] Update to Apache flink-connector-parent pom. by Chesnay Schepler · 3 years ago
  46. 72e3bef [FLINK-26822] Add Cassandra Source by Etienne Chauchot · 3 years ago
  47. 6f83d22 [FLINK-30963][ci] Streamline binary URL configuration by Chesnay Schepler · 3 years, 1 month ago
  48. ebb0e6e [hotfix] Reuse workflow by Chesnay Schepler · 3 years, 3 months ago
  49. 693dc52 [hotfix][ci] Remove repo name from workflow files by Chesnay Schepler · 3 years, 3 months ago
  50. 46b1128 [hotfix][ci] Only run weekly in Apache repo by Chesnay Schepler · 3 years, 3 months ago
  51. 98528f0 [FLINK-30353][ci] Limit concurrency by Chesnay Schepler · 3 years, 3 months ago
  52. 77b088f [hotfix] Setup auto-linking by Chesnay Schepler · 3 years, 3 months ago
  53. 6954ffa Update version to 4.0-SNAPSHOT by Chesnay Schepler · 3 years, 3 months ago
  54. 2c2de84 [hotfix] Fix submodule by Chesnay Schepler · 3 years, 3 months ago
  55. 691e460 [FLINK-29982] Externalize flink-connector-cassandra by Etienne Chauchot · 3 years, 9 months ago
  56. 02ad03e [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5 by Sergey Nuyanzin · 3 years, 9 months ago
  57. 81898a7 [hotfix][cassandra][tests] Use CassandraTupleOutputFormat by Sergey Nuyanzin · 3 years, 6 months ago
  58. 37e6f1f Update version to 1.17-SNAPSHOT by huangxingbo · 3 years, 6 months ago
  59. 12bc41b [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files by Benchao Li · 3 years, 8 months ago
  60. 12d9d38 [FLINK-29017][docs] Replace all links to github master with shortcode by Ryan Skraba · 3 years, 7 months ago
  61. d58190e [FLINK-28198][connectors][cassandra] raise driver timeouts per session request and raise it higher than cluster side timetouts (#20184) by Etienne Chauchot · 3 years, 8 months ago
  62. d68afed [FLINK-27884][connectors] Move OutputFormatBase to flink-core by Etienne Chauchot · 3 years, 8 months ago
  63. ab9bb20 [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format. by Etienne Chauchot · 3 years, 9 months ago
  64. 6fa71e2 [FLINK-27964][python] Support Cassandra connector in Python DataStream API by Mingde Peng · 3 years, 9 months ago
  65. dd7f7d9 [FLINK-26824][cassandra] Upgrade driver to 3.11.2 by Etienne Chauchot · 3 years, 9 months ago
  66. 5e224bd [FLINK-27457][cassandra] Implement flush() logic in output formats by Etienne Chauchot · 3 years, 9 months ago
  67. 5a4e3e0 [FLINK-27779][connectors/cassandra] Remove `flink-table-planner` in favor of `flink-table-test-utils` by Alexander Preuß · 3 years, 10 months ago
  68. dc85408 [FLINK-27185][connector] Convert connector-cassandra module to assertj by Alexander Preuß · 3 years, 10 months ago
  69. 01bfc49 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 3 years, 11 months ago
  70. 00892d7 [FLINK-27390][build] Remove unused flink-tests dependencies by Chesnay Schepler · 3 years, 11 months ago
  71. 345e2d7 [FLINK-27229][cassandra][build] Remove test netty dependency by Chesnay Schepler · 3 years, 11 months ago
  72. 06eca8c [FLINK-27253][cassandra][build] Remove custom surefire config by Chesnay Schepler · 3 years, 11 months ago
  73. 6d16475 [FLINK-27225][build] Remove redundant reuseForks settings by Chesnay Schepler · 3 years, 11 months ago
  74. e7211cc [FLINK-27024][build] Cleanup surefire configuration by Chesnay Schepler · 4 years ago
  75. b332c8d [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100 by Yubin Li · 4 years ago
  76. ad5b459 [FLINK-25771][cassandra][tests] Remove keyspace drop by Etienne Chauchot · 4 years ago
  77. 271a3a6 Update version to 1.16-SNAPSHOT by Yun Gao · 4 years ago
  78. 97af88d [FLINK-25771][cassandra][tests] Raise client timeouts by Etienne Chauchot · 4 years ago
  79. 8fe36d0 [FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5 parallel tests by slinkydeveloper · 4 years ago
  80. b9ec0f0 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules by Jing Ge · 4 years ago
  81. 7a104d5 [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos by Etienne Chauchot · 4 years, 1 month ago
  82. 6658e50 [hotfix] Fix JUnit 5 mini cluster arch unit rules by Dawid Wysakowicz · 4 years, 1 month ago
  83. 1a971c9 [hotfix][build] Move one-off properties into using modules by Chesnay Schepler · 4 years, 1 month ago
  84. acf7b97 [FLINK-26054][build] Add enforcer rule to forbid direct dependency on table planner by Francesco Guardiani · 4 years, 1 month ago
  85. 4f6c078 [FLINK-25892][cassandra][test] add ArchUnit tests for test code by Jing Ge · 4 years, 1 month ago
  86. 065cdec [FLINK-25129][docs] Restructure project configuation pages by Daisy T · 4 years, 1 month ago
  87. f755756 [FLINK-25771][connectors][Cassandra][test] Add a test that raiseCassandraRequestsTimeouts indeed changes the configuration inside the container. by Etienne Chauchot · 4 years, 1 month ago
  88. ed03381 [FLINK-25771][connectors][Cassandra][test] Raise all read/write/miscellaneous requests timeouts by Etienne Chauchot · 4 years, 1 month ago
  89. 70ad121 [FLINK-25147][connectors][Cassandra][test] Use parent test containers version by Etienne Chauchot · 4 years, 1 month ago
  90. f5604b1 [FLINK-25776][build] sync netty versions by Chesnay Schepler · 4 years, 1 month ago
  91. 206486e [FLINK-25674][connectors][cassandra][tests] use constants instead of string literals to avoid copy/paste by Etienne Chauchot · 4 years, 2 months ago
  92. 3476cf9 [FLINK-25674][connectors][cassandra][tests] Add drop tables to be idempotent in case of retrials and the related test by Etienne Chauchot · 4 years, 2 months ago
  93. cb83648 [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings by Till Rohrmann · 4 years, 2 months ago
  94. b34172e [FLINK-25415] Add retries to CasandraConnectorITCase by Etienne Chauchot · 4 years, 2 months ago
  95. b3fe6d1 [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests. by Etienne Chauchot · 4 years, 2 months ago
  96. 195801c [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed. by Etienne Chauchot · 4 years, 2 months ago
  97. 5acf998 [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers by Etienne Chauchot · 4 years, 3 months ago
  98. bfa9633 [FLINK-24596][table] Allow using unified Sinks with the DataStreamSinkProvider by Fabian Paul · 4 years, 5 months ago
  99. d3260aa [FLINK-22775][cassandra][tests] Lower write consistency level to ANY by Etienne Chauchot · 4 years, 3 months ago
  100. 02cd92b [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 4 years, 4 months ago