gofmt0%

Gofmt formats Go programs. We run gofmt -s on your code, where -s is for the "simplify" command

An error occurred while running this test (AddError: could not parse "_repos/src/github.com/pingcap/ticdc@v0.0.0-20211217120037-9455667fa945/cmd/kafka-consumer/fatal error: out of memory allocating heap arena map:1::warning: file is not gofmted with -s (gofmt)" - strconv.Atoi: parsing " out of memory allocating heap arena map": invalid syntax)

go_vet0%

go vet examines Go source code and reports suspicious constructs, such as Printf calls whose arguments do not align with the format string.

An error occurred while running this test (exit status 2)

gocyclo89%

Gocyclo calculates cyclomatic complexities of functions in Go source code. The cyclomatic complexity of a function is calculated according to the following rules: 1 is the base complexity of a function +1 for each 'if', 'for', 'case', '&&' or '||' Go Report Card warns on functions with cyclomatic complexity > 15.

• cdc/sorter/unified/heap_sorter.go
  • Line 97: warning: cyclomatic complexity 23 of function (*heapSorter).flush() is high (> 15) (gocyclo)

• dm/loader/lightning.go
  • Line 182: warning: cyclomatic complexity 21 of function (*LightningLoader).restore() is high (> 15) (gocyclo)

• cdc/sink/mq.go
  • Line 275: warning: cyclomatic complexity 21 of function (*mqSink).runWorker() is high (> 15) (gocyclo)

• pkg/txnutil/lock_resolver.go
  • Line 48: warning: cyclomatic complexity 18 of function (*resolver).Resolve() is high (> 15) (gocyclo)

• dm/dm/ctl/master/operate_schema.go
  • Line 56: warning: cyclomatic complexity 18 of function operateSchemaCmd() is high (> 15) (gocyclo)

• dm/syncer/syncer.go
  • Line 1389: warning: cyclomatic complexity 111 of function (*Syncer).Run() is high (> 15) (gocyclo)
  • Line 2325: warning: cyclomatic complexity 42 of function (*Syncer).handleQueryEvent() is high (> 15) (gocyclo)
  • Line 894: warning: cyclomatic complexity 32 of function (*Syncer).addJob() is high (> 15) (gocyclo)
  • Line 2824: warning: cyclomatic complexity 30 of function (*Syncer).trackDDL() is high (> 15) (gocyclo)
  • Line 308: warning: cyclomatic complexity 28 of function (*Syncer).Init() is high (> 15) (gocyclo)
  • Line 2610: warning: cyclomatic complexity 26 of function (*Syncer).handleQueryEventPessimistic() is high (> 15) (gocyclo)
  • Line 1222: warning: cyclomatic complexity 26 of function (*Syncer).syncDDL() is high (> 15) (gocyclo)
  • Line 2099: warning: cyclomatic complexity 25 of function (*Syncer).handleRowsEvent() is high (> 15) (gocyclo)
  • Line 3253: warning: cyclomatic complexity 18 of function (*Syncer).Update() is high (> 15) (gocyclo)

• pkg/cmd/server/server.go
  • Line 141: warning: cyclomatic complexity 27 of function (*options).complete() is high (> 15) (gocyclo)

• dm/syncer/online-ddl-tools/online_ddl.go
  • Line 426: warning: cyclomatic complexity 23 of function (*RealOnlinePlugin).Apply() is high (> 15) (gocyclo)

• cdc/model/sink.go
  • Line 368: warning: cyclomatic complexity 17 of function ColumnValueString() is high (> 15) (gocyclo)

• dm/pkg/parser/common.go
  • Line 182: warning: cyclomatic complexity 35 of function SplitDDL() is high (> 15) (gocyclo)

• dm/dm/config/task_converters.go
  • Line 112: warning: cyclomatic complexity 29 of function OpenAPITaskToSubTaskConfigs() is high (> 15) (gocyclo)
  • Line 380: warning: cyclomatic complexity 16 of function SubTaskConfigsToOpenAPITask() is high (> 15) (gocyclo)

