Here is the full message Exception has occurred: SparkConnectGrpcException
(java.io.IOException) Connection reset by peer
grpc._channel._MultiThreadedRendezvous: _MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.INTERNAL deta...
I figured out the error is hiding an underlying issue with the code, which you can get to if you deploy the bundle (if you are using asset bundles) and run from a notebook in a browser.So the issue is more about the debugger not being able to stop on...
Was getting errors trying to include the code. Here is my eighth attempt:for_each_batch_partial = partial(
for_each_batch,
spark=spark,
environment=config.environment,
kinesis_options=config.kinesis_options,
mongo_options=config.m...
I recently ran into this MetadataChangedException. Watching the video @Hubert Dudek posted it's pretty clear what is going on: object storage folks not thinking like someone who builds relational database engines built it. That's to be expected. Dat...
