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