gbraes
gbraes
I have also tried to disable it using logging_level='warn' in Ray.init ```python import ray import raydp from pyspark import SparkContext, SparkConf, SQLContext configs = {} ray.init(logging_level='warn') sc = raydp.init_spark(app_name='RayDP stream...
Hi @kira-lin , I have tested using my own `log4j.properties` file where I set up the log level to `warn`. After adding that extra java option where I point to...
Thank you, @kira-lin . I have changed to Ray 1.8 and RayDP 0.4.1 and still failing... This is the code that is failing: ```python import ray import raydp from pyspark...
Hi, I finally made it works: I changed Ray to 1.12 and RayDP 0.4.2. Also I used directly the sparksession without sqlContext: ```python import ray import raydp from pyspark import...
Hi @kira-lin, no the sqlContext issue is not a problem at the moment as the Sparksession is the more modern recommended way of create pipelines. I have seen that there...