Google Git
Sign in
apache / bahir-flink / HEAD
  1. 4a8f60f [BAHIR-324] Closing KuduReader at JobManager by Shimin Huang · 11 months ago master
  2. 3744457 [BAHIR-285] Redis: fix typo error in log message by Hyeonho Kim · 11 months ago
  3. cd8f61e [BAHIR-285] Redis: add srem command (#164) by Hyeonho Kim · 11 months ago
  4. a03fa8c [BAHIR-201] Redis: add hdel command by Hyeonho Kim · 11 months ago
  5. 176242c [BAHIR-308] Remove scala prefix where we can by Joao Boto · 1 year, 1 month ago
  6. aa0f5b1 [BAHIR-308] Bump flink version to 1.17.0 by Joao Boto · 1 year, 1 month ago
  7. 5f287b9 [BAHIR-308] Bump flink version to 1.16.1 by Joao Boto · 1 year, 2 months ago
  8. 06fe56a [BAHIR-308] Bump flink version to 1.15.3 by Joao Boto · 1 year, 2 months ago
  9. 017d418 [BAHIR-308] Remove support for scala 2.11 by Joao Boto · 1 year, 10 months ago
  10. c8b6f61 [BAHIR-283] Fix dropped elements on InfluxDbSink by dave · 2 years, 7 months ago
  11. 724e17c [BAHIR-321] Make KuduFilterInfo handle String literals by Balazs Varga · 1 year, 4 months ago
  12. 510a2b1 [BAHIR-315] Move SSL config to FlinkJedisConfigBase by Sebastian Ramirez · 1 year, 6 months ago
  13. c031420 [BAHIR-319] Remove travis support by Joao Boto · 1 year, 6 months ago
  14. ffb413f [BAHIR-304] Add gitBranch option to release script by Joao Boto · 1 year, 10 months ago
  15. 5c0017c [BAHIR-317] Bump flink version to 1.14.6 by Joao Boto · 1 year, 6 months ago
  16. f3b096e [BAHIR-317] Fix distribution parent version by Joao Boto · 1 year, 6 months ago
  17. 522624f [BAHIR-315] add support for SSL connection by netsi · 1 year, 7 months ago
  18. ef3d18b [BAHIR-315] update jedis dependency to 4.3.0 by netsi · 1 year, 7 months ago
  19. efd9520 [BAHIR-312] Add license header to README.md files by Joao Boto · 1 year, 9 months ago
  20. d7d3e5d [BAHIR-284] Add option to use token authentication for influxdb2 by dave · 2 years, 7 months ago
  21. 2853a74 [BAHIR-305] Kudu Flink SQL Support DynamicSource/Sink&LookupFunction by Joao Boto · 1 year, 9 months ago
  22. 379fc87 Bump httpclient to 4.5.13 by dependabot[bot] · 1 year, 10 months ago
  23. b84e49a Bump fastjson to 1.2.83 by dependabot[bot] · 1 year, 10 months ago
  24. a19cba4 [BAHIR-304] Fix release scripts by Joao Boto · 1 year, 10 months ago
  25. e05c6e1 [maven-release-plugin] prepare for next development iteration by Joao Boto · 1 year, 10 months ago
  26. 4c38ca5 [maven-release-plugin] prepare branch release-1.1 by Joao Boto · 1 year, 10 months ago
  27. 7b9891a [BAHIR-302] Group declaration of flink dependencies on parent pom by Joao Boto · 2 years ago
  28. 8df6f30 [BAHIR-304] Fix release scripts by Joao Boto · 2 years ago
  29. 6429023 [BAHIR-243] Change KuduTestHarness with TestContainers by Joao Boto · 3 years, 2 months ago
  30. 7e9dec5 [BAHIR-302] Add enforcers by Joao Boto · 2 years, 1 month ago
  31. 2913ab0 [BAHIR-302] Bump flink version to 1.14.4 by Joao Boto · 2 years, 1 month ago
  32. 8d6c320 Update log4j to 2.17.1 by Sergey Nuyanzin · 2 years, 4 months ago
  33. ad22ec6 BAHIR-296: Bump powermock to 1.7.4 by Joao Boto · 2 years, 4 months ago
  34. e138058 BAHIR-296: Unify mockito version to 1.10.19 by Joao Boto · 2 years, 4 months ago
  35. 2c55c38 BAHIR-296: Unify and bump testcontainers version to 1.16.2 by Joao Boto · 2 years, 4 months ago
  36. eebd786 [BAHIR-296] Unify log4j libs by Joao Boto · 2 years, 4 months ago
  37. c6a0cf0 [BAHIR-296] Bump apache version to 24 by Joao Boto · 2 years, 4 months ago
  38. a2bb55f [BAHIR-294] Bump log4j2 version to 2.17.0 by Ada Wong · 2 years, 4 months ago
  39. 26b976f [BAHIR-291] Bump flink version to 1.14.2 by Joao Boto · 2 years, 4 months ago
  40. 245ac2c [BAHIR-291] Bump flink to 1.14.0 (#136) by Roc Marshal · 2 years, 4 months ago
  41. b55e265 [BAHIR-293] Fix documentation tables by Joao Boto · 2 years, 5 months ago
  42. ea06bab [BAHIR-288] Add github actions by Joao Boto · 2 years, 5 months ago
  43. f299361 [BAHIR-280] Update siddhi to 5.1.19 by Joao Boto · 2 years, 7 months ago
  44. 809a588 [BAHIR-274] Add Flink InfluxDBv2.0 Connector by 1p4pk · 3 years, 5 months ago
  45. dabbb5f [hotfix] fix flume sink and utils test by raminqaf · 3 years ago
  46. 12ee9ca [BAHIR-270] Fix malformed artifactId (#122) by yiksanchan · 3 years, 1 month ago
  47. 47d6dc7 [BAHIR-260] Add kudu table writer config (#109) by hackergin · 3 years, 1 month ago
  48. b5c7e5d [BAHIR-247] Provide connection validation/idle testing for Flink-Redis Connector (#121) by yiksanchan · 3 years, 1 month ago
  49. bd63cb1 [BAHIR-269] Apache Pinot Connector Sink (#113) by mschroederi · 3 years, 1 month ago
  50. b618a77 [BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120) by yiksanchan · 3 years, 2 months ago
  51. cabee21 [BAHIR-267] Unify Redis commands builder (#119) by yiksanchan · 3 years, 2 months ago
  52. bfc09d3 [BAHIR-263] Update flink to 1.12.2 (#115) by Joao Boto · 3 years, 2 months ago
  53. abd9941 [BAHIR-263] Update flink version to 1.11.3 (#112) by cheegoday · 3 years, 2 months ago
  54. 464a08f [BAHIR-266] Redis - Fix java8 stream use (#117) by yiksanchan · 3 years, 2 months ago
  55. b4efa30 [BAHIR-264] Fix dependencies in flink-connector-redis (#116) by yiksanchan · 3 years, 2 months ago
  56. 9dcb7d6 [BAHIR-265] Fix Redis log messages (#118) by yiksanchan · 3 years, 2 months ago
  57. f968c81 [BAHIR-262] Add support to redis cluster password (#101) by ahern88 · 3 years, 2 months ago
  58. 567a887 [BAHIR-257] RedisDescriptorTest add TableFactory sql operate test (#108) by housezhang · 3 years, 3 months ago
  59. d169452 [BAHIR-254] Update Redis to remove usage of deprecated methods (#102) by housezhang · 3 years, 4 months ago
  60. f0b3e1e [BAHIR-241] Upgrade all connectors to Flink 1.11 (#99) by Gyula Fora · 3 years, 7 months ago
  61. ff681dc [BAHIR-245] Add git .asf.yaml file (#98) by Joao Boto · 3 years, 8 months ago
  62. 8a4cadc [BAHIR-244] Update travis dist to bionic (#97) by Joao Boto · 3 years, 8 months ago
  63. 33def8c Fix Redis documentation link to sadd (#94) by Xuebing Li · 3 years, 9 months ago
  64. 86cce39 BAHIR-240: replace docker test by testcontainer (#89) by Joao Boto · 3 years, 9 months ago
  65. 6e872c7 Add zincrby command to Redis connector (#86) by lei_charles · 3 years, 9 months ago
  66. e215544 Add batch table env support and filter push down to Kudu connector (#82) by Sebastian Liu · 3 years, 10 months ago
  67. 8723e6b Remove @author tag based on Apache recommendation by Luciano Resende · 4 years ago
  68. e71c6e6 Update Redis connector with HINCRBY (#81) by lei_charles · 4 years ago
  69. 16b4b21 Kudu Connector rework (#78) by Márton Balassi · 4 years ago
  70. 8b6bbf9 Fix typo RedisVadidator -> RedisValidator (#80) by Ahoo Wang · 4 years ago
  71. ae9272b Bump Flink version to 1.10.0 by Marton Balassi · 4 years ago
  72. a58b454 [HOTFIX] Fix NPE on getAdditionalTTL (#77) by zhangmang · 4 years, 1 month ago
  73. f86a478 [BAHIR-220] Add redis descriptor to enable connection as a table (#72) by hzyuemeng1 · 4 years, 1 month ago
  74. 197af74 Use HTTPS instead of HTTP to resolve dependencies (#76) by Jonathan Leitschuh · 4 years, 3 months ago
  75. d3bc0cb Fix NotSerializableException in Kudu connector (#74) by Darcy · 4 years, 3 months ago
  76. ee4e8e6 Fix "the client has already been closed" bug (#75) by WangJ1an · 4 years, 3 months ago
  77. cf8bf2b Add support "upsert part of columns of a kudu table" (#70) by Darcy · 4 years, 5 months ago
  78. e097635 Bump fastjson from 1.2.16 to 1.2.25 in /flink-connector-netty (#69) by dependabot[bot] · 4 years, 5 months ago
  79. 09a0556 Bump activemq.version in /flink-connector-activemq (#68) by dependabot[bot] · 4 years, 5 months ago
  80. 05d5b92 Bump netty-all in /flink-connector-netty to 4.1.42.Final (#67) by dependabot[bot] · 4 years, 6 months ago
  81. 03265df [BAHIR-155] TTL to HSET and SETEX command (#66) by Artur Magalhães · 4 years, 7 months ago
  82. 55240a9 [BAHIR-214] Improve speed and solve eventual consistence issues (#64) by Joao Boto · 4 years, 8 months ago
  83. cd18714 [BAHIR-215] Bump flink version to 1.9.0 (#65) by Joao Boto · 4 years, 8 months ago
  84. 311eea1 [BAHIR-210] upgrade flink to 1.8.1 (#62) by Joao Boto · 4 years, 8 months ago
  85. bdb39f3 [BAHIR-207] Add tests for scala 2.12 on travis (#59) by Joao Boto · 4 years, 10 months ago
  86. 7f1d6af [BAHIR-209] upgrade kudu version to 1.10.0 (#61) by Joao Boto · 4 years, 10 months ago
  87. 4f92704 [BAHIR-85] Enable changing additional key without restarting (#60) by Ton van Bart · 4 years, 10 months ago
  88. d14557f [BAHIR-205] Support password configuration for redis cluster by Like · 4 years, 11 months ago
  89. 2721320 Add missing placeholder for log message by liketic · 5 years ago
  90. 2c90823 [BAHIR-200] Move tests from docker to kudu-test-utils (#49) by Joao Boto · 5 years ago
  91. 92c7bb1 Update pom scm configuration by Luciano Resende · 5 years ago
  92. 568bb5b [BAHIR-206] Update Flink to release 1.8.0 by eskabetxe · 5 years ago
  93. 8dc8e7e [BAHIR-202] Improve KuduSink throughput using async FlushMode by SuXingLee · 5 years ago
  94. dd02c6d [BAHIR-177] Fixes state recovery/size of the recovered queue by Dominik Wosin · 5 years ago
  95. e5b1cae [BAHIR-190] Fixed premature exit on empty queue by Krystex · 5 years ago
  96. c1310f5 [BAHIR-206] Revert back to Flink version 1.7.2 by Luciano Resende · 5 years ago
  97. 86ad89f [BAHIR-206] bump flink version to 1.8.0 by eskabetxe · 5 years ago
  98. 3f1b3ba [BAHIR-204] [activemq] ActiveMQ Source only emits previously unprocessed records now by Konstantin Knauf · 5 years ago
  99. 45b6beb [BAHIR-199] Bump kudu version to 1.9.0 by Joao Boto · 5 years ago
  100. 0467041 [BAHIR-198] Bump flink version to 1.7.2 by Joao Boto · 5 years ago