Skip to content

Commit 8046b48

Browse files
committed
chore: Add spark.metrics.executorMetricsSource.enabled configuration
- Updated configuration files to include "spark.metrics.executorMetricsSource.enabled" set to "false" for improved metrics handling. - Ensured consistency across application and test configurations by aligning the settings in Constants.scala and application.conf. - Modified SparkSuite to reflect the new configuration, enhancing test environment setup.
1 parent a3207d2 commit 8046b48

3 files changed

Lines changed: 5 additions & 2 deletions

File tree

api/src/main/scala/io/github/datacatering/datacaterer/api/model/Constants.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,8 @@ object Constants {
288288
"spark.hadoop.fs.s3a.bucket.all.committer.magic.enabled" -> "true",
289289
"spark.hadoop.fs.hdfs.impl" -> "org.apache.hadoop.hdfs.DistributedFileSystem",
290290
"spark.hadoop.fs.file.impl" -> "com.globalmentor.apache.hadoop.fs.BareLocalFileSystem",
291-
"spark.sql.extensions" -> "io.delta.sql.DeltaSparkSessionExtension,org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions"
291+
"spark.sql.extensions" -> "io.delta.sql.DeltaSparkSessionExtension,org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions",
292+
"spark.metrics.executorMetricsSource.enabled" -> "false"
292293
)
293294

294295
//jdbc defaults

app/src/test/resources/application.conf

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,8 @@ runtime{
4040
"spark.hadoop.fs.s3a.bucket.all.committer.magic.enabled": "true",
4141
"spark.hadoop.fs.hdfs.impl": "org.apache.hadoop.hdfs.DistributedFileSystem",
4242
"spark.hadoop.fs.file.impl": "com.globalmentor.apache.hadoop.fs.BareLocalFileSystem",
43-
"spark.sql.extensions": "io.delta.sql.DeltaSparkSessionExtension,org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions"
43+
"spark.sql.extensions": "io.delta.sql.DeltaSparkSessionExtension,org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions",
44+
"spark.metrics.executorMetricsSource.enabled": "false"
4445
}
4546
}
4647

app/src/test/scala/io/github/datacatering/datacaterer/core/util/SparkSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ trait SparkSuite extends AnyFunSuite with BeforeAndAfterAll with BeforeAndAfterE
1414
.config("spark.sql.shuffle.partitions", "2")
1515
// .config("spark.ui.enabled", "false")
1616
.config("spark.sql.extensions", "org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions,io.delta.sql.DeltaSparkSessionExtension")
17+
.config("spark.metrics.executorMetricsSource.enabled", "false")
1718
.getOrCreate()
1819
}
1920

0 commit comments

Comments
 (0)