• dm/dumpling/dumpling.go
  • Line 233: warning: cyclomatic complexity 16 of function (*Dumpling).constructArgs() is high (> 15) (gocyclo)

• cdc/sorter/leveldb/cleaner.go
  • Line 71: warning: cyclomatic complexity 17 of function (*CleanerActor).Poll() is high (> 15) (gocyclo)

• cdc/owner/owner.go
  • Line 359: warning: cyclomatic complexity 28 of function (*Owner).handleQueries() is high (> 15) (gocyclo)

• dm/checker/checker.go
  • Line 105: warning: cyclomatic complexity 28 of function (*Checker).Init() is high (> 15) (gocyclo)
  • Line 255: warning: cyclomatic complexity 18 of function (*Checker).Process() is high (> 15) (gocyclo)

• dm/relay/file_util.go
  • Line 165: warning: cyclomatic complexity 24 of function getTxnPosGTIDs() is high (> 15) (gocyclo)

• dm/pkg/binlog/event/event.go
  • Line 519: warning: cyclomatic complexity 36 of function GenRowsEvent() is high (> 15) (gocyclo)
  • Line 364: warning: cyclomatic complexity 26 of function GenTableMapEvent() is high (> 15) (gocyclo)

• dm/pkg/binlog/reader/util.go
  • Line 34: warning: cyclomatic complexity 25 of function GetGTIDsForPosFromStreamer() is high (> 15) (gocyclo)

• pkg/util/overlap_merge.go
  • Line 54: warning: cyclomatic complexity 20 of function OverlapCoveringMerge() is high (> 15) (gocyclo)

• dm/dm/master/etcd.go
  • Line 93: warning: cyclomatic complexity 20 of function prepareJoinEtcd() is high (> 15) (gocyclo)

• pkg/orchestrator/reactor_state.go
  • Line 173: warning: cyclomatic complexity 19 of function (*ChangefeedReactorState).UpdateCDCKey() is high (> 15) (gocyclo)

• dm/dm/portal/api.go
  • Line 463: warning: cyclomatic complexity 16 of function adjustConfig() is high (> 15) (gocyclo)

• tests/utils/cdc_state_checker/state.go
  • Line 53: warning: cyclomatic complexity 23 of function (*cdcReactorState).Update() is high (> 15) (gocyclo)

• pkg/applier/redo.go
  • Line 93: warning: cyclomatic complexity 19 of function (*RedoApplier).consumeLogs() is high (> 15) (gocyclo)

• dm/pkg/ha/relay.go
  • Line 100: warning: cyclomatic complexity 16 of function GetRelayConfig() is high (> 15) (gocyclo)

• dm/dm/ctl/master/query_status.go
  • Line 117: warning: cyclomatic complexity 17 of function wrapTaskResult() is high (> 15) (gocyclo)

• dm/pkg/conn/baseconn.go
  • Line 118: warning: cyclomatic complexity 21 of function (*BaseConn).ExecuteSQLWithIgnoreError() is high (> 15) (gocyclo)

• dm/dm/master/shardddl/optimist.go
  • Line 299: warning: cyclomatic complexity 18 of function (*Optimist).buildLockJoinedAndTTS() is high (> 15) (gocyclo)

• dm/pkg/ha/bound.go
  • Line 262: warning: cyclomatic complexity 17 of function WatchSourceBound() is high (> 15) (gocyclo)

• dm/relay/relay.go
  • Line 551: warning: cyclomatic complexity 33 of function (*Relay).handleEvents() is high (> 15) (gocyclo)
  • Line 178: warning: cyclomatic complexity 30 of function (*Relay).process() is high (> 15) (gocyclo)
  • Line 746: warning: cyclomatic complexity 18 of function (*Relay).reSetupMeta() is high (> 15) (gocyclo)
  • Line 360: warning: cyclomatic complexity 17 of function (*Relay).tryRecoverLatestFile() is high (> 15) (gocyclo)

