2.9

Adjusted Signal

2.9

Raw Pattern Score

100%

Time Factor

2026-10-31

Last Push

26.4K

Stars

Java

Language

3.7M

Lines of Code

19.0K

Files

4.3K

Pattern Hits

2026-10-31

Scan Date

0.04

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.9/100 · LOW

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

Hallucinated Dependency & Supply Chain Risk 8.3/100 · LOW

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

Agent Over-Engineering Ratio 3.8/100 · LOW

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

PR Review Velocity Impact 13.3/100 · LOW

Which changes need focused human review? 4345 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 502HIGH 324MEDIUM 98LOW 3421

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 4345 distinct pattern matches across 25 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 Indicators502 hits · 5625 pts

Severity	File	Line	Snippet	Context
CRITICAL	…main/java/org/apache/flink/table/legacy/api/Types.java	154	return org.apache.flink.api.common.typeinfo.Types.ROW(types);	CODE
CRITICAL	…main/java/org/apache/flink/table/legacy/api/Types.java	172	return org.apache.flink.api.common.typeinfo.Types.ROW_NAMED(fieldNames, types);	CODE
CRITICAL⚡	…/org/apache/flink/table/client/cli/CliStringsTest.java	54	+ "\tat org.apache.flink.table.gateway.rest.handler.statement.FetchResultsHandler.handleRequest(Fetc	CODE
CRITICAL⚡	…/org/apache/flink/table/client/cli/CliStringsTest.java	56	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServiceI	CODE
CRITICAL⚡	…/org/apache/flink/table/client/cli/CliStringsTest.java	59	+ "\tat org.apache.flink.table.gateway.service.operation.OperationManager.processThrowable(Operation	CODE
CRITICAL⚡	…/org/apache/flink/table/client/cli/CliStringsTest.java	63	+ "\tat org.apache.flink.table.planner.parse.CalciteParser.parse(CalciteParser.java:60)\n"	CODE
CRITICAL⚡	…/org/apache/flink/table/client/cli/CliStringsTest.java	67	+ "\tat org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.convertException(FlinkSqlParserImpl.java	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	167	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	172	+ "\tat org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParse	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	209	+ "\tat org.apache.flink.table.gateway.rest.handler.operation.AbstractOperationHandler.handleReq	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	211	+ "\tat org.apache.flink.table.gateway.service.operation.OperationManager.cancelOperation(Operat	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	229	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	242	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	255	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	271	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	274	+ "\tat org.apache.flink.table.gateway.service.operation.OperationManager.cancelOperation(Operat	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	288	+ "\tat org.apache.flink.table.gateway.service.SqlGatewayServiceImpl.fetchResults(SqlGatewayServ	CODE
CRITICAL	…/org/apache/flink/table/client/cli/CliStringsTest.java	292	+ "\tat org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:	CODE
CRITICAL	…che/flink/table/client/gateway/ExecutorImplITCase.java	616	org.apache.flink.core.testutils.CommonTestUtils.setEnv(envMap);	CODE
CRITICAL	…/java/org/apache/flink/table/client/cli/CliClient.java	399	org.apache.flink.core.fs.Path path = new org.apache.flink.core.fs.Path(uri.toString());	CODE
CRITICAL	…/apache/flink/table/runtime/application/SqlDriver.java	215	org.apache.flink.core.fs.Path path = new org.apache.flink.core.fs.Path(uri);	CODE
CRITICAL	…le/gateway/service/application/ScriptRunnerITCase.java	94	org.apache.flink.core.testutils.CommonTestUtils.setEnv(map);	CODE
CRITICAL	…le/gateway/service/application/ScriptRunnerITCase.java	125	org.apache.flink.core.testutils.CommonTestUtils.setEnv(originalEnv);	CODE
CRITICAL	…/table/planner/plan/FlinkCalciteCatalogReaderTest.java	191	org.apache.flink.table.api.Schema.newBuilder()	CODE
CRITICAL	…/table/planner/plan/FlinkCalciteCatalogReaderTest.java	194	org.apache.flink.table.api.Schema.newBuilder()	CODE
CRITICAL	…plan/optimize/CorrelVariableNormalizerShuttleTest.java	64	com.google.common.collect.ImmutableSet.of(oldId));	CODE
CRITICAL	…rules/logical/MetadataFilterInReadingMetadataTest.java	252	metadata.put("event_time", org.apache.flink.table.api.DataTypes.TIMESTAMP(3));	CODE
CRITICAL	…rules/logical/MetadataFilterInReadingMetadataTest.java	309	metadata.put("timestamp", org.apache.flink.table.api.DataTypes.TIMESTAMP(3));	CODE
CRITICAL	…rules/logical/MetadataFilterInReadingMetadataTest.java	382	metadata.put("event_time", org.apache.flink.table.api.DataTypes.TIMESTAMP(3));	CODE
CRITICAL	…able/planner/factories/TestValuesRuntimeFunctions.java	448	new org.apache.flink.streaming.api.watermark.Watermark(	CODE
CRITICAL	…table/planner/plan/batch/sql/join/LookupJoinTest.scala	136	// at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.rel(FlinkPlannerImpl.scala:125)	COMMENT
CRITICAL	…ink/table/planner/plan/metadata/MetadataTestUtil.scala	526	.schema(org.apache.flink.table.api.Schema.newBuilder.fromResolvedSchema(resolvedSchema).build)	CODE
CRITICAL	…flink/table/planner/runtime/FileSystemITCaseBase.scala	371	new File(new org.apache.flink.core.fs.Path("file:" + resultPath + "/a=1/.b=2").toUri)	STRING
CRITICAL	…main/java/org/apache/calcite/runtime/SqlFunctions.java	6344	return org.apache.commons.lang3.StringUtils.replaceChars(s, search, replacement);	CODE
CRITICAL	…main/java/org/apache/calcite/runtime/SqlFunctions.java	6357	return org.apache.commons.lang3.Strings.CI.replace(s, search, replacement);	CODE
CRITICAL	…/plan/rules/logical/JoinToMultiJoinForReorderRule.java	640	com.google.common.collect.ImmutableMap.builder();	CODE
CRITICAL	…le/planner/plan/rules/logical/JoinToMultiJoinRule.java	271	com.google.common.collect.ImmutableMap.copyOf(newJoinFieldRefCountsMap),	CODE
CRITICAL⚡	…lan/rules/logical/FlinkAggregateJoinTransposeRule.java	235	final List<Integer> leftKeys = com.google.common.collect.Lists.newArrayList();	CODE
CRITICAL⚡	…lan/rules/logical/FlinkAggregateJoinTransposeRule.java	236	final List<Integer> rightKeys = com.google.common.collect.Lists.newArrayList();	CODE
CRITICAL⚡	…lan/rules/logical/FlinkAggregateJoinTransposeRule.java	237	final List<Boolean> filterNulls = com.google.common.collect.Lists.newArrayList();	CODE
CRITICAL	…lan/rules/logical/FlinkAggregateJoinTransposeRule.java	492	com.google.common.collect.ImmutableList.of(newGroupSet),	CODE
CRITICAL	…/plan/rules/logical/ProjectMultiJoinTransposeRule.java	315	com.google.common.collect.ImmutableMap.copyOf(newJoinFieldRefCountsMap),	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	196	com.google.common.collect.Iterables.getOnlyElement(argLists);	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	355	com.google.common.collect.Lists.newArrayList();	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	383	com.google.common.collect.Lists.newArrayList(	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	460	com.google.common.collect.ImmutableList.copyOf(groupSetTreeSet);	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	646	com.google.common.collect.ImmutableList.builder();	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	692	com.google.common.collect.Lists.newArrayList(aggregate.getAggCallList());	CODE
CRITICAL	…ogical/FlinkAggregateExpandDistinctAggregatesRule.java	865	final List<RexNode> conditions = com.google.common.collect.Lists.newArrayList();	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	558	com.google.common.collect.ImmutableSet.copyOf(	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	943	com.google.common.collect.ImmutableMap.builder();	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	986	com.google.common.collect.Multimaps.newSortedSetMultimap(	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	991	return com.google.common.collect.Sets.newTreeSet();	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	1396	com.google.common.collect.ImmutableMap.copyOf(mapSubQueryNodeToCorSet);	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	1463	com.google.common.collect.ImmutableSortedMap.copyOf(oldToNewOutputs);	CODE
CRITICAL	…e/planner/plan/rules/logical/SubQueryDecorrelator.java	1502	this.subQueryMap = com.google.common.collect.ImmutableMap.copyOf(subQueryMap);	CODE
CRITICAL	…le/planner/plan/rules/logical/FlinkFilterJoinRule.java	111	com.google.common.collect.ImmutableList.copyOf(joinFilters);	CODE
CRITICAL	…le/planner/plan/rules/logical/FlinkFilterJoinRule.java	124	com.google.common.collect.ImmutableList.copyOf(aboveFilters);	CODE
CRITICAL	…le/planner/plan/rules/logical/FlinkFilterJoinRule.java	167	if (com.google.common.collect.Sets.newHashSet(joinFilters)	CODE
CRITICAL	…le/planner/plan/rules/logical/FlinkFilterJoinRule.java	168	.equals(com.google.common.collect.Sets.newHashSet(origJoinFilters))) {	CODE
442 more matches not shown…

Hyper-Verbose Identifiers1775 hits · 1608 pts

Severity	File	Line	Snippet	Context
LOW	…/org/apache/flink/table/api/codegen/TypeAnalyzer.scala	466	def getOrElseUpdate(tpe: Type)(orElse: Int => UDTDescriptor): UDTDescriptor = {	CODE
LOW	…me/operators/join/deltajoin/TailOutputDataHandler.java	34	public class TailOutputDataHandler extends DeltaJoinHandlerBase {	CODE
LOW	…che/flink/table/planner/calcite/FlinkPlannerImpl.scala	92	def getOrCreateSqlValidator(): FlinkCalciteSqlValidator = {	CODE
LOW	flink-python/pyflink/find_flink_home.py	33	def _is_apache_flink_libraries_home(path):	CODE
LOW	flink-python/pyflink/serializers.py	38	def _load_from_stream_without_unbatching(self, stream: BytesIO):	CODE
LOW	flink-python/pyflink/serializers.py	159	def _load_from_stream_without_unbatching(self, stream):	CODE
LOW	flink-python/pyflink/gen_protos.py	119	def _install_grpcio_tools_and_generate_proto_files(force, output_dir):	CODE
LOW	flink-python/pyflink/gen_protos.py	188	def _check_grpcio_tools_version():	CODE
LOW	flink-python/pyflink/java_gateway.py	40	def is_launch_gateway_disabled():	CODE
LOW	flink-python/pyflink/pyflink_gateway_server.py	87	def prepare_environment_variables(env):	CODE
LOW	flink-python/pyflink/pyflink_gateway_server.py	185	def construct_flink_classpath(env):	CODE
LOW	flink-python/pyflink/pyflink_gateway_server.py	207	def construct_hadoop_classpath(env):	CODE
LOW	flink-python/pyflink/pyflink_gateway_server.py	262	def launch_gateway_server_process(env, args):	CODE
LOW⚡	flink-python/pyflink/datastream/functions.py	149	def get_number_of_parallel_subtasks(self) -> int:	CODE
LOW⚡	flink-python/pyflink/datastream/functions.py	156	def get_max_number_of_parallel_subtasks(self) -> int:	CODE
LOW⚡	flink-python/pyflink/datastream/functions.py	163	def get_index_of_this_subtask(self) -> int:	CODE
LOW	flink-python/pyflink/datastream/functions.py	179	def get_task_name_with_subtasks(self) -> str:	CODE
LOW	flink-python/pyflink/datastream/functions.py	1584	def process_broadcast_element(self, value: IN2, ctx: Context):	CODE
LOW	flink-python/pyflink/datastream/functions.py	1696	def process_broadcast_element(self, value: IN2, ctx: Context):	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	108	def register_slot_sharing_group(self, slot_sharing_group: SlotSharingGroup) \	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	195	def disable_operator_chaining(self) -> 'StreamExecutionEnvironment':	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	215	def is_chaining_of_operators_with_different_max_parallelism_enabled(self) -> bool:	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	290	def get_checkpointing_consistency_mode(self) -> CheckpointingMode:	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	302	def enable_changelog_state_backend(self, enabled: bool) -> 'StreamExecutionEnvironment':	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	338	def is_changelog_state_backend_enabled(self) -> Optional[bool]:	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	353	def set_default_savepoint_directory(self, directory: str) -> 'StreamExecutionEnvironment':	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	369	def get_default_savepoint_directory(self) -> Optional[str]:	CODE
LOW⚡	…hon/pyflink/datastream/stream_execution_environment.py	593	def get_default_local_parallelism(self) -> int:	CODE
LOW⚡	…hon/pyflink/datastream/stream_execution_environment.py	601	def set_default_local_parallelism(self, parallelism: int):	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	671	def get_execution_environment(configuration: Configuration = None) \	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	889	def is_unaligned_checkpoints_enabled(self):	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	895	def is_force_unaligned_checkpoints(self):	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	110	def get_min_pause_between_checkpoints(self) -> int:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	121	def set_min_pause_between_checkpoints(self,	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	139	def get_max_concurrent_checkpoints(self) -> int:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	150	def set_max_concurrent_checkpoints(self, max_concurrent_checkpoints: int) -> 'CheckpointConfig':	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	162	def is_fail_on_checkpointing_errors(self) -> bool:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	174	def set_fail_on_checkpointing_errors(self,	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	198	def get_tolerable_checkpoint_failure_number(self) -> int:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	207	def set_tolerable_checkpoint_failure_number(self,	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	227	def set_externalized_checkpoint_retention(	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	263	def is_externalized_checkpoints_enabled(self) -> bool:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	271	def get_externalized_checkpoint_retention(self) -> Optional['ExternalizedCheckpointRetention']:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	285	def is_unaligned_checkpoints_enabled(self) -> bool:	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	293	def enable_unaligned_checkpoints(self, enabled: bool = True) -> 'CheckpointConfig':	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	310	def disable_unaligned_checkpoints(self) -> 'CheckpointConfig':	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	326	def set_aligned_checkpoint_timeout(self, alignment_timeout: Duration) -> 'CheckpointConfig':	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	341	def get_aligned_checkpoint_timeout(self) -> 'Duration':	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	378	def set_force_unaligned_checkpoints(	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	390	def is_force_unaligned_checkpoints(self) -> 'bool':	CODE
LOW	flink-python/pyflink/datastream/window.py	65	def long_to_int_with_bit_mixing(x: int) -> int:	CODE
LOW	flink-python/pyflink/datastream/window.py	117	def get_window_start_with_offset(timestamp: int, offset: int, window_size: int):	CODE
LOW	flink-python/pyflink/datastream/window.py	360	def get_current_processing_time(self) -> int:	CODE
LOW⚡	flink-python/pyflink/datastream/window.py	386	def register_processing_time_timer(self, time: int) -> None:	CODE
LOW⚡	flink-python/pyflink/datastream/window.py	396	def register_event_time_timer(self, time: int) -> None:	CODE
LOW⚡	flink-python/pyflink/datastream/window.py	406	def delete_processing_time_timer(self, time: int) -> None:	CODE
LOW	flink-python/pyflink/datastream/window.py	529	def get_current_processing_time(self) -> int:	CODE
LOW	flink-python/pyflink/datastream/window.py	779	def register_next_fire_timestamp(self,	CODE
LOW	flink-python/pyflink/datastream/window.py	906	def register_next_fire_timestamp(self,	CODE
LOW	flink-python/pyflink/datastream/timerservice.py	41	def register_processing_time_timer(self, timestamp: int):	CODE
1715 more matches not shown…

Over-Commented Block931 hits · 910 pts

Severity	File	Line	Snippet	Context
LOW	azure-pipelines.yml	1	# Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	azure-pipelines.yml	21	# - end-to-end tests	COMMENT
LOW	…link/table/types/logical/utils/LogicalTypeMerging.java	201	// Adopted from "https://docs.microsoft.com/en-us/sql/t-sql/data-types/precision-	COMMENT
LOW	flink-table/flink-sql-client/bin/sql-client.sh	1	#!/usr/bin/env bash	COMMENT
LOW	…rg/apache/flink/table/client/gateway/ExecutorImpl.java	561	List<SqlGatewayRestAPIVersion> gatewayVersions =	COMMENT
LOW	…pache/flink/table/api/codegen/TypeInformationGen.scala	221	def mkTraversableTypeInfo[T: c.WeakTypeTag](	COMMENT
LOW	…rs/join/stream/StreamingMiniBatchJoinOperatorTest.java	481	"3 Bellevue Drive, Pottstown, PA 19464",	COMMENT
LOW	…rs/join/stream/StreamingMiniBatchJoinOperatorTest.java	701	rowOfKind(	COMMENT
LOW	…/runtime/operators/join/interval/TimeIntervalJoin.java	81		COMMENT
LOW	…/operators/join/stream/StreamingMultiJoinOperator.java	461	// state at current depth	COMMENT
LOW	…/operators/join/stream/StreamingMultiJoinOperator.java	481	// true for its recursive calls).	COMMENT
LOW	…/operators/join/stream/StreamingMultiJoinOperator.java	541	// associations that the left side has. This is only necessary for left joins to know	COMMENT
LOW	…/operators/join/stream/StreamingMultiJoinOperator.java	701	true, input)); // true for isInputRecordActive	COMMENT
LOW	…rs/join/stream/bundle/InputSideHasUniqueKeyBundle.java	61	return bundle.keySet();	COMMENT
LOW	flink-table/flink-sql-gateway/bin/sql-gateway.sh	1	#!/usr/bin/env bash	COMMENT
LOW	…odes/exec/stream/ProcessTableFunctionTestPrograms.java	2241	// Watermark transitions from 1969-12-31T23:59:59.995Z	COMMENT
LOW	…odes/exec/stream/ProcessTableFunctionTestPrograms.java	2281	.setupTableSource(TIMED_SOURCE_LATE_EVENTS)	COMMENT
LOW	…odes/exec/stream/ProcessTableFunctionTestPrograms.java	2301	// to 1970-01-01T00:01:39.998Z	COMMENT
LOW	…e/planner/plan/nodes/exec/common/SortTestPrograms.java	61	.addSchema("a INT", "b VARCHAR", "c BIGINT")	COMMENT
LOW	…jsonplan/ConfigureOperatorLevelStateTtlJsonITCase.java	221	// +--------------+--------------+-------------------------------------+-------------------+	COMMENT
LOW	…/table/planner/runtime/stream/sql/WatermarkITCase.java	81	// SourceFunction does not support watermark moving back. SourceStreamTask does not support	COMMENT
LOW	…able/planner/runtime/batch/ParallelismSettingTest.java	201	+ " 'connector' = 'values',\n"	COMMENT
LOW	…/flink/table/planner/functions/CastFunctionITCase.java	2081	// .fromCase(VARCHAR(5), "Flink", null)	COMMENT
LOW	…/flink/table/planner/functions/CastFunctionITCase.java	2101	.fromCase(INTERVAL(YEAR()), 0, Period.of(0, 0, 0))	COMMENT
LOW	…link/table/planner/plan/stream/sql/DeltaJoinTest.scala	1261	@Test	COMMENT
LOW	…link/table/planner/plan/stream/sql/DeltaJoinTest.scala	1421	\| on b1 = c1 and b2 = c2 and c1 <> cast(b2 as double)	COMMENT
LOW	…link/table/planner/plan/stream/sql/DeltaJoinTest.scala	1461	}	COMMENT
LOW	…link/table/planner/plan/stream/sql/DeltaJoinTest.scala	1501	def testMultiRHS3(): Unit = {	COMMENT
LOW	…able/planner/plan/utils/NestedProjectionUtilTest.scala	161		COMMENT
LOW	…table/planner/plan/batch/sql/join/LookupJoinTest.scala	121	"SELECT * FROM MyTable AS T JOIN LookupTable T.proc AS D ON T.a = D.id",	COMMENT
LOW	…/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala	841	// select a, b, c from (	COMMENT
LOW	…/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala	941	// FLINK-34702 introduced.	COMMENT
LOW	…/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala	1381	batchGlobalAgg,	COMMENT
LOW	…/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala	3541	// equivalent SQL is	COMMENT
LOW	…table/planner/runtime/stream/sql/CorrelateITCase.scala	461	.getResultsAsStrings("MySink")	COMMENT
LOW	…table/planner/runtime/stream/sql/CorrelateITCase.scala	481	// val sink = new TestingUpsertTableSink(Array(0))	COMMENT
LOW	…table/planner/runtime/stream/sql/CorrelateITCase.scala	501	// val sql =	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	161	@TestTemplate	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	201	// \| TOTAL \| 40 \| 19 \|	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	241		COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	381	// \| TOTAL \| 13 \| 11 \|	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	441	}	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	501	// DT3	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	541	val result = TestValuesTableFactory.getResultsAsStrings("cascadeDeltaJoinSink2")	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	601	// \| DT1 \| 4 + 5 = 9 \| 3 + 4 = 7 \|	COMMENT
LOW	…anner/runtime/stream/sql/CascadedDeltaJoinITCase.scala	701		COMMENT
LOW	…pache/flink/table/planner/runtime/utils/TestData.scala	781	// +----+---------------------+---+-----+-----+-------+------------+---+	COMMENT
LOW	…pache/flink/table/planner/runtime/utils/TestData.scala	1121	// \| -U \| 2020-10-10 00:00:04 \| 2 \| 2.0 \| 2.0 \| 2.22 \| Comment#1 \| a \|	COMMENT
LOW	…table/planner/runtime/batch/sql/Correlate2ITCase.scala	161	// registerFunction("funcDyn2", new UDTFWithDynamicType0)	COMMENT
LOW	…flink/table/planner/runtime/batch/sql/CalcITCase.scala	861	// def testUDFWithGetResultTypeFromLiteral(): Unit = {	COMMENT
LOW	…/table/planner/runtime/batch/sql/CorrelateITCase.scala	261	// def testDynamicTypeWithSQL(): Unit = {	COMMENT
LOW	…/table/planner/runtime/batch/sql/CorrelateITCase.scala	281	// checkResult(	COMMENT
LOW	…lanner/runtime/batch/sql/agg/AggregateITCaseBase.scala	1241	@Test	COMMENT
LOW	…lanner/runtime/batch/sql/agg/AggregateITCaseBase.scala	1261	// .fieldDelimiter(",")	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	141	//	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	161	// val column = arguments(1).asInstanceOf[Int]	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	181	// row.setField(i, s.length)	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	201	// }	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	221	// assert(typeInfos(0).equals(Class.forName("java.lang.String")))	COMMENT
LOW	…nk/table/planner/utils/UserDefinedTableFunctions.scala	241	// row.setField(1, i)	COMMENT
871 more matches not shown…

Cross-File Repetition161 hits · 805 pts

Severity	File	Line	Snippet	Context
HIGH	…/table/planner/plan/stream/table/TableSourceTest.scala	0	\|create table nestedtable ( \| id int, \| deepnested row<nested1 row<name string, `value` int>, \| nested2 row<num int, fla	STRING
HIGH	…nk/table/planner/plan/stream/sql/TableSourceTest.scala	0	\|create table nestedtable ( \| id int, \| deepnested row<nested1 row<name string, `value` int>, \| nested2 row<num int, fla	STRING
HIGH	…ink/table/planner/plan/batch/sql/TableSourceTest.scala	0	\|create table nestedtable ( \| id int, \| deepnested row<nested1 row<name string, `value` int>, \| nested2 row<num int, fla	STRING
HIGH	…link/table/planner/runtime/stream/sql/CalcITCase.scala	0	\|create table nestedtable ( \| id int, \| deepnested row<nested1 row<name string, `value` int>, \| nested2 row<num int, fla	STRING
HIGH	…flink/table/planner/runtime/batch/sql/CalcITCase.scala	0	\|create table nestedtable ( \| id int, \| deepnested row<nested1 row<name string, `value` int>, \| nested2 row<num int, fla	STRING
HIGH	…/planner/plan/stream/sql/PartitionableSourceTest.scala	0	\|create table partitionabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as part2 + 1) \|	STRING
HIGH	…e/planner/plan/batch/sql/PartitionableSourceTest.scala	0	\|create table partitionabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as part2 + 1) \|	STRING
HIGH	…ner/runtime/stream/sql/PartitionableSourceITCase.scala	0	\|create table partitionabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as part2 + 1) \|	STRING
HIGH	…nner/runtime/batch/sql/PartitionableSourceITCase.scala	0	\|create table partitionabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as part2 + 1) \|	STRING
HIGH	…/planner/plan/stream/sql/PartitionableSourceTest.scala	0	\|create table partitionableandfilterabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as	STRING
HIGH	…e/planner/plan/batch/sql/PartitionableSourceTest.scala	0	\|create table partitionableandfilterabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as	STRING
HIGH	…ner/runtime/stream/sql/PartitionableSourceITCase.scala	0	\|create table partitionableandfilterabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as	STRING
HIGH	…nner/runtime/batch/sql/PartitionableSourceITCase.scala	0	\|create table partitionableandfilterabletable ( \| id int, \| name string, \| part1 string, \| part2 int, \| virtualfield as	STRING
HIGH	…/planner/plan/stream/sql/WindowTableFunctionTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…le/planner/plan/stream/sql/WindowDeduplicateTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…ink/table/planner/plan/stream/sql/WindowRankTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…/planner/plan/stream/sql/agg/WindowAggregateTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…tream/ExpandWindowTableFunctionTransposeRuleTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…able/planner/plan/stream/sql/join/WindowJoinTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…ical/ProjectWindowTableFunctionTransposeRuleTest.scala	0	\|create table mytable4 ( \| a int, \| b string not null, \| c bigint, \| rowtime timestamp(3), \| proctime as proctime(), \| w	STRING
HIGH	…able/planner/plan/stream/sql/SourceWatermarkTest.scala	0	\| create table udftable ( \| a int, \| b bigint, \| c timestamp(3), \| d as func(c, a), \| watermark for c as func(func(d, a)	STRING
HIGH	…ble/planner/plan/stream/sql/FilterableSourceTest.scala	0	\| create table udftable ( \| a int, \| b bigint, \| c timestamp(3), \| d as func(c, a), \| watermark for c as func(func(d, a)	STRING
HIGH	…planner/runtime/stream/sql/SourceWatermarkITCase.scala	0	\| create table udftable ( \| a int, \| b bigint, \| c timestamp(3), \| d as func(c, a), \| watermark for c as func(func(d, a)	STRING
HIGH	…che/flink/table/planner/plan/stream/sql/RankTest.scala	0	\|select * \|from ( \| select category, shopid, max_price, \| row_number() over (partition by category order by max_price as	STRING
HIGH	…ner/plan/rules/logical/CalcRankTransposeRuleTest.scala	0	\|select * \|from ( \| select category, shopid, max_price, \| row_number() over (partition by category order by max_price as	STRING
HIGH	…link/table/planner/runtime/stream/sql/RankITCase.scala	0	\|select * \|from ( \| select category, shopid, max_price, \| row_number() over (partition by category order by max_price as	STRING
HIGH	…le/planner/plan/stream/sql/WindowDeduplicateTest.scala	0	\|select \| a, \| window_start, \| window_end, \| count(*), \| max(d) filter (where b > 1000), \| count(distinct window_time) a	STRING
HIGH	…ink/table/planner/plan/stream/sql/WindowRankTest.scala	0	\|select \| a, \| window_start, \| window_end, \| count(*), \| max(d) filter (where b > 1000), \| count(distinct window_time) a	STRING
HIGH	…/planner/plan/stream/sql/agg/WindowAggregateTest.scala	0	\|select \| a, \| window_start, \| window_end, \| count(*), \| max(d) filter (where b > 1000), \| count(distinct window_time) a	STRING
HIGH	…tream/ExpandWindowTableFunctionTransposeRuleTest.scala	0	\|select \| a, \| window_start, \| window_end, \| count(*), \| max(d) filter (where b > 1000), \| count(distinct window_time) a	STRING
HIGH	…nk/table/planner/plan/stream/sql/TableSourceTest.scala	0	\|select id, \| deepnested.nested1.name as nestedname, \| nested.`value` as nestedvalue, \| deepnested.nested2.flag as neste	STRING
HIGH	…ink/table/planner/plan/batch/sql/TableSourceTest.scala	0	\|select id, \| deepnested.nested1.name as nestedname, \| nested.`value` as nestedvalue, \| deepnested.nested2.flag as neste	STRING
HIGH	…link/table/planner/runtime/stream/sql/CalcITCase.scala	0	\|select id, \| deepnested.nested1.name as nestedname, \| nested.`value` as nestedvalue, \| deepnested.nested2.flag as neste	STRING
HIGH	…flink/table/planner/runtime/batch/sql/CalcITCase.scala	0	\|select id, \| deepnested.nested1.name as nestedname, \| nested.`value` as nestedvalue, \| deepnested.nested2.flag as neste	STRING
HIGH	…k/table/planner/plan/stream/sql/SubplanReuseTest.scala	0	\|with t as (select x.a as a, x.b as b, y.d as d, y.e as e from x, y where x.a = y.d) \|select t1., t2. from t t1, t t2	STRING
HIGH	…table/planner/plan/batch/sql/DeadlockBreakupTest.scala	0	\|with t as (select x.a as a, x.b as b, y.d as d, y.e as e from x, y where x.a = y.d) \|select t1., t2. from t t1, t t2	STRING
HIGH	…nk/table/planner/plan/batch/sql/SubplanReuseTest.scala	0	\|with t as (select x.a as a, x.b as b, y.d as d, y.e as e from x, y where x.a = y.d) \|select t1., t2. from t t1, t t2	STRING
HIGH	…k/table/planner/plan/stream/sql/SubplanReuseTest.scala	0	\|with r as (select c, sum(a) a, sum(b) b from x group by c) \| select * from r r1, r r2 where r1.a = r2.b and r2.a > 1	STRING
HIGH	…nk/table/planner/plan/batch/sql/SubplanReuseTest.scala	0	\|with r as (select c, sum(a) a, sum(b) b from x group by c) \| select * from r r1, r r2 where r1.a = r2.b and r2.a > 1	STRING
HIGH	…table/planner/plan/batch/sql/DeadlockBreakupTest.scala	0	\|with r as (select c, sum(a) a, sum(b) b from x group by c) \| select * from r r1, r r2 where r1.a = r2.b and r2.a > 1	STRING
HIGH	…ble/planner/plan/stream/sql/agg/GroupingSetsTest.scala	0	\|select b, c, avg(a) as a, group_id() as g from mytable \|group by grouping sets (b, c)	STRING
HIGH	…able/planner/plan/batch/sql/agg/GroupingSetsTest.scala	0	\|select b, c, avg(a) as a, group_id() as g from mytable \|group by grouping sets (b, c)	STRING
HIGH	…plan/rules/logical/DecomposeGroupingSetsRuleTest.scala	0	\|select b, c, avg(a) as a, group_id() as g from mytable \|group by grouping sets (b, c)	STRING
HIGH	…ble/planner/plan/stream/sql/agg/GroupingSetsTest.scala	0	\|select b, c, \| avg(a) as a, \| group_id() as g, \| grouping(b) as gb, \| grouping(c) as gc, \| grouping_id(b) as gib, \| gro	STRING
HIGH	…able/planner/plan/batch/sql/agg/GroupingSetsTest.scala	0	\|select b, c, \| avg(a) as a, \| group_id() as g, \| grouping(b) as gb, \| grouping(c) as gc, \| grouping_id(b) as gib, \| gro	STRING
HIGH	…plan/rules/logical/DecomposeGroupingSetsRuleTest.scala	0	\|select b, c, \| avg(a) as a, \| group_id() as g, \| grouping(b) as gb, \| grouping(c) as gc, \| grouping_id(b) as gib, \| gro	STRING
HIGH	…/planner/plan/stream/sql/agg/WindowAggregateTest.scala	0	\|select \| window_start, \| window_end, \| count(*), \| sum(d), \| max(d) filter (where b > 1000), \| count(distinct c) as uv	STRING
HIGH	…ical/ProjectWindowTableFunctionTransposeRuleTest.scala	0	\|select \| window_start, \| window_end, \| count(*), \| sum(d), \| max(d) filter (where b > 1000), \| count(distinct c) as uv	STRING
HIGH	…tream/ExpandWindowTableFunctionTransposeRuleTest.scala	0	\|select \| window_start, \| window_end, \| count(*), \| sum(d), \| max(d) filter (where b > 1000), \| count(distinct c) as uv	STRING
HIGH	…e/flink/table/planner/plan/common/UnnestTestBase.scala	0	\|with t1 as (select a, collect(c) as words from t group by a) \|select a, word, pos \|from t1 cross join unnest(words) wit	STRING
HIGH	…nk/table/planner/runtime/stream/sql/UnnestITCase.scala	0	\|with t1 as (select a, collect(c) as words from t group by a) \|select a, word, pos \|from t1 cross join unnest(words) wit	STRING
HIGH	…ink/table/planner/runtime/batch/sql/UnnestITCase.scala	0	\|with t1 as (select a, collect(c) as words from t group by a) \|select a, word, pos \|from t1 cross join unnest(words) wit	STRING
HIGH	…k/table/planner/plan/batch/sql/RemoveShuffleTest.scala	0	\|with r as (select * from x, y where a = d and c like 'he%') \|select sum(b) from r group by d	STRING
HIGH	…table/planner/plan/batch/sql/RemoveCollationTest.scala	0	\|with r as (select * from x, y where a = d and c like 'he%') \|select sum(b) from r group by d	STRING
HIGH	…ysical/batch/RemoveRedundantLocalHashAggRuleTest.scala	0	\|with r as (select * from x, y where a = d and c like 'he%') \|select sum(b) from r group by d	STRING
HIGH	…ysical/batch/RemoveRedundantLocalSortAggRuleTest.scala	0	\|with r as (select * from x, y where a = d and c like 'he%') \|select sum(b) from r group by d	STRING
HIGH	…k/table/planner/plan/batch/sql/RemoveShuffleTest.scala	0	\|select a, sum(b) from ( \| select * from ( \| select a, b, c, rank() over (partition by a, c order by b) rk from x) \| whe	STRING
HIGH	…table/planner/plan/batch/sql/RemoveCollationTest.scala	0	\|select a, sum(b) from ( \| select * from ( \| select a, b, c, rank() over (partition by a, c order by b) rk from x) \| whe	STRING
HIGH	…ysical/batch/RemoveRedundantLocalHashAggRuleTest.scala	0	\|select a, sum(b) from ( \| select * from ( \| select a, b, c, rank() over (partition by a, c order by b) rk from x) \| whe	STRING
HIGH	…ache/flink/table/planner/plan/batch/sql/RankTest.scala	0	\|select * from ( \| select a, b, rank() over (partition by b order by a) rk from mytable) t \|where rk <= 2 and a > 10	STRING
101 more matches not shown…

Cross-Language Confusion144 hits · 632 pts

Severity	File	Line	Snippet	Context
HIGH	…hon/pyflink/datastream/stream_execution_environment.py	377	return j_path.toString()	CODE
HIGH	flink-python/pyflink/datastream/checkpoint_storage.py	200	return j_path.toString()	CODE
HIGH	flink-python/pyflink/datastream/checkpoint_storage.py	221	return j_path.toString()	CODE
HIGH	flink-python/pyflink/datastream/checkpoint_storage.py	224	return self._j_checkpoint_storage.toString()	CODE
HIGH	flink-python/pyflink/datastream/checkpoint_storage.py	337	return j_path.toString()	CODE
HIGH	flink-python/pyflink/datastream/checkpoint_storage.py	354	return self._j_checkpoint_storage.toString()	CODE
HIGH	flink-python/pyflink/datastream/state_backend.py	161	return self._j_state_backend.toString()	CODE
HIGH	flink-python/pyflink/datastream/state_backend.py	244	Gets the configured local DB storage paths, or null, if none were configured.	STRING
HIGH	flink-python/pyflink/datastream/state_backend.py	280	:param options: The options to set (must not be null), see :class:`PredefinedOptions`.	STRING
HIGH	flink-python/pyflink/datastream/state_backend.py	358	return self._j_state_backend.toString()	CODE
HIGH	flink-python/pyflink/datastream/state.py	102	the updated value. When a partitioned state is updated with null, the state for the current	STRING
HIGH	flink-python/pyflink/datastream/slot_sharing_group.py	105	return self._j_memory_size.toString()	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	80	self.assertEqual(stream_pattern.toString(), 'stream-*')	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	116	self.assertEqual(stream_pattern.toString(), 'stream-*')	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	364	offset_reset_strategy.equals(reset_strategy._to_j_offset_reset_strategy())	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	412	offset_reset_strategy.equals(reset_strategy._to_j_offset_reset_strategy())	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	497	self.assertTrue(expected_starting_offset._j_initializer.equals(j_starting_initializer))	CODE
HIGH	…link/datastream/connectors/tests/test_dynamic_kafka.py	502	self.assertTrue(expected_stopping_offset._j_initializer.equals(j_stopping_initializer))	CODE
HIGH	…thon/pyflink/datastream/connectors/tests/test_kafka.py	75	self.assertTrue(j_start_up_mode.equals(get_gateway().jvm	CODE
HIGH	…thon/pyflink/datastream/connectors/tests/test_kafka.py	155	self.assertEqual(topic_pattern.toString(), 'test_topic*')	CODE
HIGH⚡	…thon/pyflink/datastream/connectors/tests/test_kafka.py	455	self.assertEqual(guarantee.toString(), 'none')	STRING
HIGH⚡	…thon/pyflink/datastream/connectors/tests/test_kafka.py	463	self.assertEqual(guarantee.toString(), 'at-least-once')	STRING
HIGH⚡	…thon/pyflink/datastream/connectors/tests/test_kafka.py	471	self.assertEqual(guarantee.toString(), 'exactly-once')	STRING
HIGH	…thon/pyflink/datastream/connectors/tests/test_kafka.py	362	offset_reset_strategy.equals(reset_strategy._to_j_offset_reset_strategy())	STRING
HIGH	…thon/pyflink/datastream/connectors/tests/test_kafka.py	410	offset_reset_strategy.equals(reset_strategy._to_j_offset_reset_strategy())	STRING
HIGH⚡	flink-python/pyflink/datastream/formats/orc.py	93	type_description.toString(),	CODE
HIGH	flink-python/pyflink/datastream/formats/csv.py	66	return self._j_schema.toString()	CODE
HIGH⚡	…k-python/pyflink/datastream/formats/tests/test_json.py	32	expected_jsons = ["{\"svt\":\"2020-02-24T12:58:09.209+0800\",\"ops\":null,\"ids\":null}",	CODE
HIGH⚡	…k-python/pyflink/datastream/formats/tests/test_json.py	36	"{\"svt\":\"2020-02-24T12:58:09.209+0800\",\"ops\":null,\"ids\":null}"]	CODE
HIGH⚡	…nk-python/pyflink/datastream/formats/tests/test_csv.py	231	self.assertTrue(j_row.equals(j_deserialized_row))	CODE
HIGH	…nk-python/pyflink/datastream/tests/test_data_stream.py	1087	expected = ["+I[1, [1.1, 1.2, 1.3], [null, hi, flink], 2021-01-09, 12:00:00,"	CODE
HIGH	…nk-python/pyflink/datastream/tests/test_data_stream.py	1404	expected = ['+I[[+I[1], +I[2]], [+I[3], +I[4]], {a=+I[5], b=+I[6]}, [(7), (8)], null]',	CODE
HIGH	…/datastream/tests/test_stream_execution_environment.py	226	'+I[1, null, 1, true, 32767, -2147483648, 1.23, 1.98932, [102, 108, 105, 110, 107], '	STRING
HIGH	…/datastream/tests/test_stream_execution_environment.py	229	'+I[2, null, 2, true, -21658, 557549056, 9.87, 2.98936, [102, 108, 105, 110, 107], '	STRING
HIGH	flink-python/pyflink/dataframe/dataframe.py	937	null, ``ignore_empty_and_null`` controls whether to drop the row or retain one row with	STRING
HIGH	flink-python/pyflink/dataframe/udf.py	1421	if index.equals(input_index):	CODE
HIGH	flink-python/pyflink/dataframe/udf.py	1432	if output.index.equals(index):	CODE
HIGH⚡	…ink-python/pyflink/dataframe/tests/test_over_window.py	154	self.assertIn("null, null", str(default_frame))	CODE
HIGH⚡	…ink-python/pyflink/dataframe/tests/test_over_window.py	162	self.assertIn("over(lag(amount, 1), rowtime, null, null)", str(lag))	CODE
HIGH⚡	…ink-python/pyflink/dataframe/tests/test_over_window.py	163	self.assertIn("over(lead(amount, 1), rowtime, null, null)", str(lead))	CODE
HIGH	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	788	source.write('{"id":1,"name":"a"}\nnot-json\n{"id":2,"name":null}\n')	CODE
HIGH	flink-python/pyflink/fn_execution/coder_impl_slow.py	743	A coder for primitive array value (the element of array won't be null).	STRING
HIGH	flink-python/pyflink/util/exceptions.py	167	s = e.java_exception.toString()	CODE
HIGH	flink-python/pyflink/util/exceptions.py	212	s = e.java_exception.toString()	CODE
HIGH	flink-python/pyflink/util/java_utils.py	146	existing_urls = set([url.toString() for url in context_classloader.getURLs()])	CODE
HIGH	flink-python/pyflink/util/java_utils.py	147	if all([url.toString() in existing_urls for url in jar_urls]):	CODE
HIGH	flink-python/pyflink/common/time.py	55	return isinstance(other, Duration) and self._j_duration.equals(other._j_duration)	CODE
HIGH	flink-python/pyflink/common/configuration.py	268	return self._j_configuration.equals(other._j_configuration)	CODE
HIGH	flink-python/pyflink/common/configuration.py	273	return self._j_configuration.toString()	CODE
HIGH	flink-python/pyflink/common/completable_future.py	95	return self._j_completable_future.toString()	CODE
HIGH⚡	flink-python/pyflink/common/typeinfo.py	1101	if j_type_info.equals(JLocalTimeTypeInfo.LOCAL_DATE):	CODE
HIGH⚡	flink-python/pyflink/common/typeinfo.py	1103	elif j_type_info.equals(JLocalTimeTypeInfo.LOCAL_TIME):	CODE
HIGH⚡	flink-python/pyflink/common/typeinfo.py	1105	elif j_type_info.equals(JLocalTimeTypeInfo.LOCAL_DATE_TIME):	CODE
HIGH⚡	flink-python/pyflink/common/typeinfo.py	1108	raise TypeError("Unsupported LocalTimeTypeInfo: %s." % j_type_info.toString())	CODE
HIGH	flink-python/pyflink/common/typeinfo.py	1123	return java_object.equals(java_type)	CODE
HIGH	flink-python/pyflink/common/job_execution_result.py	92	return self._j_job_execution_result.toString()	CODE
HIGH	flink-python/pyflink/common/job_id.py	37	return self._j_job_id.toString()	CODE
HIGH	…hon/pyflink/common/tests/test_serialization_schemas.py	143	self.assertTrue(schema1._j_serialization_schema.equals(schema2._j_serialization_schema))	CODE
HIGH	…hon/pyflink/common/tests/test_serialization_schemas.py	144	self.assertFalse(schema1._j_serialization_schema.equals(schema3._j_serialization_schema))	CODE
HIGH⚡	flink-python/pyflink/table/catalog.py	2015	return self._j_resolved_schema.toString()	CODE
84 more matches not shown…

Decorative Section Separators66 hits · 235 pts

Severity	File	Line	Snippet	Context
MEDIUM⚡	tools/ci/test_controller.sh	36	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	38	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	76	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	78	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	99	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	101	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	115	# =============================================================================	COMMENT
MEDIUM⚡	tools/ci/test_controller.sh	117	# =============================================================================	COMMENT
MEDIUM	tools/ci/watchdog.sh	37	# =============================================	COMMENT
MEDIUM	tools/ci/watchdog.sh	39	# =============================================	COMMENT
MEDIUM	tools/ci/watchdog.sh	95	# =============================================	COMMENT
MEDIUM	tools/ci/watchdog.sh	97	# =============================================	COMMENT
MEDIUM	docs/content.zh/docs/sql/reference/dml/insert.md	148	#----------------------------------------------------------------------------	COMMENT
MEDIUM	docs/content/docs/sql/reference/dml/insert.md	146	#----------------------------------------------------------------------------	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	31	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	33	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	109	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	111	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	134	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	136	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	168	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	170	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	198	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	200	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	241	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	243	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	263	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	265	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	277	#==============================================================================	COMMENT
MEDIUM	flink-dist/src/main/resources/config.yaml	279	#==============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	28	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	30	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	38	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	131	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	141	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	392	# ======================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	394	# ======================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	396	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	406	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	419	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	424	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	472	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	478	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	486	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	489	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	495	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	499	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	512	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	523	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	537	# =============================================================================	COMMENT
MEDIUM⚡	.github/workflows/community-review.sh	547	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	50	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	187	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	193	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	232	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	250	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	313	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	330	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	450	# =============================================================================	COMMENT
MEDIUM	.github/workflows/community-review.sh	454	# =============================================================================	COMMENT
6 more matches not shown…

Unused Imports236 hits · 184 pts

Severity	File	Line	Context
LOW	flink-python/setup.py	18	CODE
LOW	flink-python/docs/conf.py	19	CODE
LOW	flink-python/pyflink/shell.py	22	CODE
LOW	flink-python/pyflink/shell.py	23	CODE
LOW	flink-python/pyflink/shell.py	24	CODE
LOW	flink-python/pyflink/shell.py	25	CODE
LOW	flink-python/pyflink/shell.py	26	CODE
LOW	flink-python/pyflink/shell.py	27	CODE
LOW	flink-python/pyflink/shell.py	28	CODE
LOW	flink-python/pyflink/__init__.py	28	CODE
LOW	flink-python/pyflink/gen_protos.py	19	CODE
LOW	flink-python/pyflink/gen_protos.py	20	CODE
LOW	flink-python/pyflink/gen_protos.py	45	CODE
LOW	flink-python/pyflink/datastream/__init__.py	261	CODE
LOW	flink-python/pyflink/datastream/__init__.py	262	CODE
LOW	flink-python/pyflink/datastream/__init__.py	263	CODE
LOW	flink-python/pyflink/datastream/__init__.py	264	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	265	CODE
LOW	flink-python/pyflink/datastream/__init__.py	267	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	268	CODE
LOW	flink-python/pyflink/datastream/__init__.py	276	CODE
LOW	flink-python/pyflink/datastream/__init__.py	276	CODE
LOW	flink-python/pyflink/datastream/__init__.py	277	CODE
LOW	flink-python/pyflink/datastream/__init__.py	277	CODE
LOW	flink-python/pyflink/datastream/__init__.py	277	CODE
LOW	flink-python/pyflink/datastream/__init__.py	277	CODE
LOW	flink-python/pyflink/datastream/__init__.py	277	CODE
LOW	flink-python/pyflink/datastream/__init__.py	280	CODE
LOW	flink-python/pyflink/datastream/__init__.py	280	CODE
LOW	flink-python/pyflink/datastream/__init__.py	280	CODE
LOW	flink-python/pyflink/datastream/__init__.py	280	CODE
LOW	flink-python/pyflink/datastream/__init__.py	283	CODE
LOW	flink-python/pyflink/datastream/__init__.py	284	CODE
176 more matches not shown…

Deep Nesting168 hits · 137 pts

Severity	File	Line	Context
LOW	flink-python/setup.py	67	CODE
LOW	flink-python/pyflink/find_flink_home.py	41	CODE
LOW	flink-python/pyflink/serializers.py	133	CODE
LOW	flink-python/pyflink/gen_protos.py	43	CODE
LOW	flink-python/pyflink/datastream/data_stream.py	2822	CODE
LOW	flink-python/pyflink/datastream/data_stream.py	1385	CODE
LOW	flink-python/pyflink/datastream/data_stream.py	1401	CODE
LOW	flink-python/pyflink/datastream/data_stream.py	1403	CODE
LOW	flink-python/pyflink/datastream/utils.py	65	CODE
LOW	flink-python/pyflink/datastream/state.py	979	CODE
LOW	flink-python/pyflink/datastream/state.py	1010	CODE
LOW	…yflink/datastream/connectors/tests/test_file_system.py	32	CODE
LOW	…nk-python/pyflink/datastream/tests/test_data_stream.py	912	CODE
LOW	…nk-python/pyflink/datastream/tests/test_data_stream.py	933	CODE
LOW	flink-python/pyflink/dataframe/iteration.py	188	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3422	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3469	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3636	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3914	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3979	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	346	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	504	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	556	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	642	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	2271	CODE
LOW	flink-python/pyflink/dataframe/io.py	347	CODE
LOW	flink-python/pyflink/dataframe/llm.py	687	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1329	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1455	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1493	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1460	CODE
LOW	…ink-python/pyflink/dataframe/tests/test_over_window.py	199	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	121	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	136	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	239	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	265	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	283	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	320	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	345	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	678	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	747	CODE
LOW	…k-python/pyflink/dataframe/tests/test_filesystem_io.py	765	CODE
LOW	flink-python/pyflink/dataframe/tests/test_catalog.py	146	CODE
LOW	flink-python/pyflink/dataframe/tests/test_kafka_io.py	121	CODE
LOW	…k-python/pyflink/dataframe/tests/test_statement_set.py	102	CODE
LOW	…k-python/pyflink/dataframe/tests/test_statement_set.py	111	CODE
LOW	…k-python/pyflink/dataframe/tests/test_statement_set.py	187	CODE
LOW	…-python/pyflink/dataframe/tests/test_model_provider.py	183	CODE
LOW	…-python/pyflink/dataframe/tests/test_model_provider.py	284	CODE
LOW	…-python/pyflink/dataframe/tests/test_model_provider.py	447	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udtf.py	368	CODE
LOW	flink-python/pyflink/dataframe/tests/test_convert.py	89	CODE
LOW	flink-python/pyflink/dataframe/tests/test_convert.py	266	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	973	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1417	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1486	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1631	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1677	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1794	CODE
LOW	flink-python/pyflink/dataframe/tests/test_udf.py	1815	CODE
108 more matches not shown…

Structural Annotation Overuse67 hits · 109 pts

Severity	File	Line	Snippet	Context
LOW⚡	tools/ci/test_controller.sh	37	# Step 0: Check & print environment information & configure env	COMMENT
LOW⚡	tools/ci/test_controller.sh	77	# Step 1: Rebuild jars and install Flink to local maven repository	COMMENT
LOW⚡	tools/ci/test_controller.sh	100	# Step 2: Run tests	COMMENT
LOW⚡	tools/ci/test_controller.sh	116	# Step 3: Put extra logs into $DEBUG_FILES_OUTPUT_DIR	COMMENT
LOW	…zh/docs/getting-started/flink-operations-playground.md	290	#### Step 1: 观察输出	COMMENT
LOW	…zh/docs/getting-started/flink-operations-playground.md	305	#### Step 2: 模拟失败	COMMENT
LOW	…zh/docs/getting-started/flink-operations-playground.md	332	#### Step 3: 失败恢复	COMMENT
LOW	…zh/docs/getting-started/flink-operations-playground.md	378	#### Step 1: 停止 Job	COMMENT
LOW	…nt/docs/getting-started/flink-operations-playground.md	276	#### Step 1: Observing the Output	COMMENT
LOW	…nt/docs/getting-started/flink-operations-playground.md	291	#### Step 2: Introducing a Fault	COMMENT
LOW	…nt/docs/getting-started/flink-operations-playground.md	318	#### Step 3: Recovery	COMMENT
LOW	…nt/docs/getting-started/flink-operations-playground.md	362	#### Step 1: Stopping the Job	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	43	### Step 1: Get the docker-compose.yml file	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	83	### Step 2: Start the Cluster	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	89	### Step 3: Verify the Cluster is Running	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	115	### Step 1: Download Flink	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	132	### Step 2: Start the Cluster	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	140	### Step 3: Verify the Cluster is Running	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	166	### Step 1: Verify Prerequisites	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	178	### Step 2: Install PyFlink	COMMENT
LOW	docs/content/docs/getting-started/local_installation.md	195	### Step 3: Verify Installation	COMMENT
LOW	flink-end-to-end-tests/test-scripts/common.sh	980	# NOTE: This function requires at least Bash version >= 4 due to the usage of $BASHPID. Mac OS in 2020 still ships 3.x	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	127	// Step 1: Run the job with initial parallelism and take a checkpoint	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	138	// Step 2: Restore the job with a different parallelism	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	150	// Step 3: Restore from Step 2's checkpoint with random parallelism. This validates	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	139	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	142	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	150	// Step 5: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	157	// Step 5: Clean up	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	192	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	199	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	207	// Step 4: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	300	// Step 2: Generate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	309	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	345	// Step 5: Generate new test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	352	// Step 6: restart the Flink job with the savepoint	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	508	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	515	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	523	// Step 4: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	529	// Step 5: Clean up	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	579	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	588	// Step 4: Validate records before killing TaskManagers	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	597	// Step 5: Trigger TaskManager failover	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	604	// Step 6: Write test data again to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	614	// Step 7: Validate test result	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	622	// Step 8: Clean up	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	127	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	180	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	289	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	324	// Step 4: Check the result and stop Flink job with a savepoint	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	496	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	554	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	566	// Step 2: Write test data to external system	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	232	// Step 1: Preparation	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	241	// Step 2: Generate test data	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	244	// Step 3: Build and execute Flink job	COMMENT
LOW	…/connector/testframe/testsuites/SinkTestSuiteBase.java	269	// Step 4: Wait for the expected result and stop Flink job with a savepoint	COMMENT
LOW	…/connector/testframe/testsuites/SinkTestSuiteBase.java	300	// Step 4: restart the Flink job with the savepoint	COMMENT
LOW	…nt/filemerging/FileMergingSnapshotManagerTestBase.java	527	// Step 2: restore FileMergingSnapshotManagerBase from the TaskStateSnapshot.	COMMENT
LOW	…/runtime/asyncprocessing/StateExecutionController.java	96	// Step 1: build state future & assign context.	COMMENT
7 more matches not shown…

Modern Structural Boilerplate105 hits · 106 pts

Severity	File	Line	Snippet	Context
LOW	flink-python/pyflink/__init__.py	56	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/functions.py	32	__all__ = [	CODE
LOW	…hon/pyflink/datastream/stream_execution_environment.py	46	__all__ = ['StreamExecutionEnvironment']	CODE
LOW	flink-python/pyflink/datastream/checkpoint_config.py	24	__all__ = ['CheckpointConfig']	CODE
LOW	flink-python/pyflink/datastream/window.py	33	__all__ = ['Window',	CODE
LOW	flink-python/pyflink/datastream/execution_mode.py	23	__all__ = ['RuntimeExecutionMode']	CODE
LOW	flink-python/pyflink/datastream/__init__.py	291	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/checkpointing_mode.py	22	__all__ = ['CheckpointingMode']	CODE
LOW	flink-python/pyflink/datastream/data_stream.py	64	__all__ = ['CloseableIterator', 'DataStream', 'KeyedStream', 'ConnectedStreams', 'WindowedStream',	CODE
LOW	…yflink/datastream/externalized_checkpoint_retention.py	20	__all__ = ['ExternalizedCheckpointRetention']	CODE
LOW	flink-python/pyflink/datastream/checkpoint_storage.py	26	__all__ = [	CODE
LOW	…nk-python/pyflink/datastream/async_retry_strategies.py	22	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/state_backend.py	28	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/state.py	25	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/slot_sharing_group.py	19	__all__ = ['MemorySize', 'SlotSharingGroup']	CODE
LOW	flink-python/pyflink/datastream/connectors/cassandra.py	24	__all__ = [	CODE
LOW	…-python/pyflink/datastream/connectors/elasticsearch.py	27	__all__ = ['FlushBackoffType',	CODE
LOW	…-python/pyflink/datastream/connectors/dynamic_kafka.py	27	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/kinesis.py	26	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/__init__.py	21	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/jdbc.py	24	__all__ = [	CODE
LOW	…-python/pyflink/datastream/connectors/hybrid_source.py	24	__all__ = [	CODE
LOW	…ink-python/pyflink/datastream/connectors/number_seq.py	21	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/rabbitmq.py	23	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/kafka.py	34	__all__ = [	CODE
LOW	…nk-python/pyflink/datastream/connectors/file_system.py	36	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/connectors/pulsar.py	29	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/formats/orc.py	29	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/formats/avro.py	29	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/formats/parquet.py	30	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/formats/csv.py	29	__all__ = [	CODE
LOW	flink-python/pyflink/datastream/formats/json.py	22	__all__ = [	CODE
LOW	flink-python/pyflink/metrics/__init__.py	21	__all__ = ["MetricGroup", "Metric", "Counter", "Meter", "Distribution"]	CODE
LOW	flink-python/pyflink/dataframe/catalog.py	27	__all__ = [	CODE
LOW	flink-python/pyflink/dataframe/iteration.py	39	__all__ = ["CloseableIterator"]	CODE
LOW	flink-python/pyflink/dataframe/over_window.py	28	__all__ = ["FrameBoundary", "preceding", "following"]	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	103	__all__ = ["DataFrame", "GroupedDataFrame", "col", "lit"]	CODE
LOW	flink-python/pyflink/dataframe/convert.py	57	__all__ = [	CODE
LOW	flink-python/pyflink/dataframe/io.py	30	__all__ = ["read_catalog_table", "read_generic", "read_json", "read_kafka", "read_parquet"]	CODE
LOW	flink-python/pyflink/dataframe/udaf.py	48	__all__ = ["udaf"]	CODE
LOW	flink-python/pyflink/dataframe/__init__.py	91	__all__ = [	CODE
LOW	flink-python/pyflink/dataframe/llm.py	34	__all__ = [	CODE
LOW⚡	flink-python/pyflink/dataframe/llm.py	549	def set_model_provider(provider: ModelProvider, /) -> None:	CODE
LOW⚡	flink-python/pyflink/dataframe/llm.py	554	def set_model_provider(*, provider: ModelProvider) -> None:	CODE
LOW⚡	flink-python/pyflink/dataframe/llm.py	559	def set_model_provider(name: str, provider: ModelProvider) -> None:	CODE
LOW	flink-python/pyflink/dataframe/llm.py	628	def set_default_model_provider(name: str) -> None:	CODE
LOW	flink-python/pyflink/dataframe/udtf.py	63	__all__ = ["udtf"]	CODE
LOW	flink-python/pyflink/dataframe/context.py	28	__all__ = [	CODE
LOW	flink-python/pyflink/dataframe/context.py	65	def set_table_environment(t_env: Optional[TableEnvironment]) -> None:	CODE
LOW	flink-python/pyflink/dataframe/dataframe_config.py	24	__all__ = [	CODE
LOW	flink-python/pyflink/dataframe/sql.py	38	__all__ = ["sql"]	CODE
LOW	flink-python/pyflink/dataframe/datatype.py	25	__all__ = ["DataType"]	CODE
LOW	flink-python/pyflink/dataframe/udf.py	60	__all__ = ["udf"]	CODE
LOW	flink-python/pyflink/fn_execution/state_impl.py	109	def set_current_namespace(self, namespace: N) -> None:	CODE
LOW	flink-python/pyflink/fn_execution/coders.py	42	__all__ = ['FlattenRowCoder', 'RowCoder', 'BigIntCoder', 'TinyIntCoder', 'BooleanCoder',	CODE
LOW	flink-python/pyflink/fn_execution/internal_state.py	48	def set_current_namespace(self, namespace: N) -> None:	CODE
LOW	…pyflink/fn_execution/datastream/embedded/state_impl.py	52	def set_current_namespace(self, namespace) -> None:	CODE
LOW	flink-python/pyflink/fn_execution/formats/__init__.py	20	__all__ = [	CODE
LOW	…/pyflink/fn_execution/beam/beam_worker_pool_service.py	211	def _set_log_level_overrides(config) -> None:	CODE
LOW	flink-python/pyflink/util/api_stability_decorators.py	27	__all__ = ["Deprecated", "Experimental", "Internal", "PublicEvolving", "Public"]	CODE
45 more matches not shown…

Verbosity Indicators51 hits · 85 pts

Severity	File	Line	Snippet	Context
LOW⚡	tools/ci/test_controller.sh	37	# Step 0: Check & print environment information & configure env	COMMENT
LOW⚡	tools/ci/test_controller.sh	77	# Step 1: Rebuild jars and install Flink to local maven repository	COMMENT
LOW⚡	tools/ci/test_controller.sh	100	# Step 2: Run tests	COMMENT
LOW⚡	tools/ci/test_controller.sh	116	# Step 3: Put extra logs into $DEBUG_FILES_OUTPUT_DIR	COMMENT
LOW	…nnector/file/table/stream/AbstractStreamingWriter.java	157	// - If there are multiple entries, Flink downscaled, and we need to check if all are	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	127	// Step 1: Run the job with initial parallelism and take a checkpoint	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	138	// Step 2: Restore the job with a different parallelism	COMMENT
LOW	…nalignedCheckpointRescaleWithMixedExchangesITCase.java	150	// Step 3: Restore from Step 2's checkpoint with random parallelism. This validates	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	139	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	142	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	150	// Step 5: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	157	// Step 5: Clean up	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	192	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	199	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	207	// Step 4: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	300	// Step 2: Generate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	309	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	345	// Step 5: Generate new test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	352	// Step 6: restart the Flink job with the savepoint	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	508	// Step 2: Write test data to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	515	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	523	// Step 4: Validate test data	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	529	// Step 5: Clean up	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	579	// Step 3: Build and execute Flink job	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	588	// Step 4: Validate records before killing TaskManagers	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	597	// Step 5: Trigger TaskManager failover	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	604	// Step 6: Write test data again to external system	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	614	// Step 7: Validate test result	COMMENT
LOW⚡	…onnector/testframe/testsuites/SourceTestSuiteBase.java	622	// Step 8: Clean up	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	127	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	180	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	289	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	324	// Step 4: Check the result and stop Flink job with a savepoint	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	496	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	554	// Step 1: Preparation	COMMENT
LOW	…onnector/testframe/testsuites/SourceTestSuiteBase.java	566	// Step 2: Write test data to external system	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	232	// Step 1: Preparation	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	241	// Step 2: Generate test data	COMMENT
LOW⚡	…/connector/testframe/testsuites/SinkTestSuiteBase.java	244	// Step 3: Build and execute Flink job	COMMENT
LOW	…/connector/testframe/testsuites/SinkTestSuiteBase.java	269	// Step 4: Wait for the expected result and stop Flink job with a savepoint	COMMENT
LOW	…/connector/testframe/testsuites/SinkTestSuiteBase.java	300	// Step 4: restart the Flink job with the savepoint	COMMENT
LOW	…/apache/flink/state/forst/fs/ForStFlinkFileSystem.java	149	// the file system, so we need to check if it works.	COMMENT
LOW	…nt/filemerging/FileMergingSnapshotManagerTestBase.java	527	// Step 2: restore FileMergingSnapshotManagerBase from the TaskStateSnapshot.	COMMENT
LOW	…/runtime/asyncprocessing/StateExecutionController.java	96	// Step 1: build state future & assign context.	COMMENT
LOW⚡	…/runtime/asyncprocessing/AsyncExecutionController.java	306	// Step 1: try to seize the capacity, if the current in-flight records exceeds the limit,	COMMENT
LOW⚡	…/runtime/asyncprocessing/AsyncExecutionController.java	310	// Step 3: try to occupy the key and place it into right buffer.	COMMENT
LOW⚡	…/runtime/asyncprocessing/AsyncExecutionController.java	316	// Step 4: trigger the (active) buffer if needed.	COMMENT
LOW⚡	…va/org/apache/flink/runtime/dispatcher/Dispatcher.java	1026	// Step 1: cleanup remaining suspended jobs for the application	COMMENT
LOW⚡	…va/org/apache/flink/runtime/dispatcher/Dispatcher.java	1029	// Step 2: finalize the archived application after all jobs are marked as terminated	COMMENT
LOW⚡	…va/org/apache/flink/runtime/dispatcher/Dispatcher.java	1060	// Step 3: create a dirty result for the application	COMMENT
LOW⚡	…va/org/apache/flink/runtime/dispatcher/Dispatcher.java	1065	// Step 4: perform application cleanup and mark result clean after all cleanup	COMMENT

Empty Error Handlers16 hits · 80 pts

Severity	File	Line	Snippet	Context
HIGH	flink-python/setup.py	83	except IndexError:	CODE
HIGH	flink-python/setup.py	96	except IndexError:	CODE
HIGH	flink-python/pyflink/find_flink_home.py	81	except Exception:	CODE
HIGH	flink-python/pyflink/find_flink_home.py	68	except Exception:	CODE
HIGH	flink-python/pyflink/dataframe/udtf.py	509	except Exception:	CODE
HIGH	flink-python/pyflink/dataframe/udf.py	1106	except ImportError:	CODE
HIGH	flink-python/pyflink/dataframe/udf.py	1112	except ImportError:	CODE
HIGH	flink-python/pyflink/dataframe/udf.py	1200	except Exception:	CODE
HIGH	…ink-python/pyflink/dataframe/tests/test_over_window.py	214	except TypeError:	CODE
HIGH	…n_execution/datastream/process/async_function/queue.py	249	except KeyError:	CODE
HIGH	…n/pyflink/fn_execution/tests/test_process_mode_boot.py	145	except:	CODE
HIGH	…/pyflink/fn_execution/table/window_process_function.py	316	except KeyError:	CODE
HIGH	flink-python/pyflink/util/api_stability_decorators.py	92	except (AttributeError, TypeError):	CODE
HIGH	flink-python/pyflink/util/java_utils.py	107	except Py4JJavaError:	CODE
HIGH	flink-python/pyflink/table/typehints.py	68	except ImportError:	CODE
HIGH	flink-python/pyflink/table/tests/test_udaf.py	195	except StopIteration:	CODE

Excessive Try-Catch Wrapping41 hits · 44 pts

Severity	File	Line	Snippet	Context
LOW	flink-python/pyflink/find_flink_home.py	68	except Exception:	CODE
LOW	flink-python/pyflink/find_flink_home.py	81	except Exception:	CODE
LOW	…python/pyflink/datastream/tests/test_async_function.py	151	except Exception as e:	CODE
LOW	…python/pyflink/datastream/tests/test_async_function.py	177	except Exception as e:	CODE
LOW	…python/pyflink/datastream/tests/test_async_function.py	203	except Exception as e:	CODE
LOW	…python/pyflink/datastream/tests/test_async_function.py	229	except Exception as e:	CODE
LOW	…python/pyflink/datastream/tests/test_async_function.py	326	except Exception as e:	CODE
LOW	flink-python/pyflink/dataframe/catalog.py	92	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3269	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3319	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/io.py	829	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/io.py	963	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/io.py	1025	except Exception as error:	CODE
LOW	flink-python/pyflink/dataframe/udtf.py	506	except Exception:	CODE
LOW	flink-python/pyflink/dataframe/udtf.py	509	except Exception:	CODE
LOW⚡	flink-python/pyflink/dataframe/sql.py	186	except Exception:	CODE
LOW⚡	flink-python/pyflink/dataframe/sql.py	194	except Exception:	CODE
LOW	flink-python/pyflink/dataframe/sql.py	328	except Exception as e:	CODE
LOW	flink-python/pyflink/dataframe/sql.py	332	except Exception:	CODE
LOW	flink-python/pyflink/dataframe/sql.py	400	except Exception as e:	CODE
LOW	flink-python/pyflink/dataframe/sql.py	404	except Exception:	CODE
MEDIUM	flink-python/pyflink/dataframe/udf.py	187	def close(self) -> None:	CODE
LOW	flink-python/pyflink/dataframe/udf.py	819	except Exception:	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1197	except Exception:	CODE
LOW	flink-python/pyflink/dataframe/udf.py	1200	except Exception:	CODE
LOW	flink-python/pyflink/fn_execution/__init__.py	39	except Exception as e:	CODE
LOW	flink-python/pyflink/fn_execution/__init__.py	54	except Exception as e:	CODE
LOW	…ecution/datastream/process/async_function/operation.py	138	except Exception as error:	CODE
LOW	…ecution/datastream/process/async_function/operation.py	222	except Exception as e:	CODE
LOW	…ecution/datastream/process/async_function/operation.py	245	except Exception as e:	CODE
LOW	…ecution/datastream/process/async_function/operation.py	285	except Exception as e:	CODE
MEDIUM	…ecution/datastream/process/async_function/operation.py	281	def exception_handler_wrapper(self, async_function, record, result_handler):	CODE
LOW	…yflink/fn_execution/table/async_function/operations.py	169	except Exception as e:	CODE
MEDIUM	…yflink/fn_execution/table/async_function/operations.py	156	def execute_async(rh):	CODE
LOW	…/pyflink/fn_execution/beam/beam_worker_pool_service.py	95	except Exception:	CODE
LOW	…/pyflink/fn_execution/beam/beam_worker_pool_service.py	145	except Exception:	CODE
LOW	…/pyflink/fn_execution/beam/beam_worker_pool_service.py	230	except Exception as e:	CODE
LOW⚡	flink-python/pyflink/table/_over_window.py	72	except Exception as exc:	CODE
LOW	…thon/pyflink/table/tests/test_async_scalar_function.py	271	except Exception as e:	STRING
LOW	…cs/content.zh/docs/dev/datastream/operators/asyncio.md	169	except Exception:	CODE
LOW	docs/content/docs/dev/datastream/operators/asyncio.md	184	except Exception:	CODE

Self-Referential Comments13 hits · 40 pts

Severity	File	Line	Snippet	Context
MEDIUM	azure-pipelines.yml	17	# This file defines an Azure Pipeline build for testing Flink. It is intended to be used	COMMENT
MEDIUM	tools/azure-pipelines/build-apache-repo.yml	18	# This file defines the Flink build for the "apache/flink" repository, including	COMMENT
MEDIUM	tools/ci/test_controller.sh	21	# This file contains generic control over the test execution.	COMMENT
MEDIUM	tools/ci/watchdog.sh	21	# This file contains a watchdog tool to monitor a task and potentially kill it after	COMMENT
MEDIUM	flink-python/pyflink/java_gateway.py	108	# Create a temporary directory where the gateway server should write the connection information.	COMMENT
MEDIUM⚡	flink-python/pyflink/datastream/state.py	931	# Creating the default Duration here would start a Py4J gateway in embedded workers.	COMMENT
MEDIUM	…yflink/fn_execution/table/async_function/operations.py	68	# Create the eval function	COMMENT
MEDIUM	…thon/pyflink/table/tests/test_async_scalar_function.py	170	# Define a regular synchronous UDF	COMMENT
MEDIUM	…on/pyflink/table/tests/test_expression_completeness.py	44	# The following methods have been replaced with the built-in methods in Python,	COMMENT
MEDIUM	…/pyflink/examples/table/async/async_scalar_function.py	88	# Create a source table	COMMENT
MEDIUM	flink-python/dev/lint-python.sh	206	# Create a Python 3.13 virtual environment as the base environment.	COMMENT
MEDIUM	flink-dist/src/main/flink-bin/bin/config.sh	188	# Define the main directory of the flink installation	COMMENT
MEDIUM	…ts/test-scripts/test_kubernetes_pyflink_application.sh	73	# Create a new docker image that has python and PyFlink installed.	COMMENT

AI Slop Vocabulary14 hits · 40 pts

Severity	File	Line	Snippet	Context
MEDIUM	…lan/rules/logical/FlinkAggregateJoinTransposeRule.java	285	// metadata more robust" is fixed) places a heavy load on	COMMENT
MEDIUM	…n/window/operators/TwoOutputWindowProcessOperator.java	498	// we don't support user utilize processing time in window operators	COMMENT
MEDIUM	…erators/TwoInputNonBroadcastWindowProcessOperator.java	712	// we don't support user utilize processing time in window operators	COMMENT
MEDIUM	…on/window/operators/OneInputWindowProcessOperator.java	485	// we don't support user utilize processing time in window operators	COMMENT
LOW	…n/pyflink/fn_execution/tests/test_process_mode_boot.py	113	# just create an empty file	COMMENT
MEDIUM	…fs/s3native/metrics/NativeS3MetricsEmissionITCase.java	154	// publishes inline, but poll to remain robust against any asynchronous delivery.	COMMENT
MEDIUM	flink-runtime-web/web-dashboard/package-lock.json	13178	"resolved": "https://registry.npmjs.org/robust-predicates/-/robust-predicates-3.0.3.tgz",	CODE
MEDIUM	…/org/apache/flink/runtime/net/ConnectionUtilsTest.java	42	// using a Absolutely unreachable outside ip:port	COMMENT
MEDIUM	…rators/coordination/OperatorCoordinatorHolderTest.java	707	// triggered checkpoint, to ensure the test conditions are robust.	COMMENT
MEDIUM	…io/network/netty/ClientTransportErrorHandlingTest.java	125	// Do this with explicit synchronization. Otherwise, this is not robust against slow timings	COMMENT
MEDIUM	…kpoint/filemerging/FileMergingSnapshotManagerBase.java	628	// Since the rocksdb state backend will leverage the PlaceholderStreamStateHandle,	COMMENT
MEDIUM	…kpoint/filemerging/FileMergingSnapshotManagerBase.java	701	// Since the rocksdb state backend will leverage the PlaceholderStreamStateHandle,	COMMENT
MEDIUM	…time/io/network/api/serialization/EventSerializer.java	302	// we do not use checkpointType.ordinal() here to make the serialization robust	COMMENT
MEDIUM	…ache/flink/runtime/state/heap/CopyOnWriteStateMap.java	505	// need to do this check when isRehashing() is false, but in order to get a more robust	COMMENT

Example Usage Blocks9 hits · 12 pts

Severity	File	Line	Snippet	Context
LOW	…esystems/flink-s3-fs-native/tools/download-crt-jars.sh	29	# Usage:	COMMENT
LOW⚡	.github/workflows/community-review.sh	138	# Usage:	COMMENT
LOW⚡	.github/workflows/community-review.sh	403	# Usage:	COMMENT
LOW⚡	.github/workflows/community-review.sh	520	# Usage:	COMMENT
LOW⚡	.github/workflows/community-review.sh	545	# Usage:	COMMENT
LOW	flink-end-to-end-tests/test-scripts/test_quickstarts.sh	21	# Usage:	COMMENT
LOW	flink-end-to-end-tests/test-scripts/test_table_api.sh	23	# Usage:	COMMENT
LOW	…d-to-end-tests/test-scripts/test_streaming_examples.sh	22	# Usage:	COMMENT
LOW	…end-tests/test-scripts/test_datastream_walkthroughs.sh	21	# Usage:	COMMENT

Slop Phrases9 hits · 12 pts

Severity	File	Line	Snippet	Context
LOW	…/java/org/apache/flink/table/api/TableEnvironment.java	1135	* semantics). For set semantics ({@link ArgumentTrait#SET_SEMANTIC_TABLE}), make sure to	COMMENT
LOW	…/java/org/apache/flink/table/api/TableEnvironment.java	1167	* semantics). For set semantics ({@link ArgumentTrait#SET_SEMANTIC_TABLE}), make sure to	COMMENT
LOW	tools/releasing/create_release_branch.sh	85	echo "Done. Don't forget to create the signed release tag at the end and push the changes."	CODE
LOW	tools/releasing/create_preview_branch.sh	97	echo "Done. Don't forget to create the signed release tag at the end and push the changes."	CODE
LOW	tools/releasing/update_branch_version.sh	64	echo "Don't forget to push the change."	CODE
LOW	tools/releasing/create_snapshot_branch.sh	70	echo "Done. Don't forget to push the branch."	CODE
LOW	…nk/connector/file/src/testutils/TestingFileSystem.java	50	* TestingFileSystem#register()} method to do that, and don't forget to {@link	COMMENT
LOW	…nk/connector/file/src/testutils/TestingFileSystem.java	50	* TestingFileSystem#register()} method to do that, and don't forget to {@link	COMMENT
LOW	…org/apache/flink/runtime/testutils/TestJvmProcess.java	130	* <p><strong>Important:</strong> Don't forget to call {@link #destroy()} to prevent resource	COMMENT

AI Structural Patterns13 hits · 12 pts

Severity	File	Line	Context
LOW	flink-python/pyflink/dataframe/dataframe.py	2798	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	2943	CODE
LOW	flink-python/pyflink/dataframe/dataframe.py	3094	CODE
LOW	flink-python/pyflink/dataframe/io.py	103	CODE
LOW	flink-python/pyflink/dataframe/io.py	186	CODE
LOW	flink-python/pyflink/dataframe/io.py	557	CODE
LOW	flink-python/pyflink/dataframe/llm.py	228	CODE
LOW	flink-python/pyflink/dataframe/llm.py	404	CODE
LOW	flink-python/pyflink/fn_execution/coder_impl_slow.py	664	CODE
LOW	flink-python/pyflink/fn_execution/coder_impl_slow.py	685	CODE
LOW	…k/fn_execution/datastream/process/timerservice_impl.py	226	CODE
LOW	flink-python/pyflink/table/udf.py	815	CODE
LOW	…python/pyflink/table/tests/test_row_based_operation.py	104	CODE

Redundant / Tautological Comments9 hits · 11 pts

Severity	File	Line	Snippet	Context
LOW	…yflink/fn_execution/table/async_function/operations.py	161	# Check if any result is a coroutine and await it	COMMENT
LOW	flink-python/pyflink/table/types.py	2012	>>> # Check if numeric values are within the allowed range.	STRING
LOW	flink-dist/src/main/flink-bin/bin/bash-java-utils.sh	117	# Print the output in case the user redirect the log to console.	COMMENT
LOW	…ink-dist/src/main/flink-bin/bin/config-parser-utils.sh	41	# Output the result	COMMENT
LOW	…ink-dist/src/main/flink-bin/bin/migrate-config-file.sh	46	# Output the result	COMMENT
LOW	flink-dist/src/main/flink-bin/bin/config.sh	363	# Check if deprecated HADOOP_HOME is set, and specify config path to HADOOP_CONF_DIR if it's empty.	COMMENT
LOW	flink-dist/src/main/flink-bin/bin/config.sh	386	# Check if deprecated HBASE_HOME is set, and specify config path to HBASE_CONF_DIR if it's empty.	COMMENT
LOW⚡	.github/workflows/community-review.sh	420	# Check if a label exists in the repository and create it if it doesn't	COMMENT
LOW⚡	.github/workflows/community-review.sh	431	# Check if the label exists	COMMENT

Magic Placeholder Names2 hits · 10 pts

Severity	File	Line	Snippet	Context
HIGH	docs/content.zh/docs/connectors/models/triton.md	441	'custom-headers' = '{"X-API-Key": "your-api-key", "X-Client-ID": "flink-job-123"}'	CODE
HIGH	docs/content/docs/connectors/models/triton.md	421	'custom-headers' = '{"X-API-Key": "your-api-key", "X-Client-ID": "flink-job-123"}'	CODE

Fake / Example Data8 hits · 8 pts

Severity	File	Line	Snippet	Context
LOW	…che/flink/table/catalog/CatalogPropertiesUtilTest.java	47	options.put("api_key", "fake_key");	CODE
LOW	…nk/api/java/typeutils/runtime/ValueComparatorTest.java	31	new StringValue("Lorem Ipsum Dolor Omit Longer"),	CODE
LOW	…peutils/runtime/AbstractGenericTypeComparatorTest.java	39	"Lorem Ipsum Dolor Omit Longer",	CODE
LOW	…ava/typeutils/runtime/CopyableValueComparatorTest.java	31	new StringValue("Lorem Ipsum Dolor Omit Longer"),	CODE
LOW	…nk/api/common/typeutils/base/StringComparatorTest.java	40	"", "Lorem Ipsum Dolor Omit Longer", "aaaa", "abcd", "abce", "abdd", "accd", "bbcd"	CODE
LOW	…i/common/typeutils/base/StringValueComparatorTest.java	42	new StringValue("Lorem Ipsum Dolor Omit Longer"),	CODE
LOW	…org/apache/flink/test/testdata/WebLogAnalysisData.java	30	+ "url_16\|tation ad sed veniam lobortis editor nonummy Ut ea ipsum aliquip dolore ut laoreet tation	CODE
LOW	…org/apache/flink/test/testdata/WebLogAnalysisData.java	36	+ "url_22\|sit exerci ad ut minim convection ad ea dolore Lorem ipsum amet sit wisi sed ullamcorper i	CODE

AI Response Leakage1 hit · 8 pts

Severity	File	Line	Snippet	Context
HIGH	…network/partition/consumer/RemoteInputChannelTest.java	237	// I've added this check just to be sure. It's freezing the current implementation that's	COMMENT

Modern AI Meta-Vocabulary2 hits · 6 pts

Severity	File	Line	Snippet	Context
MEDIUM	AGENTS.md	93	### DataStream API v2 (newer event-driven API)	COMMENT
MEDIUM	…r/runtime/stream/sql/AsyncLookupJoinTimeoutITCase.java	79	* #testNoTimeoutCompletesSuccessfully()} stays as a single sanity case ensuring the scaffolding	COMMENT

Dead Code1 hit · 2 pts

Severity	File	Line	Snippet	Context
MEDIUM	…nk-python/pyflink/datastream/tests/test_data_stream.py	1843		CODE

TODO Padding1 hit · 2 pts

Severity	File	Line	Snippet	Context
LOW	…/flink/state/changelog/ChangelogKeyedStateBackend.java	897	// TODO: implement its own streamFactory.	COMMENT

apache/flink

Open-Source Code Quality, Security and Technical Debt Review