如何在spark中使用org.slf4j.Logger？

我正试图用org.slf4j.Logger spark。如果我写如下，我将得到错误non-static field cannot be referenced from a static context。因为该方法main是静态的，但是logger非静态的。

import org.apache.spark.api.java.*;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.function.Function;
import org.apache.spark.broadcast.Broadcast;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class simpleApp {

private final Logger logger = LoggerFactory.getLogger(getClass());

public static void main(String[] args) {
    String logFile = "/user/beibei/zhaokai/spark_java/a.txt"; // Should be some file on your system
    SparkConf conf = new SparkConf().setAppName("Simple Application");
    JavaSparkContext sc = new JavaSparkContext(conf);
    JavaRDD<String> logData = sc.textFile(logFile).cache();

    logger.info("loading graph from cache");

    long numAs = logData.filter(new Function<String, Boolean>() {
        public Boolean call(String s) { return s.contains("a"); }
    }).count();

    long numBs = logData.filter(new Function<String, Boolean>() {
        public Boolean call(String s) { return s.contains("t"); }
    }).count();

    System.out.println("Lines with a: " + numAs + ", lines with t: " + numBs);
}

}
但是，如果我写的如下。我会得到另一个

错误线程“main”中的异常org.apache.spark.SparkException：任务不可序列化。

因为Class of Class simpleApp不可序列化。

import org.apache.spark.api.java.*;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.function.Function;
import org.apache.spark.broadcast.Broadcast;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class simpleApp {

private final Logger logger = LoggerFactory.getLogger(getClass());

public static void main(String[] args) {
    new simpleApp().start();
}

private void start() {
    String logFile = "/path/a.txt"; // Should be some file on your system
    SparkConf conf = new SparkConf().setAppName("Simple Application");
    JavaSparkContext sc = new JavaSparkContext(conf);
    JavaRDD<String> logData = sc.textFile(logFile).cache();

    logger.info("loading graph from cache");

    long numAs = logData.filter(new Function<String, Boolean>() {
        public Boolean call(String s) { return s.contains("a"); }
    }).count();

    long numBs = logData.filter(new Function<String, Boolean>() {
        public Boolean call(String s) { return s.contains("t"); }
    }).count();

    System.out.println("Lines with a: " + numAs + ", lines with t: " + numBs);
}

}
如果我想使用其他类似的软件包org.slf4j.Logger，我会遇到同样的问题吗？