File tree 3 files changed +6
-1
lines changed
spark-extensions/src/jmh/java/org/apache/iceberg/spark
3 files changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -99,6 +99,7 @@ subprojects {
99
99
' -Xep:MissingOverride:ERROR' ,
100
100
' -Xep:IntLongMath:ERROR' ,
101
101
' -Xep:MissingSummary:ERROR' ,
102
+ ' -Xep:AnnotateFormatMethod:ERROR' ,
102
103
)
103
104
}
104
105
}
Original file line number Diff line number Diff line change @@ -152,6 +152,7 @@ project(":iceberg-spark:iceberg-spark-extensions-${sparkMajorVersion}_${scalaVer
152
152
exclude group : ' io.netty' , module : ' netty-common'
153
153
exclude group : ' org.roaringbitmap'
154
154
}
155
+ compileOnly " com.google.errorprone:error_prone_annotations"
155
156
156
157
testImplementation project(path : ' :iceberg-data' )
157
158
testImplementation project(path : ' :iceberg-parquet' )
Original file line number Diff line number Diff line change 22
22
import static org .apache .spark .sql .functions .date_add ;
23
23
import static org .apache .spark .sql .functions .expr ;
24
24
25
+ import com .google .errorprone .annotations .FormatMethod ;
26
+ import com .google .errorprone .annotations .FormatString ;
25
27
import java .util .UUID ;
26
28
import org .apache .hadoop .conf .Configuration ;
27
29
import org .apache .iceberg .DistributionMode ;
@@ -221,7 +223,8 @@ private String newWarehouseDir() {
221
223
return hadoopConf .get ("hadoop.tmp.dir" ) + UUID .randomUUID ();
222
224
}
223
225
224
- private void sql (String query , Object ... args ) {
226
+ @ FormatMethod
227
+ private void sql (@ FormatString String query , Object ... args ) {
225
228
spark .sql (String .format (query , args ));
226
229
}
227
230
}
You can’t perform that action at this time.
0 commit comments