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