keedio / flume-ng-sql-source

Flume Source to import data from SQL Databases
Apache License 2.0
264 stars 164 forks source link

revert the change of version 1.5.2: Fix bug: when using custom query … #97

Open riccosir opened 4 years ago

riccosir commented 4 years ago

#57 is not a bug.

For proper operation of Custom Query ensure that incremental field will be returned in the first position of the Query result.

read more...

This modification makes non incremental custom query almost unable to work properly. agent.sources.sql-source.custom.query=SELECT [cTime],[x],[y],[z] FROM [table] where cTime > '$@$' order by cTime agent.sources.sql-source.start.from=2019-12-09 00:00:00