Upserts, Deletes And Incremental Processing on Big Data.
This report presents the forensic synthetic code analysis of apache/hudi, a Java project with 6,226 GitHub stars. SynthScan v2.0 examined 1,145,494 lines of code across 5861 source files, recording 1379 pattern matches distributed across 20 syntactic categories. The overall adjusted score of 4.5 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 1379 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| 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 | 151 | software.amazon.awssdk.services.glue.model.StorageDescriptor storageDescriptor = software.amazon.awssdk.services.glu | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 379 | 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 | 381 | 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 | 406 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 417 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 903 | software.amazon.awssdk.services.glue.model.StorageDescriptor storageDescriptor = software.amazon.awssdk.services.glu | CODE |
| CRITICAL | …va/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java | 955 | software.amazon.awssdk.services.glue.model.Partition.builder() | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 748 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 794 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 882 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …c/test/java/org/apache/hudi/hive/TestHiveSyncTool.java | 937 | Driver hiveDriver = new org.apache.hadoop.hive.ql.Driver(HiveTestUtil.getHiveConf()); | CODE |
| CRITICAL | …ava/org/apache/hudi/hive/ddl/HiveQueryDDLExecutor.java | 85 | this.hiveDriver = new org.apache.hadoop.hive.ql.Driver(config.getHiveConf()); | 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 | 40 | hadoopConf.set("fs.file.impl", org.apache.hadoop.fs.LocalFileSystem.class.getName()); | CODE |
| CRITICAL | …di/hadoop/realtime/TestHoodieRealtimeRecordReader.java | 128 | 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 | …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 | 181 | 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 | 888 | org.apache.hudi.common.table.view.HoodieTableFileSystemView.fileListingBasedFileSystemView( | CODE |
| CRITICAL | …rg/apache/hudi/table/upgrade/TestUpgradeDowngrade.java | 892 | 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 | 780 | 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 |
| CRITICAL | …di/functional/TestSparkConsistentBucketClustering.java | 371 | org.apache.hudi.testutils.Assertions.assertNoWriteErrors(writeStatues); | CODE |
| CRITICAL | …cala/org/apache/hudi/TestHoodieCreateRecordUtils.scala | 288 | org.apache.commons.io.FileUtils.deleteQuietly(new java.io.File(tempDir)) | CODE |
| 237 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 | .codecov.yml | 41 | default: | 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 | } | COMMENT |
| LOW | …he/hudi/io/storage/hadoop/HoodieAvroParquetReader.java | 161 | // Parquet [[GroupType]] as list, skipping the checks whether additional [[GroupType]] | 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 |
| 338 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 | 107 | // Step 1: Verify rows written correctly | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 111 | // Step 2: Assert Parquet metadata was written appropriately | COMMENT |
| LOW | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 126 | // 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 | 107 | // Step 1: Verify rows written correctly | COMMENT |
| LOW⚡ | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 111 | // Step 2: Assert Parquet metadata was written appropriately | COMMENT |
| LOW | …io/storage/row/TestHoodieInternalRowParquetWriter.java | 126 | // 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 | …a/org/apache/hudi/timeline/service/RequestHandler.java | 74 | public class RequestHandler { | CODE |
| LOW | …/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala | 560 | def getOrCreateChild(parent: NestedFieldNode, name: String): NestedFieldNode = { | CODE |
| LOW | …pache/spark/sql/hive/SparkCatalogMetaStoreClient.scala | 282 | 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_mcp.py | 30 | async def test_mcp_lists_and_calls_tools(registry) -> None: | CODE |
| LOW | hudi-agent-gateway/tests/test_mcp.py | 42 | async def test_mounted_mcp_serves_over_http(settings, fake_trino) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 30 | async def test_query_lakehouse_shapes_result(registry: ToolRegistry, fake_trino) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 39 | async def test_query_lakehouse_guardrail_error_returned_not_raised(registry: ToolRegistry) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 45 | async def test_query_lakehouse_trino_error_returned(registry: ToolRegistry, fake_trino) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 51 | async def test_query_lakehouse_timeout_gets_actionable_hint( | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 75 | async def test_row_capped_result_reports_truncated(registry: ToolRegistry, fake_trino) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 84 | async def test_list_tables_defaults(registry: ToolRegistry, fake_trino) -> None: | CODE |
| LOW⚡ | hudi-agent-gateway/tests/test_trino_tools.py | 91 | async def test_list_tables_explicit(registry: ToolRegistry, fake_trino) -> None: | CODE |
| 11 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 | 1279 | | SELECT 1 as id, 'John Doe' as name, 19 as price, 1598886001 as ts | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1281 | | SELECT 2, 'Jane Doe', 24, 1598972400 | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1293 | | CAST('John Doe' AS STRING) as name, | CODE |
| LOW | …he/spark/sql/hudi/dml/others/TestMergeIntoTable2.scala | 1316 | 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 | 1317 | 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 | 433 | Object rowKeyNotExist = HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", true, false); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 437 | 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 | 439 | HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 455 | // test get fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 456 | 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 | 458 | HoodieAvroUtils.getNestedFieldVal(rec, "fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 469 | // test get student.fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 470 | 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 | 472 | HoodieAvroUtils.getNestedFieldVal(rec, "student.fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 480 | // test get student.firstname.fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 483 | HoodieAvroUtils.getNestedFieldVal(rec, "student.firstnameNested.fake_key", false, false)).getMessage()); | CODE |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 485 | // test get student.lastname(null).fake_key | COMMENT |
| LOW⚡ | …a/org/apache/hudi/common/avro/TestHoodieAvroUtils.java | 488 | 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 | 1063 | "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_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 | 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 | 55 | # 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 |
|---|---|---|---|---|
| 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 | 104 | # Check if version is in the requested array | COMMENT |
| LOW | …ources/upgrade-downgrade-fixtures/generate-fixtures.sh | 161 | # Check if Spark binary already exists | COMMENT |
| LOW | scripts/release/validate_source_copyright.sh | 55 | # Check if the variable holding the list of files is non-empty | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | 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 |
|---|---|---|---|---|
| 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 | 473 | // TODO: Add validation for compaction and clustering cases | COMMENT |