SparkContext sc = repl.getSparkContext();
assertNotNull(SparkInterpreter.setupListeners(sc));
}
@Test
public void testCreateDataFrame() {
<BUG>if (getSparkVersionNumber() >= 13) {
</BUG>
repl.interpret("case class Person(name:String, age:Int)\n", context);
repl.interpret("val people = sc.parallelize(Seq(Person(\"moon\", 33), Person(\"jobs\", 51), Person(\"gates\", 51), Person(\"park\", 34)))\n", context);
repl.interpret("people.toDF.count", context);

SparkContext sc = repl.getSparkContext();
assertNotNull(SparkInterpreter.setupListeners(sc));
}
@Test
public void testCreateDataFrame() {
if (getSparkVersionNumber(repl) >= 13) {
repl.interpret("case class Person(name:String, age:Int)\n", context);
repl.interpret("val people = sc.parallelize(Seq(Person(\"moon\", 33), Person(\"jobs\", 51), Person(\"gates\", 51), Person(\"park\", 34)))\n", context);
repl.interpret("people.toDF.count", context);
