org.apache.flume.FlumeException: Expected one source and got 0

flume-user | Carlotta Hicks | 2 years ago
  1. 0

    RE: Java API for Flume Agent

    flume-user | 2 years ago | Carlotta Hicks
    org.apache.flume.FlumeException: Expected one source and got 0
  2. 0

    Solved: Custom jar not loaded with flume service - clouder... - Cloudera Community

    cloudera.com | 6 months ago
    org.apache.flume.FlumeException: Unable to load source type: com.cloudera.flume.source.TwitterSource, class: com.cloudera.flume.source.TwitterSource at org.apache.flume.source.DefaultSourceFactory.getCl ass(DefaultSourceFactory.java:67) at org.apache.flume.source.DefaultSourceFactory.creat e(DefaultSourceFactory.java:40) at org.apache.flume.node.AbstractConfigurationProvide r.loadSources(AbstractConfigurationProvider.java:3 27) at org.apache.flume.node.AbstractConfigurationProvide r.getConfiguration(AbstractConfigurationProvider.j ava:102) at org.apache.flume.node.PollingPropertiesFileConfigu rationProvider$FileWatcherRunnable.run(PollingProp ertiesFileConfigurationProvider.java:140) at java.util.concurrent.Executors$RunnableAdapter.cal l(Executors.java:441) at java.util.concurrent.FutureTask$Sync.innerRunAndRe set(FutureTask.java:317) at java.util.concurrent.FutureTask.runAndReset(Future Task.java:150) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.access$101(ScheduledThreadPoolE xecutor.java:98) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.runPeriodic(ScheduledThreadPool Executor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.run(ScheduledThreadPoolExecutor .java:204)
  3. 0

    Flume startup problem | DeZyre

    dezyre.com | 1 year ago
    org.apache.flume.FlumeException: Unable to load source type: com.cloudera.flume.source.TwitterSource, class: com.cloudera.flume.source.TwitterSource
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    flume+kafka Client session timed out

    Stack Overflow | 1 year ago | Zaki Smith
    org.apache.flume.FlumeException: Flume append() failed. Exception follows. 865888 at org.apache.flume.clients.log4jappender.Log4jAppender.append (Log4jAppender.java:170) 865889 at org.apache.log4j.AppenderSkeleton.doAppend(AppenderSkeleton.java:251) 865890 at org.apache.log4j.helpers.AppenderAttachableImpl.appendLoopOnAppenders (AppenderAttachableImpl.java:66) 865891 at org.apache.log4j.Category.callAppenders(Category.java:206) 865892 at org.apache.log4j.Category.forcedLog(Category.java:391) 865893 at org.apache.log4j.Category.info(Category.java:666) 865894 at kafka.utils.Logging$class.info(Unknown Source) 865895 at kafka.consumer.SimpleConsumer.info(Unknown Source) 865896 at kafka.consumer.SimpleConsumer.liftedTree1$1(Unknown Source) 865897 at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$ $sendRequest(Unknown Source) 865898 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp $1.apply$mcV$sp(Unknown Source) 865899 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp $1.apply(Unknown Source) 865900 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp $1.apply(Unknown Source) 865901 at kafka.metrics.KafkaTimer.time(Unknown Source) 865902 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(Unknown Source) 865903 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(Unknown Source) 865904 at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(Unknown Source) 865905 at kafka.metrics.KafkaTimer.time(Unknown Source) 865906 at kafka.consumer.SimpleConsumer.fetch(Unknown Source) 865907 at kafka.server.AbstractFetcherThread.processFetchRequest(Unknown Source) 865908 at kafka.server.AbstractFetcherThread.doWork(Unknown Source)
  6. 0

    Flume startup problem | DeZyre

    dezyre.com | 8 months ago
    org.apache.flume.FlumeException: Unable to load source type: com.cloudera.flume.source.TwitterSource, class: com.cloudera.flume.source.TwitterSource

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. org.apache.flume.FlumeException

      Expected one source and got 0

      at org.apache.flume.agent.embedded.EmbeddedAgent.doConfigure()
    2. org.apache.flume
      EmbeddedAgent.configure
      1. org.apache.flume.agent.embedded.EmbeddedAgent.doConfigure(EmbeddedAgent.java:160)
      2. org.apache.flume.agent.embedded.EmbeddedAgent.configure(EmbeddedAgent.java:95)
      2 frames