Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
This report presents the forensic synthetic code analysis of apache/paimon, a Java project with 3,365 GitHub stars. SynthScan v2.0 examined 1,275,369 lines of code across 6424 source files, recording 6454 pattern matches distributed across 20 syntactic categories. The overall adjusted score of 8.3 places this repository in the Low AI signal 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).
Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.
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 6454 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 |
|---|---|---|---|---|
| LOW | …n-python/pypaimon/write/global_index_update_checker.py | 23 | def scan_global_index_entries(table, snapshot): | CODE |
| LOW | …n-python/pypaimon/write/global_index_update_checker.py | 61 | def apply_global_index_update_action( | CODE |
| LOW⚡ | paimon-python/pypaimon/write/file_store_commit.py | 1078 | def _generate_partition_statistics(self, commit_entries: List[ManifestEntry]) -> List[PartitionStatistics]: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 89 | def _try_replace_manifest_files(current, replaced, replacement): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 117 | def _try_reuse_manifest_merge_result(retry_result, current_manifests): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 339 | def _hash_index_base_snapshot( | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 352 | def _overwrite_hash_index_deletes(self, partition_filter, deletes): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 829 | def _try_rewrite_row_id_conflict( | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 896 | def _create_dynamic_partition_filter(self, commit_messages: List[CommitMessage]): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 914 | def _create_static_partition_filter(self, overwrite_partition, commit_messages: List[CommitMessage]): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 935 | def _overwrite_changes_provider(self, partition_filter, commit_messages): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 959 | def _collect_changelog_entries(self, commit_messages: List[CommitMessage]) -> List[ManifestEntry]: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 978 | def _collect_manifest_entries(self, commit_messages: List[CommitMessage]) -> List[ManifestEntry]: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1005 | def _clean_up_reuse_tmp_manifests( | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1027 | def _clean_up_no_reuse_tmp_manifests( | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1185 | def _assign_row_tracking_meta(self, first_row_id_start: int, commit_entries: List[ManifestEntry]): | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 41 | def _cast_binary_to_table_schema(table: pa.Table, target_schema: pa.Schema) -> pa.Table: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 235 | def add_pending_commit_messages(self, commit_messages) -> None: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 366 | def _write_postpone_primary_key_blocks( | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 541 | def _write_primary_key_groups( | CODE |
| LOW | paimon-python/pypaimon/write/table_delete.py | 235 | def _read_existing_deletion_vectors( | CODE |
| LOW | paimon-python/pypaimon/write/table_delete.py | 279 | def _write_deletion_vector_index( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 51 | def _filter_by_whole_file_shard(splits: List[DataSplit], sub_task_id: int, total_tasks: int) -> List[DataSplit]: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 154 | def _update_by_arrow_with_row_id( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 164 | def _upsert_by_arrow_with_key( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 263 | def _matched_update_scan_table(self): | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 290 | def _validate_predicate_update(self, assignments: Mapping[str, Any]): | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 314 | def _build_predicate_update_table( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 366 | def _delete_by_partition_filter( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 406 | def _partition_delete_message(messages, partition, bucket, snapshot_id): | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 433 | def _partition_only_delete_filter( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 450 | def _rewrite_predicate_to_partition_indices( | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 502 | def update_by_arrow_with_row_id(self, table: pa.Table) -> List[CommitMessage]: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 565 | def update_by_arrow_with_row_id( | CODE |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 112 | def _load_existing_files_info(self) -> _FilesInfo: | CODE |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 425 | def _merge_update_with_original( | CODE |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 652 | def _assign_update_file_metadata(new_files: List[DataFileMeta], first_row_id: int, | CODE |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 217 | def _dedup_row_items_last_write_wins( | CODE |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 473 | def _build_key_to_row_ids_map( | CODE |
| LOW | paimon-python/pypaimon/write/row_utils.py | 89 | def row_values_to_arrow_table( | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 50 | def _create_row_key_extractor(self, static_partition): | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 88 | def _write_partition_bucket_batch(self, partition, bucket, data): | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 91 | def with_dynamic_bucket_index( | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 117 | def write_arrow_batch_to_bucket( | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 193 | def _write_partition_bucket_row( | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 274 | def _distributed_write_options(self) -> Dict[str, Any]: | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 326 | def _release_prepared_indexes(self) -> None: | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 343 | def _is_compatible_pyarrow_schema( | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 358 | def _write_cols_pyarrow_schema(self, write_cols: List[str]) -> pa.Schema: | CODE |
| LOW | paimon-python/pypaimon/write/table_write.py | 364 | def _raise_inconsistent_schema(self, data_schema: pa.Schema): | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 123 | def extract_partition_bucket_batch(self, data: pa.RecordBatch) -> Tuple[List[Tuple], List[int]]: | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 132 | def extract_partition_bucket_groups( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 228 | def extract_partition_bucket_row( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 243 | def _extract_partitions_batch(self, data: pa.RecordBatch) -> List[Tuple]: | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 513 | def _extract_key_hashes_batch(self, data: pa.RecordBatch) -> List[int]: | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 536 | def extract_partition_bucket_from_hashes_batch( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 547 | def extract_partition_bucket_status_from_hashes_batch( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 643 | def notify_precomputed_bucket_batch( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 652 | def notify_precomputed_bucket_hashes_batch( | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 756 | def extract_partition_bucket_batch( | CODE |
| 3699 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …java/org/apache/paimon/jindo/JindoMultiPartUpload.java | 72 | new com.aliyun.jindodata.api.spec.protos.JdoObjectPartList(); | CODE |
| CRITICAL | …org/apache/paimon/core/IcebergDVCompatibilityTest.java | 308 | org.apache.iceberg.data.GenericRecord.create(type); | CODE |
| CRITICAL⚡ | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 95 | org.apache.paimon.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 103 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 106 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 109 | "col2", org.apache.flink.cdc.common.types.DataTypes.INT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 193 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 196 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 199 | "col2", org.apache.flink.cdc.common.types.DataTypes.INT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 202 | org.apache.flink.cdc.common.types.DataTypes.INT().notNull()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 224 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 227 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 230 | "col2", org.apache.flink.cdc.common.types.DataTypes.INT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 252 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 255 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 259 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 262 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 265 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 295 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 298 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 302 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 305 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 308 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 334 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 337 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 341 | org.apache.flink.cdc.common.types.DataTypes.BOOLEAN()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 344 | org.apache.flink.cdc.common.types.DataTypes.BINARY(3)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 347 | org.apache.flink.cdc.common.types.DataTypes.VARBINARY(10)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 350 | org.apache.flink.cdc.common.types.DataTypes.BYTES()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 353 | org.apache.flink.cdc.common.types.DataTypes.TINYINT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 356 | org.apache.flink.cdc.common.types.DataTypes.SMALLINT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 358 | "int", org.apache.flink.cdc.common.types.DataTypes.INT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 361 | org.apache.flink.cdc.common.types.DataTypes.FLOAT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 364 | org.apache.flink.cdc.common.types.DataTypes.DOUBLE()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 367 | org.apache.flink.cdc.common.types.DataTypes.DECIMAL(6, 3)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 369 | "char", org.apache.flink.cdc.common.types.DataTypes.CHAR(5)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 372 | org.apache.flink.cdc.common.types.DataTypes.VARCHAR(10)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 375 | org.apache.flink.cdc.common.types.DataTypes.STRING()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 377 | "date", org.apache.flink.cdc.common.types.DataTypes.DATE()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 379 | "time", org.apache.flink.cdc.common.types.DataTypes.TIME()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 382 | org.apache.flink.cdc.common.types.DataTypes.TIME(6)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 385 | org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 388 | org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP(3)) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 391 | org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP_LTZ()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 394 | org.apache.flink.cdc.common.types.DataTypes.TIMESTAMP_LTZ( | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 442 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 445 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 448 | "col2", org.apache.flink.cdc.common.types.DataTypes.INT()) | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 479 | org.apache.flink.cdc.common.types.DataTypes.STRING()), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 485 | org.apache.flink.cdc.common.types.DataTypes.STRING()))); | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 490 | org.apache.flink.cdc.common.types.DataTypes.STRING()))); | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 495 | org.apache.flink.cdc.common.types.DataTypes.STRING()), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 500 | "col7_after", org.apache.flink.cdc.common.types.DataTypes.STRING()), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 531 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 534 | org.apache.flink.cdc.common.types.DataTypes.STRING() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 539 | org.apache.flink.cdc.common.types.DataTypes.STRING(), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 543 | org.apache.flink.cdc.common.types.DataTypes.STRING(), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 547 | org.apache.flink.cdc.common.types.DataTypes.STRING(), | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 576 | org.apache.flink.cdc.common.schema.Schema.newBuilder() | CODE |
| CRITICAL⚡ | …ink/pipeline/cdc/schema/PaimonMetadataApplierTest.java | 579 | org.apache.flink.cdc.common.types.DataTypes.INT().notNull()) | CODE |
| 208 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 23 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 25 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 77 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 79 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 109 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 111 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 187 | # ---------------------------------------- | COMMENT |
| MEDIUM | …-tests/src/test/resources-filtered/docker-compose.yaml | 189 | # ---------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 241 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 243 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 274 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 276 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/read_builder.py | 163 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/read_builder.py | 165 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/explain.py | 141 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/explain.py | 143 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …hon/pypaimon/read/reader/aggregation_merge_function.py | 53 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …hon/pypaimon/read/reader/aggregation_merge_function.py | 56 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …hon/pypaimon/read/reader/aggregation_merge_function.py | 118 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …hon/pypaimon/read/reader/aggregation_merge_function.py | 120 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 89 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 91 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 165 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 167 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 226 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 228 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1450 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1454 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 314 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 316 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 315 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 317 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 448 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 450 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 196 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 198 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 253 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 255 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 277 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 279 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …on-python/pypaimon/tests/schema_evolution_read_test.py | 553 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …on-python/pypaimon/tests/schema_evolution_read_test.py | 559 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 81 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 83 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 559 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 563 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 882 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 885 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 48 | # ====================================================================== | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 50 | # ====================================================================== | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 125 | # ====================================================================== | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 127 | # ====================================================================== | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 151 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 153 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 166 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 168 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 199 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 201 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 219 | # ====================================================================== | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/data_evolution_test_helpers.py | 221 | # ====================================================================== | COMMENT |
| 202 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | …pache/paimon/iceberg/IcebergRestMetadataCommitter.java | 481 | // When we create an Iceberg table via the REST catalog, we register it with | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-1.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-5.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-4.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-3.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-2.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …cdc/src/test/resources/mongodb/database/test-data-6.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …n-flink-cdc/src/test/resources/mongodb/docker/setup.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nk-cdc/src/test/resources/mongodb/table/inventory-2.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nk-cdc/src/test/resources/mongodb/table/inventory-3.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nk-cdc/src/test/resources/mongodb/table/inventory-4.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …nk-cdc/src/test/resources/mongodb/table/inventory-1.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/test/resources/mongodb/table/defaultid/defaultId-1.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …/test/resources/mongodb/table/defaultid/defaultId-2.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …resources/mongodb/table/computedcolumn/test-table-2.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …resources/mongodb/table/computedcolumn/test-table-1.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …src/test/resources/mongodb/table/event/event-insert.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …src/test/resources/mongodb/table/event/event-delete.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …src/test/resources/mongodb/table/event/event-update.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …rc/test/resources/mongodb/table/event/event-replace.js | 1 | // Licensed to the Apache Software Foundation (ASF) under one or more | COMMENT |
| LOW | …ctors/mysql/source/connection/JdbcConnectionPools.java | 61 | // Intentionally no-op. | COMMENT |
| LOW | …e/paimon/flink/action/RemoveUnexistingFilesAction.java | 221 | public void endInput() { | COMMENT |
| LOW | tools/ci/sonar_check.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/ci/docs.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/releasing/create_source_release.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/releasing/create_release_branch.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/releasing/sign_maven_repository.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/releasing/deploy_maven_repository.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/releasing/update_branch_version.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …-tests/src/test/resources-filtered/docker-compose.yaml | 1 | ################################################################################ | COMMENT |
| LOW | docs/static/rest-catalog-open-api.yaml | 1 | # | COMMENT |
| LOW | paimon-python/conftest.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/setup.py | 1 | ########################################################################## | COMMENT |
| LOW | paimon-python/dev/cfg.ini | 1 | ################################################################################ | COMMENT |
| LOW | paimon-python/dev/requirements.txt | 1 | ################################################################################ | COMMENT |
| LOW | paimon-python/dev/run_mixed_tests.sh | 1 | #!/bin/bash | COMMENT |
| LOW | paimon-python/dev/lint-python.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | paimon-python/dev/check_license_header.py | 1 | #!/usr/bin/env python | COMMENT |
| LOW | paimon-python/dev/requirements-dev.txt | 1 | ################################################################################ | COMMENT |
| LOW | paimon-python/dev/auto-check.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | paimon-python/dev/check-licensing.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | paimon-python/pypaimon/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_commit.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/blob_format_writer.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | …n-python/pypaimon/write/global_index_update_checker.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/postpone_bucket.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_delete.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_update.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/write_builder.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/row_utils.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/table_write.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/commit_callback.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/write/commit_message.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 721 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/setup.py | 44 | except Exception: | CODE |
| LOW | paimon-python/dev/check_license_header.py | 44 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/table_commit.py | 97 | except Exception: | CODE |
| LOW⚡ | paimon-python/pypaimon/write/file_store_commit.py | 1064 | except Exception as e: | CODE |
| LOW⚡ | paimon-python/pypaimon/write/file_store_commit.py | 1073 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 752 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 758 | except Exception as cleanup_err: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 797 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1021 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1051 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 154 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 158 | except Exception as abort_error: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 217 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 229 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 257 | except Exception as abort_error: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 412 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 493 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 587 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_delete.py | 308 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 58 | except Exception: # any failure here means "use the fallback" | CODE |
| LOW | paimon-python/pypaimon/write/file_store_write.py | 350 | except Exception as e: | CODE |
| MEDIUM | …mon-python/pypaimon/write/commit/conflict_detection.py | 208 | def check_conflicts( | CODE |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 217 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 224 | except Exception as e: | CODE |
| LOW | …thon/pypaimon/write/commit/row_id_conflict_rewriter.py | 139 | except Exception: | CODE |
| LOW | …thon/pypaimon/write/commit/row_id_conflict_rewriter.py | 142 | except Exception: | CODE |
| LOW | …on/pypaimon/write/commit/overwrite_changes_provider.py | 98 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/commit/commit_rollback.py | 59 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/writer/blob_writer.py | 244 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 129 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 143 | except Exception as e: | CODE |
| LOW | …-python/pypaimon/write/writer/key_value_data_writer.py | 93 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 117 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 138 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 169 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 258 | except Exception: | CODE |
| MEDIUM | paimon-python/pypaimon/write/writer/data_writer.py | 134 | def close(self): | CODE |
| LOW | paimon-python/pypaimon/write/writer/blob_file_writer.py | 192 | except Exception: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 231 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 284 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 296 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 324 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 409 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 436 | except Exception as e: | CODE |
| MEDIUM | …ython/pypaimon/write/writer/dedicated_format_writer.py | 236 | def write_row(self, row): | CODE |
| LOW | paimon-python/pypaimon/benchmark/hdfs_io_bench.py | 108 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/benchmark/hdfs_io_bench.py | 147 | except Exception as e: | CODE |
| LOW | …n-python/pypaimon/snapshot/renaming_snapshot_commit.py | 98 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 186 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 415 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/snapshot/snapshot_loader.py | 71 | except Exception as e: | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 143 | except Exception as e: | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 171 | except Exception as e: | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 194 | except Exception as e: | CODE |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 246 | except Exception as e: | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 299 | except Exception as e: | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 365 | except Exception as e: | CODE |
| LOW⚡ | paimon-python/pypaimon/changelog/changelog_manager.py | 59 | except Exception as e: | CODE |
| LOW⚡ | paimon-python/pypaimon/changelog/changelog_manager.py | 70 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/changelog/changelog_manager.py | 85 | except Exception as e: | CODE |
| 382 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …thon/pypaimon/table/source/full_text_search_builder.py | 0 | partition predicate used to prune index manifest entries. | STRING |
| HIGH | …-python/pypaimon/table/source/hybrid_search_builder.py | 0 | partition predicate used to prune index manifest entries. | STRING |
| HIGH | …n/pypaimon/table/source/batch_vector_search_builder.py | 0 | partition predicate used to prune index manifest entries. | STRING |
| HIGH | …-python/pypaimon/table/source/vector_search_builder.py | 0 | partition predicate used to prune index manifest entries. | STRING |
| HIGH | …est/scala/org/apache/paimon/spark/PaimonSinkTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …paimon/spark/sql/CreateAndDeleteTagProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …rg/apache/paimon/spark/sql/RollbackProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …est/scala/org/apache/paimon/spark/PaimonSinkTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …/spark/procedure/CreateAndDeleteTagProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …pache/paimon/spark/procedure/BranchProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …e/paimon/spark/procedure/ReplaceTagProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …rk/procedure/CreateTagFromTimestampProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …/paimon/spark/procedure/AlterBranchProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …mon/spark/procedure/ExpireSnapshotsProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …che/paimon/spark/procedure/RollbackProcedureTest.scala | 0 | |create table t (a int, b string) |tblproperties ('primary-key'='a', 'bucket'='3') | | STRING |
| HIGH | …/org/apache/paimon/spark/sql/InsertOverwriteTest.scala | 0 | |create table t (a int, b string) |tblproperties ($prop) | | STRING |
| HIGH | …he/paimon/spark/sql/InsertOverwriteTableTestBase.scala | 0 | |create table t (a int, b string) |tblproperties ($prop) | | STRING |
| HIGH | …g/apache/paimon/spark/sql/DataFrameWriteTestBase.scala | 0 | |create table t (a int, b string) |tblproperties ($prop) | | STRING |
| HIGH | …/org/apache/paimon/spark/sql/InsertOverwriteTest.scala | 0 | |create table t (a int, b int, c string) |using paimon |tblproperties ($prop) |partitioned by (a) | | STRING |
| HIGH | …he/paimon/spark/sql/InsertOverwriteTableTestBase.scala | 0 | |create table t (a int, b int, c string) |using paimon |tblproperties ($prop) |partitioned by (a) | | STRING |
| HIGH | …apache/paimon/spark/sql/TableValuedFunctionsTest.scala | 0 | |create table t (a int, b int, c string) |using paimon |tblproperties ($prop) |partitioned by (a) | | STRING |
| HIGH | …he/paimon/spark/rowops/PaimonCopyOnWriteScanTest.scala | 0 | create table t (id int, name string) | using paimon | tblproperties ('primary-key' = 'id', 'bucket' = '1') | STRING |
| HIGH | …g/apache/paimon/spark/sql/MergeIntoAlignmentTest.scala | 0 | create table t (id int, name string) | using paimon | tblproperties ('primary-key' = 'id', 'bucket' = '1') | STRING |
| HIGH | …org/apache/paimon/spark/sql/WriteMergeSchemaTest.scala | 0 | create table t (id int, name string) | using paimon | tblproperties ('primary-key' = 'id', 'bucket' = '1') | STRING |
| HIGH | …/paimon/spark/procedure/FastForwardProcedureTest.scala | 0 | |create table t (id string, name string) |using paimon |tblproperties ('primary-key'='id') | | STRING |
| HIGH | …n/spark/procedure/RemoveOrphanFilesProcedureTest.scala | 0 | |create table t (id string, name string) |using paimon |tblproperties ('primary-key'='id') | | STRING |
| HIGH | …org/apache/paimon/spark/sql/AnalyzeTableTestBase.scala | 0 | |create table t (id string, name string) |using paimon |tblproperties ('primary-key'='id') | | STRING |
| HIGH | …mon/spark/procedure/DropGlobalIndexProcedureTest.scala | 0 | |create table t (id int, title string, content string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per | STRING |
| HIGH | …n/spark/procedure/CreateGlobalIndexProcedureTest.scala | 0 | |create table t (id int, title string, content string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per | STRING |
| HIGH | …a/org/apache/paimon/spark/sql/FullTextSearchTest.scala | 0 | |create table t (id int, title string, content string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per | STRING |
| HIGH | …ala/org/apache/paimon/spark/sql/HybridSearchTest.scala | 0 | |create table t (id int, title string, content string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per | STRING |
| HIGH | …mon/spark/procedure/DropGlobalIndexProcedureTest.scala | 0 | |create table t (id int, name string, pt string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per-shard | STRING |
| HIGH | …n/spark/procedure/CreateGlobalIndexProcedureTest.scala | 0 | |create table t (id int, name string, pt string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per-shard | STRING |
| HIGH | …/org/apache/paimon/spark/sql/RowTrackingTestBase.scala | 0 | |create table t (id int, name string, pt string) |tblproperties ( | 'bucket' = '-1', | 'global-index.row-count-per-shard | STRING |
| HIGH | …e/paimon/spark/procedure/ExpireTagsProcedureTest.scala | 0 | |create table t (id string, name string) |using paimon | | STRING |
| HIGH | …e/paimon/spark/procedure/PurgeFilesProcedureTest.scala | 0 | |create table t (id string, name string) |using paimon | | STRING |
| HIGH | …rg/apache/paimon/spark/sql/PaimonSystemTableTest.scala | 0 | |create table t (id string, name string) |using paimon | | STRING |
| HIGH | …st/scala/org/apache/paimon/spark/sql/DDLTestBase.scala | 0 | |create table rtas (id bigint, data string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '2') | | STRING |
| HIGH | …/org/apache/paimon/spark/sql/FormatTableTestBase.scala | 0 | |create table rtas (id bigint, data string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '2') | | STRING |
| HIGH | …g/apache/paimon/spark/sql/DataFrameWriteTestBase.scala | 0 | |create table rtas (id bigint, data string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '2') | | STRING |
| HIGH | …paimon/spark/sql/ReplaceTableWithRestCatalogTest.scala | 0 | |create table rtas (id bigint, data string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '2') | | STRING |
| HIGH | …ache/paimon/spark/sql/DDLWithHiveCatalogTestBase.scala | 0 | |create table rtas (id bigint, data string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '2') | | STRING |
| HIGH | …st/scala/org/apache/paimon/spark/sql/DDLTestBase.scala | 0 | |replace table rt (id bigint, name string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '4') | | STRING |
| HIGH | …paimon/spark/sql/ReplaceTableWithRestCatalogTest.scala | 0 | |replace table rt (id bigint, name string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '4') | | STRING |
| HIGH | …ache/paimon/spark/sql/DDLWithHiveCatalogTestBase.scala | 0 | |replace table rt (id bigint, name string) |using paimon |tblproperties ('primary-key' = 'id', 'bucket' = '4') | | STRING |
| HIGH | …paimon/spark/sql/MergeIntoNotMatchedBySourceTest.scala | 0 | |merge into target |using source |on target.a = source.a |when matched and target.a = 5 then update set b = source.b + t | STRING |
| HIGH | …a/org/apache/paimon/spark/sql/DeletionVectorTest.scala | 0 | |merge into target |using source |on target.a = source.a |when matched and target.a = 5 then update set b = source.b + t | STRING |
| HIGH | …g/apache/paimon/spark/sql/MergeIntoTableTestBase.scala | 0 | |merge into target |using source |on target.a = source.a |when matched and target.a = 5 then update set b = source.b + t | STRING |
| HIGH | …/org/apache/paimon/spark/sql/RowTrackingTestBase.scala | 0 | |merge into target |using source |on target.a = source.a |when matched and target.a = 5 then update set b = source.b + t | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/setup.py | 51 | CODE | |
| LOW | paimon-python/setup.py | 124 | CODE | |
| LOW | paimon-python/pypaimon/write/postpone_bucket.py | 259 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 207 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 438 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 545 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 896 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1005 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1042 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1078 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1185 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 463 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 528 | CODE | |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 125 | CODE | |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 668 | CODE | |
| LOW | …on/pypaimon/write/commit/overwrite_changes_provider.py | 54 | CODE | |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 199 | CODE | |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 214 | CODE | |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 236 | CODE | |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 382 | CODE | |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 495 | CODE | |
| LOW | …imon-python/pypaimon/write/writer/format_row_writer.py | 233 | CODE | |
| LOW | paimon-python/pypaimon/benchmark/clickbench_format.py | 171 | CODE | |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 166 | CODE | |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 237 | CODE | |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 325 | CODE | |
| LOW | paimon-python/pypaimon/snapshot/time_travel_util.py | 69 | CODE | |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 332 | CODE | |
| LOW | paimon-python/pypaimon/catalog/table_query_auth.py | 66 | CODE | |
| LOW | paimon-python/pypaimon/catalog/jdbc_catalog.py | 47 | CODE | |
| LOW | paimon-python/pypaimon/catalog/rest/fuse_support.py | 39 | CODE | |
| LOW | …imon-python/pypaimon/manifest/manifest_file_manager.py | 55 | CODE | |
| LOW | …imon-python/pypaimon/manifest/manifest_file_manager.py | 96 | CODE | |
| LOW | …mon-python/pypaimon/manifest/simple_stats_evolution.py | 71 | CODE | |
| LOW | paimon-python/pypaimon/manifest/schema/file_entry.py | 92 | CODE | |
| LOW | paimon-python/pypaimon/read/merge_engine_support.py | 233 | CODE | |
| LOW | paimon-python/pypaimon/read/merge_engine_support.py | 253 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 130 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 238 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 422 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 705 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 133 | CODE | |
| LOW | paimon-python/pypaimon/read/split_read.py | 225 | CODE | |
| LOW | paimon-python/pypaimon/read/split_read.py | 638 | CODE | |
| LOW | paimon-python/pypaimon/read/split_read.py | 1306 | CODE | |
| LOW | paimon-python/pypaimon/read/split_read.py | 1467 | CODE | |
| LOW | paimon-python/pypaimon/read/streaming_table_scan.py | 128 | CODE | |
| LOW | paimon-python/pypaimon/read/table_scan.py | 411 | CODE | |
| LOW | paimon-python/pypaimon/read/sliced_split.py | 106 | CODE | |
| LOW | …mon-python/pypaimon/read/reader/auth_masking_reader.py | 46 | CODE | |
| LOW | paimon-python/pypaimon/read/reader/lance_utils.py | 26 | CODE | |
| LOW | paimon-python/pypaimon/read/reader/field_bunch.py | 74 | CODE | |
| LOW | …on-python/pypaimon/read/reader/format_mosaic_reader.py | 178 | CODE | |
| LOW | …n-python/pypaimon/read/reader/format_pyarrow_reader.py | 170 | CODE | |
| LOW | …n-python/pypaimon/read/reader/format_pyarrow_reader.py | 249 | CODE | |
| LOW | …n-python/pypaimon/read/reader/format_pyarrow_reader.py | 397 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/shard_batch_reader.py | 36 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/format_blob_reader.py | 107 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/format_blob_reader.py | 211 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/format_blob_reader.py | 224 | CODE | |
| 181 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/pypaimon/__init__.py | 26 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 27 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 28 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 29 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 30 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 22 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 35 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 36 | CODE | |
| LOW | paimon-python/pypaimon/write/table_write.py | 33 | CODE | |
| LOW | paimon-python/pypaimon/write/commit_message.py | 24 | CODE | |
| LOW | paimon-python/pypaimon/branch/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/branch/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/branch/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/branch/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/changelog/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/changelog/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/catalog/jdbc_catalog.py | 38 | CODE | |
| LOW | paimon-python/pypaimon/manifest/__init__.py | 23 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/aggregate/__init__.py | 84 | CODE | |
| LOW | …imon-python/pypaimon/read/reader/aggregate/__init__.py | 35 | CODE | |
| LOW | …n/pypaimon/tests/ray_data_evolution_merge_into_test.py | 36 | CODE | |
| LOW | paimon-python/pypaimon/tests/table_merge_into_test.py | 38 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 331 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 409 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 457 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 540 | CODE | |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1340 | CODE | |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1373 | CODE | |
| LOW | …python/pypaimon/tests/e2e/hdfs/hdfs_native_e2e_test.py | 52 | CODE | |
| LOW | paimon-python/pypaimon/tests/daft/daft_catalog_test.py | 21 | CODE | |
| LOW | paimon-python/pypaimon/tests/daft/daft_explain_test.py | 21 | CODE | |
| LOW | paimon-python/pypaimon/tests/daft/daft_data_test.py | 25 | CODE | |
| LOW | …on-python/pypaimon/tests/daft/daft_integration_test.py | 21 | CODE | |
| LOW | paimon-python/pypaimon/tests/daft/daft_sink_test.py | 26 | CODE | |
| LOW | …/pypaimon/tests/daft/daft_pk_distributed_write_test.py | 21 | CODE | |
| LOW | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 21 | CODE | |
| LOW | …mon-python/pypaimon/tests/daft/daft_on_ray_e2e_test.py | 25 | CODE | |
| LOW | paimon-python/pypaimon/tests/rest/rest_server.py | 29 | CODE | |
| LOW | paimon-python/pypaimon/cli/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 18 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 19 | CODE | |
| LOW | paimon-python/pypaimon/function/__init__.py | 23 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 20 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 27 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 27 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 28 | CODE | |
| 149 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | …imon-python/pypaimon/manifest/schema/data_file_meta.py | 64 | """Row-id range, failing fast if first_row_id is null (mirrors Java nonNullRowIdRange).""" | STRING |
| HIGH | …/pypaimon/read/reader/partial_update_merge_function.py | 24 | writes "fill in" fields the earlier writes left null, so users can | STRING |
| HIGH | …hon/pypaimon/read/reader/aggregation_merge_function.py | 25 | earlier writes left null; ``AggregateMergeFunction`` runs an actual | STRING |
| HIGH | …ython/pypaimon/read/scanner/bucket_select_converter.py | 216 | # An empty slot (e.g. all literals were null) collapses the | COMMENT |
| HIGH | paimon-python/pypaimon/tests/ray_read_by_row_id_test.py | 431 | self.assertTrue(real_schema.equals(empty.schema().base_schema)) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 448 | self.assertTrue(serial.equals(parallel)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 212 | self.assertTrue(df_serial.equals(df_parallel)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 226 | self.assertTrue(serial_df.equals(parallel_df)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 477 | self.assertTrue(df_s.equals(df_p)) | CODE |
| HIGH | …on-python/pypaimon/tests/schema_evolution_read_test.py | 719 | # while the old (non-null) file still reads correctly. | COMMENT |
| HIGH | paimon-python/pypaimon/tests/filesystem_catalog_test.py | 370 | # Default option (disabled=true) rejects nullable -> not null, mirroring | COMMENT |
| HIGH | paimon-python/pypaimon/tests/variant_test.py | 407 | self._check('{"n":null,"b":true,"i":42,"s":"hello","f":1.5}') | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/row_to_string_test.py | 53 | self.assertEqual("{null, a}", cast_row_to_string(_row(("INT", None), | CODE |
| HIGH | paimon-python/pypaimon/tests/data_evolution_test.py | 862 | self.assertEqual(arrow_res3.num_rows, 0) # Arrow: NULL==NULL is null, filtered out | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_append_only_test.py | 1105 | # partition value: isNull keeps null, drops non-null; equal is the reverse. | COMMENT |
| HIGH | …on/pypaimon/tests/schema_evolution_nested_read_test.py | 644 | self.assertEqual(rows[1]['mv'], '{null, x}') | CODE |
| HIGH⚡ | …n-python/pypaimon/tests/filesystem_catalog_tag_test.py | 126 | # duration string (matching Java's Duration.toString()). | COMMENT |
| HIGH | paimon-python/pypaimon/tests/system/tags_table_test.py | 139 | # duration string (Java Duration.toString()). | COMMENT |
| HIGH⚡ | …mon-python/pypaimon/tests/api/test_branch_dto_serde.py | 55 | # @Nullable behavior; jackson serializes nullable Long as null). | COMMENT |
| HIGH⚡ | …mon-python/pypaimon/tests/api/test_branch_dto_serde.py | 71 | # must serialize to {} (not null, not an array, not absent). | COMMENT |
| HIGH | paimon-python/pypaimon/tests/daft/daft_blob_test.py | 75 | # io_config is null without creds; embedded only for valid (non-null) rows with creds. | COMMENT |
| HIGH⚡ | …thon/pypaimon/tests/daft/daft_blob_native_read_test.py | 115 | # must still be read (as null) via fallback, not dropped. | COMMENT |
| HIGH | …on-python/pypaimon/tests/daft/daft_integration_test.py | 497 | assert pypaimon_result.equals(expected_result) | CODE |
| HIGH | paimon-python/pypaimon/common/time_utils.py | 222 | """Render a non-negative ``timedelta`` like ``java.time.Duration.toString()``. | STRING |
| HIGH | paimon-python/pypaimon/common/predicate_json_parser.py | 146 | All comparison results are coerced from three-valued (PyArrow null) to | STRING |
| HIGH | paimon-python/pypaimon/data/variant_shredding.py | 436 | # if typed_value is null → use overflow bytes directly | COMMENT |
| HIGH | paimon-python/pypaimon/ray/data_evolution_merge_join.py | 520 | "_ROW_ID is null; planner snapshot is stale " | CODE |
| HIGH | paimon-python/pypaimon/ray/data_evolution_merge_join.py | 689 | "_ROW_ID is null; the planner snapshot is stale or the row ids " | CODE |
| HIGH | paimon-python/pypaimon/ray/data_evolution_merge_join.py | 808 | "_ROW_ID is null; planner snapshot is stale " | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 518 | // Step 1: baseline | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 525 | // Step 2: drop v2 → [k, v1] | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 531 | // Step 3: option-only alter — same fields [k, v1], increments Paimon schema ID | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 537 | // Step 4: re-add v2 as BIGINT — new field ID, distinct from original v2 (STRING) | COMMENT |
| LOW⚡ | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 88 | // Step 1: Convert CDC Schema to Paimon Schema | COMMENT |
| LOW⚡ | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 92 | // Step 2: Validate Paimon Schema | COMMENT |
| LOW | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 132 | // Step 3: Convert it back | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 229 | // Step 1: Convert CDC Event to Paimon Event | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 236 | // Step 2: Check Paimon Row specs | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 248 | // Step 3: Convert it back | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 255 | // Step 4: Validate it | COMMENT |
| LOW | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1205 | // Step 1: Create a Paimon table with blob field via Flink SQL | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1217 | // Step 2: Get the Paimon FileStoreTable and its RowType | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1221 | // Step 3: Create a Flink temporary table with the same schema (BYTES column) | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1239 | // Step 4: Convert Paimon RowType to Flink RowType via LogicalTypeConversion | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1243 | // Step 5: Assert that schemaEquals considers them equal | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2091 | // Step 1: Write delta data at dt=20250808 | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2096 | // Step 2: Start streaming job (captures delta position) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2099 | // Step 3: Collect Phase 1 output (should include delta@20250808) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2106 | // Step 4: Write NEW snapshot data at dt=20250809 (simulates race condition) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2111 | // Step 5: Write NEW delta data at dt=20250810 | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2116 | // Step 6: Collect Phase 2 output (should include delta@20250810) | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 240 | // Step 1: prepend key columns to each row: (key, value) -> JoinedRow | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 276 | // Step 2: local sort by key columns (no shuffle) | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 292 | // Step 3: remove the prepended key columns and convert back to RowData | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 158 | // Step 1: Build CanonicalizedHeaders (x-acs-* headers, sorted, lowercase) | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 161 | // Step 2: Build CanonicalizedResource (path + sorted query string) | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 164 | // Step 3: Build StringToSign | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 172 | // Step 4: Calculate signature | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 175 | // Step 5: Build Authorization header | COMMENT |
| LOW | paimon-python/dev/run_mixed_tests.sh | 751 | # Step 1: Java writes 5 base files | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 744 | # Step 1: Write data to Paimon table using write_arrow (large_binary type) | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 759 | # Step 2: Read from Paimon table using to_ray() | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 783 | # Step 3: Simulate user pipeline: map_batches returns Python dict, | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 802 | # Step 4: Write mapped dataset back via write_ray(). | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 813 | # Step 5: Verify the data was written correctly | COMMENT |
| LOW⚡ | …imon-python/pypaimon/tests/shard_table_updator_test.py | 56 | # Step 1: Create table with a, b, c, d columns (all int32) | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 71 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 87 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 125 | # Step 4: Verify the result | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 158 | # Step 1: Create table with a, b, c, d columns (all int32) | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 173 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 190 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 224 | # Step 4: Verify the result | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 265 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 282 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 311 | # Step 4: Verify the result | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1367 | # Step 1: Create table with [f0, f1] | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1396 | # Step 3: Schema evolution - add column f2 | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1403 | # Step 4: Write f2 only for same rows (first_row_id = 0) | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1380 | # Step 2: Write data with ALL columns of old schema → write_cols = None | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1419 | # Step 5: Read all columns | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1742 | # Step 2: pypaimon shard update - scan and prepare commit | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1765 | # Step 3: Java compact (compact happening between scan and commit) | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1782 | # Step 4: pypaimon rewrites stale evolution files against the compacted range | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 800 | // Step 1: write data with schemaId=0 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 803 | // Step 2: ALTER TABLE SET an unrelated option -> schemaId becomes 1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 807 | // Step 3: write more data with schemaId=1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 810 | // Step 4: compact blob table using DataEvolutionCompactCoordinator | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 981 | // Step 1: write blob data — blob files record writeCols=["f2"] | COMMENT |
| 37 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 518 | // Step 1: baseline | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 525 | // Step 2: drop v2 → [k, v1] | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 531 | // Step 3: option-only alter — same fields [k, v1], increments Paimon schema ID | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 537 | // Step 4: re-add v2 as BIGINT — new field ID, distinct from original v2 (STRING) | COMMENT |
| LOW⚡ | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 88 | // Step 1: Convert CDC Schema to Paimon Schema | COMMENT |
| LOW⚡ | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 92 | // Step 2: Validate Paimon Schema | COMMENT |
| LOW | …/paimon/flink/pipeline/cdc/util/TypeConverterTest.java | 132 | // Step 3: Convert it back | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 229 | // Step 1: Convert CDC Event to Paimon Event | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 236 | // Step 2: Check Paimon Row specs | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 248 | // Step 3: Convert it back | COMMENT |
| LOW⚡ | …he/paimon/flink/pipeline/cdc/util/DataConvertTest.java | 255 | // Step 4: Validate it | COMMENT |
| LOW | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1205 | // Step 1: Create a Paimon table with blob field via Flink SQL | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1217 | // Step 2: Get the Paimon FileStoreTable and its RowType | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1221 | // Step 3: Create a Flink temporary table with the same schema (BYTES column) | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1239 | // Step 4: Convert Paimon RowType to Flink RowType via LogicalTypeConversion | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1243 | // Step 5: Assert that schemaEquals considers them equal | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2091 | // Step 1: Write delta data at dt=20250808 | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2096 | // Step 2: Start streaming job (captures delta position) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2099 | // Step 3: Collect Phase 1 output (should include delta@20250808) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2106 | // Step 4: Write NEW snapshot data at dt=20250809 (simulates race condition) | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2111 | // Step 5: Write NEW delta data at dt=20250810 | COMMENT |
| LOW⚡ | …ava/org/apache/paimon/flink/FlinkChainTableITCase.java | 2116 | // Step 6: Collect Phase 2 output (should include delta@20250810) | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 240 | // Step 1: prepend key columns to each row: (key, value) -> JoinedRow | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 276 | // Step 2: local sort by key columns (no shuffle) | COMMENT |
| LOW | …he/paimon/flink/compact/IncrementalClusterCompact.java | 292 | // Step 3: remove the prepended key columns and convert back to RowData | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 158 | // Step 1: Build CanonicalizedHeaders (x-acs-* headers, sorted, lowercase) | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 161 | // Step 2: Build CanonicalizedResource (path + sorted query string) | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 164 | // Step 3: Build StringToSign | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 172 | // Step 4: Calculate signature | COMMENT |
| LOW⚡ | …java/org/apache/paimon/rest/auth/DLFOpenApiSigner.java | 175 | // Step 5: Build Authorization header | COMMENT |
| LOW | paimon-python/dev/run_mixed_tests.sh | 751 | # Step 1: Java writes 5 base files | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 744 | # Step 1: Write data to Paimon table using write_arrow (large_binary type) | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 759 | # Step 2: Read from Paimon table using to_ray() | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 783 | # Step 3: Simulate user pipeline: map_batches returns Python dict, | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 802 | # Step 4: Write mapped dataset back via write_ray(). | COMMENT |
| LOW | paimon-python/pypaimon/tests/ray_data_test.py | 813 | # Step 5: Verify the data was written correctly | COMMENT |
| LOW⚡ | …imon-python/pypaimon/tests/shard_table_updator_test.py | 56 | # Step 1: Create table with a, b, c, d columns (all int32) | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 71 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 87 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 125 | # Step 4: Verify the result | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 158 | # Step 1: Create table with a, b, c, d columns (all int32) | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 173 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 190 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 224 | # Step 4: Verify the result | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 265 | # Step 2: Write initial data for a, b, c columns only | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 282 | # Step 3: Use ShardTableUpdator to compute d = c + b - a | COMMENT |
| LOW | …imon-python/pypaimon/tests/shard_table_updator_test.py | 311 | # Step 4: Verify the result | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1367 | # Step 1: Create table with [f0, f1] | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1396 | # Step 3: Schema evolution - add column f2 | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1403 | # Step 4: Write f2 only for same rows (first_row_id = 0) | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1380 | # Step 2: Write data with ALL columns of old schema → write_cols = None | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1419 | # Step 5: Read all columns | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1742 | # Step 2: pypaimon shard update - scan and prepare commit | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1765 | # Step 3: Java compact (compact happening between scan and commit) | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1782 | # Step 4: pypaimon rewrites stale evolution files against the compacted range | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 800 | // Step 1: write data with schemaId=0 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 803 | // Step 2: ALTER TABLE SET an unrelated option -> schemaId becomes 1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 807 | // Step 3: write more data with schemaId=1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 810 | // Step 4: compact blob table using DataEvolutionCompactCoordinator | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 981 | // Step 1: write blob data — blob files record writeCols=["f2"] | COMMENT |
| 37 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …hon/pypaimon/deletionvectors/bitmap_deletion_vector.py | 100 | # Create the full data with magic number | COMMENT |
| MEDIUM | …on-python/pypaimon/manifest/simple_stats_evolutions.py | 57 | # Create a mapping from field IDs to indices in data_fields. | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/split_read.py | 773 | # Create a callable method to read the deletion vector | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/split_read.py | 1008 | # Create a dict mapping data file name to deletion file reader method | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/split_read.py | 1326 | # Create the union reader | COMMENT |
| MEDIUM | …-python/pypaimon/read/reader/data_file_batch_reader.py | 407 | # Create a new array that fills with max_sequence_number | COMMENT |
| MEDIUM | …imon-python/pypaimon/read/datasource/ray_datasource.py | 143 | # Create a partial function to avoid capturing self in closure | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/blob_test.py | 1790 | # Create a valid blob file first | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 124 | # Create a temporary directory and file | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 1287 | # Create a descriptor | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 1701 | # Create a table with multiple columns (should fail - blob format requires single column) | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 1743 | # Create a valid blob file first | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 1828 | # Create a blob file with substantial content | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 2082 | # Create a BlobDescriptor pointing to the local file | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/oss_file_io_test.py | 85 | # Create a test directory | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/oss_file_io_test.py | 246 | # Create a file | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/reader_base_test.py | 536 | # Create a catalog and table | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/reader_base_test.py | 553 | # Create a ManifestFileManager | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 172 | # Create a different config file | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 281 | # Create a CSV file with test data | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 322 | # Create a JSON file with test data | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 362 | # Create a table to drop | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 374 | # Create the table first | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 1061 | # Create a dedicated table for this test with two batches of data | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 1126 | # Create a table to rename | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 1335 | # Create a table with no data | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 1357 | # Create a partitioned table for drop-partition test | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/cli_table_test.py | 1401 | # Create a partitioned table | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/reader_primary_key_test.py | 568 | # Create a unique table for each iteration | COMMENT |
| MEDIUM⚡ | …-python/pypaimon/tests/delta_varint_compressor_test.py | 175 | # Create a sequence with small deltas | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/binary_row_test.py | 224 | # Create a 10-column append table and write 10 rows | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/reader_append_only_test.py | 917 | # Create a unique table for each iteration | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_table_test.py | 4709 | # Create a unique table for each iteration | COMMENT |
| MEDIUM⚡ | …n-python/pypaimon/tests/filesystem_catalog_tag_test.py | 230 | # Create a second snapshot | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/filesystem_catalog_tag_test.py | 252 | # Create a second snapshot | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/branch_manager_test.py | 127 | # Create a mock manager with minimal dependencies | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/branch_manager_test.py | 178 | # Create a branch directory | COMMENT |
| MEDIUM | …-python/pypaimon/tests/py36/rest_ao_read_write_test.py | 813 | # Create a ManifestFileManager | COMMENT |
| MEDIUM⚡ | …python/pypaimon/tests/manifest/manifest_schema_test.py | 77 | # Create a mapping of field names to field definitions for easier testing | COMMENT |
| MEDIUM | …python/pypaimon/tests/manifest/manifest_schema_test.py | 126 | # Create a mapping of field names to field definitions for easier testing | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 135 | # Create a regular table and branch, then select the branch via the | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 176 | # Create a new branch | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 243 | # Create a new table with catalog environment | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 376 | # Create a branch first | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 424 | # Create a table with a comment | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 440 | # Create a table with a comment | COMMENT |
| MEDIUM | …n-python/pypaimon/tests/table/file_store_table_test.py | 462 | # Create a write builder | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 188 | # Create a tag | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 252 | # Create a tag | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 260 | # Create the same tag with ignore_if_exists=True - should not raise error | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 289 | # Create a tag | COMMENT |
| MEDIUM | …-python/pypaimon/tests/rest/rest_token_file_io_test.py | 186 | # Create a token with a standard OSS endpoint | COMMENT |
| MEDIUM | paimon-python/pypaimon/table/file_store_table.py | 79 | # Create a placeholder identifier | COMMENT |
| MEDIUM | paimon-python/pypaimon/data/generic_variant.py | 515 | # Create an Arrow StructArray ready for writing | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | paimon-python/pypaimon/snapshot/snapshot_commit.py | 81 | Commit the given snapshot. Args: base_snapshot_uuid: UUID of the snapshot on which the com | STRING |
| HIGH | …n-python/pypaimon/snapshot/renaming_snapshot_commit.py | 56 | Commit the snapshot using file renaming. Args: base_snapshot_uuid: UUID of the base snapsh | STRING |
| HIGH | paimon-python/pypaimon/snapshot/time_travel_util.py | 74 | Try to travel to a snapshot based on the options. Supports the following time travel options: | STRING |
| HIGH | …on-python/pypaimon/snapshot/catalog_snapshot_commit.py | 52 | Commit the snapshot using the catalog. Args: base_snapshot_uuid: UUID of the snapshot on w | STRING |
| HIGH | paimon-python/pypaimon/changelog/changelog_manager.py | 157 | Try to get a changelog for the given snapshot ID. Args: snapshot_id: Snapshot ID Returns: | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 142 | Load the snapshot of table identified by the given Identifier. Args: identifier: Path of the table | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 212 | List partitions of a table with pagination. Args: identifier: Path of the table. max_re | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 282 | List all branches for the table. Args: identifier: Table identifier Returns: | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 366 | Get a tag of a table. Args: identifier: Table identifier (Identifier or string). tag_na | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 389 | List tags of a table with pagination. Args: identifier: Table identifier (Identifier or string). | STRING |
| HIGH | paimon-python/pypaimon/catalog/rest/rest_catalog.py | 107 | Commit the Snapshot for table identified by the given Identifier. Args: identifier: Path o | STRING |
| HIGH | paimon-python/pypaimon/catalog/rest/rest_catalog.py | 383 | Load the latest snapshot for table. Args: identifier: Path of the table (Identifier or string). | STRING |
| HIGH | paimon-python/pypaimon/manifest/schema/file_entry.py | 93 | Merge file entries: ADD and DELETE of the same file cancel each other. - ADD: if identifier already in map, rai | STRING |
| HIGH | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 282 | Return the projected fields as a tuple. Args: element: Either an ``InternalRow`` or a ``di | STRING |
| HIGH | paimon-python/pypaimon/cli/cli.py | 33 | Load catalog configuration from a YAML file. Args: config_path: Path to the catalog configuration | STRING |
| HIGH | paimon-python/pypaimon/common/where_parser.py | 73 | Parse a SQL-like WHERE clause string into a Predicate. Args: where_string: The WHERE clause string (without | STRING |
| HIGH | paimon-python/pypaimon/common/options/options_utils.py | 31 | Convert a value to the target type. Args: value: The value to convert target_t | STRING |
| HIGH | paimon-python/pypaimon/table/instant.py | 65 | Deserialize an Instant from a dictionary. Args: data: A dictionary with a 'type' field indicating t | STRING |
| HIGH | paimon-python/pypaimon/api/rest_api.py | 353 | Commit snapshot for table. Args: identifier: Database name and table name tabl | STRING |
| HIGH | paimon-python/pypaimon/consumer/consumer.py | 44 | Load consumer from file path with retry mechanism. Args: file_io: FileIO instance for read | STRING |
| HIGH | paimon-python/pypaimon/data/variant_shredding.py | 667 | Parse the ``variant.shreddingSchema`` option value. Args: json_str: JSON-encoded Paimon ROW type where each | STRING |
| HIGH | paimon-python/pypaimon/tag/tag_manager.py | 102 | Return the tag or throw exception indicating the tag not found. Args: tag_name: Na | STRING |
| HIGH | …python/pypaimon/globalindex/btree/btree_file_footer.py | 75 | Read footer from byte data. Args: data: Byte data containing the footer | STRING |
| HIGH | …imon-python/pypaimon/globalindex/btree/block_reader.py | 57 | Seek to slice position from record position. Args: record_position: The record position to | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/pypaimon/__init__.py | 32 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/write/table_commit.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 55 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 38 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 35 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/file_store_write.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/writer/blob_writer.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 32 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 43 | logger = logging.getLogger(__name__) | CODE |
| LOW | …n-python/pypaimon/snapshot/renaming_snapshot_commit.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/snapshot/snapshot_manager.py | 24 | logger = logging.getLogger(__name__) | CODE |
| LOW | …on-python/pypaimon/snapshot/catalog_snapshot_commit.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/branch/__init__.py | 22 | __all__ = ['BranchManager', 'DEFAULT_MAIN_BRANCH', 'CatalogBranchManager', 'FileSystemBranchManager'] | CODE |
| LOW | paimon-python/pypaimon/branch/branch_manager.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/deletionvectors/__init__.py | 26 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/changelog/changelog_manager.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/changelog/__init__.py | 21 | __all__ = ['Changelog', 'ChangelogManager'] | CODE |
| LOW | paimon-python/pypaimon/changelog/changelog.py | 24 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/catalog/rest/rest_catalog.py | 57 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/catalog/rest/fuse_support.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/read/table_scan.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …hon/pypaimon/read/reader/filter_record_batch_reader.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …imon-python/pypaimon/read/datasource/ray_datasource.py | 36 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/tests/rest/rest_server.py | 1052 | def set_table_token(self, identifier: Identifier, token: "RESTToken") -> None: | CODE |
| LOW | paimon-python/pypaimon/utils/file_type.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/filesystem/pvfs.py | 47 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/cli/__init__.py | 20 | __all__ = ['main'] | CODE |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 41 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/common/options/__init__.py | 23 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/table/rollback_helper.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | …mon-python/pypaimon/table/data_evolution_merge_into.py | 60 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/table/iceberg/__init__.py | 20 | __all__ = ["IcebergTable"] | CODE |
| LOW | paimon-python/pypaimon/table/system/__init__.py | 20 | __all__ = ["SystemTable"] | CODE |
| LOW | paimon-python/pypaimon/table/row/offset_row.py | 47 | def set_row_kind_byte(self, row_kind_byte: int) -> None: | CODE |
| LOW | paimon-python/pypaimon/table/row/generic_row.py | 569 | def _set_null_bit(cls, bytes_data: bytearray, offset: int, pos: int) -> None: | CODE |
| LOW | paimon-python/pypaimon/table/object/__init__.py | 24 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/table/format/__init__.py | 27 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/api/client.py | 298 | def set_error_handler(self, error_handler: ErrorHandler) -> None: | CODE |
| LOW | paimon-python/pypaimon/api/auth/__init__.py | 30 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/consumer/__init__.py | 29 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/data/__init__.py | 21 | __all__ = ['Timestamp', 'Decimal'] | CODE |
| LOW | paimon-python/pypaimon/daft/daft_datasink.py | 37 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/daft/daft_datasource.py | 68 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/daft/__init__.py | 22 | __all__ = ["explain_paimon_scan", "read_paimon", "write_paimon", "read_blob", | CODE |
| LOW | paimon-python/pypaimon/daft/daft_predicate_visitor.py | 42 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/tag/__init__.py | 21 | __all__ = ["Tag", "TagManager"] | CODE |
| LOW | paimon-python/pypaimon/tag/tag_manager.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/ray/bucket_join.py | 37 | __all__ = ["bucket_join"] | CODE |
| LOW | paimon-python/pypaimon/ray/read_by_row_id.py | 40 | __all__ = ["read_by_row_id"] | CODE |
| LOW | paimon-python/pypaimon/ray/range_join.py | 37 | __all__ = ["range_join"] | CODE |
| LOW | paimon-python/pypaimon/ray/update_by_row_id.py | 41 | __all__ = ["update_by_row_id"] | CODE |
| LOW | paimon-python/pypaimon/ray/update_by_row_id.py | 43 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/ray/__init__.py | 35 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/ray/process_row_id_ranges.py | 24 | __all__ = ["process_row_id_ranges"] | CODE |
| LOW | paimon-python/pypaimon/ray/data_evolution_merge_into.py | 50 | __all__ = ["merge_into", "WhenMatched", "WhenNotMatched"] | CODE |
| LOW | paimon-python/pypaimon/ray/data_evolution_merge_into.py | 52 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/globalindex/__init__.py | 48 | __all__ = [ | CODE |
| 10 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/pypaimon/write/file_store_write.py | 166 | # Check if table has blob columns | COMMENT |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 226 | # Check if normal data rolling is needed | COMMENT |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 461 | # Check if normal data exceeds target size | COMMENT |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 502 | # Write file based on format | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 214 | # Check if from_branch is main branch | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 218 | # Check if from_branch is blank | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 222 | # Check if to_branch is blank | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 232 | # Check if from_branch exists | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 236 | # Check if to_branch already exists | COMMENT |
| LOW | paimon-python/pypaimon/catalog/filesystem_catalog.py | 104 | # Check if database still has tables | COMMENT |
| LOW | paimon-python/pypaimon/catalog/filesystem_catalog.py | 266 | # Check if table exists | COMMENT |
| LOW | paimon-python/pypaimon/read/split_read.py | 808 | # Check if this is a SlicedSplit to get shard_file_idx_map | COMMENT |
| LOW | paimon-python/pypaimon/read/streaming_table_scan.py | 180 | # Check if we have a prefetched result ready | COMMENT |
| LOW | paimon-python/pypaimon/read/streaming_table_scan.py | 215 | # Check if we found a scannable snapshot or skipped some | COMMENT |
| LOW | …mon-python/pypaimon/read/reader/format_lance_reader.py | 50 | # Read file metadata (footer only) to get actual schema | COMMENT |
| LOW | …imon-python/pypaimon/read/reader/shard_batch_reader.py | 37 | # Check if reader is FormatBlobReader (blob type) | COMMENT |
| LOW | …imon-python/pypaimon/read/reader/shard_batch_reader.py | 52 | # Check if batch is within the desired range | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 173 | # Check if manifest row range overlaps with any of the expected row ranges | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 178 | # Check if ranges intersect | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 506 | # Check if global index is enabled | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 917 | # Check if dv_ranges exists | COMMENT |
| LOW | …ypaimon/read/scanner/data_evolution_split_generator.py | 267 | # Check if file overlaps with any of the row ranges | COMMENT |
| LOW | …ypaimon/read/scanner/data_evolution_split_generator.py | 284 | # Check if blob file overlaps with any merged range | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/blob_test.py | 1799 | # Read the file and corrupt the header (last 5 bytes: index_length + version) | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 113 | # Write file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 118 | # Read file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 136 | # Write file using context manager | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 140 | # Read file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 500 | # Write file | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 159 | # Write file in chunks | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 224 | # Write file | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 240 | # Write files | COMMENT |
| LOW | paimon-python/pypaimon/tests/blob_table_test.py | 4065 | # Check if the field name matches the actual blob column name | COMMENT |
| LOW | …n-python/pypaimon/tests/rest/rest_object_table_test.py | 135 | # Write files via pvfs, including a nested subdirectory file | COMMENT |
| LOW | paimon-python/pypaimon/tests/rest/rest_server.py | 1068 | # Check if table exists | COMMENT |
| LOW⚡ | paimon-python/pypaimon/cli/cli_table.py | 393 | # Check if table is FileStoreTable | COMMENT |
| LOW | paimon-python/pypaimon/schema/table_schema.py | 62 | # Check if primary keys contain all partition keys | COMMENT |
| LOW | paimon-python/pypaimon/schema/schema.py | 76 | # Check if Vector type with dedicated file format | COMMENT |
| LOW | paimon-python/pypaimon/tag/tag_manager.py | 272 | # Check if old tag exists | COMMENT |
| LOW | paimon-python/pypaimon/tag/tag_manager.py | 276 | # Check if new tag already exists | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ion/cdc/mongodb/strategy/MongoVersionStrategyTest.java | 53 | assertThat(result).containsEntry("name", "John Doe"); | CODE |
| LOW | …ion/cdc/mongodb/strategy/MongoVersionStrategyTest.java | 77 | assertThat(result).containsEntry("name", "John Doe"); | CODE |
| LOW | …ormat/debezium/DebeziumAvroRecordParserTestSimple.java | 70 | afterRecord.put("name", "John Doe"); | CODE |
| LOW | …source/align/AlignedContinuousFileSplitEnumerator.java | 70 | private static final String PLACEHOLDER_SPLIT = "placeholder"; | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 272 | fake_token = MagicMock() | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 273 | fake_token.token = token_payload | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 275 | fake_file_io.token = fake_token | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 312 | fake_token = MagicMock() | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 313 | fake_token.token = initial_token | CODE |
| LOW⚡ | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 315 | fake_file_io.token = fake_token | CODE |
| LOW | …n-python/pypaimon/tests/daft/daft_catalog_rest_test.py | 327 | fake_token.token = refreshed_token | CODE |
| LOW | …ache/paimon/operation/AllPlaceholdersRecordReader.java | 42 | private static final Path PLACEHOLDER_PATH = new Path("placeholder"); | CODE |
| LOW | …g/apache/paimon/data/variant/PaimonShreddingUtils.java | 771 | new RowToColumnConverter(RowType.of(new DataField(0, "placeholder", readType))); | CODE |
| LOW | …va/org/apache/paimon/format/csv/CsvFileFormatTest.java | 84 | // Second row: "John Doe",,"Developer" (empty middle field) | COMMENT |
| LOW | …va/org/apache/paimon/format/csv/CsvFileFormatTest.java | 88 | assertThat(fields[0]).isEqualTo("John Doe"); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …hon/pypaimon/deletionvectors/bitmap_deletion_vector.py | 111 | CODE | |
| LOW | …imon-python/pypaimon/manifest/schema/data_file_meta.py | 88 | CODE | |
| LOW | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1345 | CODE | |
| LOW | paimon-python/pypaimon/api/api_response.py | 305 | CODE | |
| LOW | paimon-python/pypaimon/api/api_response.py | 410 | CODE | |
| LOW | paimon-python/pypaimon/daft/daft_datasource.py | 305 | CODE | |
| LOW | paimon-python/pypaimon/daft/daft_paimon.py | 196 | CODE | |
| LOW | paimon-python/pypaimon/daft/daft_paimon.py | 481 | CODE | |
| LOW | paimon-python/pypaimon/ray/ray_paimon.py | 50 | CODE | |
| LOW | paimon-python/pypaimon/ray/range_join.py | 331 | CODE | |
| LOW | paimon-python/pypaimon/globalindex/btree/block_entry.py | 50 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …on/pypaimon/write/commit/overwrite_changes_provider.py | 56 | # Empty table: nothing existing to delete, just add the new files. | COMMENT |
| LOW | paimon-python/pypaimon/read/split_read.py | 1147 | # No need to merge fields, just create a single file reader | COMMENT |
| LOW | …mon-python/pypaimon/tests/rest/test_fuse_local_path.py | 221 | # Should not raise, just set state to False | COMMENT |
| MEDIUM | …ava/org/apache/paimon/sort/zorder/ZOrderByteUtils.java | 41 | * https://aws.amazon.com/blogs/database/z-order-indexing-for-multifaceted-queries-in-amazon-dynamodb-part-2/ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/releasing/update_branch_version.sh | 61 | echo "If this is a new version to be released (or a candidate to be voted on), don't forget to create a signed release t | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/pypaimon/tests/rest/rest_function_test.py | 108 | def test_function(self): | CODE |