lib/wukong/streamer/base.rb in wukong-1.4.2 vs lib/wukong/streamer/base.rb in wukong-1.4.5

@@ -15,10 +15,10 @@
 
       #
       # Pass each record to +#process+
       #
       def stream
-        Log.info("Streaming on:\t%s" % [Script.input_file])
+        Log.info("Streaming on:\t%s" % [Script.input_file]) unless Script.input_file.blank?
         before_stream
         $stdin.each do |line|
           record = recordize(line.chomp)
           next unless record
           process(*record) do |output_record|