[#547] ParallelWriter returns taskNotSerializable

# New features and improvements

None.

# Breaking changes

None.

# Migration

None.

# Bug fixes

Solves the taskNotSerializable thrown by the hot parallel write scenario.

# How this feature was tested

Existing unit tests.

# Related issue

Closes #547

Author: Aleksandar Milosevic

.gitlab-ci.yml

@@ -39,7 +39,9 @@ test-kernel:
   artifacts:
     reports:
       junit: 'test-output/*.xml'
-      cobertura: 'target/scala-2.*/coverage-report/cobertura.xml'
+      coverage_report:
+        coverage_format: cobertura
+        path: 'target/scala-2.*/coverage-report/cobertura.xml'
   tags:
     - gitlab-org
   only:
@@ -64,7 +66,9 @@ test-plugin:
   artifacts:
     reports:
       junit: 'test-output/*.xml'
-      cobertura: 'target/scala-2.*/coverage-report/cobertura.xml'
+      coverage_report:
+        coverage_format: cobertura
+        path: 'target/scala-2.*/coverage-report/cobertura.xml'
   tags:
     - gitlab-org
   only:
@@ -88,7 +92,9 @@ test-repo:
   artifacts:
     reports:
       junit: 'test-output/*.xml'
-      cobertura: 'target/scala-2.*/coverage-report/cobertura.xml'
+      coverage_report:
+        coverage_format: cobertura
+        path: 'target/scala-2.*/coverage-report/cobertura.xml'
   tags:
     - gitlab-org
   only:

plugin-parallel-write-spark/src/main/scala/it/agilelab/bigdata/wasp/consumers/spark/plugins/parallel/utils/MetastoreCatalogService.scala

@@ -9,7 +9,7 @@ import java.util.concurrent.ConcurrentHashMap
 import java.util.function
 import scala.util.{Failure, Success, Try}
 
-object MetastoreCatalogService extends DataCatalogService {
+object MetastoreCatalogService extends DataCatalogService with Serializable {
   private lazy val catalogCache: ConcurrentHashMap[String, CatalogTable] = new ConcurrentHashMap[String, CatalogTable]()
 
   def getSchema(sparkSession: SparkSession, entityCoordinates: CatalogCoordinates): StructType =