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 summarizes scanner evidence for apache/paimon, a Java project with 3,417 GitHub stars. SynthScan examined 1,598,458 lines of code across 7234 source files, recording 10316 pattern matches distributed across 22 syntactic categories. The legacy adjusted pattern signal is 9.8 (Moderate pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 8546 finding(s).
Are imports declared and package/API names verified? 663 finding(s).
Are wrappers, guards, and repeated structures necessary? 7800 finding(s).
Which changes need focused human review? 10316 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 10316 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tools/ci/test_result.py | 42 | def test_selected_groups_pass_and_unselected_groups_skip(self): | CODE |
| LOW⚡ | tools/ci/test_result.py | 45 | def test_selected_failure_cancellation_and_unexpected_skip_fail(self): | CODE |
| LOW⚡ | tools/ci/test_result.py | 50 | def test_planner_failure_fails_even_if_other_groups_report_success(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 36 | def test_spark_keeps_common_docs_and_interoperability_tests(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 45 | def test_shared_and_unknown_changes_run_all_java(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 52 | def test_parent_pom_also_validates_python_build(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 56 | def test_docs_and_markdown_do_not_start_maven(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 64 | def test_mixed_changes_take_union(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 74 | def test_java_python_fixtures_run_python(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 82 | def test_leaf_modules_and_workflows(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 91 | def test_ci_logic_and_manual_run_validate_every_consumer(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 98 | def test_empty_diff_does_not_run_expensive_jobs(self): | CODE |
| LOW⚡ | tools/ci/test_plan.py | 103 | def test_size_guard_handles_spaces_deletions_and_symlinks(self): | CODE |
| LOW | tools/ci/test_plan.py | 137 | def test_pr_uses_merge_base_instead_of_including_base_branch_changes(self): | CODE |
| LOW | tools/ci/test_plan.py | 147 | def test_push_includes_all_commits_and_both_sides_of_renames(self): | CODE |
| LOW | tools/ci/test_plan.py | 159 | def test_large_diffs_do_not_truncate_late_core_changes(self): | CODE |
| LOW | tools/ci/test_plan.py | 170 | def test_new_branch_missing_commits_and_manual_run_fall_back(self): | CODE |
| LOW | tools/ci/test_plan.py | 186 | def test_pr_unavailable_diff_runs_full_ci_with_unchanged_oversized_file(self): | CODE |
| LOW | tools/ci/test_plan.py | 207 | def test_pr_size_guard_ignores_unchanged_but_rejects_changed_oversized_files(self): | CODE |
| LOW | tools/ci/test_plan.py | 222 | def test_github_outputs_are_valid_json_and_summary_explains_selection(self): | CODE |
| LOW | tools/ci/test_deploy_maven_repository.py | 31 | def test_deploy_runs_once_without_recursing_into_reactor(self): | CODE |
| LOW | tools/ci/test_java_commands.py | 43 | def test_every_lane_builds_dependencies_but_only_tests_selected_modules(self): | CODE |
| LOW | tools/ci/test_java_commands.py | 56 | def test_spark_retains_all_connector_versions_and_scala_variants(self): | CODE |
| LOW | tools/ci/test_java_commands.py | 76 | def test_flink_coverage_includes_cdc_and_both_major_versions(self): | CODE |
| LOW | tools/ci/test_java_commands.py | 92 | def test_unknown_suite_fails_instead_of_silently_running_no_tests(self): | CODE |
| LOW | tools/ci/test_java_commands.py | 98 | def test_python_build_selects_runnable_modules_not_just_aggregator_poms(self): | CODE |
| LOW | docs/scripts/validate-rest-openapi.js | 90 | function requireRequiredProperties(schemaName, names) { | CODE |
| LOW | docs/scripts/validate-rest-openapi.js | 97 | function requireTypedIntegerProperties(schemaName, names) { | CODE |
| LOW | docs/scripts/validate-rest-openapi.js | 194 | function requireArrayOfIdentifiers(contract, schemaName, propertyName) { | CODE |
| LOW | docs/scripts/validate-rest-openapi.js | 207 | function requireNullableStringProperty(contract, schemaName, propertyName) { | CODE |
| LOW | docs/scripts/validate-rest-openapi.js | 419 | function validateManagementOpenApi() { | CODE |
| LOW | paimon-python/conftest.py | 202 | def pytest_collection_modifyitems(items): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 104 | def test_sdist_and_wheel_share_version_and_commit(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 116 | def test_distribution_contents(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 147 | def test_metadata_preserves_core_and_extra_conditions(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 166 | def test_dev_group_reuses_product_extras(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 176 | def test_sdist_rebuild_preserves_provenance_in_another_git_repo(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 191 | def test_release_override_applies_to_both_formats(self): | CODE |
| LOW | paimon-python/dev/test_packaging.py | 203 | def test_invalid_release_override_fails(self): | CODE |
| LOW | paimon-python/pypaimon/write/native_write.py | 42 | def _native_partition_types_supported(schema, partition_keys, legacy_partition_name=True): | CODE |
| LOW | paimon-python/pypaimon/write/native_write.py | 192 | def with_blob_uri_reader_factory(self, uri_reader_factory): | CODE |
| LOW | paimon-python/pypaimon/write/native_write.py | 228 | def _prepare_native_arrow_data(self, data): | CODE |
| 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/native_update.py | 72 | def create_native_update_by_row_id(table, commit_user, commit_identifier): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 91 | def create_native_shard_updator(table, commit_user, projection, columns, shard, shard_count, stream=False): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 139 | def _supported_upsert_key_type(data_type): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 149 | def _native_update_columns_supported(table, columns): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 222 | def create_native_predicate_update(table, commit_user, predicate, columns=None): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 271 | def _raise_native_row_id_error(error): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 288 | def update_by_arrow_with_row_id(self, data: pa.Table): | CODE |
| LOW | paimon-python/pypaimon/write/native_update.py | 295 | def update_by_arrow_batches_with_row_id(self, tables): | CODE |
| LOW⚡ | paimon-python/pypaimon/write/file_store_commit.py | 1075 | def _generate_partition_statistics(self, commit_entries: List[ManifestEntry]) -> List[PartitionStatistics]: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 57 | def _row_id_check_from_messages(messages: List[CommitMessage]) -> Optional[int]: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 79 | def _reject_compact_increment(messages: List[CommitMessage]): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 184 | def _set_fixed_bucket_commit_check(self, messages): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 334 | def _overwrite_hash_index_deletes(self, partition_filter, deletes): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 777 | def _try_rewrite_row_id_conflict( | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 886 | def _create_dynamic_partition_filter(self, commit_messages: List[CommitMessage]): | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 904 | def _create_static_partition_filter(self, overwrite_partition, commit_messages: List[CommitMessage]): | CODE |
| 6611 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …java/org/apache/paimon/jindo/JindoMultiPartUpload.java | 76 | 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 | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 482 | org.apache.paimon.iceberg.metadata.IcebergMetadata.fromPath( | CODE |
| CRITICAL | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 1078 | org.apache.paimon.iceberg.metadata.IcebergMetadata.fromPath( | 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 |
| 286 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # | COMMENT |
| LOW | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 721 | // Verifies correct behaviour across a full schema-evolution cycle: | COMMENT |
| LOW | …pache/paimon/iceberg/IcebergRestMetadataCommitter.java | 801 | COMMENT | |
| LOW | …pache/paimon/iceberg/IcebergRestMetadataCommitter.java | 821 | // accumulate multiple schema versions (e.g. IDs 0, 1, 2, 3) that all have | 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/utils.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/ci/test_result.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/ci/plan.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/ci/test_plan.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/ci/test_deploy_maven_repository.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/ci/test_java_commands.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/ci/run-java-tests.sh | 1 | #!/usr/bin/env bash | 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/docs/pypaimon/ray-data.md | 321 | static_partition=None, | COMMENT |
| LOW | docs/docs/pypaimon/reading.md | 341 | print(read_builder.explain()) | COMMENT |
| LOW | docs/docs/pypaimon/reading.md | 361 | # Files: 4 | COMMENT |
| LOW | docs/static/rest-catalog-open-api.yaml | 1 | # | COMMENT |
| LOW | docs/static/rest-management-open-api.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/conftest.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pyproject.toml | 1 | ################################################################################ | COMMENT |
| LOW | paimon-python/setup.py | 1 | ########################################################################## | COMMENT |
| LOW | paimon-python/dev/test_packaging.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/dev/cfg.ini | 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/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/dev/install.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/_version.py | 1 | ########################################################################## | COMMENT |
| LOW | paimon-python/pypaimon/__init__.py | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | paimon-python/pypaimon/build_info.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 |
| 1004 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 | 267 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 269 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 300 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 302 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/read/read_builder.py | 252 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/read/read_builder.py | 254 | # ------------------------------------------------------------------ | 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 | 120 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 122 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 200 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 202 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 251 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …pypaimon/read/reader/blob_descriptor_convert_reader.py | 253 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1511 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1515 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 317 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 319 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 337 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 339 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 456 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …pypaimon/read/scanner/chunk_shuffle_split_generator.py | 458 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 197 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 199 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 255 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 257 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 280 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 282 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …on-python/pypaimon/tests/schema_evolution_read_test.py | 572 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …on-python/pypaimon/tests/schema_evolution_read_test.py | 578 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 86 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 88 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 584 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 588 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 948 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/pushdown_bucket_test.py | 951 | # --------------------------------------------------------------------------- | 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 |
|---|---|---|---|---|
| HIGH | paimon-python/pypaimon/__init__.py | 24 | except ImportError: | CODE |
| HIGH | paimon-python/pypaimon/build_info.py | 68 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/write/file_store_commit.py | 1070 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/write/file_store_commit.py | 1011 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/write/table_update_by_row_id.py | 842 | except (pa.lib.ArrowNotImplementedError, | CODE |
| HIGH | paimon-python/pypaimon/write/commit/commit_rollback.py | 59 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/write/writer/blob_file_writer.py | 210 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/benchmark/video_random_read.py | 83 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/benchmark/act/runner.py | 758 | except (OSError, subprocess.CalledProcessError): | CODE |
| HIGH | paimon-python/pypaimon/benchmark/act/runner.py | 768 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/changelog/changelog_manager.py | 332 | except FileNotFoundError: | CODE |
| HIGH | paimon-python/pypaimon/changelog/changelog_manager.py | 347 | except FileNotFoundError: | CODE |
| HIGH | paimon-python/pypaimon/changelog/changelog_manager.py | 200 | except FileNotFoundError: | CODE |
| HIGH | paimon-python/pypaimon/catalog/filesystem_catalog.py | 270 | except TableNotExistException: | CODE |
| HIGH | paimon-python/pypaimon/manifest/__init__.py | 24 | except ImportError: | CODE |
| HIGH | …imon-python/pypaimon/manifest/manifest_file_manager.py | 236 | except KeyError: | CODE |
| HIGH | paimon-python/pypaimon/manifest/fastavro_py36_compat.py | 74 | except ImportError: | CODE |
| HIGH | paimon-python/pypaimon/read/table_read.py | 692 | except queue.Full: | CODE |
| HIGH | paimon-python/pypaimon/read/table_read.py | 1725 | except ValueError: | CODE |
| HIGH | …on-python/pypaimon/read/reader/format_mosaic_reader.py | 94 | except ValueError: | CODE |
| HIGH | …n-python/pypaimon/read/reader/format_pyarrow_reader.py | 349 | except binascii.Error: | CODE |
| HIGH | …imon-python/pypaimon/read/reader/format_blob_reader.py | 224 | except StopIteration: | CODE |
| HIGH | …on-python/pypaimon/read/reader/format_vortex_reader.py | 71 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/blob_test.py | 192 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/tests/blob_test.py | 3169 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/tests/blob_test.py | 4090 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_read_by_row_id_test.py | 61 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_bucket_join_test.py | 60 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/oss_file_io_test.py | 76 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_data_test.py | 59 | except (ImportError, AttributeError): | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_data_test.py | 68 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_data_test.py | 72 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/tests/ray_data_test.py | 55 | except (ImportError, AttributeError): | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 338 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 412 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 452 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 471 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 486 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/external_paths_test.py | 510 | except Exception: | CODE |
| HIGH | paimon-python/pypaimon/tests/vector_table_test.py | 141 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/tests/split_provider_test.py | 68 | except OSError: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 101 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 122 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 141 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 162 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 181 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 194 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 221 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 265 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 297 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 309 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 338 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 350 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 380 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 393 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 430 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 439 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 476 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 486 | except SystemExit: | CODE |
| HIGH | paimon-python/pypaimon/tests/cli_table_test.py | 496 | except SystemExit: | CODE |
| 128 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/dev/check_license_header.py | 44 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/build_info.py | 46 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_commit.py | 133 | except Exception as error: | CODE |
| LOW⚡ | paimon-python/pypaimon/write/file_store_commit.py | 1070 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 717 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 722 | except Exception as cleanup_err: | 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 | 1011 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1036 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1058 | except Exception as error: | CODE |
| LOW | …n-python/pypaimon/write/map_shared_shredding_writer.py | 191 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 186 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 190 | except Exception as abort_error: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 265 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 275 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 442 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 533 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_delete.py | 309 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 140 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 203 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 225 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 317 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 365 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 626 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 699 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 737 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/write_builder.py | 85 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 179 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 549 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 156 | except Exception as error: | CODE |
| MEDIUM | paimon-python/pypaimon/write/table_upsert_by_key.py | 151 | def _create_native_upsert(self, data, upsert_keys, columns): | CODE |
| LOW | paimon-python/pypaimon/write/row_utils.py | 70 | except Exception as error: | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 62 | except Exception: # any failure here means "use the fallback" | CODE |
| LOW | paimon-python/pypaimon/write/file_store_write.py | 369 | except Exception as e: | CODE |
| MEDIUM | …mon-python/pypaimon/write/commit/conflict_detection.py | 221 | def check_conflicts( | CODE |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 230 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 237 | except Exception as e: | CODE |
| LOW | …thon/pypaimon/write/commit/row_id_conflict_rewriter.py | 138 | 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 | 99 | 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 | 306 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 125 | except Exception as e: | CODE |
| LOW | …mon-python/pypaimon/write/writer/single_file_writer.py | 51 | except Exception: | CODE |
| LOW | …mon-python/pypaimon/write/writer/single_file_writer.py | 77 | except Exception: | CODE |
| LOW | …mon-python/pypaimon/write/writer/single_file_writer.py | 90 | except Exception: | CODE |
| LOW | …-python/pypaimon/write/writer/key_value_data_writer.py | 108 | except Exception as e: | CODE |
| LOW | …n-python/pypaimon/write/writer/postpone_data_writer.py | 41 | except Exception: | CODE |
| LOW | …n-python/pypaimon/write/writer/postpone_data_writer.py | 99 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 141 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 179 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 207 | except Exception as e: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 334 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 514 | except Exception: | CODE |
| MEDIUM | paimon-python/pypaimon/write/writer/data_writer.py | 175 | def close(self): | CODE |
| LOW | …-python/pypaimon/write/writer/composite_data_writer.py | 70 | except Exception as e: | CODE |
| LOW | …-python/pypaimon/write/writer/composite_data_writer.py | 182 | except Exception: | CODE |
| LOW | paimon-python/pypaimon/write/writer/blob_file_writer.py | 210 | except Exception: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 227 | except Exception as e: | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 314 | except Exception as e: | CODE |
| 463 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/ci/plan.py | 49 | CODE | |
| LOW | paimon-python/dev/test_packaging.py | 147 | CODE | |
| LOW | paimon-python/pypaimon/write/postpone_bucket.py | 285 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 192 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 420 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 533 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 826 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 886 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 995 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1017 | CODE | |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 1184 | CODE | |
| LOW | paimon-python/pypaimon/write/native_commit.py | 41 | CODE | |
| LOW | …n-python/pypaimon/write/map_shared_shredding_writer.py | 412 | CODE | |
| LOW | …n-python/pypaimon/write/map_shared_shredding_writer.py | 117 | CODE | |
| LOW | …n-python/pypaimon/write/map_shared_shredding_writer.py | 281 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 412 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update.py | 289 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update.py | 372 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 105 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 141 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 497 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 556 | CODE | |
| LOW | paimon-python/pypaimon/write/table_update_by_row_id.py | 836 | CODE | |
| LOW | paimon-python/pypaimon/write/native_merge_into.py | 32 | CODE | |
| LOW | paimon-python/pypaimon/write/native_merge_into.py | 86 | CODE | |
| LOW | paimon-python/pypaimon/write/native_blob_rows.py | 68 | CODE | |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 438 | CODE | |
| LOW | paimon-python/pypaimon/write/video_format_writer.py | 175 | CODE | |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 136 | CODE | |
| LOW | …mon-python/pypaimon/write/commit/conflict_detection.py | 679 | CODE | |
| LOW | …on/pypaimon/write/commit/overwrite_changes_provider.py | 54 | CODE | |
| LOW | …mon-python/pypaimon/write/writer/single_file_writer.py | 55 | CODE | |
| LOW | paimon-python/pypaimon/write/writer/data_writer.py | 256 | CODE | |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 366 | 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/benchmark/act/runner.py | 749 | CODE | |
| LOW | paimon-python/pypaimon/benchmark/act/robomind_agilex.py | 759 | CODE | |
| LOW | paimon-python/pypaimon/benchmark/act/compare.py | 118 | 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 | 80 | CODE | |
| LOW | …on-python/pypaimon/branch/filesystem_branch_manager.py | 330 | CODE | |
| LOW | paimon-python/pypaimon/catalog/jdbc_catalog.py | 50 | 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 | 197 | CODE | |
| LOW | paimon-python/pypaimon/manifest/manifest_sidecar.py | 344 | CODE | |
| LOW | paimon-python/pypaimon/manifest/manifest_sidecar.py | 475 | CODE | |
| LOW | paimon-python/pypaimon/manifest/manifest_sidecar.py | 509 | 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 | 241 | CODE | |
| LOW | paimon-python/pypaimon/read/merge_engine_support.py | 261 | CODE | |
| LOW | paimon-python/pypaimon/read/read_builder.py | 51 | CODE | |
| LOW | paimon-python/pypaimon/read/read_type.py | 41 | CODE | |
| LOW | paimon-python/pypaimon/read/read_type.py | 82 | CODE | |
| LOW | paimon-python/pypaimon/read/read_type.py | 195 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 204 | CODE | |
| 415 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | paimon-python/pypaimon/write/table_write.py | 331 | if data.schema.equals(schema, check_metadata=True): | CODE |
| HIGH | paimon-python/pypaimon/write/writer/write_buffer.py | 59 | elif not data.schema.equals(self._schema): | CODE |
| HIGH | paimon-python/pypaimon/catalog/table_query_auth.py | 160 | "Column masking on '{}' is JSON null; refusing to read rather than " | CODE |
| HIGH⚡ | …imon-python/pypaimon/manifest/schema/data_file_meta.py | 67 | """Row-id range, failing fast if first_row_id is null (mirrors Java nonNullRowIdRange).""" | STRING |
| HIGH | paimon-python/pypaimon/read/table_read.py | 337 | if batch.schema.equals(target_schema, check_metadata=True): | CODE |
| HIGH | …/pypaimon/read/reader/partial_update_merge_function.py | 24 | writes "fill in" fields the earlier writes left null, so users can | STRING |
| HIGH | …mon-python/pypaimon/read/reader/concat_batch_reader.py | 175 | if batches and not batch.schema.equals(batches[0].schema, check_metadata=True): | CODE |
| 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 | 532 | self.assertTrue(real_schema.equals(empty.schema().base_schema)) | CODE |
| HIGH | …imon/tests/format_pyarrow_shared_shredding_map_test.py | 187 | self.assertTrue(selected.equals(expected_array)) | CODE |
| HIGH | …imon/tests/format_pyarrow_shared_shredding_map_test.py | 249 | self.assertTrue(selected.equals(expected_array)) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/reader_parallel_test.py | 452 | self.assertTrue(serial.equals(parallel)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 213 | self.assertTrue(df_serial.equals(df_parallel)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 227 | self.assertTrue(serial_df.equals(parallel_df)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_parallel_test.py | 481 | self.assertTrue(df_s.equals(df_p)) | CODE |
| HIGH | …on-python/pypaimon/tests/schema_evolution_read_test.py | 738 | # while the old (non-null) file still reads correctly. | COMMENT |
| HIGH | paimon-python/pypaimon/tests/polars_map_null_test.py | 72 | assert batch.schema.equals(schema, check_metadata=True) | CODE |
| HIGH | …python/pypaimon/tests/test_format_row_reader_writer.py | 96 | # null, plus the 19..28 band and the compact p<=18 path. | COMMENT |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 104 | assert result.equals(baseline) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 105 | assert result.equals(_expected(table, runs)) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 115 | assert result.equals(baseline) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 179 | assert result.equals(_expected(fixture[1], [(i, i) for i in rows])) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 237 | assert optimized.equals(baseline) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 238 | assert optimized.equals(table.slice(selected_row, 1)) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 384 | assert result.equals(baseline) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 488 | assert actual.equals(_expected(fixture[1], [(5, 6), (4500, 4501)])) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 517 | assert actual.equals(_expected(fixture[1], [(4500, 4540)])) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 620 | assert actual.equals(baseline) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/parquet_page_index_test.py | 621 | assert actual.equals(_expected(table.select(names), runs)) | CODE |
| HIGH | paimon-python/pypaimon/tests/parquet_page_index_test.py | 146 | assert result.equals(_expected(table, kwargs.get('row_ranges', RUNS))) | CODE |
| HIGH | paimon-python/pypaimon/tests/parquet_page_index_test.py | 640 | assert actual.equals(baseline) | CODE |
| HIGH | paimon-python/pypaimon/tests/parquet_page_index_test.py | 682 | assert actual.equals(table.slice(4500, 41)) | CODE |
| HIGH | …n-python/pypaimon/tests/search_result_metadata_test.py | 57 | assert before.equals(after.select(["id"])) | CODE |
| HIGH | …imon-python/pypaimon/tests/table_upsert_by_key_test.py | 706 | self.assertTrue(original_data.equals(self._read_all(table).sort_by('id'))) | CODE |
| HIGH⚡ | paimon-python/pypaimon/tests/snapshot_manager_test.py | 53 | for payload in ('{}', '{"snapshot": null}'): | CODE |
| HIGH | paimon-python/pypaimon/tests/filesystem_catalog_test.py | 394 | # Default option (disabled=true) rejects nullable -> not null, mirroring | COMMENT |
| HIGH | paimon-python/pypaimon/tests/variant_test.py | 468 | 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⚡ | …imon-python/pypaimon/tests/batch_vector_lookup_test.py | 120 | assert all(table.equals(expected) for table in actual) | CODE |
| HIGH | paimon-python/pypaimon/tests/data_evolution_test.py | 864 | self.assertEqual(arrow_res3.num_rows, 0) # Arrow: NULL==NULL is null, filtered out | CODE |
| HIGH | …hon/pypaimon/tests/table_read_chunked_overflow_test.py | 60 | self.assertTrue(actual.schema.equals(schema, check_metadata=True)) | CODE |
| HIGH | paimon-python/pypaimon/tests/reader_append_only_test.py | 1161 | # partition value: isNull keeps null, drops non-null; equal is the reverse. | COMMENT |
| HIGH | …on/pypaimon/tests/schema_evolution_nested_read_test.py | 680 | 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 | 498 | assert pypaimon_result.equals(expected_result) | CODE |
| HIGH | paimon-python/pypaimon/management/java_string.py | 26 | """Java ``String.length()``: UTF-16 code units, not code points.""" | STRING |
| HIGH | paimon-python/pypaimon/utils/file_store_path_factory.py | 206 | # Legacy Timestamp.toString() uses UTC fields. Java's non-legacy | COMMENT |
| HIGH | paimon-python/pypaimon/schema/arrow_schema.py | 78 | if data.schema.equals(schema, check_metadata=False): | CODE |
| HIGH | paimon-python/pypaimon/multimodal/arrow_utils.py | 65 | if table.schema.equals(target_schema, check_metadata=False): | CODE |
| HIGH | paimon-python/pypaimon/multimodal/lerobot/metadata.py | 556 | if any(not item.equals(schema, check_metadata=False) | 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 | 559 | All comparison results are coerced from three-valued (PyArrow null) to | STRING |
| HIGH | paimon-python/pypaimon/data/variant_shredding.py | 488 | # if typed_value is null → use overflow bytes directly | COMMENT |
| HIGH | paimon-python/pypaimon/ray/data_evolution_merge_join.py | 771 | "_ROW_ID is null; planner snapshot is stale " | CODE |
| 2 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 | …aimon/spark/procedure/FMGlobalIndexProcedureTest.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 |
| HIGH | …/spark/sql/CatalogManagedPartitionEdgeParityTest.scala | 0 | create table $tablename (id int, payload string, dt string, hour string) |using csv |partitioned by (dt, hour) |tblprope | STRING |
| HIGH | …n/spark/sql/CatalogManagedPartitionDdlParityTest.scala | 0 | create table $tablename (id int, payload string, dt string, hour string) |using csv |partitioned by (dt, hour) |tblprope | STRING |
| HIGH | …mon/spark/sql/CatalogManagedPartitionAnalyzeTest.scala | 0 | create table $tablename (id int, payload string, dt string, hour string) |using csv |partitioned by (dt, hour) |tblprope | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | paimon-python/pypaimon/__init__.py | 29 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 30 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 31 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 32 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 33 | CODE | |
| LOW | paimon-python/pypaimon/__init__.py | 23 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 38 | CODE | |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 39 | CODE | |
| LOW | paimon-python/pypaimon/write/table_write.py | 35 | 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/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 | 39 | CODE | |
| LOW | paimon-python/pypaimon/tests/table_merge_into_test.py | 38 | CODE | |
| LOW | …hon/pypaimon/tests/native_plan_resolved_schema_test.py | 30 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 365 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 443 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 491 | CODE | |
| LOW | paimon-python/pypaimon/tests/reader_append_only_test.py | 574 | CODE | |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1390 | CODE | |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1423 | 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 | |
| 180 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 747 | // Step 1: baseline | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 754 | // Step 2: drop v2 → [k, v1] | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 760 | // Step 3: option-only alter — same fields [k, v1], increments Paimon schema ID | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 766 | // 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 | 1414 | // Step 1: Create a Paimon table with blob field via Flink SQL | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1426 | // Step 2: Get the Paimon FileStoreTable and its RowType | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1430 | // Step 3: Create a Flink temporary table with the same schema (BYTES column) | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1448 | // Step 4: Convert Paimon RowType to Flink RowType via LogicalTypeConversion | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1452 | // 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 | 731 | # 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 | 1369 | # Step 1: Create table with [f0, f1] | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1398 | # Step 3: Schema evolution - add column f2 | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1405 | # Step 4: Write f2 only for same rows (first_row_id = 0) | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1382 | # Step 2: Write data with ALL columns of old schema → write_cols = None | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1421 | # Step 5: Read all columns | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1891 | # Step 2: pypaimon shard update - scan and prepare commit | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1914 | # Step 3: Java compact (compact happening between scan and commit) | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1931 | # Step 4: pypaimon rewrites stale evolution files against the compacted range | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 897 | // Step 1: write data with schemaId=0 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 900 | // Step 2: ALTER TABLE SET an unrelated option -> schemaId becomes 1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 904 | // Step 3: write more data with schemaId=1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 907 | // Step 4: compact blob table using DataEvolutionCompactCoordinator | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 1078 | // 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 | 747 | // Step 1: baseline | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 754 | // Step 2: drop v2 → [k, v1] | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 760 | // Step 3: option-only alter — same fields [k, v1], increments Paimon schema ID | COMMENT |
| LOW⚡ | …e/paimon/iceberg/IcebergRestMetadataCommitterTest.java | 766 | // 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 | 1414 | // Step 1: Create a Paimon table with blob field via Flink SQL | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1426 | // Step 2: Get the Paimon FileStoreTable and its RowType | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1430 | // Step 3: Create a Flink temporary table with the same schema (BYTES column) | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1448 | // Step 4: Convert Paimon RowType to Flink RowType via LogicalTypeConversion | COMMENT |
| LOW⚡ | …test/java/org/apache/paimon/flink/BlobTableITCase.java | 1452 | // 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 | 731 | # 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 | 1369 | # Step 1: Create table with [f0, f1] | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1398 | # Step 3: Schema evolution - add column f2 | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/data_evolution_test.py | 1405 | # Step 4: Write f2 only for same rows (first_row_id = 0) | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1382 | # Step 2: Write data with ALL columns of old schema → write_cols = None | COMMENT |
| LOW | paimon-python/pypaimon/tests/data_evolution_test.py | 1421 | # Step 5: Read all columns | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1891 | # Step 2: pypaimon shard update - scan and prepare commit | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1914 | # Step 3: Java compact (compact happening between scan and commit) | COMMENT |
| LOW | …n-python/pypaimon/tests/e2e/java_py_read_write_test.py | 1931 | # Step 4: pypaimon rewrites stale evolution files against the compacted range | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 897 | // Step 1: write data with schemaId=0 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 900 | // Step 2: ALTER TABLE SET an unrelated option -> schemaId becomes 1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 904 | // Step 3: write more data with schemaId=1 | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 907 | // Step 4: compact blob table using DataEvolutionCompactCoordinator | COMMENT |
| LOW⚡ | …/test/java/org/apache/paimon/append/BlobTableTest.java | 1078 | // 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 | 104 | # Create a mapping from field IDs to indices in data_fields. | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/read/split_read.py | 904 | # Create a callable method to read the deletion vector | COMMENT |
| MEDIUM | paimon-python/pypaimon/read/split_read.py | 1646 | # Create the union reader | COMMENT |
| MEDIUM | …imon-python/pypaimon/read/datasource/ray_datasource.py | 151 | # Create a partial function to avoid capturing self in closure | COMMENT |
| MEDIUM⚡ | paimon-python/pypaimon/tests/blob_test.py | 3911 | # Create a valid blob file first | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 178 | # Create a temporary directory and file | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 1410 | # Create a descriptor | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 3822 | # Create a table with multiple columns (should fail - blob format requires single column) | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 3864 | # Create a valid blob file first | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 3949 | # Create a blob file with substantial content | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_test.py | 4203 | # 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 | 539 | # Create a catalog and table | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/reader_base_test.py | 556 | # 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 | 622 | # Create a unique table for each iteration | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/native_blob_update_test.py | 421 | # Create a new logical column with no files in the older snapshot. | 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 | 971 | # Create a unique table for each iteration | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/blob_table_test.py | 4906 | # 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 | 129 | # Create a mock manager with minimal dependencies | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/branch_manager_test.py | 180 | # 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 | 239 | # Create a tag | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 303 | # Create a tag | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 311 | # Create the same tag with ignore_if_exists=True - should not raise error | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/table/simple_table_test.py | 340 | # Create a tag | COMMENT |
| MEDIUM | …-python/pypaimon/tests/rest/rest_token_file_io_test.py | 326 | # Create a token with a standard OSS endpoint | COMMENT |
| MEDIUM | paimon-python/pypaimon/table/file_store_table.py | 80 | # Create a placeholder identifier | COMMENT |
| MEDIUM | paimon-python/pypaimon/data/generic_variant.py | 563 | # 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 | 85 | 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 | 151 | Load the snapshot of table identified by the given Identifier. Args: identifier: Path of the table | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 233 | List partitions of a table with pagination. Args: identifier: Path of the table. max_re | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 303 | List all branches for the table. Args: identifier: Table identifier Returns: | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 387 | Get a tag of a table. Args: identifier: Table identifier (Identifier or string). tag_na | STRING |
| HIGH | paimon-python/pypaimon/catalog/catalog.py | 410 | List tags of a table with pagination. Args: identifier: Table identifier (Identifier or string). | STRING |
| HIGH | paimon-python/pypaimon/catalog/rest/rest_catalog.py | 122 | Commit the Snapshot for table identified by the given Identifier. Args: identifier: Path o | STRING |
| HIGH | paimon-python/pypaimon/catalog/rest/rest_catalog.py | 444 | 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 | 285 | 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 | 75 | 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 | 370 | 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 | 719 | 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 | 76 | 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 | 35 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/write/table_commit.py | 26 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/file_store_commit.py | 54 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/ray_datasink.py | 41 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/table_update.py | 57 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/write_builder.py | 30 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/table_upsert_by_key.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/write/row_key_extractor.py | 39 | 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 | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | …mon-python/pypaimon/write/writer/data_vector_writer.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | …-python/pypaimon/write/writer/composite_data_writer.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ython/pypaimon/write/writer/dedicated_format_writer.py | 44 | 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 | 67 | 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_read.py | 51 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/read/table_scan.py | 34 | 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 | 1127 | 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 | 48 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/cli/__init__.py | 20 | __all__ = ['main'] | CODE |
| LOW | paimon-python/pypaimon/multimodal/window_dataset.py | 835 | __all__ = ["ContiguousWindowDataset"] | CODE |
| LOW | paimon-python/pypaimon/multimodal/__init__.py | 62 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/multimodal/lerobot/__init__.py | 27 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/multimodal/rosbag/__init__.py | 26 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/common/options/__init__.py | 28 | __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 | 59 | __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 | 54 | 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 | 311 | def set_user_agent(self, value: str) -> None: | CODE |
| LOW | paimon-python/pypaimon/api/client.py | 314 | def set_error_handler(self, error_handler: ErrorHandler) -> None: | CODE |
| LOW | paimon-python/pypaimon/api/auth/__init__.py | 31 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/consumer/__init__.py | 29 | __all__ = [ | CODE |
| LOW | paimon-python/pypaimon/data/__init__.py | 32 | __all__ = [ | 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 | 26 | __all__ = ["Tag", "TagManager"] | CODE |
| LOW | paimon-python/pypaimon/tag/tag_manager.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/ray/merge_condition.py | 32 | logger = logging.getLogger(__name__) | CODE |
| LOW | paimon-python/pypaimon/ray/bucket_join.py | 37 | __all__ = ["bucket_join"] | CODE |
| 20 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 212 | # Check if from_branch is main branch | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 216 | # Check if from_branch is blank | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 220 | # Check if to_branch is blank | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 230 | # Check if from_branch exists | COMMENT |
| LOW⚡ | …on-python/pypaimon/branch/filesystem_branch_manager.py | 234 | # Check if to_branch already exists | COMMENT |
| LOW | paimon-python/pypaimon/catalog/filesystem_catalog.py | 114 | # Check if database still has tables | COMMENT |
| LOW | paimon-python/pypaimon/catalog/filesystem_catalog.py | 281 | # Check if table exists | COMMENT |
| LOW | paimon-python/pypaimon/read/split_read.py | 1029 | # Check if this is a SlicedSplit to get shard_file_idx_map | COMMENT |
| LOW | paimon-python/pypaimon/read/streaming_table_scan.py | 183 | # Check if we have a prefetched result ready | COMMENT |
| LOW | paimon-python/pypaimon/read/streaming_table_scan.py | 216 | # 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 | 58 | # Check if batch is within the desired range | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 176 | # Check if manifest row range overlaps with any of the expected row ranges | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 181 | # Check if ranges intersect | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 557 | # Check if global index is enabled | COMMENT |
| LOW | paimon-python/pypaimon/read/scanner/file_scanner.py | 991 | # 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 | 3920 | # Read the file and corrupt the header (last 5 bytes: index_length + version) | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 399 | # Write file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 404 | # Read file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 422 | # Write file using context manager | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 426 | # Read file | COMMENT |
| LOW⚡ | paimon-python/pypaimon/tests/jindo_file_system_test.py | 786 | # Write file | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 445 | # Write file in chunks | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 510 | # Write file | COMMENT |
| LOW | paimon-python/pypaimon/tests/jindo_file_system_test.py | 526 | # Write files | COMMENT |
| LOW | paimon-python/pypaimon/tests/blob_table_test.py | 4262 | # 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 | 1143 | # 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 | 67 | # 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 | …hon/pypaimon/deletionvectors/bitmap_deletion_vector.py | 111 | CODE | |
| LOW | …imon-python/pypaimon/manifest/schema/data_file_meta.py | 91 | CODE | |
| LOW | paimon-python/pypaimon/read/native_plan.py | 443 | CODE | |
| LOW | paimon-python/pypaimon/read/table_read.py | 1318 | CODE | |
| LOW | …n-python/pypaimon/read/reader/format_pyarrow_reader.py | 367 | CODE | |
| LOW | …n-python/pypaimon/read/reader/aggregate/aggregators.py | 1348 | CODE | |
| LOW | …python/pypaimon/management/list_permissions_request.py | 30 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/query.py | 125 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/query.py | 168 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/window_dataset.py | 85 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/lerobot/dataset.py | 97 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/lerobot/dataset.py | 589 | CODE | |
| LOW | paimon-python/pypaimon/multimodal/lerobot/dataset.py | 635 | CODE | |
| LOW | paimon-python/pypaimon/api/api_response.py | 317 | CODE | |
| LOW | paimon-python/pypaimon/api/api_response.py | 422 | 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 | 468 | CODE | |
| LOW | paimon-python/pypaimon/ray/ray_paimon.py | 53 | CODE | |
| LOW | paimon-python/pypaimon/ray/ray_paimon.py | 150 | 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 | …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 | 71 | 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 | 806 | new RowToColumnConverter(RowType.of(new DataField(0, "placeholder", readType))); | CODE |
| LOW | …va/org/apache/paimon/format/csv/CsvFileFormatTest.java | 90 | // Second row: "John Doe",,"Developer" (empty middle field) | COMMENT |
| LOW | …va/org/apache/paimon/format/csv/CsvFileFormatTest.java | 94 | assertThat(fields[0]).isEqualTo("John Doe"); | 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 | 1462 | # No need to merge fields, just create a single file reader | COMMENT |
| MEDIUM | paimon-python/pypaimon/tests/write/write_buffer_test.py | 142 | # harness has none of; record that it ran and do the rest. | 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 |
|---|---|---|---|---|
| MEDIUM | paimon-python/pypaimon/tests/native_read_test.py | 905 | CODE |
| 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 |