Alexander Lorenz-Alten created FLUME-1222:
---------------------------------------------
Summary: rolling file sink "Directory may not be null"
(Preconditions check) error when a directory is set
Key: FLUME-1222
URL: https://issues.apache.org/jira/browse/FLUME-1222
Project: Flume
Issue Type: Bug
Components: Sinks+Sources
Affects Versions: v1.2.0
Reporter: Alexander Lorenz-Alten
Priority: Blocker
12/05/22 08:24:21 INFO lifecycle.LifecycleSupervisor: Starting lifecycle
supervisor 1
12/05/22 08:24:21 INFO node.FlumeNode: Flume node starting - agent1
12/05/22 08:24:21 INFO nodemanager.DefaultLogicalNodeManager: Node manager
starting
12/05/22 08:24:21 INFO lifecycle.LifecycleSupervisor: Starting lifecycle
supervisor 10
12/05/22 08:24:21 INFO properties.PropertiesFileConfigurationProvider:
Configuration provider starting
12/05/22 08:24:21 INFO properties.PropertiesFileConfigurationProvider:
Reloading configuration file:/flumeNG/test1.cnf
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:sink
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:log-sink1
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:sink
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:log-sink1
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:sink
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Processing:sink
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Added sinks: sink Agent: agent1
12/05/22 08:24:22 INFO conf.FlumeConfiguration: Post-validation flume
configuration contains configuration for agents: [agent1]
12/05/22 08:24:22 INFO properties.PropertiesFileConfigurationProvider: Creating
channels
12/05/22 08:24:23 INFO properties.PropertiesFileConfigurationProvider: created
channel ch1
12/05/22 08:24:23 INFO sink.DefaultSinkFactory: Creating instance of sink sink
typefile_roll
>>>>>>>> content of directory:null <<<<<<<<<<
12/05/22 08:24:23 ERROR properties.PropertiesFileConfigurationProvider: Failed
to load configuration data. Exception follows.
java.lang.IllegalArgumentException: Directory may not be nullnull
at
com.google.common.base.Preconditions.checkArgument(Preconditions.java:88)
at
org.apache.flume.sink.RollingFileSink.configure(RollingFileSink.java:85)
at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
at
org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.loadSinks(PropertiesFileConfigurationProvider.java:350)
at
org.apache.flume.conf.properties.PropertiesFileConfigurationProvider.load(PropertiesFileConfigurationProvider.java:223)
at
org.apache.flume.conf.file.AbstractFileConfigurationProvider.doLoad(AbstractFileConfigurationProvider.java:123)
at
org.apache.flume.conf.file.AbstractFileConfigurationProvider.access$300(AbstractFileConfigurationProvider.java:38)
at
org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:202)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at
java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:317)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:98)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:204)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Config:
agent1.channels.ch1.type = memory
agent1.sources.avro-source1.channels = ch1
agent1.sources.avro-source1.type = avro
agent1.sources.avro-source1.bind = 0.0.0.0
agent1.sources.avro-source1.port = 41414
agent1.sinks.log-sink1.channel = ch1
agent1.sinks.log-sink1.type = logger
agent1.sinks.sink.channel = ch1
agent1.sinks.sink.directory = /home/alex/test1/
agent1.sinks.sink.rollInterval=0
agent1.sinks.sink.type = file_roll
agent1.channels = ch1
agent1.sources = avro-source1
agent1.sinks = sink
I added System.out.print ("content of directory:" + directory +"\n"); indeed
the variable is empty.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
