Agreed. How does asynchronous communication relate to Spark Structured
streaming?
In the previous post of yours, you made your Spark to run on the driver in
a single JVM. You attempted to increase the number of executors to 3 after
submission of the job that (as Sean alluded to) would not
What do you mean by asynchronously here?
On Sun, Mar 26, 2023, 10:22 AM Emmanouil Kritharakis <
kritharakismano...@gmail.com> wrote:
> Hello again,
>
> Do we have any news for the above question?
> I would really appreciate it.
>
> Thank you,
>
>
Hello again,
Do we have any news for the above question?
I would really appreciate it.
Thank you,
--
Emmanouil (Manos) Kritharakis
Ph.D. candidate in the Department of Computer Science
Hello all,
The data is generated by the vendors, while some days, the data size will be
very huge, and it will overflow the default value of
spark.kryoserializer.buffer.max,
So how to calculate the spark.kryoserializer.buffer.max when the data size is
changed ahead of raising the exception
