Google Git
Sign in
apache / flink-connector-jdbc / HEAD
  1. 02e86e3 [FLINK-28140][python][docs] Improve the documentation connector pages and metrics pages by Mingde Peng · 1 year, 10 months ago
  2. 947da1d [FLINK-19869][connectors/jdbc] Add support for postgres UUID type by Bobby Richard · 1 year, 11 months ago
  3. cf8496f [FLINK-28217] Bumps [mysql-connector-java](https://github.com/mysql/mysql-connector-j) from 8.0.27 to 8.0.29. by dependabot[bot] · 2 years ago
  4. 164930c [FLINK-27794][connectors/jdbc] Fix the wrong primary key for MysqlCatalog when there are tables with same name in different databases by dusukang · 1 year, 11 months ago
  5. 806b9d4 [FLINK-27185][connector] Convert connector-jdbc module to assertj by Alexander Preuß · 2 years, 1 month ago
  6. 9837826 [FLINK-27501][tests] Migrate SerializerTestBase to JUnit5 by Chesnay Schepler · 2 years ago
  7. 9ddc369 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 2 years, 1 month ago
  8. 6cbf588 [FLINK-27212][table-planner] Use UTF-8 encoding when casting between binary/character string by Marios Trivyzas · 2 years, 1 month ago
  9. 633efa0 [FLINK-27234][jdbc] Enable fork-reuse for unit tests by Chesnay Schepler · 2 years, 2 months ago
  10. c250af5 [FLINK-25926][Connectors][JDBC] Update org.postgresql:postgresql to 42.3.3. This required adding support for smallserial and applying changes after refactoring pgjdbc/pgjdbc#1194. PG's bytea[] now uses primitive arrays. This closes #18604 by MartijnVisser · 2 years, 2 months ago
  11. 64c1685 [FLINK-26709][table] Replace TableConfig.getConfiguration.set() by Marios Trivyzas · 2 years, 2 months ago
  12. d725fff [hotfix][docs]add the missing ending symbol ‘;’ by zoucao · 2 years, 3 months ago
  13. 45868bc [FLINK-26716][test][connectors/jdbc] Migrate PostgreSQL tests to Testcontainers by Alexander Fedulov · 2 years, 2 months ago
  14. 8834abe [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100 by Yubin Li · 2 years, 3 months ago
  15. 1111549 [hotfix][table] Replace TableConfig constructor with getDefault() by Marios Trivyzas · 2 years, 3 months ago
  16. d454d39 [FLINK-26551][table-planner] Change legacy casting config option to DISABLED by default by slinkydeveloper · 2 years, 3 months ago
  17. c1ec37e Update version to 1.16-SNAPSHOT by Yun Gao · 2 years, 3 months ago
  18. 4943cb1 [FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5 parallel tests by slinkydeveloper · 2 years, 3 months ago
  19. 7bf3488 [hotfix][tests] Add instructions for updating archunit stores by slinkydeveloper · 2 years, 3 months ago
  20. 3bc8075 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules by Jing Ge · 2 years, 3 months ago
  21. 5b41098 [hotfix] Fix JUnit 5 mini cluster arch unit rules by Dawid Wysakowicz · 2 years, 3 months ago
  22. 0ca170c [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure by Roc Marshal · 2 years, 4 months ago
  23. c94300e [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210 by martijnvisser · 2 years, 4 months ago
  24. 3cbfab6 [FLINK-22311] [connector/jdbc] Validate maxRetries for XA Sink by Maciej Bryński · 3 years ago
  25. bc2e3f9 [FLINK-25892][jdbc][test] add ArchUnit tests for test code by Jing Ge · 2 years, 4 months ago
  26. 28fdf05 [FLINK-25129][docs] Restructure project configuation pages by Daisy T · 2 years, 4 months ago
  27. dc073ce [FLINK-25391][connector-jdbc] Forward catalog table options by slinkydeveloper · 2 years, 5 months ago
  28. a28c041 [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem. by Roc Marshal · 2 years, 9 months ago
  29. a478d1c [FLINK-25351][annotations] Introduce `FlinkVersion` as a global enum by Marios Trivyzas · 2 years, 5 months ago
  30. 8d57f59 [FLINK-14100][jdbc] Introduce Oracle dialect for JDBC Connector by Joao Boto · 2 years, 7 months ago
  31. ab854a7 [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206 by martijnvisser · 2 years, 5 months ago
  32. 963f422 [FLINK-25239][connector/jdbc] delete useless variables by Ada Wong · 2 years, 6 months ago
  33. 7c29c07 [hotfix][docs] Fixing multiple 404 links in docs by martijnvisser · 2 years, 5 months ago
  34. 8738f20 [hotfix][jdbc] Fix method name typo in Postgres test by Ada Wong · 2 years, 5 months ago
  35. f6b2e03 [FLINK-23375][connector/jdbc] Build JDBC test jar. by Alexander Fedulov · 2 years, 6 months ago
  36. 1e8ba64 [FLINK-25229][table] Introduce flink-table-api-bridge-base by slinkydeveloper · 2 years, 6 months ago
  37. 17e6045 [hotfix][docs] Improve the description of JDBC docs (#17661) by mans2singh · 2 years, 6 months ago
  38. 01befa8 [FLINK-25060][table-common] Replace projection methods of FLINK-24399 with the new Projection util by slinkydeveloper · 2 years, 6 months ago
  39. 3ee75da [FLINK-24596][core] Introduce SerializableFunction and unify usages by Fabian Paul · 2 years, 6 months ago
  40. 5af11ed [FLINK-25065][docs] Update document for "lookup.cache.caching-missing-key" option for jdbc connector (#17918) by gaurav726 · 2 years, 6 months ago
  41. bed82b8 [FLINK-24861][connector][jdbc] Support to disable caching missing key for lookup cache (#17754) by gaurav726 · 2 years, 6 months ago
  42. bd262c8 [FLINK-24771][jdbc][tests] Bump test dependencies mariadb-java-client to 2.7.4 and mysql-connector-java to 8.0.27 by martijnvisser · 2 years, 7 months ago
  43. b175b51 [FLINK-24719][jdbc] Update Postgres test dependencies by martijnvisser · 2 years, 7 months ago
  44. 8920524 [FLINK-24747][table] Let SupportsProjectionPushDown#applyProjection provide the projected data type by slinkydeveloper · 2 years, 7 months ago
  45. 8d50344 [FLINK-24599][table] Replace static methods with convenient methods in LogicalType by Marios Trivyzas · 2 years, 7 months ago
  46. 30e4f57 [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 2 years, 7 months ago
  47. 1480468 [FLINK-24397][connectors/jdbc] Cleanup the Jdbc table connector by removing legacy by Fabian Paul · 2 years, 8 months ago
  48. 00a35ac [FLINK-24253][jdbc] move default implementations to AbstractDialect by sjwiesman · 2 years, 9 months ago
  49. 37b2c26 [FLINK-24253][jdbc] Cleanup JavaDoc of newly public interfaces by sjwiesman · 2 years, 9 months ago
  50. 576e7fc [FLINK-24253][jdbc] Mark Dialect as Public and move converter out of internal package by sjwiesman · 2 years, 9 months ago
  51. d632f98 [FLINK-24253][jdbc] Load Dialects via ServiceLoader by sjwiesman · 2 years, 9 months ago
  52. 7954b55 [FLINK-24253][jdbc] Migrate JDBC validation from TableSchema to DataType by sjwiesman · 2 years, 9 months ago
  53. 5b776b5 [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency by Roman Khachatryan · 2 years, 9 months ago
  54. bb36ba8 [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest by Roman Khachatryan · 2 years, 9 months ago
  55. 11bd793 [FLINK-23859] Fix typos by hapihu · 2 years, 9 months ago
  56. 0871b50 [FLINK-23854][datastream] Expose the restored checkpoint id in ManagedInitializationContext. by Arvid Heise · 2 years, 9 months ago
  57. 13b2df7 Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 9 months ago
  58. 43942c0 [FLINK-23776][docs] Clarify JDBC XA sink usage by Roman Khachatryan · 2 years, 9 months ago
  59. 6c582d0 [FLINK-23876][docs] Add JDBC XA DataSource examples by Roman Khachatryan · 2 years, 9 months ago
  60. 97db2d6 [hotfix][docs] Remove list of supported JDBC drivers by Roman Khachatryan · 2 years, 9 months ago
  61. 274d038 [FLINK-23909][connector-jdbc][scala-shell][yarn] Remove redundant variables and improve some style format in coding. by Roc Marshal · 2 years, 9 months ago
  62. c4e7262 [FLINK-23813][connectors/jdbc] Update delete executor in TableJdbcUpsertOutputFormat by Roman Khachatryan · 2 years, 9 months ago
  63. a2dcb97 [FLINK-23044][docs] Fix typos by hapihu · 2 years, 9 months ago
  64. 9cf0c1e [FLINK-23652][core/metrics] Extract Operator(IO)MetricGroup interfaces and expose them in RuntimeContext by Arvid Heise · 3 years ago
  65. 720d9f1 [hotfix][test/testcontainers] Use Testcontainer BOM to manage versions in the project by Qingsheng Ren · 2 years, 10 months ago
  66. bd02ff2 [FLINK-23644][build] Resolve maven warnings by Chesnay Schepler · 2 years, 10 months ago
  67. 2c56865 [FLINK-23437][jdbc] Add an option to (dis)allow XA transaction multiplexing by Roman Khachatryan · 2 years, 10 months ago
  68. 2b085be [hotfix][connector][jdbc] Corrected exception variable name (#16662) by mans2singh · 2 years, 10 months ago
  69. f22770c [FLINK-22889][tests] Log InnoDB details in JdbcExactlyOnceSinkE2eTest to ease debugging by Roman Khachatryan · 2 years, 11 months ago
  70. 187c4b7 [FLINK-22889][tests] Configure MySQL lock wait timeout in JdbcExactlyOnceSinkE2eTest by Roman Khachatryan · 2 years, 11 months ago
  71. a9f9720 [FLINK-22889][tests] Use LogLevelRule JdbcExactlyOnceSinkE2eTest by Roman Khachatryan · 2 years, 11 months ago
  72. 3c2bff0 [FLINK-23329][build] Bump flink-shaded to 14.0 by Chesnay Schepler · 2 years, 10 months ago
  73. 3b1f41d [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  74. bbc68fa [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink by Jan Brusch · 3 years, 3 months ago
  75. 7a05c85 [hotfix][connectors/jdbc] Rename JdbcDynamicOutputFormatBuilder to JdbcOutputFormatBuilder by Roman Khachatryan · 2 years, 10 months ago
  76. d10c0bb [hotfix][connectors/jdbc] Merge Batching and Abstract into JdbcOutputFormat by Roman Khachatryan · 2 years, 11 months ago
  77. 0129173 [hotfix][connectors/jdbc] Rename JdbcOutputFormat to JdbcRowOutputFormat by Roman Khachatryan · 2 years, 11 months ago
  78. 617a6df Revert "[FLINK-18783] Load Akka with separate classloader" by Piotr Nowojski · 2 years, 11 months ago
  79. 258d77d [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  80. cbc0e76 [FLINK-23064][connector-jdbc] Create PublicEvolving JdbcOptions by Ingo Bürk · 2 years, 11 months ago
  81. e76e614 [FLINK-22889] Add debug statements to JdbcExactlyOnceSinkE2eTest by Roman Khachatryan · 2 years, 11 months ago
  82. 61c478a [FLINK-22879][table] Rename flink-table-planner-blink to flink-table-planner by Timo Walther · 2 years, 11 months ago
  83. e3d82a0 [FLINK-21448] Add dependency for ChangelogStateBackend ITTests by Yangyang ZHANG · 3 years ago
  84. d535a28 [FLINK-22880][table] Remove 'blink' term from code base by Timo Walther · 3 years ago
  85. 719de26 [FLINK-22462][tests] Fix JdbcExactlyOnceSinkE2eTest by pausing emission until checkpoint confirmed by Roman Khachatryan · 2 years, 11 months ago
  86. 4937592 [FLINK-23084] Move Executors/-ThreadFactory to flink-core by Chesnay Schepler · 3 years ago
  87. ebf2703 [FLINK-22462][tests] Fix and harden JdbcExactlyOnceSinkE2eTest by Roman Khachatryan · 3 years, 1 month ago
  88. a633348 [FLINK-22462][connectors / jdbc] Fix XA connection leak by Roman Khachatryan · 3 years ago
  89. 94abd73 [FLINK-22744][docs] Update and simplify docs for EnvironmentSettings by Timo Walther · 3 years ago
  90. 5ec7721 [FLINK-22744][table] Update and simplify EnvironmentSettings by Timo Walther · 3 years ago
  91. 9d0e7ff [FLINK-22776][connector-jdbc] Delete unuseful casting to byte[] in AbstractJdbcRowConverter class by wuren · 3 years ago
  92. c3aa498 [FLINK-22889][tests] Ignore JdbcExactlyOnceSinkE2eTest temporarily by Roman Khachatryan · 3 years ago
  93. 0427df9 [FLINK-22822][connector-jdbc] Clean up flink-connector-jdbc's pom.xml by Timo Walther · 3 years ago
  94. a0a45f9 [FLINK-22782][docs] Remove legacy planner from Chinese docs by SteNicholas · 3 years ago
  95. 0ddc0a9 [FLINK-22740][docs] Drop legacy planner references in docs by Timo Walther · 3 years ago
  96. 198bba2 [FLINK-22471][connector-jdbc] Improve spelling and avoid repeating default values by Ingo Bürk · 3 years, 1 month ago
  97. f0699e3 [FLINK-22289] Update JDBC XA sink docs by Yuan Mei · 3 years, 1 month ago
  98. b9e6403 [hotfix][docs] Fix typo in jdbc execution options by Cemre Mengu · 3 years, 1 month ago
  99. ae28f9b [FLINK-22239][tests] Test JDBC XA Sink against PostgreSQL by Roman Khachatryan · 3 years, 1 month ago
  100. 7c42c11 [FLINK-22239][jdbc] Rollback XA transactions on recovery by Roman Khachatryan · 3 years, 1 month ago