• cdc/model/sink_gen.go
  • Line 1318: warning: cyclomatic complexity 27 of function (*RedoLog).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 1087: warning: cyclomatic complexity 27 of function (*RedoLog).DecodeMsg() is high (> 15) (gocyclo)
  • Line 1734: warning: cyclomatic complexity 26 of function (*RedoRowChangedEvent).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 2097: warning: cyclomatic complexity 26 of function (*RowChangedEvent).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 1868: warning: cyclomatic complexity 26 of function (*RowChangedEvent).DecodeMsg() is high (> 15) (gocyclo)
  • Line 1508: warning: cyclomatic complexity 26 of function (*RedoRowChangedEvent).DecodeMsg() is high (> 15) (gocyclo)
  • Line 2430: warning: cyclomatic complexity 26 of function (*SimpleTableInfo).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 2215: warning: cyclomatic complexity 26 of function (*SimpleTableInfo).DecodeMsg() is high (> 15) (gocyclo)
  • Line 486: warning: cyclomatic complexity 21 of function (*DDLEvent).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 295: warning: cyclomatic complexity 21 of function (*DDLEvent).DecodeMsg() is high (> 15) (gocyclo)
  • Line 638: warning: cyclomatic complexity 21 of function (*RedoColumn).DecodeMsg() is high (> 15) (gocyclo)
  • Line 815: warning: cyclomatic complexity 21 of function (*RedoColumn).UnmarshalMsg() is high (> 15) (gocyclo)
  • Line 1971: warning: cyclomatic complexity 19 of function (*RowChangedEvent).EncodeMsg() is high (> 15) (gocyclo)
  • Line 1617: warning: cyclomatic complexity 17 of function (*RedoRowChangedEvent).EncodeMsg() is high (> 15) (gocyclo)
  • Line 2322: warning: cyclomatic complexity 16 of function (*SimpleTableInfo).EncodeMsg() is high (> 15) (gocyclo)
  • Line 1203: warning: cyclomatic complexity 16 of function (*RedoLog).EncodeMsg() is high (> 15) (gocyclo)

• pkg/orchestrator/etcd_worker.go
  • Line 122: warning: cyclomatic complexity 22 of function (*EtcdWorker).Run() is high (> 15) (gocyclo)

• cdc/processor/manager.go
  • Line 68: warning: cyclomatic complexity 16 of function (*Manager).Tick() is high (> 15) (gocyclo)

• pkg/cmd/cli/cli_changefeed_create.go
  • Line 177: warning: cyclomatic complexity 23 of function (*createChangefeedOptions).completeCfg() is high (> 15) (gocyclo)
  • Line 380: warning: cyclomatic complexity 17 of function (*createChangefeedOptions).run() is high (> 15) (gocyclo)

• dm/loader/convert_data.go
  • Line 100: warning: cyclomatic complexity 19 of function parseRowValues() is high (> 15) (gocyclo)

• tests/integration_tests/move_table/main.go
  • Line 46: warning: cyclomatic complexity 18 of function main() is high (> 15) (gocyclo)

• dm/pkg/checker/privilege.go
  • Line 126: warning: cyclomatic complexity 20 of function verifyPrivileges() is high (> 15) (gocyclo)

• dm/pkg/schema/tracker.go
  • Line 88: warning: cyclomatic complexity 20 of function NewTracker() is high (> 15) (gocyclo)

• cdc/sink/mysql_worker.go
  • Line 77: warning: cyclomatic complexity 18 of function (*mysqlSinkWorker).run() is high (> 15) (gocyclo)

• dm/pkg/ha/stage.go
  • Line 330: warning: cyclomatic complexity 17 of function watchStage() is high (> 15) (gocyclo)

• dm/pkg/ha/keepalive.go
  • Line 82: warning: cyclomatic complexity 17 of function KeepAlive() is high (> 15) (gocyclo)
  • Line 185: warning: cyclomatic complexity 16 of function WatchWorkerEvent() is high (> 15) (gocyclo)

• cdc/kv/client.go
  • Line 1059: warning: cyclomatic complexity 16 of function (*eventFeedSession).receiveFromStream() is high (> 15) (gocyclo)

