UNSUBSCRIBE
Unsubscribe
Hi all,
I wrote an application that needs an environment variable. I can set this
variable with
--conf 'spark.executor.extraJavaOptions=-Dbasicauth=myuser:mypwd'
in spark-submit and it works well in standalone cluster mode.
But, I want set it inside the application code, because the variable
Hi,
I have a problem with Structured Streaming and Kafka.
I have 2 brokers and a topic with 8 partitions and replication factor 2.
This is my driver program:
public static void main(String[] args)
{
SparkSession spark = SparkSession
.builder()
