Open ghost opened 2 years ago
i have written below code to my spark structured streaming program, but i doesnot print recommendation in driver log, why?
`var options: Map[String, String] = Map();
options += ("streamingLens.expectedMicroBatchSLAMillis" -> "30000");
options += ("streamingLens.reporter.intervalMinutes" -> "2");
val streamingLens = new StreamingLens(spark, options);`
i have written below code to my spark structured streaming program, but i doesnot print recommendation in driver log, why?
`var options: Map[String, String] = Map();
options += ("streamingLens.expectedMicroBatchSLAMillis" -> "30000");
options += ("streamingLens.reporter.intervalMinutes" -> "2");
val streamingLens = new StreamingLens(spark, options);`