1. 33def8c Fix Redis documentation link to sadd (#94) by Xuebing Li · 5 days ago master
  2. 86cce39 BAHIR-240: replace docker test by testcontainer (#89) by Joao Boto · 13 days ago
  3. 6e872c7 Add zincrby command to Redis connector (#86) by lei_charles · 13 days ago
  4. e215544 Add batch table env support and filter push down to Kudu connector (#82) by Sebastian Liu · 4 weeks ago
  5. 8723e6b Remove @author tag based on Apache recommendation by Luciano Resende · 3 months ago
  6. e71c6e6 Update Redis connector with HINCRBY (#81) by lei_charles · 3 months ago
  7. 16b4b21 Kudu Connector rework (#78) by Márton Balassi · 3 months ago
  8. 8b6bbf9 Fix typo RedisVadidator -> RedisValidator (#80) by Ahoo Wang · 3 months ago
  9. ae9272b Bump Flink version to 1.10.0 by Marton Balassi · 4 months ago
  10. a58b454 [HOTFIX] Fix NPE on getAdditionalTTL (#77) by zhangmang · 4 months ago
  11. f86a478 [BAHIR-220] Add redis descriptor to enable connection as a table (#72) by hzyuemeng1 · 5 months ago
  12. 197af74 Use HTTPS instead of HTTP to resolve dependencies (#76) by Jonathan Leitschuh · 6 months ago
  13. d3bc0cb Fix NotSerializableException in Kudu connector (#74) by Darcy · 7 months ago
  14. ee4e8e6 Fix "the client has already been closed" bug (#75) by WangJ1an · 7 months ago
  15. cf8bf2b Add support "upsert part of columns of a kudu table" (#70) by Darcy · 8 months ago
  16. e097635 Bump fastjson from 1.2.16 to 1.2.25 in /flink-connector-netty (#69) by dependabot[bot] · 8 months ago
  17. 09a0556 Bump activemq.version in /flink-connector-activemq (#68) by dependabot[bot] · 8 months ago
  18. 05d5b92 Bump netty-all in /flink-connector-netty to 4.1.42.Final (#67) by dependabot[bot] · 9 months ago
  19. 03265df [BAHIR-155] TTL to HSET and SETEX command (#66) by Artur Magalhães · 10 months ago
  20. 55240a9 [BAHIR-214] Improve speed and solve eventual consistence issues (#64) by Joao Boto · 11 months ago
  21. cd18714 [BAHIR-215] Bump flink version to 1.9.0 (#65) by Joao Boto · 12 months ago
  22. 311eea1 [BAHIR-210] upgrade flink to 1.8.1 (#62) by Joao Boto · 12 months ago
  23. bdb39f3 [BAHIR-207] Add tests for scala 2.12 on travis (#59) by Joao Boto · 1 year, 1 month ago
  24. 7f1d6af [BAHIR-209] upgrade kudu version to 1.10.0 (#61) by Joao Boto · 1 year, 1 month ago
  25. 4f92704 [BAHIR-85] Enable changing additional key without restarting (#60) by Ton van Bart · 1 year, 1 month ago
  26. d14557f [BAHIR-205] Support password configuration for redis cluster by Like · 1 year, 2 months ago
  27. 2721320 Add missing placeholder for log message by liketic · 1 year, 3 months ago
  28. 2c90823 [BAHIR-200] Move tests from docker to kudu-test-utils (#49) by Joao Boto · 1 year, 3 months ago
  29. 92c7bb1 Update pom scm configuration by Luciano Resende · 1 year, 3 months ago
  30. 568bb5b [BAHIR-206] Update Flink to release 1.8.0 by eskabetxe · 1 year, 3 months ago
  31. 8dc8e7e [BAHIR-202] Improve KuduSink throughput using async FlushMode by SuXingLee · 1 year, 5 months ago
  32. dd02c6d [BAHIR-177] Fixes state recovery/size of the recovered queue by Dominik Wosin · 1 year, 4 months ago
  33. e5b1cae [BAHIR-190] Fixed premature exit on empty queue by Krystex · 1 year, 3 months ago
  34. c1310f5 [BAHIR-206] Revert back to Flink version 1.7.2 by Luciano Resende · 1 year, 3 months ago
  35. 86ad89f [BAHIR-206] bump flink version to 1.8.0 by eskabetxe · 1 year, 3 months ago
  36. 3f1b3ba [BAHIR-204] [activemq] ActiveMQ Source only emits previously unprocessed records now by Konstantin Knauf · 1 year, 4 months ago
  37. 45b6beb [BAHIR-199] Bump kudu version to 1.9.0 by Joao Boto · 1 year, 5 months ago
  38. 0467041 [BAHIR-198] Bump flink version to 1.7.2 by Joao Boto · 1 year, 5 months ago
  39. 603d4e0 [BAHIR-180] Improve eventual consistence for Kudu connector by eskabetxe · 1 year, 7 months ago
  40. 3098fc5 [BAHIR-197] Add RpcClient and FlumeSink to connector by ambition119 · 1 year, 6 months ago
  41. e12255a [BAHIR-196] Added scala 2.12 and updated plugins by eskabetxe · 1 year, 5 months ago
  42. cdaec61 [BAHIR-195] bump flink version to 1.7.1 by Joao Boto · 1 year, 6 months ago
  43. 2e6d743 [BAHIR-194] bump kudu version to 1.8.0 by Joao Boto · 1 year, 6 months ago
  44. a58ef9a [BAHIR-191] uddate flume version to 1.9.0 by eskabetxe · 1 year, 7 months ago
  45. 4edd80e Close obsolete PRs by Luciano Resende · 1 year, 7 months ago
  46. b07045e [BAHIR-189] Updated Siddhi Version to 4.3. by Dominik.Wosinski · 1 year, 7 months ago
  47. a17c3ec [BAHIR-179] Fail Docker integration tests silently by eskabetxe · 1 year, 7 months ago
  48. 34af7ef [BAHIR-188] update flink to 1.7.0 by Joao Boto · 1 year, 8 months ago
  49. 898e913 [BAHIR-178] Added option to create new InfluxDb database by Wojciech Luczkow · 1 year, 11 months ago
  50. f6c6362 Disable Flume tests that dependes on docker by Luciano Resende · 1 year, 9 months ago
  51. 72cbe80 [BAHIR-114] update flume to 1.8 and add some tests by Joao Boto · 2 years ago
  52. 8b10118 BAHIR-176: update flink to 1.6.0 and some cleaning by Joao Boto · 2 years ago
  53. c760e3c [BAHIR-99] kudu connector by Joao Boto · 2 years, 1 month ago
  54. ca795cc Correcting connector version in README.me by Anton Rudacov · 2 years, 2 months ago
  55. 58c55f3 [BAHIR-174] Removed using TypeInfoParser from flink-library-siddhi by Dominik.Wosinski · 2 years ago
  56. 567792b [BAHIR-173] Update Flink version to 1.5.1 by Dominik.Wosinski · 2 years, 1 month ago
  57. 55605cb [BAHIR-162] Stop publishing MD5 hash with releases by Luciano Resende · 2 years, 4 months ago
  58. 0eceb1d [BAHIR-156] Improved integration test cases by Aleksandr Chermenin · 2 years, 8 months ago
  59. 50f3f12 [BAHIR-144] Add flink-library-siddhi by Hao Chen · 2 years, 9 months ago
  60. 6a243f3 [BAHIR-145] Fix the JedisCluster function called when performing PFADD by Bang, Phiradet · 2 years, 9 months ago
  61. 4f0179a As per mailing list discussion, remove Java 7 by Robert Metzger · 2 years, 11 months ago
  62. f07276e [BAHIR-134] Add InfluxDb sink for flink stream by zhouhai02 · 3 years ago
  63. b580566 [BAHIR-129] Upgrade Flink version to 1.3.0 by zhouhai02 · 3 years ago
  64. 86c84d2 [maven-release-plugin] prepare for next development iteration by Luciano Resende · 3 years, 3 months ago
  65. 9350cb5 [maven-release-plugin] prepare release v1.0-rc5 by Luciano Resende · 3 years, 3 months ago v1.0-rc5
  66. 4db44f8 [BAHIR-118] Define scala version to use based on profiles by Luciano Resende · 3 years, 3 months ago
  67. 4eca1a2 [BAHIR-119] Extend Travis Ci profile to support Scala 2.10 and 2.11 by Luciano Resende · 3 years, 3 months ago
  68. 357c775 [maven-release-plugin] prepare for next development iteration by Luciano Resende · 3 years, 3 months ago
  69. 6cda707 [maven-release-plugin] prepare release v1.0-rc4 by Luciano Resende · 3 years, 3 months ago v1.0-rc4
  70. 8cc5252 [BAHIR-115] log4j.properties for ActiveMQ connector tests by Christian Kadner · 3 years, 4 months ago
  71. 0acc98c [BAHIR-112] Build Scala, enable Scalatest, enable Scalastyle by Christian Kadner · 3 years, 4 months ago
  72. 3f7223f [BAHIR-111] Update imports after FLINK-4707 by Christian Kadner · 3 years, 4 months ago
  73. 9188fd5 [MINOR] Tweaking assembly naming by Luciano Resende · 3 years, 4 months ago
  74. 48b1f6f [maven-release-plugin] prepare for next development iteration by Luciano Resende · 3 years, 4 months ago
  75. 447c215 [maven-release-plugin] prepare release v1.0-rc3 by Luciano Resende · 3 years, 4 months ago v1.0-rc3
  76. 5fbe12a [MINOR] Properly active scala 2.10 versus 2.11 by Luciano Resende · 3 years, 4 months ago
  77. e23fa65 [MINOR] Update expected extension on release script by Luciano Resende · 3 years, 4 months ago
  78. 4b86db1 [maven-release-plugin] prepare for next development iteration by Luciano Resende · 3 years, 4 months ago
  79. 6f1a5d1 [maven-release-plugin] prepare release v1.0-rc2 by Luciano Resende · 3 years, 4 months ago v1.0-rc2
  80. 0eec4fb [BAHIR-105] Fix expected distribution extension by Luciano Resende · 3 years, 4 months ago
  81. f606679 [maven-release-plugin] prepare for next development iteration by Luciano Resende · 3 years, 4 months ago
  82. 6c3a6ac [maven-release-plugin] prepare release v1.0-rc1 by Luciano Resende · 3 years, 4 months ago v1.0-rc1
  83. f51664b [MINOR] Remove hardcoded scala version from dependencies by Luciano Resende · 3 years, 4 months ago
  84. 109a76a [MINOR] Fix parent id typo by Luciano Resende · 3 years, 4 months ago
  85. 573edca [BAHIR-105] Add distribution module for Flink extensions by Luciano Resende · 3 years, 4 months ago
  86. 8e8371e [MINOR] Update supported signatures by Luciano Resende · 3 years, 4 months ago
  87. 84a43e9 [MINOR] Fix artifact version pattern by Luciano Resende · 3 years, 4 months ago
  88. 0f87c1e [MINOR] Update copyright years by Luciano Resende · 3 years, 4 months ago
  89. 016148d [MINOR] Remove auto-generated comments by Luciano Resende · 3 years, 4 months ago
  90. b21bd71 [BAHIR-96] Add release util scripts for Bahir Flink by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  91. 1304758 [BAHIR-95] Add ZREM to Redis commands by ariskk · 3 years, 5 months ago
  92. 3f18034 [BAHIR-91] Upgrade Flink version to 1.2.0 by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  93. 9f30688 [BAHIR-94] Add link to "Linking with Optional Modules" in READMEs by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  94. c06d9d7 [BAHIR-93] Correct all version strings to be 1.0-SNAPSHOT by Tzu-Li (Gordon) Tai · 3 years, 5 months ago
  95. a830077 [BAHIR-73][bahir-flink] flink-streaming-akka source connector by Subhobrata Dey · 3 years, 10 months ago
  96. 2d1225f [BAHIR-72] support netty: pushed tcp/http connector by shijinkui · 3 years, 10 months ago
  97. 6b0f682 [BAHIR-71] invalid jira link of bahir-flink README.md by shijinkui · 3 years, 10 months ago
  98. dd8dcbe [BAHIR-68] Add README.md documentation for Flink Extensions by Robert Metzger · 3 years, 10 months ago
  99. a105a7c BAHIR-59[AMQ] Fix constructor visibility and error messages (rmetzger) by tedyu · 4 years ago
  100. 1f839d5 [BAHIR-58] Add ActiveMQ connector by Robert Metzger · 4 years ago