• dm/pkg/dumpling/utils.go
  • Line 42: warning: cyclomatic complexity 30 of function ParseMetaData() is high (> 15) (gocyclo)

• cdc/sink/mysql_params.go
  • Line 92: warning: cyclomatic complexity 28 of function parseSinkURIToParams() is high (> 15) (gocyclo)

• cdc/scheduler/schedule_dispatcher.go
  • Line 149: warning: cyclomatic complexity 25 of function (*BaseScheduleDispatcher).Tick() is high (> 15) (gocyclo)

• dm/syncer/schema.go
  • Line 36: warning: cyclomatic complexity 26 of function (*Syncer).OperateSchema() is high (> 15) (gocyclo)

• dm/dm/worker/subtask_test.go
  • Line 167: warning: cyclomatic complexity 17 of function (*testSubTask).TestSubTaskNormalUsage() is high (> 15) (gocyclo)

• dm/pkg/shardddl/optimism/table.go
  • Line 231: warning: cyclomatic complexity 16 of function WatchSourceTables() is high (> 15) (gocyclo)

• dm/dm/ctl/master/operate_source.go
  • Line 59: warning: cyclomatic complexity 16 of function operateSourceFunc() is high (> 15) (gocyclo)

• dm/dm/config/task.go
  • Line 428: warning: cyclomatic complexity 100 of function (*TaskConfig).adjust() is high (> 15) (gocyclo)

• dm/loader/loader.go
  • Line 1356: warning: cyclomatic complexity 26 of function (*Loader).restoreData() is high (> 15) (gocyclo)
  • Line 140: warning: cyclomatic complexity 19 of function (*Worker).run() is high (> 15) (gocyclo)
  • Line 287: warning: cyclomatic complexity 18 of function (*Worker).dispatchSQL() is high (> 15) (gocyclo)
  • Line 488: warning: cyclomatic complexity 16 of function (*Loader).Init() is high (> 15) (gocyclo)

• cdc/sink/producer/kafka/config.go
  • Line 97: warning: cyclomatic complexity 23 of function CompleteConfigsAndOpts() is high (> 15) (gocyclo)
  • Line 208: warning: cyclomatic complexity 16 of function newSaramaConfig() is high (> 15) (gocyclo)

• tests/integration_tests/bank/case.go
  • Line 424: warning: cyclomatic complexity 29 of function run() is high (> 15) (gocyclo)

• cdc/sink/codec/maxwell.go
  • Line 93: warning: cyclomatic complexity 20 of function rowEventToMaxwellMessage() is high (> 15) (gocyclo)

• cdc/sorter/leveldb/table_sorter.go
  • Line 442: warning: cyclomatic complexity 17 of function (*Sorter).poll() is high (> 15) (gocyclo)

• dm/pkg/shardddl/optimism/lock.go
  • Line 115: warning: cyclomatic complexity 50 of function (*Lock).TrySync() is high (> 15) (gocyclo)
  • Line 619: warning: cyclomatic complexity 18 of function (*Lock).DeleteColumnsByOp() is high (> 15) (gocyclo)

• dm/dm/master/scheduler/scheduler.go
  • Line 506: warning: cyclomatic complexity 32 of function (*Scheduler).transferWorkerAndSource() is high (> 15) (gocyclo)
  • Line 1067: warning: cyclomatic complexity 25 of function (*Scheduler).StartRelay() is high (> 15) (gocyclo)
  • Line 1594: warning: cyclomatic complexity 23 of function (*Scheduler).recoverWorkersBounds() is high (> 15) (gocyclo)
  • Line 2010: warning: cyclomatic complexity 22 of function (*Scheduler).tryBoundForSource() is high (> 15) (gocyclo)
  • Line 2292: warning: cyclomatic complexity 19 of function (*Scheduler).getNextLoadTaskTransfer() is high (> 15) (gocyclo)
  • Line 1181: warning: cyclomatic complexity 19 of function (*Scheduler).StopRelay() is high (> 15) (gocyclo)
  • Line 713: warning: cyclomatic complexity 19 of function (*Scheduler).AddSubTasks() is high (> 15) (gocyclo)
  • Line 623: warning: cyclomatic complexity 18 of function (*Scheduler).TransferSource() is high (> 15) (gocyclo)
  • Line 813: warning: cyclomatic complexity 16 of function (*Scheduler).RemoveSubTasks() is high (> 15) (gocyclo)

