Upserts, Deletes And Incremental Processing on Big Data.
This report summarizes scanner evidence for apache/hudi, a Java project with 6,294 GitHub stars. SynthScan examined 1,195,538 lines of code across 5973 source files, recording 1451 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 4.4 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 871 finding(s).
Are imports declared and package/API names verified? 383 finding(s).
Are wrappers, guards, and repeated structures necessary? 297 finding(s).
Which changes need focused human review? 1451 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 1451 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 302 | org.apache.hudi.common.schema.internal.InternalSchema internalSchema = new org.apache.hudi.common.schema.internal.In | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 303 | org.apache.hudi.common.schema.internal.Types.RecordType.get( | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 304 | org.apache.hudi.common.schema.internal.Types.Field.get(0, false, "id", org.apache.hudi.common.schema.interna | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 306 | org.apache.hudi.common.schema.internal.utils.SerDeHelper.toJson(internalSchema)); | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 385 | org.apache.hudi.common.schema.internal.InternalSchema internalSchema = new org.apache.hudi.common.schema.internal.In | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 386 | org.apache.hudi.common.schema.internal.Types.RecordType.get( | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 387 | org.apache.hudi.common.schema.internal.Types.Field.get(0, false, "id", org.apache.hudi.common.schema.interna | CODE |
| CRITICAL⚡ | …/apache/hudi/common/table/TestTableSchemaResolver.java | 389 | org.apache.hudi.common.schema.internal.utils.SerDeHelper.toJson(internalSchema)); | CODE |
| CRITICAL | …hudi/common/table/timeline/TestArchivedTimelineV1.java | 767 | archivedMetaWrapper.setHoodieCommitMetadata(org.apache.hudi.avro.model.HoodieCommitMetadata.newBuilder().build() | CODE |
| CRITICAL | …hudi/common/table/timeline/TestArchivedTimelineV1.java | 778 | archivedMetaWrapper.setHoodieInflightReplaceMetadata(convertCommitMetadata(new org.apache.hudi.common.model.Ho | CODE |
| CRITICAL | …hudi/common/table/timeline/TestArchivedTimelineV1.java | 785 | archivedMetaWrapper.setHoodieCommitMetadata(org.apache.hudi.avro.model.HoodieCommitMetadata.newBuilder().build() | CODE |
| CRITICAL | …main/java/org/apache/hudi/tools/TimelineInspector.java | 319 | org.apache.hudi.common.schema.HoodieSchema.fromAvroSchema( | CODE |
| CRITICAL | …/hudi/aws/TestHoodieAWSCredentialsProviderFactory.java | 37 | AwsSessionCredentials credentials = (AwsSessionCredentials) org.apache.hudi.aws.credentials.HoodieAWSCredentialsProv | CODE |
| CRITICAL | …/hudi/aws/TestHoodieAWSCredentialsProviderFactory.java | 53 | AwsSessionCredentials credentials = (AwsSessionCredentials) org.apache.hudi.aws.credentials.HoodieAWSCredentialsProv | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 175 | software.amazon.awssdk.services.glue.model.StorageDescriptor storageDescriptor = software.amazon.awssdk.services.glu | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 417 | software.amazon.awssdk.services.glue.model.Partition awsPart1 = software.amazon.awssdk.services.glue.model.Partition | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 419 | software.amazon.awssdk.services.glue.model.Partition awsPart2 = software.amazon.awssdk.services.glue.model.Partition | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 444 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 455 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 941 | software.amazon.awssdk.services.glue.model.StorageDescriptor storageDescriptor = software.amazon.awssdk.services.glu | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 993 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 1056 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 777 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 823 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 911 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 966 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …ava/org/apache/hudi/hive/ddl/HiveQueryDDLExecutor.java | 96 | this.hiveDriver = new org.apache.hadoop.hive.ql.Driver(sessionConf); | CODE |
| CRITICAL | …mples-spark/src/test/python/HoodiePySparkQuickstart.py | 43 | self.dataGen = spark._jvm.org.apache.hudi.QuickstartUtils.DataGenerator() | CODE |
| CRITICAL | …mples-spark/src/test/python/HoodiePySparkQuickstart.py | 85 | inserts = self.spark._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(self.dataGen.generateInserts(10)) | CODE |
| CRITICAL | …mples-spark/src/test/python/HoodiePySparkQuickstart.py | 92 | updates = self.spark._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(self.dataGen.generateUniqueUpdates | CODE |
| CRITICAL | …mples-spark/src/test/python/HoodiePySparkQuickstart.py | 219 | inserts = self.spark._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(self.dataGen.generateInserts(10)) | CODE |
| CRITICAL | …pache/hudi/examples/spark/HoodieMorCompactionJob.scala | 78 | client.commitCompaction(instant.get(), result, org.apache.hudi.common.util.Option.empty()) | CODE |
| CRITICAL | …i/hadoop/utils/TestHoodieRealtimeInputFormatUtils.java | 50 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); | CODE |
| CRITICAL | …di/hadoop/realtime/TestHoodieRealtimeRecordReader.java | 129 | storageConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); | CODE |
| CRITICAL | …a/org/apache/hudi/io/hfile/TestHFileCompatibility.java | 278 | org.apache.hudi.io.hfile.HFileContext context = org.apache.hudi.io.hfile.HFileContext.builder() | CODE |
| CRITICAL | …/hudi/timeline/service/TimelineServiceTestHarness.java | 172 | response = org.apache.http.client.fluent.Request.Get(url).connectTimeout(10000).socketTimeout(10000).execute() | CODE |
| CRITICAL | …/hudi/timeline/service/TimelineServiceTestHarness.java | 176 | response = org.apache.http.client.fluent.Request.Post(url).connectTimeout(10000).socketTimeout(10000).execute( | CODE |
| CRITICAL | …es/public/lib/vis-timeline/vis-timeline-graph2d.min.js | 47 | function Zv(){return Zv=Object.assign||function(t){for(var e=1;e<arguments.length;e++){var i=arguments[e];for(var n in i | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_2ExtendedSqlAstBuilder.scala | 430 | ctx.errorCapturingUnitToUnitInterval.body.from.getText.toLowerCase(Locale.ROOT) | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_2ExtendedSqlAstBuilder.scala | 431 | val toUnit = ctx.errorCapturingUnitToUnitInterval.body.to.getText.toLowerCase(Locale.ROOT) | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_2ExtendedSqlAstBuilder.scala | 445 | ctx.errorCapturingMultiUnitsInterval.body.unit.asScala.map( | CODE |
| CRITICAL | …spark/sql/parser/HoodieSpark4_2ExtendedSqlParser.scala | 203 | new org.antlr.v4.runtime.misc.Pair(token.getTokenSource, token.getInputStream), | CODE |
| CRITICAL | …spark/sql/parser/HoodieSpark4_1ExtendedSqlParser.scala | 203 | new org.antlr.v4.runtime.misc.Pair(token.getTokenSource, token.getInputStream), | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_1ExtendedSqlAstBuilder.scala | 430 | ctx.errorCapturingUnitToUnitInterval.body.from.getText.toLowerCase(Locale.ROOT) | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_1ExtendedSqlAstBuilder.scala | 431 | val toUnit = ctx.errorCapturingUnitToUnitInterval.body.to.getText.toLowerCase(Locale.ROOT) | CODE |
| CRITICAL | …k/sql/parser/HoodieSpark4_1ExtendedSqlAstBuilder.scala | 445 | ctx.errorCapturingMultiUnitsInterval.body.unit.asScala.map( | CODE |
| CRITICAL | …ala/org/apache/spark/sql/Spark4HoodieUnsafeUtils.scala | 66 | org.apache.spark.sql.classic.Dataset.ofRows(spark.asInstanceOf[org.apache.spark.sql.classic.SparkSession], plan) | CODE |
| CRITICAL | …ala/org/apache/spark/sql/Spark4HoodieUnsafeUtils.scala | 79 | org.apache.spark.sql.classic.Dataset.ofRows(spark.asInstanceOf[org.apache.spark.sql.classic.SparkSession], LocalRela | CODE |
| CRITICAL | …ala/org/apache/spark/sql/Spark4HoodieUnsafeUtils.scala | 93 | org.apache.spark.sql.classic.Dataset.ofRows(spark.asInstanceOf[org.apache.spark.sql.classic.SparkSession], LocalRela | CODE |
| CRITICAL | …n/scala/org/apache/spark/sql/Spark4DataFrameUtil.scala | 38 | org.apache.spark.sql.classic.Dataset.ofRows(sparkSession.asInstanceOf[org.apache.spark.sql.classic.SparkSession], lo | CODE |
| CRITICAL | …a/org/apache/spark/sql/adapter/BaseSpark4Adapter.scala | 184 | org.apache.spark.sql.classic.Dataset.ofRows(sqlContext.sparkSession.asInstanceOf[org.apache.spark.sql.classic.SparkS | CODE |
| CRITICAL | …apache/hudi/io/storage/TestHoodieSparkLanceWriter.java | 710 | StructType blobStruct = (StructType) org.apache.spark.sql.types.BlobType.dataType(); | CODE |
| CRITICAL | …rg/apache/hudi/table/upgrade/TestUpgradeDowngrade.java | 924 | org.apache.hudi.common.table.view.HoodieTableFileSystemView.fileListingBasedFileSystemView( | CODE |
| CRITICAL | …rg/apache/hudi/table/upgrade/TestUpgradeDowngrade.java | 928 | List<String> partitionPaths = org.apache.hudi.common.fs.FSUtils.getAllPartitionPaths( | CODE |
| CRITICAL | …on/rollback/TestMergeOnReadRollbackActionExecutor.java | 399 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(statusesList); | CODE |
| CRITICAL | …functional/TestSparkNonBlockingConcurrencyControl.java | 846 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatuses); | CODE |
| CRITICAL | …he/hudi/functional/TestSparkClusteringCornerCases.java | 81 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatuses); | CODE |
| CRITICAL | …i/functional/TestColStatsRecordWithMetadataRecord.java | 534 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatuses); | CODE |
| CRITICAL | …he/hudi/functional/TestSparkSortAndSizeClustering.java | 245 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatues); | CODE |
| CRITICAL | …/apache/hudi/functional/TestConsistentBucketIndex.java | 278 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatues); | CODE |
| 239 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …k/sql/parser/HoodieSpark4_2ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …k/sql/parser/HoodieSpark4_1ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …k/sql/parser/HoodieSpark3_5ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …k/sql/parser/HoodieSpark4_0ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …k/sql/parser/HoodieSpark3_4ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …k/sql/parser/HoodieSpark3_3ExtendedSqlAstBuilder.scala | 0 | partition by: cannot mix partition expressions and partition columns: |expressions: $references |columns: $columns | STRING |
| HIGH | …n/scala/org/apache/spark/sql/avro/AvroSerializer.scala | 0 | "$data" cannot be written since it's not defined in enum | STRING |
| HIGH | …n/scala/org/apache/spark/sql/avro/AvroSerializer.scala | 0 | "$data" cannot be written since it's not defined in enum | STRING |
| HIGH | …n/scala/org/apache/spark/sql/avro/AvroSerializer.scala | 0 | "$data" cannot be written since it's not defined in enum | STRING |
| HIGH | …n/scala/org/apache/spark/sql/avro/AvroSerializer.scala | 0 | "$data" cannot be written since it's not defined in enum | STRING |
| HIGH | …e/hudi/functional/TestPartitionStatsIndexWithSql.scala | 0 | | insert into $tablename | values (1, 'a1', 1000, 10), (2, 'a2', 2000, 20), (3, 'a3', 3000, 30), (4, 'a4', 2000, 10), (5 | STRING |
| HIGH | …pache/spark/sql/hudi/dml/insert/TestInsertTable4.scala | 0 | | insert into $tablename | values (1, 'a1', 1000, 10), (2, 'a2', 2000, 20), (3, 'a3', 3000, 30), (4, 'a4', 2000, 10), (5 | STRING |
| HIGH | …ql/hudi/dml/others/TestHoodieTableValuedFunction.scala | 0 | | insert into $tablename | values (1, 'a1', 1000, 10), (2, 'a2', 2000, 20), (3, 'a3', 3000, 30), (4, 'a4', 2000, 10), (5 | STRING |
| HIGH | …udi/analysis/TestHoodiePruneFileSourcePartitions.scala | 0 | | insert into $tablename values | (1, 'a1', 10, 1000, "2021-01-05"), | (2, 'a2', 20, 2000, "2021-01-06"), | (3, 'a3', 30 | STRING |
| HIGH | …pache/spark/sql/hudi/dml/insert/TestInsertTable3.scala | 0 | | insert into $tablename values | (1, 'a1', 10, 1000, "2021-01-05"), | (2, 'a2', 20, 2000, "2021-01-06"), | (3, 'a3', 30 | STRING |
| HIGH | …apache/spark/sql/hudi/dml/insert/TestInsertTable.scala | 0 | | insert into $tablename values | (1, 'a1', 10, 1000, "2021-01-05"), | (2, 'a2', 20, 2000, "2021-01-06"), | (3, 'a3', 30 | STRING |
| HIGH | …he/spark/sql/hudi/dml/others/TestDeleteFromTable.scala | 0 | | insert into $tablename values | (1, 'a1', 10, 1000, "2021-01-05"), | (2, 'a2', 20, 2000, "2021-01-06"), | (3, 'a3', 30 | STRING |
| HIGH | …che/spark/sql/hudi/feature/TestDataSkippingQuery.scala | 0 | | insert into $tablename values | (1, 'a1', 10, 1000, "2021-01-05"), | (2, 'a2', 20, 2000, "2021-01-06"), | (3, 'a3', 30 | STRING |
| HIGH | …pache/spark/sql/hudi/dml/insert/TestInsertTable2.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …apache/spark/sql/hudi/dml/insert/TestInsertTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …apache/spark/sql/hudi/dml/others/TestDeleteTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …apache/spark/sql/hudi/dml/others/TestUpdateTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …che/spark/sql/hudi/dml/others/TestMergeIntoTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …l/others/TestMergeIntoTableWithNonRecordKeyField.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …he/spark/sql/hudi/dml/others/TestTimeTravelTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …cala/org/apache/spark/sql/hudi/ddl/TestSpark3DDL.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ala/org/apache/spark/sql/hudi/ddl/TestAlterTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …/org/apache/spark/sql/hudi/ddl/TestTruncateTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …cala/org/apache/spark/sql/hudi/ddl/TestDropTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …la/org/apache/spark/sql/hudi/ddl/TestCreateTable.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …che/spark/sql/hudi/common/TestROPathFilterOnRead.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …l/hudi/procedure/TestShowInvalidParquetProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …pache/spark/sql/hudi/procedure/TestCallProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …he/spark/sql/hudi/procedure/TestCommitsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …che/spark/sql/hudi/procedure/TestFsViewProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …park/sql/hudi/procedure/TestCopyToTableProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …e/spark/sql/hudi/procedure/TestMetadataProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …/hudi/procedure/TestShowAuditLockStatusProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …k/sql/hudi/procedure/TestCopyToTempViewProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ql/hudi/procedure/TestValidateAuditLockProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …sql/hudi/procedure/TestCleanupAuditLockProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ark/sql/hudi/procedure/TestSetAuditLockProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …he/spark/sql/hudi/procedure/TestRepairsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …rk/sql/hudi/procedure/TestTruncateTableProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …udi/procedure/TestRunTimelineCompactionProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …k/sql/hudi/procedure/TestArchiveCommitsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ql/hudi/procedure/TestShowTimelineTableProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …park/sql/hudi/procedure/TestShowCleansProcedures.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ache/spark/sql/hudi/procedure/TestCleanProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …l/hudi/procedure/TestValidateHoodieSyncProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …k/sql/hudi/procedure/TestExportInstantsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ache/spark/sql/hudi/procedure/TestStatsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …spark/sql/hudi/procedure/TestSavepointsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …l/hudi/procedure/TestUpgradeOrDowngradeProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …sql/hudi/procedure/TestShowFsPathDetailProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …/hudi/procedure/TestShowTablePropertiesProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …ocedure/TestCleanupStaleInflightCommitsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …/hudi/procedure/TestShowInflightCommitsProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| HIGH | …i/procedure/TestDeltaStreamerCheckpointProcedure.scala | 0 | |create table $tablename ( | id int, | name string, | ts long | ) using hudi | location '${tmp.getcanonicalpath}' | tblp | STRING |
| 39 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | .codecov.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | azure-pipelines-20230430.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | packaging/hudi-cli-bundle/hudi-cli-with-bundle.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | packaging/hudi-cli-bundle/conf/hudi-env.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | packaging/bundle-validation/validate.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/bundle-validation/validate.sh | 61 | fi | COMMENT |
| LOW | packaging/bundle-validation/ci_run.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/bundle-validation/run_docker_java17.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/bundle-validation/flink/compact.sh | 1 | # | COMMENT |
| LOW | packaging/bundle-validation/azure/build.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/bundle-validation/cli/commands.txt | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | packaging/bundle-validation/kafka/consume.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/bundle-validation/kafka/produce.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …/bundle-validation/docker_java17/docker_java17_test.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1180hive313spark350scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ndle-validation/base/build_flink1190hive313spark350.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …undle-validation/base/build_flink221hive313spark351.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …undle-validation/base/build_flink211hive313spark351.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ndle-validation/base/build_flink1181hive313spark343.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1200hive313spark411scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1200hive313spark400scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1200hive313spark350scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1190hive313spark350scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1200hive313spark420scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1180hive313spark351scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ndle-validation/base/build_flink1200hive313spark350.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1190hive313spark351scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …idation/base/build_flink1200hive313spark351scala213.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ndle-validation/base/build_flink1180hive313spark350.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …undle-validation/base/build_flink200hive313spark351.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ndle-validation/base/build_flink1181hive313spark334.sh | 1 | #!/bin/bash | COMMENT |
| LOW | packaging/hudi-timeline-server-bundle/run_server.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …pache/hudi/common/table/read/TestEventTimeMerging.java | 61 | metaProps.setProperty(ORDERING_FIELDS.key(), "timestamp"); | COMMENT |
| LOW | …pache/hudi/common/table/read/TestEventTimeMerging.java | 81 | // but we cannot since their ordering value is 1 < 3. | COMMENT |
| LOW | …che/hudi/common/table/read/TestCustomRecordMerger.java | 81 | // ------------------------------------------------------------- | COMMENT |
| LOW | …i/common/table/read/TestOverwriteWithLatestMerger.java | 61 | } | COMMENT |
| LOW | …he/hudi/io/storage/hadoop/HoodieAvroParquetReader.java | 141 | @Override | COMMENT |
| LOW | …he/hudi/io/storage/hadoop/HoodieAvroParquetReader.java | 161 | // the "element" type (representing record stored inside the list itself). | COMMENT |
| LOW | …ain/java/org/apache/hudi/common/util/AvroOrcUtils.java | 641 | // The time-millis logical type represents a time of day, with no reference to a particular calendar, time | COMMENT |
| LOW | …ain/java/org/apache/hudi/common/util/AvroOrcUtils.java | 661 | // - UTC-adjusted timestamps (TimestampMillis/Micros) are converted to ORC Timestamp | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/Chart.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/values.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/values.yaml | 21 | # want a bigger open-weight model served in-cluster, then point the | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/templates/deployment.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/templates/service.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/vllm/templates/pvc.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ehouse/charts/hudi-agent-gateway/values-local-dev.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-agent-gateway/Chart.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-agent-gateway/values.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …se/charts/hudi-agent-gateway/templates/deployment.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …house/charts/hudi-agent-gateway/templates/service.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …ehouse/charts/hudi-agent-gateway/templates/secret.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-trino/values-local-dev.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-trino/Chart.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-trino/values.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …-lakehouse/charts/hudi-trino/templates/deployment.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …use/charts/hudi-trino/templates/configmap-catalog.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-trino/templates/service.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | hudi-lakehouse/charts/hudi-trino/templates/secret.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 367 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 944 | // Step 1: Scan by a list of keys | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 960 | // Step 2: Scan by the same list of keys (no new scanning should be performed, | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 1027 | // Step 1: Scan by a list of keys | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 1043 | // Step 2: Scan by the same list of keys (no new scanning should be performed, | COMMENT |
| LOW | …c/main/java/org/apache/hudi/hadoop/fs/CachingPath.java | 157 | // NOTE: This method does NOT perform any normalization, assuming that the incoming paths | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 108 | // Step 1: Verify rows written correctly | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 112 | // Step 2: Assert Parquet metadata was written appropriately | COMMENT |
| LOW | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 127 | // Step 3: Make sure Bloom Filter contains all the record keys | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 506 | // Step 1: Write parquet source table with non-nullable fields | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 510 | // Step 2: Configure and perform metadata-only bootstrap | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 515 | // Step 3: Read bootstrapped table and verify records | COMMENT |
| LOW | …est/java/org/apache/hudi/functional/TestBootstrap.java | 532 | // Step 4: Perform an update | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 436 | // Step 1: Insert and upsert with column stats enabled | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 459 | // Step 2: Disable column stats but set auto.delete.partitions=false, then do an upsert | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 488 | // Step 3: Verify column_stats partition is NOT deleted from table config | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 494 | // Step 4: Verify column_stats partition received new log files (from HoodieCommitMetadata) | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 506 | // Step 5: Verify column stats log files contain valid column stats records | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 56 | // Step 1: Serialize/de- original [[HoodieSparkRecord]] | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 71 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 91 | // Step 1: Serialize/de- original [[HoodieRecord]] | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 102 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW⚡ | …/hudi/common/model/TestHoodieRecordSerialization.scala | 130 | // Step 1: Serialize/de- original [[HoodieRecord]] | COMMENT |
| LOW⚡ | …/hudi/common/model/TestHoodieRecordSerialization.scala | 136 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 364 | // Step 1: Bootstrap table w/ N records (t/h bulk-insert) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 374 | // Step 2: Update M records out of those (t/h update) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 396 | // Step 1: Bootstrap table w/ N records (t/h bulk-insert) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 404 | // Step 2: Update M records out of those (t/h update) | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 156 | // Step 1: Create table and insert initial records (initial commit) | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 170 | // Step 2: Update records to generate new log files with updated stats. | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 184 | // Step 3: Trigger inline compaction (produces a new base file). | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 197 | // Step 4: Perform cleaning to remove older log files (leaving behind delete blocks). | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 210 | // Step 5: Downgrade the table to version 6. | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 231 | // Step 6: Read the table using a predicate on 'price' to force column stats usage. | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 241 | // Step 7: Do an update with table version 6 to trigger metadata compaction. | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 264 | // Step 8: Upgrade the table back to current version (version 8) and validate record index. | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 704 | // Step 2: Create table and secondary index on 'rider' column | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 837 | // Step 1: Initial Insertion with null values | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 890 | // Step 2: Delete by record key whose secondary index is null and validate secondary index | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 913 | // Step 3: Update null to non-null | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 941 | // Step 4: Update non-null to null | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 964 | // Step 5: Update null to null (should be no-op but validate) | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 977 | // Step 6: Insert new record with null description | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 998 | // Step 7: Insert new record with non-null description | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 1049 | // Step 8: Test delete record behavior in log files (MOR specific) | COMMENT |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 406 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 415 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 501 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 509 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 536 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 545 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 427 | // Step 4: Trigger Compaction with this update as the compaction frequency is set to 3 commits | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 447 | // Step 5: Trigger Clustering with this update as the clustering frequency is set to 4 commits | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 462 | // Step 6: Perform Deletes on Records and Validate Secondary Index | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 476 | // Step 7: Final Update and Validation | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 562 | // Step 4: Perform Time Travel Query | STRING |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 42 | // Step 1: Set Up Test Data | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 48 | // Step 2: Call the Method | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 50 | // Step 3: Assertions | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 64 | // Step 1: Set Up Test Data | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 71 | // Step 2: Call the Method | COMMENT |
| 96 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 944 | // Step 1: Scan by a list of keys | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 960 | // Step 2: Scan by the same list of keys (no new scanning should be performed, | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 1027 | // Step 1: Scan by a list of keys | COMMENT |
| LOW | …apache/hudi/common/functional/TestHoodieLogFormat.java | 1043 | // Step 2: Scan by the same list of keys (no new scanning should be performed, | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 108 | // Step 1: Verify rows written correctly | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 112 | // Step 2: Assert Parquet metadata was written appropriately | COMMENT |
| LOW | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 127 | // Step 3: Make sure Bloom Filter contains all the record keys | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 506 | // Step 1: Write parquet source table with non-nullable fields | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 510 | // Step 2: Configure and perform metadata-only bootstrap | COMMENT |
| LOW⚡ | …est/java/org/apache/hudi/functional/TestBootstrap.java | 515 | // Step 3: Read bootstrapped table and verify records | COMMENT |
| LOW | …est/java/org/apache/hudi/functional/TestBootstrap.java | 532 | // Step 4: Perform an update | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 436 | // Step 1: Insert and upsert with column stats enabled | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 459 | // Step 2: Disable column stats but set auto.delete.partitions=false, then do an upsert | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 488 | // Step 3: Verify column_stats partition is NOT deleted from table config | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 494 | // Step 4: Verify column_stats partition received new log files (from HoodieCommitMetadata) | COMMENT |
| LOW | …g/apache/hudi/functional/TestHoodieBackedMetadata.java | 506 | // Step 5: Verify column stats log files contain valid column stats records | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 56 | // Step 1: Serialize/de- original [[HoodieSparkRecord]] | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 71 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 91 | // Step 1: Serialize/de- original [[HoodieRecord]] | COMMENT |
| LOW | …/hudi/common/model/TestHoodieRecordSerialization.scala | 102 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW⚡ | …/hudi/common/model/TestHoodieRecordSerialization.scala | 130 | // Step 1: Serialize/de- original [[HoodieRecord]] | COMMENT |
| LOW⚡ | …/hudi/common/model/TestHoodieRecordSerialization.scala | 136 | // Step 2: Serialize the already cloned record, and assert that ser/de loop is lossless | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 364 | // Step 1: Bootstrap table w/ N records (t/h bulk-insert) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 374 | // Step 2: Update M records out of those (t/h update) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 396 | // Step 1: Bootstrap table w/ N records (t/h bulk-insert) | COMMENT |
| LOW⚡ | …ache/hudi/functional/TestParquetColumnProjection.scala | 404 | // Step 2: Update M records out of those (t/h update) | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 156 | // Step 1: Create table and insert initial records (initial commit) | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 170 | // Step 2: Update records to generate new log files with updated stats. | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 184 | // Step 3: Trigger inline compaction (produces a new base file). | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 197 | // Step 4: Perform cleaning to remove older log files (leaving behind delete blocks). | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 210 | // Step 5: Downgrade the table to version 6. | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 231 | // Step 6: Read the table using a predicate on 'price' to force column stats usage. | COMMENT |
| LOW⚡ | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 241 | // Step 7: Do an update with table version 6 to trigger metadata compaction. | COMMENT |
| LOW | …g/apache/hudi/functional/TestSevenToEightUpgrade.scala | 264 | // Step 8: Upgrade the table back to current version (version 8) and validate record index. | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 704 | // Step 2: Create table and secondary index on 'rider' column | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 837 | // Step 1: Initial Insertion with null values | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 890 | // Step 2: Delete by record key whose secondary index is null and validate secondary index | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 913 | // Step 3: Update null to non-null | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 941 | // Step 4: Update non-null to null | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 964 | // Step 5: Update null to null (should be no-op but validate) | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 977 | // Step 6: Insert new record with null description | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 998 | // Step 7: Insert new record with non-null description | COMMENT |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 1049 | // Step 8: Test delete record behavior in log files (MOR specific) | COMMENT |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 406 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 415 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 501 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 509 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 536 | // Step 1: Initial Insertion of Records | STRING |
| LOW⚡ | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 545 | // Step 3: Perform Update Operations on Subset of Records | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 427 | // Step 4: Trigger Compaction with this update as the compaction frequency is set to 3 commits | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 447 | // Step 5: Trigger Clustering with this update as the clustering frequency is set to 4 commits | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 462 | // Step 6: Perform Deletes on Records and Validate Secondary Index | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 476 | // Step 7: Final Update and Validation | STRING |
| LOW | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 562 | // Step 4: Perform Time Travel Query | STRING |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 42 | // Step 1: Set Up Test Data | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 48 | // Step 2: Call the Method | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 50 | // Step 3: Assertions | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 64 | // Step 1: Set Up Test Data | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 71 | // Step 2: Call the Method | COMMENT |
| LOW⚡ | …ava/org/apache/hudi/common/util/TestBaseFileUtils.java | 73 | // Step 3: Assertions | COMMENT |
| 95 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 81 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 83 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 114 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 116 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 172 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 174 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 215 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 217 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 261 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 263 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 301 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 303 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 434 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 436 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 516 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 518 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 567 | # ====================================================== | COMMENT |
| MEDIUM | …on/vector_blob_demo/hudi_dataframe_vector_blob_demo.py | 569 | # ====================================================== | COMMENT |
| MEDIUM⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 273 | # ====================================================== | COMMENT |
| MEDIUM⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 275 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 71 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 73 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 100 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 102 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 157 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 159 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 191 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 193 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 236 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 238 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 346 | # ====================================================== | COMMENT |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 348 | # ====================================================== | COMMENT |
| MEDIUM⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 396 | # ====================================================== | STRING |
| MEDIUM⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 398 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 441 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 443 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 494 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 496 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 536 | # ====================================================== | STRING |
| MEDIUM | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 538 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 73 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 75 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 111 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 113 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 162 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 164 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 202 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 204 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 262 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 264 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 317 | # ====================================================== | COMMENT |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 319 | # ====================================================== | COMMENT |
| MEDIUM⚡ | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 347 | # ====================================================== | STRING |
| MEDIUM⚡ | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 349 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 405 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 407 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 465 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 467 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 532 | # ====================================================== | STRING |
| MEDIUM | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 534 | # ====================================================== | STRING |
| 21 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 280 | def stage_to_parquet_with_pyarrow(data, embedding_dim: int, staging_path: str) -> None: | CODE |
| LOW | …g/apache/hudi/timeline/service/TestRequestHandler.java | 55 | class TestRequestHandler extends HoodieCommonTestHarness { | CODE |
| LOW | …eline-service/src/main/resources/public/js/timeline.js | 461 | function findPreviousCompletedClean(currentRequestTs) { | CODE |
| LOW | …eline-service/src/main/resources/public/js/timeline.js | 877 | function renderInternalSchemaHistory(data, historyList) { | CODE |
| LOW | …a/org/apache/hudi/timeline/service/RequestHandler.java | 76 | public class RequestHandler { | CODE |
| LOW | …/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala | 603 | def getOrCreateChild(parent: NestedFieldNode, name: String): NestedFieldNode = { | CODE |
| LOW | …pache/spark/sql/hive/SparkCatalogMetaStoreClient.scala | 345 | override def get_role_grants_for_principal(arg0: org.apache.hadoop.hive.metastore.api.GetRoleGrantsForPrincipalRequest | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 45 | def test_langchain_derivation(simple_registry: ToolRegistry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 56 | async def test_mcp_derivation_matches(simple_registry: ToolRegistry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 66 | async def test_same_payload_via_both_paths(simple_registry: ToolRegistry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 77 | async def test_invocation_logged_once( | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 90 | def test_duplicate_registration_rejected(simple_registry: ToolRegistry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_registry.py | 95 | def test_is_tool_error_parses_not_substring_matches() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 66 | async def test_non_streaming_chat_returns_trace(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 83 | async def test_streaming_chat_event_order(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 108 | async def test_streaming_error_event_on_model_failure(client, settings, registry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 131 | async def test_validation_rejects_empty_message(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_api_meta.py | 43 | async def test_ready_reports_dependency_failures(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 47 | def test_ollama_factory_plumbs_base_url() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 56 | def test_openai_compatible_factory_plumbs_base_url() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 67 | async def test_hosted_provider_ready_without_network() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 73 | async def test_local_provider_unreachable_reports_not_ready() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 98 | async def test_list_models_falls_back_to_default(monkeypatch) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_llm.py | 111 | def test_build_chat_model_override() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 29 | def test_plain_select_gets_limit_injected() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 34 | def test_existing_smaller_limit_is_preserved() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 39 | def test_oversized_limit_is_lowered() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 44 | def test_cte_select_is_allowed() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 49 | def test_union_is_allowed_and_capped() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 71 | def test_non_select_statements_are_rejected(sql: str) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 76 | def test_select_wrapping_dml_is_rejected() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 82 | def test_multiple_statements_are_rejected() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 92 | def test_comment_smuggled_dml_is_rejected() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 97 | def test_string_literal_containing_dml_is_fine() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_guardrails.py | 102 | def test_quoted_identifiers_round_trip() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_sessions.py | 33 | def test_touch_tracks_sessions() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_sessions.py | 40 | def test_ttl_sweep_evicts_idle_sessions(monkeypatch) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_sessions.py | 52 | def test_lru_eviction_beyond_max_sessions() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_sessions.py | 61 | def test_last_access_refresh_prevents_eviction() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_ui.py | 38 | async def test_root_redirects_to_ui(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_ui.py | 55 | async def test_ui_assets_served_with_content_types(client, asset: str, content_type: str) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_ui.py | 61 | async def test_ui_is_self_contained(client) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 28 | async def test_loop_executes_tool_and_answers(settings, registry, fake_trino) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 45 | async def test_checkpointer_preserves_history_across_turns(settings, registry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 67 | def test_system_prompt_interpolation(settings) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 74 | def test_agent_cache_builds_per_model_and_caps(settings, registry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 89 | async def test_loop_repairs_broken_thinking_block_before_next_model_call( | CODE |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 127 | def test_repair_thinking_blocks_restores_missing_field() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_config.py | 47 | def test_invalid_provider_rejected() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_config.py | 52 | def test_anthropic_requires_key() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_config.py | 62 | def test_openai_compatible_requires_base_url() -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_config.py | 67 | def test_unprefixed_api_key_alias(monkeypatch: pytest.MonkeyPatch) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_config.py | 73 | def test_prefixed_api_key_alias(monkeypatch: pytest.MonkeyPatch) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 115 | def _run_flink_design_validator( | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 132 | def test_flink_references_exist_and_are_linked_from_skill() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 141 | def test_engine_router_is_lazy_and_keeps_spark_on_shared_flow() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 204 | def test_flink_capability_manifest_validates_without_current_checkout_discovery() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 211 | def test_flink_capability_validation_emits_pinned_evidence() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 224 | def test_flink_capability_validation_rejects_option_absent_from_release_baseline() -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 233 | def test_flink_capability_validation_rejects_unverified_versions() -> None: | CODE |
| 40 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …g/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java | 206 | new Text("John Doe"), | CODE |
| LOW | …g/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java | 214 | assertEquals(new Text("John Doe"), serializer.getValue(record, "name")); | CODE |
| LOW | …g/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java | 306 | new Text("John Doe"), | CODE |
| LOW | …g/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java | 314 | assertEquals(new Utf8("John Doe"), serializer.getValueAsJava(record, "name")); | CODE |
| LOW | …apache/hudi/io/storage/TestHoodieSparkLanceReader.java | 290 | expectedRows.add(createRow(1, "Alice", createRow("123 Main St", "New York", 10001))); | CODE |
| LOW | …apache/hudi/io/storage/TestHoodieSparkLanceWriter.java | 463 | UTF8String.fromString("123 Main St"), | CODE |
| LOW⚡ | …di/functional/TestFileGroupReaderPartitionColumn.scala | 99 | Row("c", 2550218872L, 2L, "IN", "0x100000021ce30", "Acme Corp", "plan change", 11.0), | CODE |
| LOW⚡ | …di/functional/TestFileGroupReaderPartitionColumn.scala | 105 | Row("c", 2550220512L, 14L, "IN", "0x10000008d8892", "Acme Corp", "deactivation", 17.0), | CODE |
| LOW⚡ | …di/functional/TestFileGroupReaderPartitionColumn.scala | 106 | Row("c", 2550220784L, 16L, "CN", "0x10000007352cd", "Acme Corp", "telecoms activity", 18.0) | CODE |
| LOW | …di/functional/TestFileGroupReaderPartitionColumn.scala | 120 | Row("u", 2650218872L, 2L, "US", "0x100000021ce30", "Acme Corp", "plan change", 11.0), | CODE |
| LOW | …apache/hudi/functional/TestSecondaryIndexPruning.scala | 1872 | spark.sql(s"update $tableName set name = 'John Doe' where record_key_col = 'id1'") | STRING |
| LOW | …apache/hudi/functional/TestSecondaryIndexPruning.scala | 1879 | spark.sql(s"update $tableName set name = 'Jane Doe' where record_key_col = 'id2'") | STRING |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1281 | | SELECT 1 as id, 'John Doe' as name, 19 as price, 1598886001 as ts | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1283 | | SELECT 2, 'Jane Doe', 24, 1598972400 | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1295 | | CAST('John Doe' AS STRING) as name, | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1318 | Seq(1, "John Doe", 19, if (recordMergeMode == RecordMergeMode.EVENT_TIME_ORDERING.name()) 1598886001L else 1 | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1319 | Seq(2, "Jane Doe", 24, 1598972400L), | CODE |
| LOW | …ql/hudi/dml/others/TestPartialUpdateForMergeInto.scala | 643 | | SELECT 'emp_001' as record_key, 'John Doe' as name, 30 as age, | CODE |
| LOW | …ql/hudi/dml/others/TestPartialUpdateForMergeInto.scala | 663 | | SELECT 'emp_001' as record_key, 'John Doe' as name, 30 as age, | CODE |
| LOW | …ql/hudi/dml/others/TestPartialUpdateForMergeInto.scala | 715 | | SELECT 'emp_001' as record_key, 'John Doe' as name, 30 as age, | CODE |
| LOW | …ql/hudi/dml/others/TestPartialUpdateForMergeInto.scala | 727 | |using ( SELECT 'emp_001' as record_key, 'John Doe' as name, 35 as age, cast(1598886200 as BIGINT) as ts) s | CODE |
| LOW⚡ | …park/sql/hudi/common/TestTableColumnTypeMismatch.scala | 620 | |select 1 as id, 'John Doe' as name, 19 as price, 1598886000 as ts | CODE |
| LOW⚡ | …park/sql/hudi/common/TestTableColumnTypeMismatch.scala | 622 | |select 2, 'Jane Doe', 24, 1598972400 | CODE |
| LOW⚡ | …park/sql/hudi/common/TestTableColumnTypeMismatch.scala | 632 | | cast('John Doe' as ${testCase.sourceSchema.find(_._1 == "name").get._2}) as name, | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 438 | Object rowKeyNotExist = HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", true, false); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 442 | assertEquals("fake_key(Part -fake_key) field not found in record. Acceptable fields were :[timestamp, _row_key, non_ | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 444 | HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 460 | // test get fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 461 | assertEquals("fake_key(Part -fake_key) field not found in record. Acceptable fields were :[firstname, lastname, stud | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 463 | HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 474 | // test get student.fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 475 | assertEquals("student.fake_key(Part -fake_key) field not found in record. Acceptable fields were :[firstnameNested, | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 477 | HoodieAvroUtils.getNestedFieldVal(rec, "student.fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 485 | // test get student.firstname.fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 488 | HoodieAvroUtils.getNestedFieldVal(rec, "student.firstnameNested.fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 490 | // test get student.lastname(null).fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 493 | HoodieAvroUtils.getNestedFieldVal(rec, "student.lastnameNested.fake_key", false, false)).getMessage()); | CODE |
| LOW | …di/io/TestSecondaryIndexStreamingTrackerFileSlice.java | 273 | nameMap.put("key1", "John Doe"); | CODE |
| LOW | …i/index/expression/TestHoodieSparkExpressionIndex.java | 162 | RowFactory.create("John Doe"), | CODE |
| LOW | …i-utilities/src/test/resources/data/nested_data_1.json | 1 | {"firstName":"John","lastName":"Doe","birthdate":{"year":1990,"month":5,"day":15},"address":{"street":"123 Main St","cit | CODE |
| LOW | …i/utilities/deltastreamer/TestHoodieDeltaStreamer.java | 1163 | "placeholder", false, true, false, null, HoodieTableType.MERGE_ON_READ.name()); | CODE |
| LOW | …apache/hudi/utilities/sources/TestAvroKafkaSource.java | 90 | private static final String PHONE = "555-0100"; | CODE |
| LOW | …es/sources/helpers/TestCloudObjectsSelectorCommon.java | 230 | Row address1 = RowFactory.create("123 Main St", "Springfield", "12345", RowFactory.create("India", "IN")); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …mples-spark/src/test/python/HoodiePySparkQuickstart.py | 18 | CODE | |
| LOW | hudi-agent-gateway/tests/test_registry.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/conftest.py | 22 | CODE | |
| LOW | hudi-agent-gateway/tests/test_api_meta.py | 17 | CODE | |
| LOW | hudi-agent-gateway/tests/test_llm.py | 17 | CODE | |
| LOW | hudi-agent-gateway/tests/test_guardrails.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_sessions.py | 17 | CODE | |
| LOW | hudi-agent-gateway/tests/test_ui.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_agent_loop.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_config.py | 17 | CODE | |
| LOW | hudi-agent-gateway/tests/test_hudi_architect_skill.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_mcp.py | 19 | CODE | |
| LOW | hudi-agent-gateway/tests/test_trino_tools.py | 17 | CODE | |
| LOW | hudi-agent-gateway/tests/integration/test_live_stack.py | 25 | CODE | |
| LOW | …y/skills/hudi-architect/validate_flink_capabilities.py | 26 | CODE | |
| LOW | …gateway/skills/hudi-architect/validate_flink_design.py | 26 | CODE | |
| LOW | …teway/skills/hudi-architect/redact_sensitive_values.py | 25 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/sessions.py | 28 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/config.py | 25 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/log.py | 24 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/llm.py | 25 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/cli.py | 19 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/agent.py | 19 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/app.py | 19 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/mcp_server.py | 19 | CODE | |
| LOW | …agent-gateway/src/hudi_agent_gateway/tools/registry.py | 30 | CODE | |
| LOW | …agent-gateway/src/hudi_agent_gateway/tools/__init__.py | 23 | CODE | |
| LOW | …t-gateway/src/hudi_agent_gateway/tools/trino_client.py | 19 | CODE | |
| LOW | …ent-gateway/src/hudi_agent_gateway/tools/guardrails.py | 24 | CODE | |
| LOW | …nt-gateway/src/hudi_agent_gateway/tools/trino_tools.py | 25 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/models.py | 19 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/chat.py | 19 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/meta.py | 19 | CODE | |
| LOW | scripts/pr_compliance.py | 20 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | …t/python/vector_blob_demo/hudi_sql_vector_blob_demo.py | 407 | # `named_struct('type', 'INLINE', 'data', <bytes>, 'reference', null)` is | STRING |
| HIGH | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 87 | # DESCRIPTOR → image_bytes.data is null; you must call read_blob() to materialize | COMMENT |
| HIGH⚡ | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 359 | # named_struct('type','OUT_OF_LINE','data', null, 'reference', named_struct(path, offset, length, managed)) | STRING |
| HIGH | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 425 | "\nInspecting stored OUT_OF_LINE blobs — `data` is null, `reference.*` points " | STRING |
| HIGH | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 436 | " `data` is suppressed (length(data) is null), `reference.*` synthesized to point\n" | STRING |
| HIGH | …/test/python/vector_blob_demo/hudi_blob_reader_demo.py | 620 | print("✓ Story: bytes live in the Hudi base files but are read lazily — image_bytes.data is null,") | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | .codecov.yml | 57 | # Integration-test harness (test DAGs, fixtures, generators), not production behavior. | COMMENT |
| MEDIUM | …t/functional/TestHoodieClientOnCopyOnWriteStorage.java | 1079 | // rollback should have succeeded. Essentially, the pending clustering should not hinder the rollback of regular com | COMMENT |
| MEDIUM | …ache/hudi/functional/TestParquetColumnProjection.scala | 57 | // is not robust, and works most reliably only when we read just a single file. As such, making table | COMMENT |
| MEDIUM | …/spark/sql/hudi/feature/index/TestSecondaryIndex.scala | 875 | // TODO [HUDI-9549] predicate of is null / not null will not leverage index lookup as of today | COMMENT |
| MEDIUM | …pache/hudi/common/table/log/block/HoodieDataBlock.java | 61 | // TODO rebase records/content to leverage Either to warrant | COMMENT |
| MEDIUM | scripts/release/validate_source_binary_files.sh | 39 | # than on a list of permitted MIME types keeps this robust against libmagic's | COMMENT |
| MEDIUM | …/hudi/integ2/testcontainers/command/CommandResult.java | 83 | // Normalize whitespace for more robust matching | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/sessions.py | 61 | except Exception: # noqa: BLE001 - eviction must never take the server down | CODE |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/sessions.py | 83 | except Exception: # noqa: BLE001 | CODE |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/llm.py | 88 | except Exception as e: # noqa: BLE001 - discovery must never break the API | CODE |
| LOW | …agent-gateway/src/hudi_agent_gateway/tools/registry.py | 89 | except Exception: | CODE |
| LOW | …t-gateway/src/hudi_agent_gateway/tools/trino_client.py | 120 | except Exception: | CODE |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/chat.py | 109 | except Exception as e: | CODE |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/chat.py | 159 | except Exception as e: # noqa: BLE001 - stream must terminate with an error event | CODE |
| LOW⚡ | hudi-notebooks/notebooks/spark3/utils.py | 167 | except Exception as e: | CODE |
| LOW | hudi-notebooks/notebooks/spark3/utils.py | 184 | except Exception as e: | CODE |
| MEDIUM | hudi-notebooks/notebooks/spark3/utils.py | 185 | print(f"Error converting DataFrame to Pandas: {e}") | CODE |
| LOW⚡ | hudi-notebooks/notebooks/spark4/utils.py | 190 | except Exception as e: | CODE |
| LOW⚡ | hudi-notebooks/notebooks/spark4/utils.py | 199 | except Exception as e: | CODE |
| LOW⚡ | hudi-notebooks/notebooks/spark4/utils.py | 204 | except Exception as e: | CODE |
| LOW | hudi-notebooks/notebooks/spark4/utils.py | 215 | except Exception as e: | CODE |
| LOW | hudi-notebooks/notebooks/spark4/utils.py | 245 | except Exception as e: | CODE |
| LOW | hudi-notebooks/notebooks/spark4/utils.py | 264 | except Exception as e: | CODE |
| MEDIUM | hudi-notebooks/notebooks/spark4/utils.py | 265 | print(f"Error converting DataFrame to Pandas: {e}") | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | rfc/rfc-109/rfc-109.md | 992 | | #19096 | Vector index options and Spark DDL scaffolding (§8). | CODE |
| MEDIUM | …ay/skills/hudi-architect/references/decision-tables.md | 283 | ### Projected partition count guardrails | COMMENT |
| MEDIUM | hudi-agent-gateway/src/hudi_agent_gateway/config.py | 68 | # --- guardrails / shaping --- | COMMENT |
| MEDIUM | scripts/pr_compliance.py | 246 | #Class that orchestrates the validation of the entire body | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | hudi-agent-gateway/tests/test_chat_sse.py | 51 | CODE | |
| LOW | …y/skills/hudi-architect/validate_flink_capabilities.py | 155 | CODE | |
| LOW | …gateway/skills/hudi-architect/validate_flink_design.py | 166 | CODE | |
| LOW | …gateway/skills/hudi-architect/validate_flink_design.py | 405 | CODE | |
| LOW | …-gateway/skills/hudi-architect/validate_config_keys.py | 92 | CODE | |
| LOW | …-gateway/skills/hudi-architect/validate_config_keys.py | 109 | CODE | |
| LOW | …-gateway/skills/hudi-architect/validate_config_keys.py | 133 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/chat.py | 69 | CODE | |
| LOW | hudi-agent-gateway/src/hudi_agent_gateway/api/chat.py | 127 | CODE | |
| LOW | scripts/pr_compliance.py | 210 | CODE | |
| LOW | scripts/pr_compliance.py | 284 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | hudi-examples/hudi-examples-dbt/dbt_project.yml | 41 | # In this example config, we tell dbt to build all models in the example/ directory | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | packaging/bundle-validation/validate.sh | 305 | # Create a temporary directory for CLI commands output | COMMENT |
| MEDIUM | hudi-kafka-connect/demo/setupKafka.sh | 124 | # Create the topic with 4 partitions | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docker/hoodie/hadoop/hive_base/conf/hive-env.sh | 48 | # Set HADOOP_HOME to point to a specific hadoop install directory | COMMENT |
| LOW | …ources/upgrade-downgrade-fixtures/generate-fixtures.sh | 106 | # Check if version is in the requested array | COMMENT |
| LOW | …ources/upgrade-downgrade-fixtures/generate-fixtures.sh | 163 | # Check if Spark binary already exists | COMMENT |
| LOW | scripts/release/validate_source_copyright.sh | 59 | # Check if the variable holding the list of files is non-empty | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …i/examples/quickstart/source/ContinuousFileSource.java | 59 | * <p>NOTE: this class is represented twice: in test utils and in quickstart. Don't forget to update both files. | COMMENT |
| LOW | …org/apache/hudi/utils/source/ContinuousFileSource.java | 59 | * <p>NOTE: this class is represented twice: in test utils and in quickstart. Don't forget to update both files. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/release/copy_staging_repo.sh | 20 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …e/hudi/utilities/TestHoodieMetadataTableValidator.java | 491 | // TODO: Add validation for compaction and clustering cases | COMMENT |