File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed
spark/src/main/scala/org/apache/comet/rules Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -118,6 +118,16 @@ case class CometScanRule(session: SparkSession) extends Rule[SparkPlan] {
118
118
return withInfos(scanExec, fallbackReasons.toSet)
119
119
}
120
120
121
+ val encryptionEnabled : Boolean =
122
+ conf.getConfString(" parquet.crypto.factory.class" , " " ).nonEmpty &&
123
+ conf.getConfString(" parquet.encryption.kms.client.class" , " " ).nonEmpty
124
+
125
+ if (scanImpl != CometConf .SCAN_NATIVE_COMET && encryptionEnabled) {
126
+ fallbackReasons +=
127
+ " Full native scan disabled because encryption is not supported"
128
+ return withInfos(scanExec, fallbackReasons.toSet)
129
+ }
130
+
121
131
val typeChecker = new CometScanTypeChecker (scanImpl)
122
132
val schemaSupported =
123
133
typeChecker.isSchemaSupported(scanExec.requiredSchema, fallbackReasons)
You can’t perform that action at this time.
0 commit comments