• dm/pkg/election/election.go
  • Line 201: warning: cyclomatic complexity 23 of function (*Election).campaignLoop() is high (> 15) (gocyclo)

• cdc/kv/client_bench_test.go
  • Line 100: warning: cyclomatic complexity 16 of function prepareBenchMultiStore() is high (> 15) (gocyclo)

• dm/pkg/binlog/event/generator.go
  • Line 35: warning: cyclomatic complexity 16 of function NewGenerator() is high (> 15) (gocyclo)

• cdc/sink/codec/json.go
  • Line 120: warning: cyclomatic complexity 16 of function formatColumnVal() is high (> 15) (gocyclo)

• pkg/config/server_config.go
  • Line 193: warning: cyclomatic complexity 20 of function (*ServerConfig).ValidateAndAdjust() is high (> 15) (gocyclo)

• cdc/sorter/unified/unified_sorter.go
  • Line 110: warning: cyclomatic complexity 18 of function (*Sorter).Run() is high (> 15) (gocyclo)

• dm/pkg/ha/load_task.go
  • Line 95: warning: cyclomatic complexity 17 of function WatchLoadTask() is high (> 15) (gocyclo)

• cdc/sink/codec/canal.go
  • Line 137: warning: cyclomatic complexity 20 of function (*canalEntryBuilder).buildColumn() is high (> 15) (gocyclo)

• cmd/kafka-consumer/main.go
  • Line 377: warning: cyclomatic complexity 23 of function (*Consumer).ConsumeClaim() is high (> 15) (gocyclo)

• dm/syncer/checkpoint.go
  • Line 919: warning: cyclomatic complexity 16 of function (*RemoteCheckPoint).Load() is high (> 15) (gocyclo)
  • Line 604: warning: cyclomatic complexity 16 of function (*RemoteCheckPoint).FlushPointsExcept() is high (> 15) (gocyclo)

• dm/pkg/shardddl/optimism/info.go
  • Line 223: warning: cyclomatic complexity 16 of function WatchInfo() is high (> 15) (gocyclo)

• dm/relay/local_reader.go
  • Line 500: warning: cyclomatic complexity 33 of function (*BinlogReader).parseFile() is high (> 15) (gocyclo)
  • Line 654: warning: cyclomatic complexity 19 of function (*BinlogReader).waitBinlogChanged() is high (> 15) (gocyclo)

• dm/dm/worker/server.go
  • Line 93: warning: cyclomatic complexity 25 of function (*Server).Start() is high (> 15) (gocyclo)
  • Line 264: warning: cyclomatic complexity 20 of function (*Server).observeRelayConfig() is high (> 15) (gocyclo)
  • Line 357: warning: cyclomatic complexity 18 of function (*Server).observeSourceBound() is high (> 15) (gocyclo)

• dm/dm/master/shardddl/pessimist.go
  • Line 280: warning: cyclomatic complexity 20 of function (*Pessimist).UnlockLock() is high (> 15) (gocyclo)

• cdc/entry/codec.go
  • Line 246: warning: cyclomatic complexity 16 of function unflatten() is high (> 15) (gocyclo)

• cdc/model/kv_gen.go
  • Line 62: warning: cyclomatic complexity 19 of function (*RawKVEntry).DecodeMsg() is high (> 15) (gocyclo)
  • Line 241: warning: cyclomatic complexity 19 of function (*RawKVEntry).UnmarshalMsg() is high (> 15) (gocyclo)

• dm/pkg/shardddl/optimism/operation.go
  • Line 226: warning: cyclomatic complexity 16 of function WatchOperationPut() is high (> 15) (gocyclo)

