diff --git a/lib/etl/control/source/database_source.rb b/lib/etl/control/source/database_source.rb
index <HASH>..<HASH> 100644
--- a/lib/etl/control/source/database_source.rb
+++ b/lib/etl/control/source/database_source.rb
@@ -172,7 +172,7 @@ module ETL #:nodoc:
       def query
         return @query if @query
         q = "SELECT #{select} FROM #{@table}"
-        q << " #{join}" if join
+        q << " JOIN #{join}" if join
         
         conditions = []
         if new_records_only
Fix for #<I> - source :join does not prepend 'join' in SQL query