bahir-flink.git
4 hours ago[BAHIR-312] Add license header to README.md files master
Joao Boto [Sat, 30 Jul 2022 15:45:39 +0000 (17:45 +0200)] 
[BAHIR-312] Add license header to README.md files

2 months ago[BAHIR-284] Add option to use token authentication for influxdb2
dave [Thu, 7 Oct 2021 13:12:23 +0000 (09:12 -0400)] 
[BAHIR-284] Add option to use token authentication for influxdb2

2 months ago[BAHIR-305] Kudu Flink SQL Support DynamicSource/Sink&LookupFunction
Joao Boto [Sun, 17 Jul 2022 12:30:01 +0000 (14:30 +0200)] 
[BAHIR-305] Kudu Flink SQL Support DynamicSource/Sink&LookupFunction

3 months agoBump httpclient to 4.5.13
dependabot[bot] [Wed, 6 Jul 2022 09:59:53 +0000 (09:59 +0000)] 
Bump httpclient to 4.5.13

Bumps httpclient from 4.5.2 to 4.5.13.

---
updated-dependencies:
- dependency-name: org.apache.httpcomponents:httpclient
  dependency-type: direct:development
...

Signed-off-by: dependabot[bot] <support@github.com>
3 months agoBump fastjson to 1.2.83
dependabot[bot] [Wed, 6 Jul 2022 09:58:17 +0000 (09:58 +0000)] 
Bump fastjson to 1.2.83

