Home / debezium / debezium
Repository Analysis

debezium/debezium

1.7 Likely human-written View on GitHub
1.7
Adjusted Score
1.7
Raw Score
100%
Time Factor
—
Last Push
—
Stars
—
Language
501,668
Lines of Code
3538
Files
245
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 48HIGH 14MEDIUM 6LOW 177

Pattern Findings

245 matches across 10 categories. Click a row to expand file-level details.

Hallucination Indicators48 hits · 590 pts
SeverityFileLineSnippet
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java989 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(),
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java994 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java999 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java1003 r.deliver(io.debezium.data.geometry.Geometry.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java1014 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geography.createValue(fieldDefn.schema(),
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java1019 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java1024 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…ezium/connector/postgresql/PostgresValueConverter.java1028 r.deliver(io.debezium.data.geometry.Geography.createValue(schema, geom.getWkb(), geom.getSrid()));
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java236 new SchemaAndValueField("VAL_DATE", org.apache.kafka.connect.data.Timestamp.builder().optional().build(),
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java238 new SchemaAndValueField("VAL_TS", org.apache.kafka.connect.data.Timestamp.builder().optional().build(),
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java240 new SchemaAndValueField("VAL_TS_PRECISION2", org.apache.kafka.connect.data.Timestamp.builder().optional().bu
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java242 new SchemaAndValueField("VAL_TS_PRECISION4", org.apache.kafka.connect.data.Timestamp.builder().optional().bu
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java244 new SchemaAndValueField("VAL_TS_PRECISION9", org.apache.kafka.connect.data.Timestamp.builder().optional().bu
CRITICAL…zium/connector/oracle/AbstractOracleDatatypesTest.java252 new SchemaAndValueField("VAL_MAX_DATE", org.apache.kafka.connect.data.Timestamp.builder().optional().build()
CRITICAL…bezium/connector/sqlserver/SqlServerMaxColumnTest.java91 final var fieldDefn = new org.apache.kafka.connect.data.Field(
CRITICAL…bezium/connector/sqlserver/SqlServerMaxColumnTest.java124 final var fieldDefn = new org.apache.kafka.connect.data.Field(
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java141 new SchemaAndValueField("val_date", org.apache.kafka.connect.data.Date.builder().optional().build(),
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java145 new SchemaAndValueField("val_time_p2", org.apache.kafka.connect.data.Time.builder().optional().build(),
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java149 new SchemaAndValueField("val_time", org.apache.kafka.connect.data.Time.builder().optional().build(),
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java153 new SchemaAndValueField("val_time_p7", org.apache.kafka.connect.data.Time.builder().optional().build(),
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java157 new SchemaAndValueField("val_datetime2", org.apache.kafka.connect.data.Timestamp.builder().optional().build(
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java162 new SchemaAndValueField("val_datetime", org.apache.kafka.connect.data.Timestamp.builder().optional().build()
CRITICAL…onnector/sqlserver/AbstractSqlServerDatatypesTest.java166 new SchemaAndValueField("val_smalldatetime", org.apache.kafka.connect.data.Timestamp.builder().optional().bu
CRITICAL…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2534 Bson filter = com.mongodb.client.model.Filters.eq("name", "Jon Snow");
CRITICAL…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2602 Bson filter = com.mongodb.client.model.Filters.eq("name", "Jon Snow");
CRITICAL…onnector/mongodb/metadata/MongoDbMetadataProvider.java31 componentMetadataFactory.createComponentMetadata(new MongoDbSinkConnector(), io.debezium.connector.mongo
CRITICAL…/io/debezium/transforms/ExtractNewRecordStateTest.java1018 org.apache.kafka.connect.errors.ConnectException e = org.junit.jupiter.api.Assertions.assertThrows(
CRITICAL…java/io/debezium/transforms/TimezoneConverterTest.java59 .field("order_date_kc_timestamp", org.apache.kafka.connect.data.Timestamp.builder().optional().build())
CRITICAL…connector/jdbc/transforms/FieldNameTransformation.java242 builder = org.apache.kafka.connect.transforms.util.SchemaUtil.copySchemaBasics(
CRITICAL…a/io/debezium/connector/common/BaseSourceTaskTest.java165 org.apache.kafka.connect.util.LoggingContext.clear();
CRITICAL…a/io/debezium/connector/common/BaseSourceTaskTest.java175 try (var kafkaLoggingContext = org.apache.kafka.connect.util.LoggingContext.forTask(connectorTaskId)) {
CRITICAL…ommon/src/test/java/io/debezium/data/VerifyRecord.java86 avroKeyConverter = new io.apicurio.registry.utils.converter.AvroConverter();
CRITICAL…ommon/src/test/java/io/debezium/data/VerifyRecord.java87 avroValueConverter = new io.apicurio.registry.utils.converter.AvroConverter();
CRITICAL…/main/java/io/debezium/jdbc/TemporalPrecisionMode.java57 x -> org.apache.kafka.connect.data.Time.builder(),
CRITICAL…/main/java/io/debezium/jdbc/TemporalPrecisionMode.java58 x -> org.apache.kafka.connect.data.Timestamp.builder()),
CRITICAL…rc/main/java/io/debezium/connector/SnapshotRecord.java48 && io.debezium.data.Enum.LOGICAL_NAME.equals(source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY).sche
CRITICAL…-common/src/main/java/io/debezium/data/SchemaUtil.java332 SchemaBuilder builder = org.apache.kafka.connect.transforms.util.SchemaUtil.copySchemaBasics(source);
CRITICAL…a/io/debezium/connector/mysql/MySqlDatabaseSchema.java77 return new io.debezium.connector.mysql.antlr.MySqlPtAntlrDdlParser(
CRITICAL…/io/debezium/connector/mysql/MySqlConnectorConfig.java298 .withDefault(com.mysql.cj.jdbc.Driver.class.getName())
CRITICAL…sql/antlr/listener/ColumnDefinitionParserListener.java288 dataType = io.debezium.relational.ddl.DataType.userDefinedType(contextText);
CRITICAL…ava/io/debezium/connector/mysql/gtid/MySqlGtidSet.java42 new com.github.shyiko.mysql.binlog.GtidSet(gtids).getUUIDSets().forEach(uuidSet -> {
CRITICAL…ain/java/io/debezium/connector/binlog/EventBuffer.java166 // Position for TABLE_MAP is not stored by com.github.shyiko.mysql.binlog.BinaryLogClient.updateClientBinlogFile
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java136 return io.debezium.data.geometry.Point.builder();
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java145 return io.debezium.data.geometry.Geometry.builder();
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java641 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(),
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java647 r.deliver(io.debezium.data.geometry.Point.createValue(fieldDefn.schema(), geometry.getWkb(), geometr
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java667 return convertValue(column, fieldDefn, data, io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(),
CRITICAL…ezium/connector/binlog/jdbc/BinlogValueConverters.java672 r.deliver(io.debezium.data.geometry.Geometry.createValue(fieldDefn.schema(), geometry.getWkb(), geometry
Fake / Example Data87 hits · 86 pts
SeverityFileLineSnippet
LOW…va/io/debezium/connector/postgresql/OpenLineageIT.java549 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java6332 connection.execute("INSERT INTO dbz1676 values ('doe','john',21,'123 Main St', 'john@doe.com', sysdate, 1)")
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java6386 connection.execute("INSERT INTO dbz1676 values ('doe','john',21,'123 Main St', 'john@doe.com', sysdate, 1, '
LOW…ava/io/debezium/connector/sqlserver/OpenLineageIT.java209 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));
LOW…/debezium/connector/mongodb/JsonSerializationTest.java22 var composite = new BsonDocument("email", new BsonString("foo@bar.com"))
LOW…/debezium/connector/mongodb/JsonSerializationTest.java34 var composite = new BsonDocument("email", new BsonString("foo@bar.com"))
LOW…/java/io/debezium/connector/mongodb/OpenLineageIT.java270 assertThat(ownership).contains(entry("Mario", "maintainer"), entry("John Doe", "Data scientist"));
LOW…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2789 Document doc = new Document("_id", 4367438483L).append("name", "John Doe").append("age", 25);
LOW…/io/debezium/connector/mongodb/MongoDbConnectorIT.java2800 Document doc1 = new Document("_id", 1).append("name", "Jane Doe").append("age", 22);
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java872 .append("fullName", "John Doe")
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java892 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java910 .append("fullName", "John Doe")
LOW…or/mongodb/transforms/outbox/MongoEventRouterTest.java920 assertThat(payload.get("fullName")).isEqualTo("John Doe");
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java102 .append("fullName", "John Doe")
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java125 assertThat(payload.get("fullName")).isEqualTo("John Doe");
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java141 .append("fullName", "John Doe")
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java167 assertThat(payload.get("fullName")).isEqualTo("John Doe");
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java181 .append("fullName", "John Doe")
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java205 assertThat(payload.get("fullName")).isEqualTo("John Doe");
LOW…/mongodb/transforms/outbox/MongoEventRouterTestIT.java224 .append("fullName", "John Doe")
LOW…java/io/debezium/transforms/TimezoneConverterTest.java214 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java259 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java302 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java345 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java388 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java433 before.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java476 customersBefore.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java511 ordersBefore.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java546 otherBefore.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java589 customersBefore.put("name", "John Doe");
LOW…java/io/debezium/transforms/TimezoneConverterTest.java624 ordersBefore.put("name", "John Doe");
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java986 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1036 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1078 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1141 assertThat(payloadStruct.get("fullName")).isEqualTo("John Doe");
LOW…ava/io/debezium/transforms/outbox/EventRouterTest.java1174 assertThat(valueStruct.get("fullName")).isEqualTo("John Doe");
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java211 .after("name", "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java237 .after(columnNameTransformation.apply("name"), "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java347 .after("name", "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java367 .after("name", "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java382 .before("name", "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java384 .after("name", "Jane Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java423 .before("name", "John Doe")
LOW…io/debezium/connector/jdbc/util/SinkRecordFactory.java440 .before("name", "John Doe")
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java61 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java233 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…dbc/integration/AbstractJdbcSinkDeleteEnabledTest.java261 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java67 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java98 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java129 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java157 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java164 .column("name").isText(false).hasValues("John Doe")
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java193 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java221 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java228 .column("name").isText(false).hasValues("John Doe")
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java262 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java290 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java317 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java346 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
LOW…bc/integration/AbstractJdbcSinkPrimaryKeyModeTest.java376 getSink().assertColumnType(tableAssert, "name", ValueType.TEXT, "John Doe");
27 more matches not shown…
Cross-File Repetition12 hits · 60 pts
SeverityFileLineSnippet
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (1 , null, null, null, null, null, null, null, null, null, null, null, n
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (1 , null, null, null, null, null, null, null, null, null, null, null, n
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (1 , null, null, null, null, null, null, null, null, null, null, null, n
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (2 , '{"jfield": 111}'::json , '{"jfield": 211}'::jsonb , '2017-09-15'::
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (2 , '{"jfield": 111}'::json , '{"jfield": 211}'::jsonb , '2017-09-15'::
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (2 , '{"jfield": 111}'::json , '{"jfield": 211}'::jsonb , '2017-09-15'::
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (3 , '{"jfield": 222}'::json , '{"jfield": 222}'::jsonb , '2017-02-10'::
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (3 , '{"jfield": 222}'::json , '{"jfield": 222}'::jsonb , '2017-02-10'::
HIGH…or/postgresql/PostgresTemporalPrecisionHandlingIT.java0insert into temporaltype.test_data_types values (3 , '{"jfield": 222}'::json , '{"jfield": 222}'::jsonb , '2017-02-10'::
HIGH…rc/test/resources/mariadb/examples/fast/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quote
HIGH…arser/src/test/resources/mysql/examples/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quote
HIGH…rc/test/resources/mysql/examples/legacy/dml_select.sql0as col2; select '\'quoted string\' ' col1, 'backslash \\ ' ', two double quote "" ' ', two single quote
Over-Commented Block45 hits · 45 pts
SeverityFileLineSnippet
LOW…a/io/debezium/connector/postgresql/PostgresSchema.java181 * Discard any currently-cached schemas and rebuild them using the filters.
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java161 // LSN point.
LOW…gresql/connection/pgoutput/PgOutputMessageDecoder.java401 //
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java4821
LOW…va/io/debezium/connector/oracle/OracleConnectorIT.java4841 // of the events should be the following:
LOW…/main/java/io/debezium/connector/oracle/CommitScn.java361
LOW…gminer/AbstractLogMinerStreamingChangeEventSource.java361 if (sequenceUnavailable) {
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java21 * todo When you use the SKIP_CORRUPTION option to DBMS_LOGMNR.START_LOGMNR, any corruptions in the redo log files a
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java141 // combined with a list of redo logs that should be mined.
LOW…va/io/debezium/connector/oracle/logminer/SqlUtils.java161 // SELECT A.NAME AS FILE_NAME, A.FIRST_CHANGE# FIRST_CHANGE, A.NEXT_CHANGE# NEXT_CHANGE, 'YES',
LOW…le/logminer/buffered/BufferedLogMinerQueryBuilder.java121 // generated to capture the following operations as a baseline:
LOWdebezium-quarkus-outbox-reactive/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarku
LOWquarkus-debezium-parent/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarku
LOW…ezium/connector/mongodb/ShardedMongoDbConnectorIT.java81
LOW…/io/debezium/connector/mongodb/MongoDbConnectorIT.java1761 verifyCreateOperation(record);
LOW…ium/connector/mongodb/ChangeStreamPipelineFactory.java221 // Per https://debezium.io/documentation/reference/stable/connectors/mongodb.html#mongodb-property-skipped-opera
LOW…bezium/connector/jdbc/JdbcSinkConnectorConfigTest.java241 // final JdbcSinkConnectorConfig config = new JdbcSinkConnectorConfig(properties);
LOW…ium/connector/jdbc/e2e/AbstractJdbcSinkPipelineIT.java601 // based on the supplied scale. For example, a scale of -1 rounds to a factor of 10 while scale
LOW…ium/connector/jdbc/e2e/AbstractJdbcSinkPipelineIT.java2761 ResultSet::getString);
LOW…ium/connector/jdbc/type/connect/ConnectStringType.java41 // this case we should ignore it.
LOW…ebezium/connector/jdbc/dialect/db2i/ZonedTimeType.java41 // NOTE:
LOW…debezium/connector/jdbc/dialect/db2/ZonedTimeType.java41 // NOTE:
LOW…nnector/mariadb/MariaDbStreamingChangeEventSource.java121 // todo: Cache ANNOTATE_ROWS query with events
LOW.github/nightly-build-config.yml1# ========================================
LOW.github/workflows/debezium-workflow-pr.yml241 uses: actions/cache@v5
LOW.github/workflows/debezium-workflow-push.yml61 # This step is responsible for pulling down artifacts
LOW…ce/snapshot/incremental/AbstractChunkQueryBuilder.java101 // (k1 > ?)
LOW…/src/test/resources/mariadb/examples/fast/ddl_drop.sql81#end
LOW…rser/src/test/resources/mysql/examples/expressions.sql1#begin
LOW…arser/src/test/resources/mysql/examples/dml_select.sql121#end
LOW…arser/src/test/resources/mysql/examples/dml_select.sql221-- Index hints: https://dev.mysql.com/doc/refman/5.7/en/index-hints.html
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql121#PARTITION BY LIST (partition_index) (
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql341SET i = i + 1;
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql561# IF @merchantId > 0 THEN
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql581# WHERE tax_vat.default = 1
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql601# SELECT tax_vat.tax_vat_id
LOW…arser/src/test/resources/mysql/examples/ddl_create.sql761#begin
LOW…src/test/resources/mysql/examples/legacy/dml_table.sql1###https://dev.mysql.com/doc/refman/8.0/en/table.html
LOWdebezium-quarkus-outbox-common/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarku
LOW…a/io/debezium/connector/binlog/BinlogRegressionIT.java221 //
LOW…a/io/debezium/connector/binlog/BinlogRegressionIT.java561 // c4 TIMESTAMP(2)
LOW…a/io/debezium/connector/binlog/BinlogReadBinLogIT.java321 if (sql.equalsIgnoreCase("BEGIN") || sql.equalsIgnoreCase("COMMIT")) {
LOW…va/io/debezium/connector/binlog/BinlogConnectorIT.java881
LOW…/connector/binlog/BinlogSnapshotChangeEventSource.java141 // With REPEATABLE READ, all SELECT queries within the scope of a transaction (which we don't yet have) will rea
LOWdebezium-quarkus-outbox/README.md1# Debezium Extensions for Quarkus have been moved to a [separate repository](https://github.com/debezium/debezium-quarku
Unused Imports32 hits · 32 pts
SeverityFileLineSnippet
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py4
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py5
LOWdebezium-e2e-benchmark/py/time1-tpcplot-full.py8
LOWdebezium-e2e-benchmark/py/tpcplot.py5
LOWdebezium-e2e-benchmark/py/tpcplot.py6
LOWdebezium-e2e-benchmark/py/tpcplot.py9
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py4
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py5
LOWdebezium-e2e-benchmark/py/time1-tpcplot-detail.py8
LOWdebezium-e2e-benchmark/py/time-delta-hist.py4
LOWdebezium-e2e-benchmark/py/time-delta-hist.py5
LOWdebezium-e2e-benchmark/py/time-delta-hist.py8
LOWdebezium-e2e-benchmark/py/tpc-run-test.py6
LOWdebezium-e2e-benchmark/py/tpc-run-test.py10
LOWdebezium-e2e-benchmark/py/tpc-run-test.py11
LOWdebezium-e2e-benchmark/py/tpc-run-test.py12
LOWdebezium-e2e-benchmark/py/tpc-run-test.py14
LOWdebezium-e2e-benchmark/py/tpc-run-test.py15
LOWdebezium-e2e-benchmark/py/tpc-run-test.py16
LOWdebezium-e2e-benchmark/py/runplots.py3
LOWdebezium-e2e-benchmark/py/runplots.py4
LOWdebezium-e2e-benchmark/py/runplots.py6
LOWdebezium-e2e-benchmark/py/runplots.py7
LOWdebezium-e2e-benchmark/py/runplots.py8
LOWdebezium-e2e-benchmark/py/runplots.py9
LOWdebezium-e2e-benchmark/py/runplots.py10
LOWdebezium-e2e-benchmark/py/runplots.py11
LOWdebezium-e2e-benchmark/py/runplots.py12
LOWdebezium-e2e-benchmark/py/runplots.py13
LOWdebezium-e2e-benchmark/py/runplots.py14
LOWdebezium-e2e-benchmark/py/runplots.py16
LOWdebezium-e2e-benchmark/py/runplots.py17
Verbosity Indicators8 hits · 18 pts
SeverityFileLineSnippet
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4038 // Step 1: Create table WITHOUT duplicate columns
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4046 // Step 2: Insert initial data
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4049 // Step 3: Start connector - should succeed (no duplicates yet)
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4055 // Step 4: Wait for streaming to start
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4058 // Step 5: NOW ALTER TABLE to add duplicate column during streaming
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4062 // Step 6: Insert a record to trigger RELATION message processing
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4067 // Step 7: Wait for some time to allow RELATION message processing
LOW…zium/connector/postgresql/RecordsStreamProducerIT.java4070 // Step 8: Connector should fail due to Layer 2 validation in handleRelationMessage()
Decorative Section Separators5 hits · 15 pts
SeverityFileLineSnippet
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4448 // ── Scenario 1: INSERT — jsonb must be the real inserted value ─────
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4458 // ── Scenario 2: UPDATE that does NOT touch the jsonb column ────────
MEDIUM…debezium/connector/postgresql/PostgresConnectorIT.java4485 // ── Scenario 4: UPDATE that DOES change the jsonb column ──────────
MEDIUM.github/nightly-build-config.yml1# ========================================
MEDIUM.github/nightly-build-config.yml3# ========================================
Cross-Language Confusion (JS/TS)2 hits · 10 pts
SeverityFileLineSnippet
HIGH…-mongodb/src/test/resources/initialize-mongo-single.js66 print('Error, exiting!')
HIGH…resources/mongodb/sharded/command-templates/init-rs.js9 print("is primary result: ", isPrimary);
Redundant / Tautological Comments5 hits · 8 pts
SeverityFileLineSnippet
LOWjenkins-jobs/scripts/check-contributors.sh31 # Check if the supplied contributor name from git history should be filtered
LOW.github/actions/check-artifact-size/action.yml85 # Check if this repository exceeds its specific threshold
LOW.github/actions/check-artifact-size/action.yml209 # Check if exceeds warning threshold (Latest Version - triggers Zulip)
LOW.github/actions/check-artifact-size/action.yml237 # Check if exceeds warning threshold (Final Version - report only, no Zulip)
LOW.github/actions/check-artifact-size/action.yml262 # Check if any LATEST version warnings were recorded (triggers Zulip)
Self-Referential Comments1 hit · 2 pts
SeverityFileLineSnippet
MEDIUM…rc/test/java/io/debezium/config/ConfigurationTest.java286 assertThat(ddlFilter.test("# Create the new ENTITY table which will be the parent of all other resource tables.\