File tree Expand file tree Collapse file tree 2 files changed +13
-0
lines changed
spark-operator/src/main/java/org/apache/spark/k8s/operator Expand file tree Collapse file tree 2 files changed +13
-0
lines changed Original file line number Diff line number Diff line change 4242
4343import org .apache .spark .k8s .operator .client .KubernetesClientFactory ;
4444import org .apache .spark .k8s .operator .config .SparkOperatorConf ;
45+ import org .apache .spark .k8s .operator .config .SparkOperatorConfManager ;
4546import org .apache .spark .k8s .operator .config .SparkOperatorConfigMapReconciler ;
4647import org .apache .spark .k8s .operator .metrics .MetricsService ;
4748import org .apache .spark .k8s .operator .metrics .MetricsSystem ;
@@ -96,6 +97,11 @@ public SparkOperator() {
9697 this .sparkClusterSentinelManager = new SentinelManager <>();
9798 this .registeredOperators = new ArrayList <>();
9899 this .registeredOperators .add (registerSparkOperator ());
100+ if (SparkOperatorConf .LOG_CONF .getValue ()) {
101+ for (var entry : SparkOperatorConfManager .INSTANCE .getAll ().entrySet ()) {
102+ log .info ("{} = {}" , entry .getKey (), entry .getValue ());
103+ }
104+ }
99105 if (SparkOperatorConf .DYNAMIC_CONFIG_ENABLED .getValue ()) {
100106 this .registeredOperators .add (registerSparkOperatorConfMonitor ());
101107 }
Original file line number Diff line number Diff line change 3232/** Spark Operator Configuration options. */
3333@ Slf4j
3434public final class SparkOperatorConf {
35+ public static final ConfigOption <Boolean > LOG_CONF =
36+ ConfigOption .<Boolean >builder ()
37+ .key ("spark.logConf" )
38+ .description ("When enabled, operator will print configurations" )
39+ .typeParameterClass (Boolean .class )
40+ .defaultValue (false )
41+ .build ();
3542
3643 /** Name of the operator. */
3744 public static final ConfigOption <String > OPERATOR_APP_NAME =
You can’t perform that action at this time.
0 commit comments