• dm/pkg/binlog/event/util.go
  • Line 381: warning: cyclomatic complexity 25 of function statusVarsToKV() is high (> 15) (gocyclo)

• cdc/entry/schema_storage.go
  • Line 549: warning: cyclomatic complexity 23 of function (*schemaSnapshot).handleDDL() is high (> 15) (gocyclo)

• dm/pkg/shardddl/optimism/lock_test.go
  • Line 53: warning: cyclomatic complexity 21 of function (*testLock).TestLockTrySyncNormal() is high (> 15) (gocyclo)

• dm/dm/master/config.go
  • Line 222: warning: cyclomatic complexity 24 of function (*Config).adjust() is high (> 15) (gocyclo)

• cdc/sink/mysql_syncpoint_store.go
  • Line 41: warning: cyclomatic complexity 21 of function newMySQLSyncpointStore() is high (> 15) (gocyclo)

• cdc/model/schema_storage.go
  • Line 175: warning: cyclomatic complexity 17 of function (*TableInfo).initColumnsFlag() is high (> 15) (gocyclo)
  • Line 67: warning: cyclomatic complexity 16 of function WrapTableInfo() is high (> 15) (gocyclo)

• cdc/sorter/unified/merger.go
  • Line 39: warning: cyclomatic complexity 73 of function runMerger() is high (> 15) (gocyclo)

• tests/integration_tests/dailytest/db.go
  • Line 219: warning: cyclomatic complexity 26 of function genColumnData() is high (> 15) (gocyclo)

• cdc/kv/region_worker.go
  • Line 439: warning: cyclomatic complexity 26 of function (*regionWorker).eventHandler() is high (> 15) (gocyclo)
  • Line 620: warning: cyclomatic complexity 24 of function (*regionWorker).handleEventEntry() is high (> 15) (gocyclo)
  • Line 289: warning: cyclomatic complexity 19 of function (*regionWorker).resolveLock() is high (> 15) (gocyclo)

• dm/syncer/error.go
  • Line 64: warning: cyclomatic complexity 32 of function (*Syncer).handleSpecialDDLError() is high (> 15) (gocyclo)

• cdc/sink/codec/java.go
  • Line 67: warning: cyclomatic complexity 27 of function MysqlToJavaType() is high (> 15) (gocyclo)

• cdc/sink/mysql.go
  • Line 601: warning: cyclomatic complexity 18 of function (*mysqlSink).prepareDMLs() is high (> 15) (gocyclo)
  • Line 83: warning: cyclomatic complexity 16 of function newMySQLSink() is high (> 15) (gocyclo)

• cdc/processor/pipeline/sorter.go
  • Line 86: warning: cyclomatic complexity 25 of function (*sorterNode).Init() is high (> 15) (gocyclo)

• dm/pkg/shardddl/pessimism/operation.go
  • Line 219: warning: cyclomatic complexity 20 of function watchOperation() is high (> 15) (gocyclo)

• cdc/entry/mounter.go
  • Line 440: warning: cyclomatic complexity 16 of function formatColVal() is high (> 15) (gocyclo)

• dm/dm/master/openapi.go
  • Line 408: warning: cyclomatic complexity 18 of function (*Server).DMAPIStartTask() is high (> 15) (gocyclo)

• cdc/kv/client_test.go
  • Line 1503: warning: cyclomatic complexity 18 of function (*clientSuite).TestStreamRecvWithErrorAndResolvedGoBack() is high (> 15) (gocyclo)

• dm/dm/master/server.go
  • Line 1577: warning: cyclomatic complexity 61 of function (*Server).waitOperationOk() is high (> 15) (gocyclo)
  • Line 993: warning: cyclomatic complexity 27 of function (*Server).getStatusFromWorkers() is high (> 15) (gocyclo)
  • Line 1268: warning: cyclomatic complexity 26 of function (*Server).OperateSource() is high (> 15) (gocyclo)
  • Line 2134: warning: cyclomatic complexity 18 of function (*Server).GetCfg() is high (> 15) (gocyclo)
  • Line 408: warning: cyclomatic complexity 17 of function (*Server).StartTask() is high (> 15) (gocyclo)

