Skip to content
This repository was archived by the owner on Jan 8, 2020. It is now read-only.

Commit 8a52564

Browse files
author
Luis Lázaro
committed
Merge branch 'develop'
# Conflicts: # pom.xml
2 parents aa71618 + 6131924 commit 8a52564

File tree

2 files changed

+17
-3
lines changed

2 files changed

+17
-3
lines changed

README.md

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,15 +29,15 @@ Download the official mysql jdbc driver and copy in libext flume plugins directo
2929
```
3030
$ wget https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.35.tar.gz
3131
$ tar xzf mysql-connector-java-5.1.35.tar.gz
32-
$ cp mysql-connector-java-5.1.35-bin.jar $FLUME_HOME/plugins.d/lib/sql-source/libext
32+
$ cp mysql-connector-java-5.1.35-bin.jar $FLUME_HOME/plugins.d/sql-source/libext
3333
```
3434

3535
##### Microsoft SQLServer
3636
Download the official Microsoft 4.1 Sql Server jdbc driver and copy in libext flume plugins directory:
3737
Download URL: https://www.microsoft.com/es-es/download/details.aspx?id=11774
3838
```
3939
$ tar xzf sqljdbc_4.1.5605.100_enu.tar.gz
40-
$ cp sqljdbc_4.1/enu/sqljdbc41.jar $FLUME_HOME/plugins.d/lib/sql-source/libext
40+
$ cp sqljdbc_4.1/enu/sqljdbc41.jar $FLUME_HOME/plugins.d/sql-source/libext
4141
```
4242

4343
##### IBM DB2
@@ -150,3 +150,8 @@ Special thanks
150150

151151
I used flume-ng-kafka to guide me (https://github.com/baniuyao/flume-ng-kafka-source.git).
152152
Thanks to [Frank Yao](https://github.com/baniuyao).
153+
154+
Version History
155+
---------------
156+
Actual stable version is 1.5.0 (compatible with Apache Flume 1.8.0)
157+
Previous stable version is 1.4.3 (compatible with Apache Flume prior to 1.7.0)

src/main/java/org/keedio/flume/source/SQLSource.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,16 @@
4545
* @author <a href="mailto:mvalle@keedio.com">Marcelo Valle</a>
4646
*/
4747
public class SQLSource extends AbstractSource implements Configurable, PollableSource {
48-
48+
@Override
49+
public long getBackOffSleepIncrement() {
50+
return 0;
51+
}
52+
53+
@Override
54+
public long getMaxBackOffSleepInterval() {
55+
return 0;
56+
}
57+
4958
private static final Logger LOG = LoggerFactory.getLogger(SQLSource.class);
5059
protected SQLSourceHelper sqlSourceHelper;
5160
private SqlSourceCounter sqlSourceCounter;

0 commit comments

Comments
 (0)