tengine.sources = tengine
tengine.sources.tengine.type = exec
tengine.sources.tengine.command = tail -n +0 -F /data/log/tengine/access.log
tengine.sources.tengine.channels = file4log

tengine.sinks = hdfs4log
tengine.sinks.hdfs4log.type = hdfs
tengine.sinks.hdfs4log.channel = file4log
tengine.sinks.hdfs4log.serializer = avro_event
tengine.sinks.hdfs4log.hdfs.path = hdfs://hdfs.kisops.org:8020/flume/tengine
tengine.sinks.hdfs4log.hdfs.filePrefix = access
tengine.sinks.hdfs4log.hdfs.fileSuffix = .log
tengine.sinks.hdfs4log.hdfs.rollInterval = 3600
tengine.sinks.hdfs4log.hdfs.rollCouont = 3600
tengine.sinks.hdfs4log.hdfs.rollSize = 506870912
tengine.sinks.hdfs4log.hdfs.batchSize = 1048576
tengine.sinks.hdfs4log.hdfs.threadsPoolSize = 38
tengine.sinks.hdfs4log.hdfs.fileType = DataStream
tengine.sinks.hdfs4log.hdfs.writeFormat = Text

tengine.channels = file4log
tengine.channels.file4log.type = file
tengine.channels.file4log.capacity = 1048576
tengine.channels.file4log.transactionCapacity = 1048576
tengine.channels.file4log.checkpointDir = /data/log/hdfs
tengine.channels.file4log.dataDirs = /data/log/tengine