We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7232130 commit c2a676aCopy full SHA for c2a676a
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/DataSourceV2ScanExec.scala
@@ -71,7 +71,7 @@ case class DataSourceV2ScanExec(
71
override protected def doExecute(): RDD[InternalRow] = {
72
Events.sendScan(
73
tableName,
74
- pushedFilters.reduce(And).sql,
+ if (pushedFilters.nonEmpty) pushedFilters.reduce(And).sql else "true",
75
V2Util.columns(reader.readSchema()).asJava,
76
options.asJava)
77
0 commit comments