AI Slop Code Risk Monitor

apache/seatunnel

SlopCodeMonitor badge for apache/seatunnel Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.

2.0 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

This report summarizes scanner evidence for apache/seatunnel, a Java project with 9,777 GitHub stars. SynthScan examined 1,350,006 lines of code across 8329 source files, recording 1232 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 2.0 (Low pattern signal); it is not an authorship estimate.

Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.

2.0
Adjusted Signal
2.0
Raw Pattern Score
100%
Time Factor
2026-10-31
Last Push
9.8K
Stars
Java
Language
1.4M
Lines of Code
8.3K
Files
1.2K
Pattern Hits
2026-10-31
Scan Date
0.02
HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 3.4/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 887 finding(s).

Hallucinated Dependency & Supply Chain Risk 4.7/100 · LOW

Are imports declared and package/API names verified? 198 finding(s).

Agent Over-Engineering Ratio 2.8/100 · LOW

Are wrappers, guards, and repeated structures necessary? 542 finding(s).

PR Review Velocity Impact 9.1/100 · LOW

Which changes need focused human review? 1232 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

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.

Severity Breakdown

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.

CRITICAL 107HIGH 58MEDIUM 51LOW 1016

Directory Score Breakdown

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.

Pattern Findings

The scanner identified 1232 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hallucination Indicators107 hits · 1170 pts
SeverityFileLineSnippetContext
CRITICAL…eatunnel/openmldb/source/OpenMldbSourceReaderTest.java225 org.apache.seatunnel.shade.com.typesafe.config.ConfigFactory.parseString(CODE
CRITICAL…eatunnel/openmldb/source/OpenMldbSourceReaderTest.java231 org.apache.seatunnel.shade.com.typesafe.config.ConfigFactory.parseString(CODE
CRITICAL…nnel/edgesocket/source/EdgeSocketSourceReaderTest.java628 new org.apache.seatunnel.connectors.seatunnel.edgesocket.config.EdgeSocketConfig(CODE
CRITICAL⚡…connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java132 org.junit.jupiter.api.Assertions.assertTrue(Mem0SinkWriter.isRetryableStatus(408));CODE
CRITICAL⚡…connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java133 org.junit.jupiter.api.Assertions.assertTrue(Mem0SinkWriter.isRetryableStatus(429));CODE
CRITICAL⚡…connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java134 org.junit.jupiter.api.Assertions.assertTrue(Mem0SinkWriter.isRetryableStatus(500));CODE
CRITICAL⚡…connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java135 org.junit.jupiter.api.Assertions.assertFalse(Mem0SinkWriter.isRetryableStatus(400));CODE
CRITICAL⚡…connectors/seatunnel/mem0/sink/Mem0SinkWriterTest.java136 org.junit.jupiter.api.Assertions.assertFalse(Mem0SinkWriter.isRetryableStatus(401));CODE
CRITICAL…nnectors/seatunnel/http/client/HttpClientProvider.java293 org.apache.seatunnel.connectors.seatunnel.http.source.FilenameExtractor.extract(CODE
CRITICAL…connectors/seatunnel/hugegraph/utils/DataTypeUtil.java354 return org.apache.hugegraph.util.DateUtil.parse(s);CODE
CRITICAL…connectors/seatunnel/hugegraph/utils/DataTypeUtil.java494 com.google.common.base.Splitter.on(listFormat.getElemDelimiter())CODE
CRITICAL…seatunnel/connectors/seatunnel/hive/sink/HiveSink.java244 org.apache.seatunnel.api.table.catalog.TablePath.of(table);CODE
CRITICAL…seatunnel/connectors/seatunnel/hive/sink/HiveSink.java319 org.apache.seatunnel.api.table.catalog.TablePath.of(table);CODE
CRITICAL…onnectors/seatunnel/hive/sink/HiveSaveModeHandler.java262 new org.apache.hadoop.hive.metastore.api.SerDeInfo();CODE
CRITICAL…onnectors/seatunnel/hive/sink/HiveSaveModeHandler.java331 new org.apache.hadoop.hive.metastore.api.SerDeInfo();CODE
CRITICAL…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java721 org.apache.seatunnel.api.table.catalog.PhysicalColumn.of(CODE
CRITICAL…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java733 org.apache.seatunnel.api.table.catalog.PhysicalColumn.of(CODE
CRITICAL⚡…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java744 org.apache.seatunnel.api.table.catalog.TableSchema.builder()CODE
CRITICAL⚡…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java749 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
CRITICAL⚡…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java755 return org.apache.seatunnel.api.table.catalog.CatalogTable.of(CODE
CRITICAL…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java774 new org.apache.hadoop.hive.metastore.api.StorageDescriptor();CODE
CRITICAL…nectors/seatunnel/hive/utils/HiveMetaStoreCatalog.java781 new org.apache.hadoop.hive.metastore.api.FieldSchema(CODE
CRITICAL…ternal/dialect/oracle/container/OracleCatalogTest.java127 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
CRITICAL…t/kingbase/container/KingbaseCatalogContainerTest.java115 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
CRITICAL…ctors/seatunnel/jdbc/utils/JdbcFieldTypeUtilsTest.java88 org.junit.jupiter.api.Assertions.assertThrows(CODE
CRITICAL…ternal/executor/CopyManagerBatchStatementExecutor.java160 org.apache.commons.codec.binary.Base64.encodeBase64String(CODE
CRITICAL…el/paimon/handler/PaimonBranchSaveModeHandlerTest.java269 org.apache.seatunnel.api.table.catalog.PrimaryKey.of(CODE
CRITICAL…ctors/seatunnel/paimon/utils/RowTypeConverterTest.java188 new org.apache.seatunnel.api.table.type.DecimalType(30, 8);CODE
CRITICAL…connectors/seatunnel/paimon/catalog/PaimonCatalog.java296 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
CRITICAL…on/source/converter/SqlToPaimonPredicateConverter.java397 org.apache.seatunnel.common.utils.DateTimeUtils.parse(strValue));CODE
CRITICAL…onnectors/seatunnel/paimon/utils/RowTypeConverter.java501 return new org.apache.seatunnel.api.table.type.DecimalType(CODE
CRITICAL⚡…rs/seatunnel/databend/sink/DatabendSinkWriterTest.java284 org.junit.jupiter.api.Assertions.assertTrue(mergeSql.contains("raw_data:id as id"));CODE
CRITICAL⚡…rs/seatunnel/databend/sink/DatabendSinkWriterTest.java285 org.junit.jupiter.api.Assertions.assertTrue(mergeSql.contains("raw_data:name as name"));CODE
CRITICAL⚡…rs/seatunnel/databend/sink/DatabendSinkWriterTest.java286 org.junit.jupiter.api.Assertions.assertFalse(mergeSql.contains("raw_data:score as score"));CODE
CRITICAL…l/connectors/seatunnel/lance/catalog/LanceCatalog.java383 org.apache.seatunnel.api.table.catalog.PrimaryKey.of(pkName, pkColumnList));CODE
CRITICAL…l/connectors/seatunnel/lance/catalog/LanceCatalog.java396 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
CRITICAL…l/connectors/seatunnel/lance/catalog/LanceCatalog.java447 new com.lancedb.lance.namespace.model.JsonArrowDataType();CODE
CRITICAL…/connectors/bigquery/sink/BigQuerySinkFactoryTest.java92 org.junit.jupiter.api.Assertions.assertEquals(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java214 com.google.cloud.bigquery.Schema.of(Field.of("id", StandardSQLTypeName.STRING));CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java265 com.google.cloud.bigquery.Schema.of(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java313 com.google.cloud.bigquery.Schema.of(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java440 com.google.cloud.bigquery.Schema.of(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java457 com.google.cloud.bigquery.Schema.of(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java462 com.google.cloud.bigquery.Schema.of(CODE
CRITICAL…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java536 org.apache.seatunnel.api.table.catalog.PrimaryKey.of(CODE
CRITICAL…unnel/connectors/bigquery/catalog/BigQueryCatalog.java275 com.google.cloud.bigquery.PrimaryKey.newBuilder()CODE
CRITICAL…unnel/connectors/bigquery/catalog/BigQueryCatalog.java280 com.google.cloud.bigquery.TableConstraints.newBuilder()CODE
CRITICAL…/connectors/bigquery/client/BigQueryClientFactory.java63 com.google.api.gax.core.NoCredentialsProvider.create())CODE
CRITICAL…onnectors/seatunnel/fluss/source/FlussAdminClient.java149 return com.alibaba.fluss.metadata.TablePath.of(CODE
CRITICAL…ors/seatunnel/fluss/source/FlussSourceSplitReader.java303 com.alibaba.fluss.metadata.TablePath.of(CODE
CRITICAL…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java121 org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTable(CODE
CRITICAL…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java464 org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTable(CODE
CRITICAL…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java522 new org.apache.seatunnel.api.table.type.DecimalType(20, 6),CODE
CRITICAL…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java539 org.apache.seatunnel.api.table.catalog.CatalogTableUtil.getCatalogTable(CODE
CRITICAL⚡…c/main/java/io/debezium/connector/mysql/GtidUtils.java50 new com.github.shyiko.mysql.binlog.GtidSet.Interval(CODE
CRITICAL⚡…c/main/java/io/debezium/connector/mysql/GtidUtils.java55 new com.github.shyiko.mysql.binlog.GtidSet.Interval(CODE
CRITICAL⚡…c/main/java/io/debezium/connector/mysql/GtidUtils.java62 new com.github.shyiko.mysql.binlog.GtidSet.UUIDSet(CODE
CRITICAL…m/connector/mysql/MySqlStreamingChangeEventSource.java1154 gtidSet = new com.github.shyiko.mysql.binlog.GtidSet(filteredGtidSetStr);CODE
CRITICAL…m/connector/mysql/MySqlStreamingChangeEventSource.java1160 gtidSet = new com.github.shyiko.mysql.binlog.GtidSet("");CODE
CRITICAL…s/seatunnel/iceberg/sink/IcebergFormatVersionTest.java181 org.apache.seatunnel.api.table.catalog.TableIdentifier.of(CODE
47 more matches not shown…
Hyper-Verbose Identifiers395 hits · 376 pts
SeverityFileLineSnippetContext
LOWtools/check_connector_registration.py97def find_all_connector_modules(connectors_dir):CODE
LOWtools/check_connector_registration.py121def get_new_connector_modules_from_diff(repo_root, base_ref, connectors_dir):CODE
LOW⚡tools/check_connector_registration.py174def is_module_declared_in_parent_pom(connector_abs_dir):CODE
LOWtools/check_connector_registration.py216def build_plugin_mapping_jars(plugin_mapping_path):CODE
LOW⚡tools/update_modules_check/test_run_engines.py35 def test_translation_base_change_runs_flink_and_spark(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py38 def test_translation_flink_change_runs_flink_only(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py41 def test_translation_spark_change_runs_spark_only(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py44 def test_translation_base_and_flink_change_run_both_engines(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py50 def test_engine_change_runs_zeta_only(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py56 def test_engine_and_translation_change_run_every_engine(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py62 def test_engine_and_connector_change_run_every_engine(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py68 def test_shared_changes_run_every_engine(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py75 def test_unknown_change_runs_every_engine(self) -> None:CODE
LOWtools/update_modules_check/test_run_engines.py91 def test_flink_only_translation_change_prints_flink(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py104 def test_no_group_prints_every_engine(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py107 def test_workflow_passes_every_group_flag(self) -> None:CODE
LOW⚡tools/update_modules_check/test_run_engines.py114 def test_translation_probes_stay_narrow(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py56 def test_modules_to_json_preserves_exact_module_tokens(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py63 def test_module_outputs_use_json_empty_array(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py74 def test_every_module_is_assigned_once(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py83 def test_unknown_module_does_not_reshuffle_existing_modules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py97 def test_sharding_is_independent_of_module_order(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py105 def test_historical_seed_assignments_are_preserved(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py129 def test_full_and_updated_paths_apply_their_ownership_rules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py168 def test_regular_shards_keep_only_remaining_modules_once(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py190 def test_regular_shards_fail_fast_when_dedicated_modules_disappear(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py206 def test_regular_shards_allow_optional_dedicated_modules_to_be_absent(CODE
LOWtools/update_modules_check/test_update_modules_check.py222 def test_workflow_keeps_dedicated_jobs_for_excluded_modules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py252 def test_dedicated_job_conditions_match_json_module_tokens(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py268 def test_updated_shards_list_only_shards_with_modules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py301 def test_updated_shards_agree_with_per_shard_modules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py314 def test_updated_shards_reject_non_positive_shard_count(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py320 def test_updated_module_jobs_are_gated_on_their_shard(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py347 def test_full_shard_rejects_non_positive_shard_count(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py353 def test_full_shard_rejects_out_of_range_index(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py379 def test_standalone_paths_map_to_their_test_modules(self) -> None:CODE
LOWtools/update_modules_check/test_update_modules_check.py394 def test_standalone_modules_exist_and_match_workflow_filter(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py27 def test_force_full_api_check_on_dev_branch(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py30 def test_force_full_api_check_on_main_and_master_branches(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py37 def test_force_full_api_check_on_release_branch(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py40 def test_force_full_api_check_on_two_component_release_branch(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py43 def test_force_full_api_check_on_pull_request_base_branch(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py46 def test_skip_force_full_api_check_for_fork_owner(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py49 def test_skip_force_full_api_check_on_pull_request_merge_ref(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py52 def test_skip_force_full_api_check_on_non_version_release_branch(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py57 def test_skip_force_full_api_check_on_release_tag(self) -> None:CODE
LOW⚡tools/update_modules_check/test_ci_scope.py62 def test_skip_full_api_check_for_ci_only_fork_change(self) -> None:CODE
LOWtools/update_modules_check/test_ci_scope.py75 def test_skip_full_api_check_for_benchmark_tools_change(self) -> None:CODE
LOWtools/update_modules_check/test_ci_scope.py84 def test_skip_full_api_check_for_dist_only_fork_change(self) -> None:CODE
LOWtools/update_modules_check/test_ci_scope.py98 def test_run_full_api_check_for_source_api_change(self) -> None:CODE
LOWtools/update_modules_check/test_ci_scope.py111 def test_run_full_api_check_for_mixed_lightweight_and_source_change(self) -> None:CODE
LOWtools/update_modules_check/test_ci_scope.py125 def test_protected_branch_keeps_full_api_for_lightweight_change(self) -> None:CODE
LOWtools/update_modules_check/update_modules_check.py140def replace_comma_to_commacolon(modules_str):CODE
LOWtools/update_modules_check/update_modules_check.py163def get_dependency_tree_includes(modules_str):CODE
LOWtools/update_modules_check/update_modules_check.py229def _filter_shared_it_modules(modules, extra_exclusions=()):CODE
LOWtools/update_modules_check/update_modules_check.py240def filter_dedicated_shard_modules(modules, dedicated_modules, fail_on_missing):CODE
LOWtools/update_modules_check/update_modules_check.py257def split_full_connector_it_modules(modules, total_num):CODE
LOWtools/update_modules_check/update_modules_check.py295def build_sub_update_it_modules(modules, total_num, current_num):CODE
LOWtools/update_modules_check/update_modules_check.py314def get_sub_update_it_modules(modules, total_num, current_num):CODE
LOWtools/update_modules_check/update_modules_check.py318def build_sub_update_it_shards(modules, total_num):CODE
335 more matches not shown…
Over-Commented Block353 hits · 345 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW.licenserc.yaml1# Licensed to Apache Software Foundation (ASF) under one or more contributorCOMMENT
LOW…ctors/seatunnel/rocketmq/common/RocketMqAdminUtil.java341 && topicRouteAvailable(adminClient, topic)) {COMMENT
LOW…rs/seatunnel/airtable/source/AirtableSourceReader.java121 long exponential = 1L << Math.min(20, Math.max(0, retryCount - 1));COMMENT
LOW…rs/seatunnel/airtable/source/AirtableSourceReader.java141 // is at its most persistent. Spread the wait downwards instead. The capCOMMENT
LOW…ectors/seatunnel/airtable/sink/AirtableSinkWriter.java201COMMENT
LOW…ectors/seatunnel/prometheus/sink/PrometheusWriter.java121 if (batchSize > 0 && batchList.size() >= batchSize) {COMMENT
LOW…ectors/seatunnel/prometheus/sink/PrometheusWriter.java161 }COMMENT
LOW…src/test/resources/python/ignore_stdin_wait_forever.py1#COMMENT
LOW…or-python/src/test/resources/python/emit_then_sleep.py1#COMMENT
LOW…thon/src/test/resources/python/emit_without_newline.py1#COMMENT
LOW…/test/resources/python/spawn_stderr_child_then_exit.py1#COMMENT
LOW…onnector-python/src/test/resources/python/emit_rows.py1#COMMENT
LOW…on/src/test/resources/python/emit_then_wait_forever.py1#COMMENT
LOW…/test/resources/python/spawn_stdout_child_then_exit.py1#COMMENT
LOW…or-python/src/test/resources/python/exit_with_error.py1#COMMENT
LOW…g/apache/seatunnel/connectors/doris/util/HttpUtil.java41 // BE. The default waitForContinue timeout of HttpRequestExecutor is only 3s: when FE is busyCOMMENT
LOW…nel/connectors/doris/source/serialization/Routing.java1// Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…/selectdb/sink/writer/SelectDBSinkStateSerializer.java1// Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ectdb/sink/committer/SelectDBCommitInfoSerializer.java1// Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/seatunnel/cdc/sqlserver/source/offset/LsnOffset.java101 return offset.get(SourceInfo.EVENT_SERIAL_NO_KEY);COMMENT
LOW…logminer/processor/AbstractLogMinerEventProcessor.java941 }COMMENT
LOW…atunnel/cdc/mysql/config/MySqlSourceConfigFactory.java81COMMENT
LOW…rs/seatunnel/cdc/mysql/source/offset/BinlogOffset.java161 }COMMENT
LOW…nnectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java161 case "TINYINT":COMMENT
LOW…m/connector/mysql/MySqlStreamingChangeEventSource.java281 }COMMENT
LOW…io/debezium/connector/mysql/legacy/SnapshotReader.java201 // ------COMMENT
LOW…io/debezium/connector/mysql/legacy/SnapshotReader.java581 if (snapshotLockingMode.usesMinimalLocking() && isLocked) {COMMENT
LOW…/cdc/base/source/enumerator/SnapshotSplitAssigner.java201 public void onCompletedSplits(List<SnapshotSplitWatermark> completedSplitWatermarks) {COMMENT
LOW…atunnel/shade/com/typesafe/config/impl/PathParser.java101 if (Tokens.isValueWithType(t, ConfigValueType.STRING)) {COMMENT
LOWtools/check_connector_registration.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOW…pgrade_compatibility/run_upgrade_compatibility_test.sh1#!/usr/bin/env bashCOMMENT
LOW…ols/upgrade_compatibility/run_upgrade_compatibility.sh1#!/usr/bin/env bashCOMMENT
LOW…bility/scenarios/generic-fake-localfile/seatunnel.yaml1#COMMENT
LOW…lity/scenarios/mysql-cdc-multitable-localfile/setup.sh1#!/usr/bin/env bashCOMMENT
LOW…y/scenarios/mysql-cdc-multitable-localfile/teardown.sh1#!/usr/bin/env bashCOMMENT
LOW…cenarios/mysql-cdc-multitable-localfile/seatunnel.yaml1#COMMENT
LOWtools/update_modules_check/test_run_engines.py1#!/usr/bin/env python3COMMENT
LOWtools/update_modules_check/test_update_modules_check.py1#!/usr/bin/env python3COMMENT
LOWtools/update_modules_check/run_engines.py1#!/usr/bin/env python3COMMENT
LOWtools/update_modules_check/test_ci_scope.py1#!/usr/bin/env python3COMMENT
LOWtools/update_modules_check/update_modules_check.py1#!/usr/bin/env python3COMMENT
LOWtools/update_modules_check/update_modules_check.py21COMMENT
LOWtools/update_modules_check/check_file_updates.py1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOWtools/update_modules_check/ci_scope.py1#!/usr/bin/env python3COMMENT
LOWtools/dependencies/checkLicense.sh1#!/usr/bin/env bashCOMMENT
LOWtools/dependencies/license.py1#!/usr/bin/env pythonCOMMENT
LOWtools/github/free_disk_space.sh1#!/usr/bin/env bashCOMMENT
LOWtools/benchmarks/test_save_jmh_result.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/profile_report.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/test_profile_benchmarks.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/run_benchmarks.sh1#!/usr/bin/env bashCOMMENT
LOWtools/benchmarks/test_regression_report.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/profile_benchmarks.sh1#!/usr/bin/env bashCOMMENT
LOWtools/benchmarks/test_run_benchmarks.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/regression_report.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/save_jmh_result.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/test_profile_report.py1#!/usr/bin/env python3COMMENT
LOWtools/benchmarks/suites/benchmarks_core.txt1# Licensed to the Apache Software Foundation (ASF) under one or moreCOMMENT
LOWtools/spotless_check/pre-commit.sh1#!/bin/shCOMMENT
293 more matches not shown…
Decorative Section Separators40 hits · 123 pts
SeverityFileLineSnippetContext
MEDIUM…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java334 // ────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…tors/bigquery/sink/BigQueryCatalogAndSaveModeTest.java336 // ────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…nel/file/writer/ParquetWriteStrategyEvolutionTest.java245 // ── helpers ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/ParquetTypeCoercionTest.java207 // ── helper ─────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java114 // ── Helper to build a NoOpWriteStrategy with a given FileSinkConfig ──────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java164 // ── ADD_COLUMN ────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java205 // ── DROP_COLUMN ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java225 // ── RENAME_COLUMN (AlterTableChangeColumnEvent) ───────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java252 // ── UPDATE_COLUMN / MODIFY_COLUMN ─────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java278 // ── Batch / AlterTableColumnsEvent ────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java306 // ── Disabled flag: applySchemaChange fails fast with actionable message ────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java321 // ── finishAndCloseFile called on each schema change ───────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java341 // ── getFieldSafe bounds check ─────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java357 // ── IndexInRow stays consistent after ADD then DROP ───────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java390 // ── Case-insensitive DROP ─────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java410 // ── RENAME with position change ───────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java457 // ── beingWrittenFile cleared even when finishAndCloseFile throws ──────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java492 // ── Type-zoo coverage ─────────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java616 // ── Inner NoOp strategy ───────────────────────────────────────────────────────COMMENT
MEDIUM…ors/seatunnel/file/writer/FileSchemaEvolutionTest.java691 // ── Config validation ─────────────────────────────────────────────────────COMMENT
MEDIUM…/seatunnel/file/sink/writer/AbstractWriteStrategy.java236 // ── Schema Evolution ──────────────────────────────────────────────────────────COMMENT
MEDIUMtools/check_connector_registration.py53# ---------------------------------------------------------------------------COMMENT
MEDIUMtools/check_connector_registration.py56# ---------------------------------------------------------------------------COMMENT
MEDIUMtools/check_connector_registration.py79# ---------------------------------------------------------------------------COMMENT
MEDIUMtools/check_connector_registration.py81# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tools/check_connector_registration.py169# ---------------------------------------------------------------------------COMMENT
MEDIUM⚡tools/check_connector_registration.py171# ---------------------------------------------------------------------------COMMENT
MEDIUMtools/check_connector_registration.py237# ---------------------------------------------------------------------------COMMENT
MEDIUMtools/check_connector_registration.py239# ---------------------------------------------------------------------------COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py42# ─── Data structures ────────────────────────────────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py128# ─── Golden Examples ─────────────────────────────────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py160# ─── Plan parser ─────────────────────────────────────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py234# ─── Slot filling & pipeline expansion ───────────────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py426# ─── Scenario Skills (loaded from skills/*.md) ──────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py480# ─── Skill Router ────────────────────────────────────────────────────────────COMMENT
MEDIUMseatunnel-cli/seatunnel_cli/skills.py520# ─── Skill Executor ──────────────────────────────────────────────────────────COMMENT
MEDIUM…unnel-trace/seatunnel-trace-analyzer/analyze-traces.sh58# ---------------------------------------------------------------------------COMMENT
MEDIUM…unnel-trace/seatunnel-trace-analyzer/analyze-traces.sh64# ---------------------------------------------------------------------------COMMENT
MEDIUMseatunnel-edge-agent/config/agent.yaml16# ─────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUMseatunnel-edge-agent/config/agent.yaml21# ─────────────────────────────────────────────────────────────────────────────COMMENT
Empty Error Handlers23 hits · 115 pts
SeverityFileLineSnippetContext
HIGHseatunnel-cli/benchmark/runner.py365except Exception:CODE
HIGHseatunnel-cli/benchmark/execution.py270except OSError:CODE
HIGHseatunnel-cli/benchmark/execution.py330except OSError:CODE
HIGHseatunnel-cli/benchmark/execution.py363except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/connectors.py99except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/memory.py323except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/memory.py148except OSError:CODE
HIGHseatunnel-cli/seatunnel_cli/memory.py245except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py211except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py223except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py423except ImportError:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py1229except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py520except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py469except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py663except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py499except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py318except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py331except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py270except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py290except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py382except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/cli.py1382except Exception:CODE
HIGHseatunnel-cli/seatunnel_cli/llm_provider.py1367except Exception:CODE
Cross-File Repetition21 hits · 105 pts
SeverityFileLineSnippetContext
HIGHseatunnel-cli/tests/test_validate_hocon_placeholders.py0env { parallelism = 1 job.mode = "batch" } source { fakesource { row.num = 5 schema { fields { id = "bigint" } } plugin_STRING
HIGHseatunnel-cli/tests/test_benchmark_gates.py0env { parallelism = 1 job.mode = "batch" } source { fakesource { row.num = 5 schema { fields { id = "bigint" } } plugin_STRING
HIGHseatunnel-cli/tests/test_benchmark_comparison.py0env { parallelism = 1 job.mode = "batch" } source { fakesource { row.num = 5 schema { fields { id = "bigint" } } plugin_STRING
HIGHdocs/zh/connectors/formats/protobuf.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/zh/connectors/source/Kafka.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/zh/connectors/sink/Kafka.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/en/connectors/formats/protobuf.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/en/connectors/source/Kafka.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/en/connectors/sink/Kafka.md0syntax = "proto3"; package org.apache.seatunnel.format.protobuf; option java_outer_classname = "protobufe2e"; message peSTRING
HIGHdocs/zh/connectors/source/Kafka.md0com.sun.security.auth.module.krb5loginmodule required usekeytab=true keytab="/etc/kafka/kafka.keytab" principal="user@reSTRING
HIGHdocs/zh/connectors/sink/Kafka.md0com.sun.security.auth.module.krb5loginmodule required usekeytab=true keytab="/etc/kafka/kafka.keytab" principal="user@reSTRING
HIGHdocs/en/connectors/source/Kafka.md0com.sun.security.auth.module.krb5loginmodule required usekeytab=true keytab="/etc/kafka/kafka.keytab" principal="user@reSTRING
HIGHdocs/en/connectors/sink/Kafka.md0com.sun.security.auth.module.krb5loginmodule required usekeytab=true keytab="/etc/kafka/kafka.keytab" principal="user@reSTRING
HIGHdocs/zh/connectors/source/Rabbitmq.md0syntax = "proto3"; message person { int64 id = 1; string name = 2; }STRING
HIGHdocs/zh/connectors/sink/Rabbitmq.md0syntax = "proto3"; message person { int64 id = 1; string name = 2; }STRING
HIGHdocs/en/connectors/source/Rabbitmq.md0syntax = "proto3"; message person { int64 id = 1; string name = 2; }STRING
HIGHdocs/en/connectors/sink/Rabbitmq.md0syntax = "proto3"; message person { int64 id = 1; string name = 2; }STRING
HIGHdocs/zh/connectors/sink/StarRocks.md0create table if not exists shop.`${table_name}` ( ${rowtype_primary_key}, ${rowtype_fields} ) engine=olap primary key ($STRING
HIGHdocs/zh/introduction/configuration/schema-evolution.md0create table if not exists shop.`${table_name}` ( ${rowtype_primary_key}, ${rowtype_fields} ) engine=olap primary key ($STRING
HIGHdocs/en/connectors/sink/StarRocks.md0create table if not exists shop.`${table_name}` ( ${rowtype_primary_key}, ${rowtype_fields} ) engine=olap primary key ($STRING
HIGHdocs/en/introduction/configuration/schema-evolution.md0create table if not exists shop.`${table_name}` ( ${rowtype_primary_key}, ${rowtype_fields} ) engine=olap primary key ($STRING
Structural Annotation Overuse54 hits · 96 pts
SeverityFileLineSnippetContext
LOW…/seatunnel/file/sink/writer/AbstractWriteStrategy.java254 // Step 1: flush + close all open writers; register partial files for commit.COMMENT
LOW…/seatunnel/file/sink/writer/AbstractWriteStrategy.java265 // Step 2: adopt the upstream's actual produced schema, propagated through the chain viaCOMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java281 // Step 3: update sinkColumnNames to reflect the structural change.COMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java289 // Step 4: rebuild sinkColumnsIndexInRow from sinkColumnNames + new seaTunnelRowType.COMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java297 // Step 5: let subclasses invalidate any format-specific cached schema objects.COMMENT
LOW⚡seatunnel-cli/seatunnel_cli/skills.py536 # Step 1: Fill routing labels / defaults for each pipelineCOMMENT
LOW⚡seatunnel-cli/seatunnel_cli/skills.py540 # Step 2: Collect all required options across pipelines (deduplicated)COMMENT
LOWseatunnel-cli/seatunnel_cli/skills.py553 # Step 3: Single LLM call (fast model) to judge what's missingCOMMENT
LOWdocs/en/edge-agent/quick-start.md19## Step 1: Install Edge Agent on the edge hostCOMMENT
LOWdocs/en/edge-agent/download.md8## Step 1: PreparationCOMMENT
LOWdocs/en/edge-agent/download.md18## Step 2: Download the binary packageCOMMENT
LOWdocs/en/edge-agent/download.md41## Step 3: Build from sourceCOMMENT
LOWdocs/en/edge-agent/download.md65## Step 4: Verify package layoutCOMMENT
LOWdocs/en/introduction/concepts/metadata-spi.md274### Step 1: Add DependencyCOMMENT
LOWdocs/en/introduction/concepts/metadata-spi.md289### Step 2: Create a Provider ClassCOMMENT
LOW⚡docs/en/introduction/concepts/metadata-spi.md339### Step 3: Configure seatunnel.yamlCOMMENT
LOW⚡docs/en/introduction/concepts/metadata-spi.md352### Step 4: Package and DeployCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-flink.md17## Step 1: Deploy SeaTunnel And ConnectorsCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-flink.md21## Step 2: Deployment And Config FlinkCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-flink.md27## Step 3: Add Job Config File To Define A JobCOMMENT
LOWdocs/en/getting-started/locally/quick-start-flink.md77## Step 4: Run SeaTunnel ApplicationCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md45### Step 1: Deploy SeaTunnel And ConnectorsCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md51### Step 2: Add Job Config File To Define A JobCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md96### Step 3: Run SeaTunnel ApplicationCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md146#### Step 1: Download the ConnectorCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md163#### Step 2: Place the MySQL DriverCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md167#### Step 3: Add Job Configuration File to Define the JobCOMMENT
LOW…etting-started/locally/quick-start-seatunnel-engine.md209#### Step 4: Run the SeaTunnel ApplicationCOMMENT
LOWdocs/en/getting-started/locally/run-your-first-job.md10## Step 1: Finish local deploymentCOMMENT
LOWdocs/en/getting-started/locally/run-your-first-job.md14## Step 2: Install only the plugins this sample needsCOMMENT
LOWdocs/en/getting-started/locally/run-your-first-job.md33## Step 3: Use a minimal jobCOMMENT
LOWdocs/en/getting-started/locally/run-your-first-job.md74## Step 4: Run it in local modeCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-spark.md17## Step 1: Deployment SeaTunnel And ConnectorsCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-spark.md21## Step 2: Deploy And Config SparkCOMMENT
LOW⚡docs/en/getting-started/locally/quick-start-spark.md28## Step 3: Add Job Config File To Define A JobCOMMENT
LOWdocs/en/getting-started/locally/quick-start-spark.md78## Step 4: Run SeaTunnel ApplicationCOMMENT
LOWdocs/en/engines/zeta/stain-trace-quickstart.md107### Step 1: Configure EngineCOMMENT
LOWdocs/en/engines/zeta/stain-trace-quickstart.md134### Step 2: Enable Task-level SwitchCOMMENT
LOW⚡docs/en/engines/zeta/stain-trace-quickstart.md162### Step 3: Run Your JobCOMMENT
LOW⚡docs/en/engines/zeta/stain-trace-quickstart.md166### Step 4: View Trace FilesCOMMENT
LOW⚡docs/en/engines/zeta/stain-trace-quickstart.md176### Step 5: Generate HTML Report Using Analysis ToolCOMMENT
LOWdocs/en/engines/zeta/tuning-guide.md168#### Step 1: Identify when slow operations occurCOMMENT
LOWdocs/en/engines/zeta/tuning-guide.md180#### Step 2: Check overall node healthCOMMENT
LOWdocs/en/engines/zeta/tuning-guide.md189#### Step 3: Isolate the bottleneck layerCOMMENT
LOWdocs/en/engines/zeta/download-seatunnel.md10## Step 1: PreparationCOMMENT
LOWdocs/en/engines/zeta/download-seatunnel.md16## Step 2: Download SeaTunnelCOMMENT
LOWdocs/en/engines/zeta/download-seatunnel.md28## Step 3: Download The Connector PluginCOMMENT
LOWdocs/en/engines/zeta/download-seatunnel.md71## Step 4: seatunnel-shade jar package download addressCOMMENT
LOW…slation/flink/sink/FlinkSimpleAggregatedCommitter.java117 // Step 1: Combine commits into global commit with schema evolution supportCOMMENT
LOW…slation/flink/sink/FlinkSimpleAggregatedCommitter.java136 // Step 2: Commit the global commitCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java179 // Step 1: Run job to write data from MySQL to IcebergCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java185 // Step 2: Run verification job (Iceberg -> Assert)COMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java202 // Step 1: Run job to write data from PostgreSQL to IcebergCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java208 // Step 2: Run verification job (Iceberg -> Assert)COMMENT
Fake / Example Data55 hits · 58 pts
SeverityFileLineSnippetContext
LOW…tors/seatunnel/salesforce/sink/SalesforceSinkTest.java94 options.put("username", "user@example.com");CODE
LOW…ctors/seatunnel/fake/source/FakeDataGeneratorTest.java97 @ValueSource(strings = {"fake-data.schema.conf"})CODE
LOW…ctors/seatunnel/fake/source/FakeDataGeneratorTest.java129 @ValueSource(strings = {"fake-data.schema.conf"})CODE
LOW…ctors/seatunnel/fake/source/FakeDataGeneratorTest.java178 @ValueSource(strings = {"fake-data.column.conf"})CODE
LOW…ctors/seatunnel/fake/source/FakeDataGeneratorTest.java241 @ValueSource(strings = {"fake-data.schema.default.conf"})CODE
LOW…eatunnel/firebase/source/FirebaseSourceReaderTest.java398 assertEquals("Jane Doe", row.getField(0));CODE
LOW…/seatunnel/firebase/client/FirebaseHttpClientTest.java78 queryParams.put("equalTo", "John Doe");CODE
LOW…/seatunnel/firebase/client/FirebaseHttpClientTest.java86 // Asserts values are quote-wrapped ("name", "John Doe") and percent-encoded (%22)COMMENT
LOW…nnel/file/config/BaseFileSourceConfigMetadataTest.java124 new String[] {"placeholder"},CODE
LOW…nnel/file/config/BaseFileSourceConfigMetadataTest.java140 new String[] {"placeholder"},CODE
LOW…ynamodb/source/AmazonDynamoDBMultiTableSourceTest.java69 + "access_key_id = \"dummy-key\"\n"CODE
LOW…sform/validator/DataValidatorTransformFactoryTest.java341 SeaTunnelRow validRow = map(transform, tablePath, 1, "John Doe", 18, "jane@example.com");CODE
LOW…g/apache/seatunnel/transform/sql/SQLTransformTest.java1054 Assertions.assertEquals("John Doe", result.get(0).getField(0));CODE
LOW…he/seatunnel/transform/sql/SQLStringFunctionsTest.java89 Assertions.assertEquals("John Doe", outRow.getField(1));CODE
LOW…he/seatunnel/transform/sql/SQLStringFunctionsTest.java108 Assertions.assertEquals("John Doe", outRow.getField(0));CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java94 userData.put("address", "123 Main St");CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java107 Assertions.assertEquals("123 Main St", outRow.getField(0));CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java174 SeaTunnelRow innerRow = new SeaTunnelRow(new Object[] {"123 Main St", "New York"});CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java183 Assertions.assertEquals("123 Main St", outRow.getField(0));CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java204 SeaTunnelRow addressRow = new SeaTunnelRow(new Object[] {"123 Main St", "10001"});CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java205 SeaTunnelRow userRow = new SeaTunnelRow(new Object[] {"John Doe", addressRow});CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java217 Assertions.assertEquals("123 Main St", outRow.getField(0));CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java218 Assertions.assertEquals("John Doe", outRow.getField(1));CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java233 userData.put("name", "John Doe");CODE
LOW…nel/transform/sql/zeta/functions/CastFunctionTest.java243 Assertions.assertEquals("John Doe", outRow.getField(0));CODE
LOWdocs/zh/connectors/source/Jira.md105 email = "admin@example.com"CODE
LOWdocs/zh/connectors/source/AmazonDynamoDB.md174 access_key_id = "dummy-key"CODE
LOWdocs/zh/connectors/source/AmazonDynamoDB.md206 access_key_id = "dummy-key"CODE
LOWdocs/zh/connectors/source/AmazonDynamoDB.md228 access_key_id = "dummy-key"CODE
LOW…cs/zh/connectors/common-options/sink-common-options.md53 plugin_output = "fake_name"CODE
LOW…cs/zh/connectors/common-options/sink-common-options.md64 plugin_input = "fake_name"CODE
LOWdocs/zh/connectors/sink/AmazonDynamoDB.md135 access_key_id = "dummy-key"CODE
LOWdocs/zh/connectors/sink/AmazonDynamoDB.md165 access_key_id = "dummy-key"CODE
LOWdocs/en/connectors/source/Jira.md105 email = "admin@example.com"CODE
LOWdocs/en/connectors/source/AmazonDynamoDB.md180 access_key_id = "dummy-key"CODE
LOWdocs/en/connectors/source/AmazonDynamoDB.md212 access_key_id = "dummy-key"CODE
LOWdocs/en/connectors/source/AmazonDynamoDB.md235 access_key_id = "dummy-key"CODE
LOW…cs/en/connectors/common-options/sink-common-options.md61 plugin_output = "fake_name"CODE
LOW…cs/en/connectors/common-options/sink-common-options.md72 plugin_input = "fake_name"CODE
LOWdocs/en/connectors/sink/Hive.md595 fields = [1, "John Doe", "Engineering", 75000.50, "2022-01-15"]CODE
LOWdocs/en/connectors/sink/AmazonDynamoDB.md135 access_key_id = "dummy-key"CODE
LOWdocs/en/connectors/sink/AmazonDynamoDB.md165 access_key_id = "dummy-key"CODE
LOW…trace-analyzer/src/main/resources/template/report.html909 if (typeof I18N[lang][key] === 'string') el.setAttribute('placeholder', I18N[lang][key]);CODE
LOW…org/apache/seatunnel/common/exception/CommonError.java231 params.put("placeholder", placeholder);CODE
LOW…onnector-starrocks-e2e/src/test/resources/ddl/shop.sql78 ( 1, 'John Doe', 'john@example.com', '123-456-7890', '123 Main St' ),CODE
LOW…onnector-starrocks-e2e/src/test/resources/ddl/shop.sql78 ( 1, 'John Doe', 'john@example.com', '123-456-7890', '123 Main St' ),CODE
LOW…nel/e2e/connector/amazondynamodb/AmazondynamodbIT.java162 AwsBasicCredentials.create("dummy-key", "dummy-secret")))CODE
LOW…c/test/resources/elasticsearch/st_index_nest_data.json2 "name": "John Doe",CODE
LOW…c/test/resources/elasticsearch/st_index_nest_data.json5 "street": "123 Main St",CODE
LOW…t/resources/elasticsearch/st_index_full_type_data.json135 "name": "John Doe",CODE
LOW⚡…tor-http-e2e/src/test/resources/mockserver-config.json4232 "email": "avo@example.org"CODE
LOW⚡…tor-http-e2e/src/test/resources/mockserver-config.json4242 "email": "TaoZex@example.org"CODE
LOW⚡…tor-http-e2e/src/test/resources/mockserver-config.json4252 "email": "test@example.org"CODE
LOW⚡…tor-http-e2e/src/test/resources/mockserver-config.json4262 "email": "Jack@example.org"CODE
LOW⚡…tor-http-e2e/src/test/resources/mockserver-config.json4272 "email": "Lisa@example.org"CODE
Excessive Try-Catch Wrapping53 hits · 47 pts
SeverityFileLineSnippetContext
LOW…src/main/resources/python_transform/worker_template.py71 except Exception:CODE
LOWseatunnel-cli/benchmark/runner.py289 except Exception as e:CODE
LOWseatunnel-cli/benchmark/runner.py328 except Exception as e:CODE
LOWseatunnel-cli/benchmark/runner.py346 except Exception:CODE
LOWseatunnel-cli/benchmark/runner.py365 except Exception:CODE
LOWseatunnel-cli/benchmark/runner.py412 except Exception as e:CODE
LOWseatunnel-cli/benchmark/runner.py441 except Exception:CODE
LOWseatunnel-cli/benchmark/execution.py360 except Exception:CODE
LOWseatunnel-cli/benchmark/execution.py363 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py99 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py112 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py141 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py343 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py529 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/skills.py369 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/skills.py475 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py145 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py245 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py295 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py323 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py373 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py561 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/memory.py623 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/rest.py105 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py211 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py223 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py425 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py469 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py499 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py520 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py658 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py663 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1229 except Exception:STRING
MEDIUMseatunnel-cli/seatunnel_cli/cli.py1860 print("Error: Failed to export metadata. "CODE
LOWseatunnel-cli/seatunnel_cli/cli.py270 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py290 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py318 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py331 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py382 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py499 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py688 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py787 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py923 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1013 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1211 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1225 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1353 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1382 except Exception:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1525 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1575 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1648 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1719 except Exception as e:CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py1367 except Exception:CODE
Deep Nesting55 hits · 44 pts
SeverityFileLineSnippetContext
LOWtools/update_modules_check/update_modules_check.py174CODE
LOWtools/update_modules_check/update_modules_check.py187CODE
LOWtools/update_modules_check/update_modules_check.py334CODE
LOWtools/update_modules_check/check_file_updates.py22CODE
LOWtools/documents/update_connector_change_log.py24CODE
LOWtools/documents/update_connector_change_log.py105CODE
LOWtools/seatunnel-python-sdk/tests/test_java_detector.py143CODE
LOWtools/seatunnel-python-sdk/tests/test_java_detector.py249CODE
LOWseatunnel-cli/benchmark/runner.py371CODE
LOWseatunnel-cli/benchmark/execution.py274CODE
LOWseatunnel-cli/benchmark/execution.py347CODE
LOWseatunnel-cli/benchmark/execution.py367CODE
LOWseatunnel-cli/benchmark/scoring.py84CODE
LOWseatunnel-cli/benchmark/compare.py47CODE
LOWseatunnel-cli/benchmark/compare.py197CODE
LOWseatunnel-cli/benchmark/report.py239CODE
LOWseatunnel-cli/benchmark/report.py285CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py318CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py350CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py583CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py670CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py1184CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py1213CODE
LOWseatunnel-cli/seatunnel_cli/skills.py210CODE
LOWseatunnel-cli/seatunnel_cli/skills.py530CODE
LOWseatunnel-cli/seatunnel_cli/memory.py175CODE
LOWseatunnel-cli/seatunnel_cli/memory.py566CODE
LOWseatunnel-cli/seatunnel_cli/agents.py153CODE
LOWseatunnel-cli/seatunnel_cli/agents.py278CODE
LOWseatunnel-cli/seatunnel_cli/agents.py343CODE
LOWseatunnel-cli/seatunnel_cli/agents.py397CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1205CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1369CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1488CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1581CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1684CODE
LOWseatunnel-cli/seatunnel_cli/agents.py1748CODE
LOWseatunnel-cli/seatunnel_cli/cli.py507CODE
LOWseatunnel-cli/seatunnel_cli/cli.py899CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1003CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1114CODE
LOWseatunnel-cli/seatunnel_cli/cli.py1389CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py1384CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py174CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py413CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py528CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py599CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py657CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py758CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py809CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py1024CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py1101CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py1170CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/checkpoints.py295CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/jobs.py199CODE
Cross-Language Confusion10 hits · 42 pts
SeverityFileLineSnippetContext
HIGHseatunnel-cli/tests/test_diagnose_checkpoints.py26 `durationMillis` (the field is omitted when null);STRING
HIGHseatunnel-cli/tests/test_benchmark_paraphrases.py211 '{"paraphrases": [null]}',STRING
HIGHseatunnel-cli/seatunnel_cli/agents.py775 "transform": null,CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py796 "transform": null,CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py804 "transform": null,CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py928 {"id": "pipeline_1", "source": {"connector": "Jdbc", "reason": "MySQL via JDBC — batch full-table read"}, "sink": {"CODE
HIGHseatunnel-cli/seatunnel_cli/agents.py943 {"id": "pipeline_1", "source": {"connector": "MySQL-CDC", "reason": "real-time change data capture"}, "sink": {"connCODE
HIGHseatunnel-cli/seatunnel_cli/agents.py958 {"id": "pipeline_1", "source": {"connector": "Jdbc", "reason": "MySQL JDBC for audit_log and orders"}, "sink": {"conCODE
HIGHseatunnel-cli/seatunnel_cli/agents.py959 {"id": "pipeline_2", "source": {"connector": "Jdbc", "reason": "MySQL JDBC for users"}, "sink": {"connector": "AsserCODE
HIGHseatunnel-cli/seatunnel_cli/diagnostics/checkpoints.py155 ``completedTimestamp`` are omitted from the JSON when null, whileSTRING
Verbosity Indicators14 hits · 28 pts
SeverityFileLineSnippetContext
LOW…/seatunnel/file/sink/writer/AbstractWriteStrategy.java254 // Step 1: flush + close all open writers; register partial files for commit.COMMENT
LOW…/seatunnel/file/sink/writer/AbstractWriteStrategy.java265 // Step 2: adopt the upstream's actual produced schema, propagated through the chain viaCOMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java281 // Step 3: update sinkColumnNames to reflect the structural change.COMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java289 // Step 4: rebuild sinkColumnsIndexInRow from sinkColumnNames + new seaTunnelRowType.COMMENT
LOW⚡…/seatunnel/file/sink/writer/AbstractWriteStrategy.java297 // Step 5: let subclasses invalidate any format-specific cached schema objects.COMMENT
LOW⚡seatunnel-cli/seatunnel_cli/skills.py536 # Step 1: Fill routing labels / defaults for each pipelineCOMMENT
LOW⚡seatunnel-cli/seatunnel_cli/skills.py540 # Step 2: Collect all required options across pipelines (deduplicated)COMMENT
LOWseatunnel-cli/seatunnel_cli/skills.py553 # Step 3: Single LLM call (fast model) to judge what's missingCOMMENT
LOW…slation/flink/sink/FlinkSimpleAggregatedCommitter.java117 // Step 1: Combine commits into global commit with schema evolution supportCOMMENT
LOW…slation/flink/sink/FlinkSimpleAggregatedCommitter.java136 // Step 2: Commit the global commitCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java179 // Step 1: Run job to write data from MySQL to IcebergCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java185 // Step 2: Run verification job (Iceberg -> Assert)COMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java202 // Step 1: Run job to write data from PostgreSQL to IcebergCOMMENT
LOW⚡…el/e2e/connector/iceberg/JdbcToIcebergTimestampIT.java208 // Step 2: Run verification job (Iceberg -> Assert)COMMENT
Modern AI Meta-Vocabulary8 hits · 23 pts
SeverityFileLineSnippetContext
MEDIUMdocs/zh/introduction/rag-data-processing.md1# RAG Ready 数据处理COMMENT
MEDIUMdocs/zh/introduction/rag-data-processing.md5## 为什么 RAG 需要一条数据管道COMMENT
MEDIUMdocs/zh/transforms/embedding.md642### Customize the embedding modelCOMMENT
MEDIUMdocs/en/introduction/rag-data-processing.md1# RAG-Ready Data ProcessingCOMMENT
MEDIUMdocs/en/introduction/rag-data-processing.md5## Why a data pipeline matters for RAGCOMMENT
MEDIUMdocs/en/introduction/rag-data-processing.md175### Which embedding model providers are supported?COMMENT
MEDIUMdocs/en/transforms/embedding.md662### Customize the embedding modelCOMMENT
MEDIUM…he/seatunnel/e2e/connector/file/local/LocalFileIT.java357 "mkdir -p /seatunnel/read/markdown && printf '# E2E Markdown RAG\\n## Child\\nBody\\n' > /seatunCODE
Magic Placeholder Names4 hits · 22 pts
SeverityFileLineSnippetContext
HIGHdocs/zh/introduction/concepts/metadata-spi.md348 api-key: your-api-keyCODE
HIGHdocs/zh/transforms/embedding.md474 api_key = "your-api-key"CODE
HIGH⚡docs/en/introduction/concepts/metadata-spi.md349 api-key: your-api-keyCODE
HIGHdocs/en/transforms/embedding.md494 api_key = "your-api-key"CODE
Unused Imports22 hits · 20 pts
SeverityFileLineSnippetContext
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py17CODE
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py18CODE
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py19CODE
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py19CODE
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py19CODE
LOWseatunnel-cli/benchmark/runner.py43CODE
LOWseatunnel-cli/benchmark/execution.py45CODE
LOWseatunnel-cli/benchmark/scoring.py36CODE
LOWseatunnel-cli/benchmark/compare.py20CODE
LOWseatunnel-cli/benchmark/report.py33CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py40CODE
LOWseatunnel-cli/seatunnel_cli/skills.py28CODE
LOWseatunnel-cli/seatunnel_cli/memory.py32CODE
LOWseatunnel-cli/seatunnel_cli/agents.py28CODE
LOWseatunnel-cli/seatunnel_cli/agents.py36CODE
LOWseatunnel-cli/seatunnel_cli/agents.py40CODE
LOWseatunnel-cli/seatunnel_cli/cli.py33CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/__init__.py20CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/__init__.py20CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/checkpoints.py46CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/jobs.py40CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/errors.py32CODE
Modern Structural Boilerplate10 hits · 10 pts
SeverityFileLineSnippetContext
LOWtools/seatunnel-python-sdk/seatunnel/__init__.py25__all__ = [CODE
LOWseatunnel-cli/seatunnel_cli/connectors.py47logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/skills.py40logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/memory.py47logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/memory.py312 def update_summary(self, summary: str) -> None:CODE
LOWseatunnel-cli/seatunnel_cli/rest.py35logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/agents.py49logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/cli.py47logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/llm_provider.py43logger = logging.getLogger(__name__)CODE
LOWseatunnel-cli/seatunnel_cli/diagnostics/__init__.py22__all__ = ["ParsedError", "parse_error"]CODE
Example Usage Blocks3 hits · 4 pts
SeverityFileLineSnippetContext
LOW…nnel-starter/src/main/bin/seatunnel-metadata-export.sh22# Usage:COMMENT
LOWseatunnel-cli/bin/seatunnel-ai.sh21# Usage:COMMENT
LOW…unnel-trace/seatunnel-trace-analyzer/analyze-traces.sh21# Usage:COMMENT
Redundant / Tautological Comments3 hits · 4 pts
SeverityFileLineSnippetContext
LOWseatunnel-cli/seatunnel_cli/agents.py259 # Check if any trigger condition matchesCOMMENT
LOWseatunnel-cli/seatunnel_cli/llm_provider.py820 # Check if this message contains tool resultsCOMMENT
LOWseatunnel-cli/seatunnel_cli/llm_provider.py835 # Check if this message contains tool use (assistant with tool calls)COMMENT
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUM…ctors/seatunnel/hive/utils/HiveTableTemplateUtils.java133 // This is a basic implementation - could be enhanced for more complex casesCOMMENT
AI Slop Vocabulary1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUMseatunnel-cli/benchmark/runner.py434 # Per-task boundary: an unexpected harness error (scoringCOMMENT