$ bin/flume-ng agent --conf conf/ -f conf/flume.conf -n
agent1
2012
-
03
-
16
16
:
36
:
11
,
918
(main)
[INFO - org.apache.flume.lifecycle.LifecycleSupervisor.start(LifecycleSupervisor.java:
58
)]
Starting lifecycle supervisor
1
2012
-
03
-
16
16
:
36
:
11
,
921
(main)
[INFO - org.apache.flume.node.FlumeNode.start(FlumeNode.java:
54
)]
Flume node starting - agent1
2012
-
03
-
16
16
:
36
:
11
,
926
(lifecycleSupervisor-
1
-
0
)
[INFO - org.apache.flume.node.nodemanager.DefaultLogicalNodeManager.start(DefaultLogicalNodeManager.java:
110
)]
Node manager starting
2012
-
03
-
16
16
:
36
:
11
,
928
(lifecycleSupervisor-
1
-
0
)
[INFO - org.apache.flume.lifecycle.LifecycleSupervisor.start(LifecycleSupervisor.java:
58
)]
Starting lifecycle supervisor
10
2012
-
03
-
16
16
:
36
:
11
,
929
(lifecycleSupervisor-
1
-
0
)
[DEBUG - org.apache.flume.node.nodemanager.DefaultLogicalNodeManager.start(DefaultLogicalNodeManager.java:
114
)]
Node manager started
2012
-
03
-
16
16
:
36
:
11
,
926
(lifecycleSupervisor-
1
-
1
)
[INFO - org.apache.flume.conf.file.AbstractFileConfigurationProvider.start(AbstractFileConfigurationProvider.java:
67
)]
Configuration provider starting
2012
-
03
-
16
16
:
36
:
11
,
930
(lifecycleSupervisor-
1
-
1
)
[DEBUG - org.apache.flume.conf.file.AbstractFileConfigurationProvider.start(AbstractFileConfigurationProvider.java:
87
)]
Configuration provider started
2012
-
03
-
16
16
:
36
:
11
,
930
(conf-file-poller-
0
)
[DEBUG - org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:
189
)]
Checking file:conf/flume.conf
for
changes
2012
-
03
-
16
16
:
36
:
11
,
931
(conf-file-poller-
0
)
[INFO - org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:
196
)]
Reloading configuration file:conf/flume.conf
2012
-
03
-
16
16
:
36
:
11
,
936
(conf-file-poller-
0
)
[DEBUG - org.apache.flume.conf.properties.FlumeConfiguration$AgentConfiguration.isValid(FlumeConfiguration.java:
225
)]
Starting validation of configuration
for
agent:
agent1, initial-configuration: AgentConfiguration[agent1]
SOURCES: {avro-source1=ComponentConfiguration[avro-source1]
CONFIG:
{port=
41414
,
channels=ch1, type=avro, bind=
0.0
.
0.0
}
RUNNER:
ComponentConfiguration[runner]
CONFIG:
{}
}
CHANNELS: {ch1=ComponentConfiguration[ch1]
CONFIG:
{type=memory}
}
SINKS: {log-sink1=ComponentConfiguration[log-sink1]
CONFIG:
{type=logger, channel=ch1}
RUNNER:
ComponentConfiguration[runner]
CONFIG:
{}
}
2012
-
03
-
16
16
:
36
:
11
,
936
(conf-file-poller-
0
)
[INFO - org.apache.flume.conf.properties.FlumeConfiguration.validateConfiguration(FlumeConfiguration.java:
119
)]
Post-validation flume configuration contains configuation
for
agents:
[agent1]
2012
-
03
-
16
16
:
36
:
11
,
937
(conf-file-poller-
0
)
[DEBUG - org.apache.flume.channel.DefaultChannelFactory.create(DefaultChannelFactory.java:
67
)]
Creating instance of channel ch1 type memory
2012
-
03
-
16
16
:
36
:
11
,
944
(conf-file-poller-
0
)
[DEBUG - org.apache.flume.source.DefaultSourceFactory.create(DefaultSourceFactory.java:
73
)]
Creating instance of source avro-source1, type avro
2012
-
03
-
16
16
:
36
:
11
,
957
(conf-file-poller-
0
)
[INFO - org.apache.flume.sink.DefaultSinkFactory.create(DefaultSinkFactory.java:
69
)]
Creating instance of sink log-sink1 typelogger
2012
-
03
-
16
16
:
36
:
11
,
963
(conf-file-poller-
0
)
[INFO - org.apache.flume.node.nodemanager.DefaultLogicalNodeManager.onNodeConfigurationChanged(DefaultLogicalNodeManager.java:
52
)]
Node configuration change:{ sourceRunners:{avro-source1=EventDrivenSourceRunner: { source:AvroSource: { bindAddress:
0.0
.
0.0
port:
41414
}
}} sinkRunners:{log-sink1=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor
@79f6f296
counterGroup:{
name:
null
counters:{}
} }} channels:{ch1=org.apache.flume.channel.MemoryChannel
@43b09468
}
}
2012
-
03
-
16
16
:
36
:
11
,
974
(lifecycleSupervisor-
1
-
1
)
[INFO - org.apache.flume.source.AvroSource.start(AvroSource.java:
122
)]
Avro source starting:AvroSource: { bindAddress:
0.0
.
0.0
port:
41414
}
2012
-
03
-
16
16
:
36
:
11
,
975
(Thread-
1
)
[DEBUG - org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:
123
)]
Polling sink runner starting
2012
-
03
-
16
16
:
36
:
12
,
352
(lifecycleSupervisor-
1
-
1
)
[DEBUG - org.apache.flume.source.AvroSource.start(AvroSource.java:
132
)]
Avro source started