• dm/syncer/optimist.go
  • Line 64: warning: cyclomatic complexity 30 of function (*Syncer).handleQueryEventOptimistic() is high (> 15) (gocyclo)

• cdc/capture/http_validator.go
  • Line 38: warning: cyclomatic complexity 26 of function verifyCreateChangefeedConfig() is high (> 15) (gocyclo)

• cdc/puller/puller.go
  • Line 106: warning: cyclomatic complexity 23 of function (*pullerImpl).Run() is high (> 15) (gocyclo)

• cdc/sorter/unified/sorter_test.go
  • Line 130: warning: cyclomatic complexity 20 of function testSorter() is high (> 15) (gocyclo)

• dm/dm/master/server_test.go
  • Line 228: warning: cyclomatic complexity 19 of function mockRevelantWorkerClient() is high (> 15) (gocyclo)

• dm/dm/config/subtask.go
  • Line 374: warning: cyclomatic complexity 34 of function (*SubTaskConfig).Adjust() is high (> 15) (gocyclo)

• pkg/p2p/server.go
  • Line 200: warning: cyclomatic complexity 23 of function (*MessageServer).run() is high (> 15) (gocyclo)

• cdc/processor/processor.go
  • Line 517: warning: cyclomatic complexity 23 of function (*processor).handleTableOperation() is high (> 15) (gocyclo)

• cdc/sink/codec/avro.go
  • Line 379: warning: cyclomatic complexity 37 of function columnToAvroNativeData() is high (> 15) (gocyclo)
  • Line 321: warning: cyclomatic complexity 19 of function getAvroDataTypeFromColumn() is high (> 15) (gocyclo)

• tests/integration_tests/dailytest/case.go
  • Line 384: warning: cyclomatic complexity 18 of function updatePKUK() is high (> 15) (gocyclo)

• dm/dm/ctl/ctl.go
  • Line 176: warning: cyclomatic complexity 16 of function MainStart() is high (> 15) (gocyclo)

• dm/dm/worker/subtask.go
  • Line 625: warning: cyclomatic complexity 19 of function (*SubTask).unitTransWaitCondition() is high (> 15) (gocyclo)

• dm/relay/local_reader_test.go
  • Line 427: warning: cyclomatic complexity 19 of function (*testReaderSuite).TestStartSyncByPos() is high (> 15) (gocyclo)

• dm/syncer/dml.go
  • Line 302: warning: cyclomatic complexity 17 of function columnValue() is high (> 15) (gocyclo)

• dm/syncer/ddl.go
  • Line 199: warning: cyclomatic complexity 16 of function adjustCollation() is high (> 15) (gocyclo)

• dm/chaos/cases/task.go
  • Line 330: warning: cyclomatic complexity 36 of function (*task).genIncrData() is high (> 15) (gocyclo)

• cdc/sink/common/flow_control_test.go
  • Line 503: warning: cyclomatic complexity 22 of function BenchmarkTableFlowController() is high (> 15) (gocyclo)
  • Line 174: warning: cyclomatic complexity 22 of function (*flowControlSuite).TestFlowControlBasic() is high (> 15) (gocyclo)
  • Line 314: warning: cyclomatic complexity 20 of function (*flowControlSuite).TestFlowControlCallBack() is high (> 15) (gocyclo)

• pkg/cmd/cli/cli_changefeed_update.go
  • Line 144: warning: cyclomatic complexity 21 of function (*updateChangefeedOptions).applyChanges() is high (> 15) (gocyclo)

golint0%

Golint is a linter for Go source code.

An error occurred while running this test (exit status 2)

license100%

Checks whether your project has a LICENSE file.

No problems detected. Good job!

ineffassign100%

IneffAssign detects ineffectual assignments in Go code.

No problems detected. Good job!

misspell100%

Misspell Finds commonly misspelled English words

No problems detected. Good job!