PySpark code issue

Job ID: 32031152

Budget: $30 – $250 USD

I have a project which involves connection from a up-steam systems to down stream sub-systems and we have to decommission some of the upsteam-systems and assign the related connections to the sub-systems to a nearby upstream system. I have the code for it and there was an issue with it.. Need to fix it.
Related categories: Python Scala PySpark Big Data Apache Spark