Google Git
Sign in
apache / flink-connector-gcp-pubsub / HEAD
  1. 725f3d6 [FLINK-35322][Connectors/Google PubSub] Remove weekly tests of 1.19 for unsupporting version v3.0 by Ahmed Hamdy · 2 weeks ago main
  2. 6be6d93 [FLINK-35135][Connectors/Google Cloud PubSub] Drop support for Flink 1.17 (#25) by Danny Cranmer · 5 weeks ago
  3. 952f296 [hotfix] Add jdk 17, 21 to ci, use dedicated name for ci by Sergey Nuyanzin · 6 weeks ago
  4. 1455ffe [hotfix] Drop support for Flink 1.16 and add support for 1.19, 1.20 by Sergey Nuyanzin · 6 weeks ago
  5. 5eace3c [hotfix] Update dependencies by Sergey Nuyanzin · 6 weeks ago
  6. 4c155b4 [hotfix][ci] Make CI against multiple Flink versions by Hang Ruan · 4 months ago
  7. b1b213c [hotfix] Update copyright year to 2024 by Hang Ruan · 4 months ago
  8. f5372f2 [FLINK-33018][Tests] Fix flaky test when cancelling source by Ryan Skraba · 9 months ago
  9. 4fdaca7 [FLINK-32031] Flink GCP Connector having issues with Conscrypt library by jjayadeep · 11 months ago
  10. d7ed02b [FLINK-30850][Tests] Prevent publishing E2E tests by Martijn Visser · 11 months ago
  11. cca2253 Update version to 3.1-SNAPSHOT by Martijn Visser · 11 months ago
  12. 01e1b6f [FLINK-31923] Run nightly builds against multiple branches and Flink versions by Martijn Visser · 12 months ago
  13. 4a07e32 [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml by Weijie Guo · 1 year, 1 month ago
  14. b356407 [hotfix] Fix incorrect artifact in zh doc. by Weijie Guo · 1 year ago
  15. 73fe434 [hotfix][Documentation] Correct the PubSubSink example. This closes #5 by weifonghsia · 1 year, 1 month ago
  16. 73ba11d [hotfix] Set copyright year to 2023 in NOTICE file by Martijn Visser · 1 year, 1 month ago
  17. 18e4dbc [FLINK-31759][pubsub] Using connector_artifact shortcode for datastream document. by Weijie Guo · 1 year, 2 months ago
  18. d2f32c1 [hotfix] Resolve dependency convergence on `junit-platform-commons` by Martijn Visser · 1 year, 2 months ago
  19. 9a1df8b [hotfix] To allow all Archunit rules to be evaluated without checking any classes by Martijn Visser · 1 year, 2 months ago
  20. ac51ce9 [hotfix] Test CI builds against Flink 1.17.0 instead of Flink 1.17-SNAPSHOT and run the weekly builds against 1.16-SNAPSHOT, 1.17-SNAPSHOT and 1.18-SNAPSHOT by Martijn Visser · 1 year, 2 months ago
  21. 4a0b156 [hotfix] Remove `archunit` to avoid issues with the weekly builds, given that the version of Archunit can differ between Flink versions. Instead, it will rely on `flink-architecture-tests-test` dependencies. by Martijn Visser · 1 year, 2 months ago
  22. 61f76b4 [hotfix] Set japicmp to latest released version for this connector by Martijn Visser · 1 year, 2 months ago
  23. 2c0e44f [hotfix] Update to Flink 1.17.0 by Martijn Visser · 1 year, 2 months ago
  24. f7e0327 [hotfix] Set correct groupId for `flink-connector-parent` by Martijn Visser · 1 year, 2 months ago
  25. 47404c4 [FLINK-30794][CI] Disable dependency convergence check for night connector builds by Martijn Visser · 1 year, 2 months ago
  26. d32b1f9 [hotfix] Allow manual triggering of nightly build by Martijn Visser · 1 year, 3 months ago
  27. 0537108 [FLINK-30963][ci] Streamline binary URL configuration by Chesnay Schepler · 1 year, 4 months ago
  28. f163009 [hotfix] Change Flink binary URL to ASF archive by Martijn Visser · 1 year, 4 months ago
  29. 7d8090b [FLINK-30872][Connector/Google PubSub] Move GCP example to GCP connector repository by Martijn Visser · 1 year, 4 months ago
  30. ca0dd1d Update version to 1.17-SNAPSHOT by huangxingbo · 1 year, 9 months ago
  31. 942a616 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 2 years, 1 month ago
  32. 824d973 Update version to 1.16-SNAPSHOT by Yun Gao · 2 years, 2 months ago
  33. 83174ac [FLINK-25039][build] Disable shading of test jar by default by Chesnay Schepler · 2 years, 6 months ago
  34. 2ae4629 [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 2 years, 7 months ago
  35. 1c9423f Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 9 months ago
  36. fcf58ac Update version to 1.14-SNAPSHOT by GuoWei Ma · 3 years, 1 month ago
  37. 977cff2 [FLINK-20651] Format code with Spotless/google-java-format by Rufus Refactor · 3 years, 5 months ago
  38. eaad434 Update version to 1.13-SNAPSHOT by Dian Fu · 3 years, 6 months ago
  39. 3cdd0ac [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies by Niels Basjes · 3 years, 11 months ago
  40. 62d4279 [FLINK-18607][build] Give the maven module a human readable name by Niels Basjes · 3 years, 10 months ago
  41. 55f84bd Update version to 1.12-SNAPSHOT by Piotr Nowojski · 4 years ago
  42. c93e10d Update version to 1.11-SNAPSHOT by Gary Yao · 4 years, 6 months ago
  43. 6f92e4f [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter by Richard Deurwaarder · 4 years, 10 months ago
  44. 1512bc1 Update version to 1.10-SNAPSHOT by Kurt Young · 4 years, 11 months ago
  45. 6c5cd55 [FLINK-9311] [pubsub] Improvements to builders + minor improvement to PubSubSink flush logic by Jiangjie (Becket) Qin · 5 years ago
  46. 9e02c4c [FLINK-9311] [pubsub] Clean up / add documentation and style issues in the PubSub connector by Richard Deurwaarder · 6 years ago
  47. c546198 [FLINK-30058][Connector/Google PubSub] Add release tools as submodule by Martijn Visser · 1 year, 4 months ago
  48. 7a2e541 [FLINK-30058][Build] Add Flink-style IntelliJ settings by Martijn Visser · 1 year, 6 months ago
  49. bb241f7 [FLINK-30058][Architecture] Add ProductionCodeArchitectureTest by Martijn Visser · 1 year, 6 months ago
  50. 55aa842 [FLINK-30058][Tests] Add DockerImageVersions by Martijn Visser · 1 year, 6 months ago
  51. e860c75 [FLINK-30058][Connector/Google PubSub] Move existing Google Cloud PubSub connector code from Flink repo to dedicated Google PubSub repo by Martijn Visser · 1 year, 6 months ago
  52. ed8610f [FLINK-24433][Tests][Buildsystem] Turn off debug logging for all end-to-end tests to avoid flooding the disk space by MartijnVisser · 2 years ago
  53. dc7c662 [FLINK-27937][tests][pubsub] Migrate flink-connectors-gcp-pubsub to JUnit5 by Sergey Nuyanzin · 1 year, 4 months ago
  54. cdb0f38 [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 2 years, 1 month ago
  55. 28c809c [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors" (#19483) by liuzhuang2017 · 2 years, 1 month ago
  56. 3e4c3fe [FLINK-27034][gcp][tests] Use testcontainers by Chesnay Schepler · 2 years, 2 months ago
  57. 562b5c4 [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100 by Yubin Li · 2 years, 3 months ago
  58. e612b32 Update version to 1.16-SNAPSHOT by Yun Gao · 2 years, 2 months ago
  59. 1ada07b [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question by Yufei Zhang · 2 years, 3 months ago
  60. c3aae7e [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules by Jing Ge · 2 years, 3 months ago
  61. cd7cd49 [hotfix] Fix JUnit 5 mini cluster arch unit rules by Dawid Wysakowicz · 2 years, 3 months ago
  62. 1671de8 [FLINK-25892][gcp-pubsub][test] add ArchUnit tests for test code by Jing Ge · 2 years, 4 months ago
  63. a5d7dc8 [FLINK-25129][docs] Restructure project configuation pages by Daisy T · 2 years, 4 months ago
  64. 1f9c82c [FLINK-25159][tests] Streamline E2E surefire setup by Chesnay Schepler · 2 years, 6 months ago
  65. 4e5babe [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 2 years, 7 months ago
  66. 9656f72 Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 9 months ago
  67. 23c51dd [FLINK-23652][core/metrics] Extract Operator(IO)MetricGroup interfaces and expose them in RuntimeContext by Arvid Heise · 3 years ago
  68. 4e8e84b [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  69. a817846 Revert "[FLINK-18783] Load Akka with separate classloader" by Piotr Nowojski · 2 years, 11 months ago
  70. 01df040 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 11 months ago
  71. ce030a1 [hotfix][docs] Fix variable name by adavis9592 · 2 years, 11 months ago
  72. 4963e90 [FLINK-23084] Move Executors/-ThreadFactory to flink-core by Chesnay Schepler · 3 years ago
  73. 8b30977 Update version to 1.14-SNAPSHOT by GuoWei Ma · 3 years, 1 month ago
  74. 1155ebe [hotfix][docs] Correct rendering of maven modules by Seth Wiesman · 3 years, 3 months ago
  75. 54d5905 [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo by Seth Wiesman · 3 years, 4 months ago
  76. c06e25a [FLINK-20651] Format code with Spotless/google-java-format by Rufus Refactor · 3 years, 5 months ago
  77. cfc4293 Update version to 1.13-SNAPSHOT by Dian Fu · 3 years, 6 months ago
  78. 032d137 [FLINK-19698] Move the CheckpointListener from flink-runtime to flink-core. by Jiangjie (Becket) Qin · 3 years, 7 months ago
  79. 45d9196 [FLINK-18363] Add user classloader to context in DeSerializationSchema by Dawid Wysakowicz · 3 years, 7 months ago
  80. c1518b5 [FLINK-19619][e2e] Pin CloudSDK version to have access to pubsub emulator in test by Robert Metzger · 3 years, 7 months ago
  81. 29c47fd [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies by Niels Basjes · 3 years, 11 months ago
  82. a7eec56 [FLINK-18607][build] Give the maven module a human readable name by Niels Basjes · 3 years, 10 months ago
  83. 648dce9 [FLINK-16572][e2e][pubsub] Acknowledge message in previous test by Robert Metzger · 4 years ago
  84. bf80cb0 [hotfix][pubsub] Use TestLogger by Robert Metzger · 4 years ago
  85. d0e5fc8 [FLINK-16572] Clean up PubSub connector e2e test by Robert Metzger · 4 years ago
  86. f89d069 Merge pull request #12301 from Xeli/FLINK-16572-logs by Richard Deurwaarder · 4 years ago
  87. ed0d5cc [FLINK-8871][checkpoint] Support to cancel checkpoing via notification on task side by Yun Tang · 4 years, 1 month ago
  88. 6a29a3b Update version to 1.12-SNAPSHOT by Piotr Nowojski · 4 years ago
  89. c16b5b9 [FLINK-17307] Add collector to deserialize in PubSub by Dawid Wysakowicz · 4 years, 1 month ago
  90. 5ea50cf [FLINK-17306] Call open of SerializationSchema in PubSub sink by Dawid Wysakowicz · 4 years, 1 month ago
  91. 3cd4c23 [FLINK-17306] Add open to PubSubDeserializationSchema by Dawid Wysakowicz · 4 years, 1 month ago
  92. f261be7 [FLINK-16572] [pubsub,e2e] Only acknowledge list of messages if the list is not empty + small style fixes (removal of uncommented code etc)] by Richard Deurwaarder · 4 years, 1 month ago
  93. e2536e1 [FLINK-15090][tests] Explicitly depend on flink-clients by tison · 4 years, 3 months ago
  94. 6f3bb77 [FLINK-15672][build][tests] Migrate test log4j configurations to log4j2 by Chesnay Schepler · 4 years, 4 months ago
  95. adb4a5d [FLINK-15672][build] Migrate to log4j2 by Chesnay Schepler · 4 years, 4 months ago
  96. fa543ee Update version to 1.11-SNAPSHOT by Gary Yao · 4 years, 6 months ago
  97. 1af4576 [FLINK-14654][logging] Fix various placeholder issues by Yun Tang · 4 years, 6 months ago
  98. d94f878 [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter by Richard Deurwaarder · 4 years, 10 months ago
  99. e665389 Update version to 1.10-SNAPSHOT by Kurt Young · 4 years, 11 months ago
  100. 58ea0ec [FLINK-9311] [pubsub] Improvements to builders + minor improvement to PubSubSink flush logic by Jiangjie (Becket) Qin · 5 years ago