Bumps [fastjson](https://github.com/alibaba/fastjson) from 1.2.25 to 1.2.83.
- [Release notes](https://github.com/alibaba/fastjson/releases)
- [Commits](https://github.com/alibaba/fastjson/compare/1.2.25...1.2.83)

---
updated-dependencies:
- dependency-name: com.alibaba:fastjson
  dependency-type: direct:development
...

Signed-off-by: dependabot[bot] <support@github.com>
3 months ago[BAHIR-304] Fix release scripts
Joao Boto [Wed, 6 Jul 2022 09:53:33 +0000 (11:53 +0200)] 
[BAHIR-304] Fix release scripts

3 months ago[maven-release-plugin] prepare for next development iteration
Joao Boto [Thu, 16 Jun 2022 13:44:53 +0000 (15:44 +0200)] 
[maven-release-plugin] prepare for next development iteration

3 months ago[maven-release-plugin] prepare branch release-1.1
Joao Boto [Thu, 16 Jun 2022 13:44:14 +0000 (15:44 +0200)] 
[maven-release-plugin] prepare branch release-1.1

5 months ago[BAHIR-302] Group declaration of flink dependencies on parent pom
Joao Boto [Mon, 2 May 2022 18:00:15 +0000 (20:00 +0200)] 
[BAHIR-302] Group declaration of flink dependencies on parent pom

5 months ago[BAHIR-304] Fix release scripts
Joao Boto [Fri, 29 Apr 2022 20:51:12 +0000 (22:51 +0200)] 
[BAHIR-304] Fix release scripts

5 months ago[BAHIR-243] Change KuduTestHarness with TestContainers
Joao Boto [Thu, 11 Mar 2021 18:03:43 +0000 (19:03 +0100)] 
[BAHIR-243] Change KuduTestHarness with TestContainers

5 months ago[BAHIR-302] Add enforcers
Joao Boto [Mon, 28 Mar 2022 15:18:05 +0000 (17:18 +0200)] 
[BAHIR-302] Add enforcers

6 months ago[BAHIR-302] Bump flink version to 1.14.4
Joao Boto [Mon, 28 Mar 2022 11:29:29 +0000 (13:29 +0200)] 
[BAHIR-302] Bump flink version to 1.14.4

7 months agoUpdate log4j to 2.17.1
Sergey Nuyanzin [Tue, 4 Jan 2022 08:33:18 +0000 (09:33 +0100)] 
Update log4j to 2.17.1

There is another CVE-2021-44832 fixed

9 months agoBAHIR-296: Bump powermock to 1.7.4
Joao Boto [Mon, 27 Dec 2021 16:11:52 +0000 (17:11 +0100)] 
BAHIR-296: Bump powermock to 1.7.4

9 months agoBAHIR-296: Unify mockito version to 1.10.19
Joao Boto [Mon, 27 Dec 2021 15:36:32 +0000 (16:36 +0100)] 
BAHIR-296: Unify mockito version to 1.10.19

9 months agoBAHIR-296: Unify and bump testcontainers version to 1.16.2
Joao Boto [Mon, 27 Dec 2021 15:33:55 +0000 (16:33 +0100)] 
BAHIR-296: Unify and bump testcontainers version to 1.16.2

9 months ago[BAHIR-296] Unify log4j libs
Joao Boto [Sun, 26 Dec 2021 18:39:56 +0000 (19:39 +0100)] 
[BAHIR-296] Unify log4j libs

9 months ago[BAHIR-296] Bump apache version to 24
Joao Boto [Sun, 26 Dec 2021 18:51:10 +0000 (19:51 +0100)] 
[BAHIR-296] Bump apache version to 24

9 months ago[BAHIR-294] Bump log4j2 version to 2.17.0
Ada Wong [Wed, 15 Dec 2021 13:18:50 +0000 (21:18 +0800)] 
[BAHIR-294] Bump log4j2 version to 2.17.0

9 months ago[BAHIR-291] Bump flink version to 1.14.2
Joao Boto [Sun, 26 Dec 2021 17:35:44 +0000 (18:35 +0100)] 
[BAHIR-291] Bump flink version to 1.14.2

9 months ago[BAHIR-291] Bump flink to 1.14.0 (#136)
Roc Marshal [Sun, 26 Dec 2021 17:27:08 +0000 (01:27 +0800)] 
[BAHIR-291] Bump flink to 1.14.0 (#136)

9 months ago[BAHIR-293] Fix documentation tables
Joao Boto [Tue, 7 Dec 2021 10:09:26 +0000 (11:09 +0100)] 
[BAHIR-293] Fix documentation tables

10 months ago[BAHIR-288] Add github actions
Joao Boto [Fri, 26 Nov 2021 19:32:20 +0000 (20:32 +0100)] 
[BAHIR-288] Add github actions

12 months ago[BAHIR-280] Update siddhi to 5.1.19
Joao Boto [Tue, 14 Sep 2021 14:43:17 +0000 (16:43 +0200)] 
[BAHIR-280] Update siddhi to 5.1.19

16 months ago[BAHIR-274] Add Flink InfluxDBv2.0 Connector
1p4pk [Sun, 6 Dec 2020 14:56:53 +0000 (15:56 +0100)] 
[BAHIR-274] Add Flink InfluxDBv2.0 Connector

Co-authored-by: Leon Papke <leonpapke@gmx.de>
Co-authored-by: Felix Seidel <felix@seidel.me>
16 months ago[hotfix] fix flume sink and utils test
raminqaf [Tue, 11 May 2021 16:01:33 +0000 (18:01 +0200)] 
[hotfix] fix flume sink and utils test

This closes #123

17 months ago[BAHIR-270] Fix malformed artifactId (#122)
yiksanchan [Wed, 7 Apr 2021 11:38:43 +0000 (04:38 -0700)] 
[BAHIR-270] Fix malformed artifactId (#122)

17 months ago[BAHIR-260] Add kudu table writer config (#109)
hackergin [Wed, 7 Apr 2021 11:35:07 +0000 (06:35 -0500)] 
[BAHIR-260] Add kudu table writer config  (#109)

17 months ago[BAHIR-247] Provide connection validation/idle testing for Flink-Redis Connector...
yiksanchan [Wed, 7 Apr 2021 11:24:01 +0000 (04:24 -0700)] 
[BAHIR-247] Provide connection validation/idle testing for Flink-Redis Connector (#121)

17 months ago[BAHIR-269] Apache Pinot Connector Sink (#113)
mschroederi [Wed, 7 Apr 2021 11:19:06 +0000 (13:19 +0200)] 
[BAHIR-269] Apache Pinot Connector Sink (#113)

18 months ago[BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120)
yiksanchan [Fri, 12 Mar 2021 08:16:37 +0000 (16:16 +0800)] 
[BAHIR-267] Fix FlinkJedisConfig names in toString methods (#120)

18 months ago[BAHIR-267] Unify Redis commands builder (#119)
yiksanchan [Fri, 12 Mar 2021 08:14:34 +0000 (16:14 +0800)] 
[BAHIR-267] Unify Redis commands builder (#119)

18 months ago[BAHIR-263] Update flink to 1.12.2 (#115)
Joao Boto [Fri, 12 Mar 2021 07:53:06 +0000 (08:53 +0100)] 
[BAHIR-263] Update flink to 1.12.2 (#115)

18 months ago[BAHIR-263] Update flink version to 1.11.3 (#112)
cheegoday [Thu, 11 Mar 2021 17:46:10 +0000 (01:46 +0800)] 
[BAHIR-263] Update flink version to 1.11.3 (#112)

BAHIR-263 - update flink version to 1.11.3
BAHIR-263 - fix netty connector unit test

18 months ago[BAHIR-266] Redis - Fix java8 stream use (#117)
yiksanchan [Thu, 11 Mar 2021 17:42:17 +0000 (01:42 +0800)] 
[BAHIR-266] Redis - Fix java8 stream use (#117)

18 months ago[BAHIR-264] Fix dependencies in flink-connector-redis (#116)
yiksanchan [Thu, 11 Mar 2021 17:37:41 +0000 (01:37 +0800)] 
[BAHIR-264] Fix dependencies in flink-connector-redis (#116)

* [BAHIR-264] Dedup dependencies
* [BAHIR-264] Change hardcode scala binary version 2.11

18 months ago[BAHIR-265] Fix Redis log messages (#118)
yiksanchan [Thu, 11 Mar 2021 17:35:24 +0000 (01:35 +0800)] 
[BAHIR-265] Fix Redis log messages (#118)

18 months ago[BAHIR-262] Add support to redis cluster password (#101)
ahern88 [Thu, 11 Mar 2021 12:59:12 +0000 (20:59 +0800)] 
[BAHIR-262] Add support to redis cluster password (#101)

* support set redis cluster password

20 months ago[BAHIR-257] RedisDescriptorTest add TableFactory sql operate test (#108)
housezhang [Fri, 22 Jan 2021 14:21:27 +0000 (22:21 +0800)] 
[BAHIR-257] RedisDescriptorTest add TableFactory sql operate test (#108)

Co-authored-by: house.zhang
20 months ago[BAHIR-254] Update Redis to remove usage of deprecated methods (#102)
housezhang [Mon, 11 Jan 2021 06:57:46 +0000 (14:57 +0800)] 
[BAHIR-254] Update Redis to remove usage of deprecated methods (#102)

RedisDescriptorTest that uses SQL or TAB API will run exception(flink1.11)
because use Deprecated method and field

Co-authored-by: house.zhang <>
2 years ago[BAHIR-241] Upgrade all connectors to Flink 1.11 (#99)
Gyula Fora [Thu, 24 Sep 2020 18:16:10 +0000 (20:16 +0200)] 
[BAHIR-241] Upgrade all connectors to Flink 1.11 (#99)

Co-authored-by: Gyula Fora <gyula@cloudera.com>
2 years ago[BAHIR-245] Add git .asf.yaml file (#98)
Joao Boto [Sat, 5 Sep 2020 03:22:36 +0000 (05:22 +0200)] 
[BAHIR-245] Add git .asf.yaml file (#98)

2 years ago[BAHIR-244] Update travis dist to bionic (#97)
Joao Boto [Thu, 27 Aug 2020 19:39:38 +0000 (21:39 +0200)] 
[BAHIR-244] Update travis dist to bionic (#97)

2 years agoFix Redis documentation link to sadd (#94)
Xuebing Li [Wed, 5 Aug 2020 07:17:07 +0000 (17:17 +1000)] 
Fix Redis documentation link to sadd (#94)

2 years agoBAHIR-240: replace docker test by testcontainer (#89)
Joao Boto [Tue, 28 Jul 2020 15:41:33 +0000 (17:41 +0200)] 
BAHIR-240: replace docker test by testcontainer (#89)

2 years agoAdd zincrby command to Redis connector (#86)
lei_charles [Tue, 28 Jul 2020 15:38:32 +0000 (23:38 +0800)] 
Add zincrby command to Redis connector (#86)

Co-authored-by: zhanglei <zhanglei@evergrande.com>
2 years agoAdd batch table env support and filter push down to Kudu connector (#82)
Sebastian Liu [Tue, 14 Jul 2020 03:25:44 +0000 (11:25 +0800)] 
Add batch table env support and filter push down to Kudu connector (#82)

Update the KuduTableSource to inherit from InputFormatTableSource
in order to support both streaming SQL and Batch SQL at the same time.
In order to reduce unnecessary data transmission, the filter push down
was also added to the KuduTableSource.

2 years agoRemove @author tag based on Apache recommendation
Luciano Resende [Wed, 27 May 2020 06:22:22 +0000 (23:22 -0700)] 
Remove @author tag based on Apache recommendation

2 years agoUpdate Redis connector with HINCRBY (#81)
lei_charles [Wed, 27 May 2020 06:14:55 +0000 (14:14 +0800)] 
Update Redis connector with HINCRBY (#81)

Update Redis connector with HINCRBY and repair
Redis Cluster example code

Co-authored-by: zhanglei <zhanglei@evergrande.com>
2 years agoKudu Connector rework (#78)
Márton Balassi [Tue, 19 May 2020 14:48:54 +0000 (16:48 +0200)] 
Kudu Connector rework (#78)

Kudu connector rework including the addition of a
connector to the Table API for it.

Co-authored-by: Gyula Fora <gyula@cloudera.com>
Co-authored-by: Balazs Varga <bvarga@cloudera.com>
2 years agoFix typo RedisVadidator -> RedisValidator (#80)
Ahoo Wang [Thu, 7 May 2020 17:23:41 +0000 (01:23 +0800)] 
Fix typo RedisVadidator -> RedisValidator (#80)

2 years agoBump Flink version to 1.10.0
Marton Balassi [Fri, 17 Apr 2020 12:42:54 +0000 (14:42 +0200)] 
Bump Flink version to 1.10.0

2 years ago[HOTFIX] Fix NPE on getAdditionalTTL (#77)
zhangmang [Tue, 7 Apr 2020 03:39:32 +0000 (11:39 +0800)] 
[HOTFIX] Fix NPE on getAdditionalTTL (#77)

Fix SetMapper to return Integer to avoid NPE as
`ttl` returns an Integer, but `getTtl()` returns an int.

2 years ago[BAHIR-220] Add redis descriptor to enable connection as a table (#72)
hzyuemeng1 [Sat, 14 Mar 2020 00:01:30 +0000 (08:01 +0800)] 
[BAHIR-220] Add redis descriptor to enable connection as a table (#72)

Add Redis table sink so we can register it to catalog,
and use Redis as a table in SQL environment

2 years agoUse HTTPS instead of HTTP to resolve dependencies (#76)
Jonathan Leitschuh [Tue, 11 Feb 2020 04:23:50 +0000 (23:23 -0500)] 
Use HTTPS instead of HTTP to resolve dependencies (#76)

This fixes a security vulnerability in this project where the `pom.xml`
files were configuring Maven to resolve dependencies over HTTP instead of
HTTPS.

Signed-off-by: Jonathan Leitschuh <Jonathan.Leitschuh@gmail.com>
2 years agoFix NotSerializableException in Kudu connector (#74)
Darcy [Sun, 19 Jan 2020 20:22:46 +0000 (04:22 +0800)] 
Fix NotSerializableException in Kudu connector (#74)

2 years agoFix "the client has already been closed" bug (#75)
WangJ1an [Sun, 19 Jan 2020 20:20:34 +0000 (04:20 +0800)] 
Fix "the client has already been closed" bug (#75)

Fix the problem "Caused by: java.lang.IllegalStateException:
Cannot proceed, the client has already been closed" when
running in Flink local mode

2 years agoAdd support "upsert part of columns of a kudu table" (#70)
Darcy [Fri, 29 Nov 2019 20:02:56 +0000 (04:02 +0800)] 
Add support "upsert part of columns of a kudu table" (#70)

Sometimes we don't want to upsert all columns of a kudu table.
So we need to support the function that upsert part of columns
of a kudu table.

2 years agoBump fastjson from 1.2.16 to 1.2.25 in /flink-connector-netty (#69)
dependabot[bot] [Fri, 29 Nov 2019 20:01:36 +0000 (12:01 -0800)] 
Bump fastjson from 1.2.16 to 1.2.25 in /flink-connector-netty (#69)

Bumps [fastjson](https://github.com/alibaba/fastjson) from 1.2.16 to 1.2.25.
- [Release notes](https://github.com/alibaba/fastjson/releases)
- [Commits](https://github.com/alibaba/fastjson/compare/1.2.16...1.2.25)

Signed-off-by: dependabot[bot] <support@github.com>
2 years agoBump activemq.version in /flink-connector-activemq (#68)
dependabot[bot] [Fri, 29 Nov 2019 20:01:11 +0000 (12:01 -0800)] 
Bump activemq.version in /flink-connector-activemq (#68)

Bumps `activemq.version` from 5.14.0 to 5.15.10.

Updates `activemq-client` from 5.14.0 to 5.15.10

Updates `activemq-junit` from 5.14.0 to 5.15.10

Updates `activemq-broker` from 5.14.0 to 5.15.10

Signed-off-by: dependabot[bot] <support@github.com>
2 years agoBump netty-all in /flink-connector-netty to 4.1.42.Final (#67)
dependabot[bot] [Fri, 1 Nov 2019 15:25:54 +0000 (08:25 -0700)] 
Bump netty-all in /flink-connector-netty to 4.1.42.Final (#67)

Bumps [netty-all](https://github.com/netty/netty) from 4.1.5.Final to 4.1.42.Final.
- [Release notes](https://github.com/netty/netty/releases)
- [Commits](https://github.com/netty/netty/compare/netty-4.1.5.Final...netty-4.1.42.Final)

Signed-off-by: dependabot[bot] <support@github.com>
2 years ago[BAHIR-155] TTL to HSET and SETEX command (#66)
Artur Magalhães [Fri, 11 Oct 2019 14:49:32 +0000 (11:49 -0300)] 
[BAHIR-155] TTL to HSET and SETEX command (#66)

- Adds Possibility to include TTL to a HASH in HSET operation.
- Adds SETEX command.

3 years ago[BAHIR-214] Improve speed and solve eventual consistence issues (#64)
Joao Boto [Tue, 3 Sep 2019 00:05:56 +0000 (02:05 +0200)] 
[BAHIR-214] Improve speed and solve eventual consistence issues (#64)

* resolve eventual consistency issues
* improve speed special on eventual consistency stream
* Update Readme

3 years ago[BAHIR-215] Bump flink version to 1.9.0 (#65)
Joao Boto [Mon, 26 Aug 2019 14:50:56 +0000 (16:50 +0200)] 
[BAHIR-215] Bump flink version to 1.9.0 (#65)

3 years ago[BAHIR-210] upgrade flink to 1.8.1 (#62)
Joao Boto [Wed, 21 Aug 2019 04:04:27 +0000 (06:04 +0200)] 
[BAHIR-210] upgrade flink to 1.8.1 (#62)

3 years ago[BAHIR-207] Add tests for scala 2.12 on travis (#59)
Joao Boto [Wed, 3 Jul 2019 22:13:51 +0000 (00:13 +0200)] 
[BAHIR-207] Add tests for scala 2.12 on travis (#59)

3 years ago[BAHIR-209] upgrade kudu version to 1.10.0 (#61)
Joao Boto [Wed, 3 Jul 2019 22:11:57 +0000 (00:11 +0200)] 
[BAHIR-209] upgrade kudu version to 1.10.0 (#61)

3 years ago[BAHIR-85] Enable changing additional key without restarting (#60)
Ton van Bart [Wed, 3 Jul 2019 22:11:15 +0000 (00:11 +0200)] 
[BAHIR-85] Enable changing additional key without restarting (#60)

We have a use case where we want to sink data to Redis as hashes but have the hashes stored under different keys which are also extracted from the data. This change makes this possible in a backward-compatible manner.

3 years ago[BAHIR-205] Support password configuration for redis cluster
Like [Sat, 8 Jun 2019 08:10:18 +0000 (16:10 +0800)] 
[BAHIR-205] Support password configuration for redis cluster

Upgrade jedis to 2.9.0 and add password for redis cluster sink.

Closes #57

3 years agoAdd missing placeholder for log message
liketic [Sat, 25 May 2019 14:01:02 +0000 (22:01 +0800)] 
Add missing placeholder for log message

3 years ago[BAHIR-200] Move tests from docker to kudu-test-utils (#49)
Joao Boto [Sun, 26 May 2019 00:45:25 +0000 (02:45 +0200)] 
[BAHIR-200] Move tests from docker to kudu-test-utils (#49)

3 years agoUpdate pom scm configuration
Luciano Resende [Sun, 19 May 2019 21:34:18 +0000 (23:34 +0200)] 
Update pom scm configuration

3 years ago[BAHIR-206] Update Flink to release 1.8.0
eskabetxe [Thu, 16 May 2019 13:57:17 +0000 (15:57 +0200)] 
[BAHIR-206] Update Flink to release 1.8.0

Closes #54

3 years ago[BAHIR-202] Improve KuduSink throughput using async FlushMode
SuXingLee [Fri, 22 Mar 2019 12:08:33 +0000 (20:08 +0800)] 
[BAHIR-202] Improve KuduSink throughput using async FlushMode

By default, KuduSink processing message one by one
without checkpoint. When checkoint is enabled, throughput
is improved by using FlushMode.AUTO_FLUSH_BACKGROUND,
and use checkpoint to ensure at-least-once.

Closes #50

3 years ago[BAHIR-177] Fixes state recovery/size of the recovered queue
Dominik Wosin [Mon, 1 Apr 2019 21:41:18 +0000 (23:41 +0200)] 
[BAHIR-177] Fixes state recovery/size of the recovered queue

Two issues are meant to be fixed in this PR:

- As described in BAHIR-177 currently the state recovery of
Bahir operators depends on randomly generated IDs, which
basically makes it impossible to recover state properly.
The chagne has been done, so that the outStreamId is
used instead of random names.

-The size of the queue recovered in restoreQueuerState()
was equal to the actual size (number of elements) of the
snapshot queue. If the queue was empty, the method would
try to create queue with the size 0, which is currently
forbidden for the PriorityQueue in Java.

Closes #51

3 years ago[BAHIR-190] Fixed premature exit on empty queue
Krystex [Thu, 9 May 2019 10:11:28 +0000 (12:11 +0200)] 
[BAHIR-190] Fixed premature exit on empty queue

When the source queue has no more messages, the job
doesn't exit anymore. This was a problem with ActiveMQ.

Closes #53

3 years ago[BAHIR-206] Revert back to Flink version 1.7.2
Luciano Resende [Fri, 17 May 2019 21:24:09 +0000 (23:24 +0200)] 
[BAHIR-206] Revert back to Flink version 1.7.2

This reverts commit 86ad89f4e9c0644a725673fdad8a5548ca837fcc.

3 years ago[BAHIR-206] bump flink version to 1.8.0
eskabetxe [Thu, 16 May 2019 13:57:17 +0000 (15:57 +0200)] 
[BAHIR-206] bump flink version to 1.8.0

Closes #54

3 years ago[BAHIR-204] [activemq] ActiveMQ Source only emits previously unprocessed records now
Konstantin Knauf [Thu, 11 Apr 2019 15:11:56 +0000 (17:11 +0200)] 
[BAHIR-204] [activemq] ActiveMQ Source only emits previously unprocessed records now

3 years ago[BAHIR-199] Bump kudu version to 1.9.0
Joao Boto [Thu, 7 Mar 2019 20:51:06 +0000 (21:51 +0100)] 
[BAHIR-199] Bump kudu version to 1.9.0

Closes #48

3 years ago[BAHIR-198] Bump flink version to 1.7.2
Joao Boto [Thu, 7 Mar 2019 20:47:56 +0000 (21:47 +0100)] 
[BAHIR-198] Bump flink version to 1.7.2

Closes #47

3 years ago[BAHIR-180] Improve eventual consistence for Kudu connector
eskabetxe [Tue, 15 Jan 2019 12:05:29 +0000 (13:05 +0100)] 
[BAHIR-180] Improve eventual consistence for Kudu connector

Closes #40

3 years ago[BAHIR-197] Add RpcClient and FlumeSink to connector
ambition119 [Fri, 1 Feb 2019 03:18:24 +0000 (11:18 +0800)] 
[BAHIR-197] Add RpcClient and FlumeSink to connector

Closes #42

3 years ago[BAHIR-196] Added scala 2.12 and updated plugins
eskabetxe [Thu, 7 Mar 2019 17:00:27 +0000 (18:00 +0100)] 
[BAHIR-196] Added scala 2.12 and updated plugins

Closes #46

3 years ago[BAHIR-195] bump flink version to 1.7.1
Joao Boto [Sun, 10 Feb 2019 22:41:47 +0000 (23:41 +0100)] 
[BAHIR-195] bump flink version to 1.7.1

Closes #45

3 years ago[BAHIR-194] bump kudu version to 1.8.0
Joao Boto [Sun, 10 Feb 2019 22:38:43 +0000 (23:38 +0100)] 
[BAHIR-194] bump kudu version to 1.8.0

Closes 44

3 years ago[BAHIR-191] uddate flume version to 1.9.0
eskabetxe [Tue, 15 Jan 2019 14:51:14 +0000 (15:51 +0100)] 
[BAHIR-191] uddate flume version to 1.9.0

Closes #41

3 years agoClose obsolete PRs
Luciano Resende [Tue, 15 Jan 2019 16:00:53 +0000 (08:00 -0800)] 
Close obsolete PRs

Closes #17

3 years ago[BAHIR-189] Updated Siddhi Version to 4.3.
Dominik.Wosinski [Mon, 14 Jan 2019 13:16:59 +0000 (14:16 +0100)] 
[BAHIR-189] Updated Siddhi Version to 4.3.

Closes #39

3 years ago[BAHIR-179] Fail Docker integration tests silently
eskabetxe [Wed, 9 Jan 2019 16:29:32 +0000 (17:29 +0100)] 
[BAHIR-179] Fail Docker integration tests silently

When running docker based integration tests locally,
fail silentily if env requirements not available.

Closes #38
Closes #35

3 years ago[BAHIR-188] update flink to 1.7.0
Joao Boto [Tue, 11 Dec 2018 20:04:23 +0000 (21:04 +0100)] 
[BAHIR-188] update flink to 1.7.0

Closes #36

3 years ago[BAHIR-178] Added option to create new InfluxDb database
Wojciech Luczkow [Tue, 18 Sep 2018 09:12:37 +0000 (11:12 +0200)] 
[BAHIR-178] Added option to create new InfluxDb database

Closes #34

3 years agoDisable Flume tests that dependes on docker
Luciano Resende [Wed, 7 Nov 2018 20:28:04 +0000 (12:28 -0800)] 
Disable Flume tests that dependes on docker

3 years ago[BAHIR-114] update flume to 1.8 and add some tests
Joao Boto [Wed, 22 Aug 2018 10:10:32 +0000 (12:10 +0200)] 
[BAHIR-114] update flume to 1.8 and add some tests

Closes #33

4 years agoBAHIR-176: update flink to 1.6.0 and some cleaning
Joao Boto [Wed, 22 Aug 2018 10:14:21 +0000 (12:14 +0200)] 
BAHIR-176: update flink to 1.6.0 and some cleaning

Closes #31
Closes #32

4 years ago[BAHIR-99] kudu connector
Joao Boto [Wed, 25 Jul 2018 18:17:36 +0000 (20:17 +0200)] 
[BAHIR-99] kudu connector

4 years agoCorrecting connector version in README.me
Anton Rudacov [Sat, 16 Jun 2018 18:56:00 +0000 (20:56 +0200)] 
Correcting connector version in README.me

Closes #28

4 years ago[BAHIR-174] Removed using TypeInfoParser from flink-library-siddhi
Dominik.Wosinski [Mon, 30 Jul 2018 08:04:46 +0000 (10:04 +0200)] 
[BAHIR-174] Removed using TypeInfoParser from flink-library-siddhi

Closes #30

4 years ago[BAHIR-173] Update Flink version to 1.5.1
Dominik.Wosinski [Fri, 20 Jul 2018 21:47:12 +0000 (23:47 +0200)] 
[BAHIR-173] Update Flink version to 1.5.1

Closes #29