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