Error: (45, 66) not found: the type SparkFlumeProtocol
Val transactionTimeout: Int, val backOffInterval: Int) extends SparkFlumeProtocol with Logging {
^
Error: (85, 13) not found: the type EventBatch
New EventBatch (" Spark sink has had stopped!" , "" Java. Util. Collections. EmptyList ())
^

CodePudding user response:

You should always use Maven to build the Spark first, then import into Intellij, then this problem is gone.