errors.toml

# AUTOGENERATED BY github.com/pingcap/errors/errdoc-gen
# YOU CAN CHANGE THE 'description'/'workaround' FIELDS IF THEM ARE IMPROPER.

["CDC:ErrAPIInvalidParam"]
error = '''
invalid api parameter
'''

["CDC:ErrActorDuplicate"]
error = '''
duplicated actor, already in use
'''

["CDC:ErrActorNotFound"]
error = '''
actor not found
'''

["CDC:ErrActorStopped"]
error = '''
actor stopped
'''

["CDC:ErrAdminStopProcessor"]
error = '''
stop processor by admin command
'''

["CDC:ErrAsyncBroadcastNotSupport"]
error = '''
Async broadcasts not supported
'''

["CDC:ErrAsyncIOCancelled"]
error = '''
asynchronous IO operation is cancelled. Internal use only, report a bug if seen in log
'''

["CDC:ErrAsyncPoolExited"]
error = '''
asyncPool has exited. Report a bug if seen externally.
'''

["CDC:ErrAvroEncodeFailed"]
error = '''
encode to avro native data
'''

["CDC:ErrAvroEncodeToBinary"]
error = '''
encode to binray from native
'''

["CDC:ErrAvroMarshalFailed"]
error = '''
json marshal failed
'''

["CDC:ErrAvroSchemaAPIError"]
error = '''
schema manager API error
'''

["CDC:ErrAvroToEnvelopeError"]
error = '''
to envelope failed
'''

["CDC:ErrAvroUnknownType"]
error = '''
unknown type for Avro: %v
'''

["CDC:ErrBufferLogTimeout"]
error = '''
send row changed events to log buffer timeout
'''

["CDC:ErrBufferReachLimit"]
error = '''
puller mem buffer reach size limit
'''

["CDC:ErrCachedTSONotExists"]
error = '''
GetCachedCurrentVersion: cache entry does not exist
'''

["CDC:ErrCanalDecodeFailed"]
error = '''
canal decode failed
'''

["CDC:ErrCanalEncodeFailed"]
error = '''
canal encode failed
'''

["CDC:ErrCaptureCampaignOwner"]
error = '''
campaign owner failed
'''

["CDC:ErrCaptureNotExist"]
error = '''
capture not exists, %s
'''

["CDC:ErrCaptureNotInitialized"]
error = '''
capture has not been initialized yet
'''

["CDC:ErrCaptureRegister"]
error = '''
capture register to etcd failed
'''

["CDC:ErrCaptureResignOwner"]
error = '''
resign owner failed
'''

["CDC:ErrCaptureSuicide"]
error = '''
capture suicide
'''

["CDC:ErrChangeFeedAlreadyExists"]
error = '''
changefeed already exists, %s
'''

["CDC:ErrChangeFeedNotExists"]
error = '''
changefeed not exists, %s
'''

["CDC:ErrChangefeedAbnormalState"]
error = '''
changefeed in abnormal state: %s, replication status: %+v
'''

["CDC:ErrChangefeedUpdateRefused"]
error = '''
changefeed update error: %s
'''

["CDC:ErrCheckClusterVersionFromPD"]
error = '''
failed to request PD %s, please try again later
'''

["CDC:ErrCheckDataDirSatisfied"]
error = '''
check data dir satisfied failed
'''

["CDC:ErrCheckDirReadable"]
error = '''
check dir readable failed
'''

["CDC:ErrCheckDirValid"]
error = '''
check dir valid failed
'''

["CDC:ErrCheckDirWritable"]
error = '''
check dir writable failed
'''

["CDC:ErrClusterIDMismatch"]
error = '''
cluster ID mismatch, tikv cluster ID is %d and request cluster ID is %d
'''

["CDC:ErrCodecDecode"]
error = '''
codec decode error
'''

["CDC:ErrConsistentLevel"]
error = '''
consistent level (%s) not support
'''

["CDC:ErrConsistentStorage"]
error = '''
consistent storage (%s) not support
'''

["CDC:ErrCraftCodecInvalidData"]
error = '''
craft codec invalid data
'''

["CDC:ErrCreateMarkTableFailed"]
error = '''
create mark table failed
'''

["CDC:ErrDDLEventIgnored"]
error = '''
ddl event is ignored
'''

["CDC:ErrDatumUnflatten"]
error = '''
unflatten datume data
'''

["CDC:ErrDecodeFailed"]
error = '''
decode failed: %s
'''

["CDC:ErrDecodeRowToDatum"]
error = '''
decode row data to datum failed
'''

["CDC:ErrEncodeFailed"]
error = '''
encode failed: %s
'''

["CDC:ErrEtcdIgnore"]
error = '''
this patch should be excluded from the current etcd txn
'''

["CDC:ErrEtcdSessionDone"]
error = '''
the etcd session is done
'''

["CDC:ErrEtcdTryAgain"]
error = '''
the etcd txn should be aborted and retried immediately
'''

["CDC:ErrEtcdTxnOpsExceed"]
error = '''
patch ops:%d of a single changefeed exceed etcd txn max ops:%d
'''

["CDC:ErrEtcdTxnSizeExceed"]
error = '''
patch size:%d of a single changefeed exceed etcd txn max size:%d
'''

["CDC:ErrEventFeedAborted"]
error = '''
single event feed aborted
'''

["CDC:ErrEventFeedEventError"]
error = '''
eventfeed returns event error
'''

["CDC:ErrExecDDLFailed"]
error = '''
exec DDL failed
'''

["CDC:ErrFetchHandleValue"]
error = '''
can't find handle column, please check if the pk is handle
'''

["CDC:ErrFileSizeExceed"]
error = '''
rawData size %d exceeds maximum file size %d
'''

["CDC:ErrFilterRuleInvalid"]
error = '''
filter rule is invalid
'''

["CDC:ErrFlowControllerAborted"]
error = '''
flow controller is aborted
'''

["CDC:ErrFlowControllerEventLargerThanQuota"]
error = '''
event is larger than the total memory quota, size: %d, quota: %d
'''

["CDC:ErrGCTTLExceeded"]
error = '''
the checkpoint-ts(%d) lag of the changefeed(%s) has exceeded the GC TTL
'''

["CDC:ErrGRPCDialFailed"]
error = '''
grpc dial failed
'''

["CDC:ErrGetAllStoresFailed"]
error = '''
get stores from pd failed
'''

["CDC:ErrGetDiskInfo"]
error = '''
get dir disk info failed
'''

["CDC:ErrGetRegionFailed"]
error = '''
get region failed
'''

["CDC:ErrGetStoreSnapshot"]
error = '''
get snapshot failed
'''

["CDC:ErrGetTiKVRPCContext"]
error = '''
get tikv grpc context failed
'''

["CDC:ErrIllegalSorterParameter"]
error = '''
illegal parameter for sorter: %s
'''

["CDC:ErrIndexKeyTableNotFound"]
error = '''
table not found with index ID %d in index kv
'''

["CDC:ErrInternalServerError"]
error = '''
internal server error
'''

["CDC:ErrIntersectNoOverlap"]
error = '''
span doesn't overlap: %+v vs %+v
'''

["CDC:ErrInvalidAdminJobType"]
error = '''
invalid admin job type: %d
'''

["CDC:ErrInvalidChangefeedID"]
error = '''
bad changefeed id, please match the pattern "^[a-zA-Z0-9]+(\-[a-zA-Z0-9]+)*$", the length should no more than %d, eg, "simple-changefeed-task",
'''

["CDC:ErrInvalidDDLJob"]
error = '''
invalid ddl job(%d)
'''

["CDC:ErrInvalidEtcdKey"]
error = '''
invalid key: %s
'''

["CDC:ErrInvalidHost"]
error = '''
host must be a URL or a host:port pair: %q
'''

["CDC:ErrInvalidRecordKey"]
error = '''
invalid record key - %q
'''

["CDC:ErrInvalidS3URI"]
error = '''
invalid s3 uri: %s
'''

["CDC:ErrInvalidServerOption"]
error = '''
invalid server option
'''

["CDC:ErrInvalidTaskKey"]
error = '''
invalid task key: %s
'''

["CDC:ErrKVStorageBackoffFailed"]
error = '''
backoff failed
'''

["CDC:ErrKVStorageRegionError"]
error = '''
req with region error
'''

["CDC:ErrKVStorageRespEmpty"]
error = '''
tikv response body missing
'''

["CDC:ErrKVStorageSendReq"]
error = '''
send req to kv storage
'''

["CDC:ErrKafkaAsyncSendMessage"]
error = '''
kafka async send message failed
'''

["CDC:ErrKafkaBrokerConfigNotFound"]
error = '''
kafka broker config item not found
'''

["CDC:ErrKafkaCreateTopic"]
error = '''
kafka create topic failed
'''

["CDC:ErrKafkaFlushUnfinished"]
error = '''
flush not finished before producer close
'''

["CDC:ErrKafkaInvalidClientID"]
error = '''
invalid kafka client ID '%s'
'''

["CDC:ErrKafkaInvalidConfig"]
error = '''
kafka config invalid
'''

["CDC:ErrKafkaInvalidPartitionNum"]
error = '''
invalid partition num %d
'''

["CDC:ErrKafkaInvalidVersion"]
error = '''
invalid kafka version
'''

["CDC:ErrKafkaNewSaramaProducer"]
error = '''
new sarama producer
'''

["CDC:ErrKafkaSendMessage"]
error = '''
kafka send message failed
'''

["CDC:ErrKafkaTopicExprInvalid"]
error = '''
invalid topic expression
'''

["CDC:ErrKafkaTopicNotExists"]
error = '''
kafka topic not exists after creation
'''

["CDC:ErrLeaseExpired"]
error = '''
owner lease expired 
'''

["CDC:ErrLeaseTimeout"]
error = '''
owner lease timeout
'''

["CDC:ErrLevelDBSorterError"]
error = '''
leveldb error: %s
'''

["CDC:ErrLoadTimezone"]
error = '''
load timezone
'''

["CDC:ErrLocateRegion"]
error = '''
locate region by id
'''

["CDC:ErrMQCodecInvalidConfig"]
error = '''
MQ Codec invalid config
'''

["CDC:ErrMQSinkUnknownProtocol"]
error = '''
unknown '%s' protocol for Message Queue sink
'''

["CDC:ErrMailboxFull"]
error = '''
mailbox is full, please try again. Internal use only, report a bug if seen externally
'''

["CDC:ErrMarshalFailed"]
error = '''
marshal failed
'''

["CDC:ErrMaxwellDecodeFailed"]
error = '''
maxwell decode failed
'''

["CDC:ErrMaxwellEncodeFailed"]
error = '''
maxwell encode failed
'''

["CDC:ErrMaxwellInvalidData"]
error = '''
maxwell invalid data
'''

["CDC:ErrMetaListDatabases"]
error = '''
meta store list databases
'''

["CDC:ErrMetaNotInRegion"]
error = '''
meta not exists in region
'''

["CDC:ErrMySQLConnectionError"]
error = '''
MySQL connection error
'''

["CDC:ErrMySQLInvalidConfig"]
error = '''
MySQL config invalid
'''

["CDC:ErrMySQLQueryError"]
error = '''
MySQL query error
'''

["CDC:ErrMySQLTxnError"]
error = '''
MySQL txn error
'''

["CDC:ErrMySQLWorkerPanic"]
error = '''
MySQL worker panic
'''

["CDC:ErrNewCaptureFailed"]
error = '''
new capture failed
'''

["CDC:ErrNewProcessorFailed"]
error = '''
new processor failed
'''

["CDC:ErrNewSemVersion"]
error = '''
create sem version
'''

["CDC:ErrNewStore"]
error = '''
new store failed
'''

["CDC:ErrNoPendingRegion"]
error = '''
received event regionID %v, requestID %v from %v, but neither pending region nor running region was found
'''

["CDC:ErrNotOwner"]
error = '''
this capture is not a owner
'''

["CDC:ErrOldValueNotEnabled"]
error = '''
old value is not enabled
'''

["CDC:ErrOpenProtocolCodecInvalidData"]
error = '''
open-protocol codec invalid data
'''

["CDC:ErrOpenProtocolCodecRowTooLarge"]
error = '''
open-protocol codec single row too large
'''

["CDC:ErrOperateOnClosedNotifier"]
error = '''
operate on a closed notifier
'''

["CDC:ErrOwnerCampaignKeyDeleted"]
error = '''
owner campaign key deleted
'''

["CDC:ErrOwnerChangedUnexpectedly"]
error = '''
owner changed unexpectedly
'''

["CDC:ErrOwnerChangefeedNotFound"]
error = '''
changefeed %s not found in owner cache
'''

["CDC:ErrOwnerEtcdWatch"]
error = '''
etcd watch returns error
'''

["CDC:ErrOwnerInconsistentStates"]
error = '''
owner encountered inconsistent state. report a bug if this happens frequently. %s
'''

["CDC:ErrOwnerNotFound"]
error = '''
owner not found
'''

["CDC:ErrOwnerSortDir"]
error = '''
owner sort dir
'''

["CDC:ErrOwnerUnknown"]
error = '''
owner running unknown error
'''

["CDC:ErrPDBatchLoadRegions"]
error = '''
pd batch load regions failed
'''

["CDC:ErrPDEtcdAPIError"]
error = '''
etcd api call error
'''

["CDC:ErrPeerMessageClientClosed"]
error = '''
peer-to-peer message client has been closed
'''

["CDC:ErrPeerMessageClientPermanentFail"]
error = '''
peer-to-peer message client has failed permanently, no need to reconnect: %s
'''

["CDC:ErrPeerMessageDataLost"]
error = '''
peer-to-peer message data lost, topic: %s, seq: %d
'''

["CDC:ErrPeerMessageDecodeError"]
error = '''
failed to decode peer-to-peer message
'''

["CDC:ErrPeerMessageDuplicateConnection"]
error = '''
peer-to-peer message duplicate connection: epoch %d
'''

["CDC:ErrPeerMessageEncodeError"]
error = '''
failed to encode peer-to-peer message
'''

["CDC:ErrPeerMessageIllegalClientVersion"]
error = '''
peer-to-peer message client reported illegal version: %s
'''

["CDC:ErrPeerMessageIllegalMeta"]
error = '''
peer-to-peer message server received an RPC call with illegal metadata
'''

["CDC:ErrPeerMessageInjectedServerRestart"]
error = '''
peer-to-peer message server injected error
'''

["CDC:ErrPeerMessageInternalSenderClosed"]
error = '''
peer-to-peer message server tries to send to a closed stream. Internal only.
'''

["CDC:ErrPeerMessageReceiverMismatch"]
error = '''
peer-to-peer message receiver is a mismatch: expected %s, got %s
'''

["CDC:ErrPeerMessageSendTryAgain"]
error = '''
peer-to-peer message client has too many pending messages to send, try again later
'''

["CDC:ErrPeerMessageServerClosed"]
error = '''
peer-to-peer message server has closed connection: %s.
'''

["CDC:ErrPeerMessageStaleConnection"]
error = '''
peer-to-peer message stale connection: old-epoch %d, new-epoch %d
'''

["CDC:ErrPeerMessageTaskQueueCongested"]
error = '''
peer-to-peer message server has too many pending tasks
'''

["CDC:ErrPeerMessageToManyPeers"]
error = '''
peer-to-peer message server got too many peers: %d peers
'''

["CDC:ErrPeerMessageTopicCongested"]
error = '''
peer-to-peer message topic has congested, aborting all connections
'''

["CDC:ErrPendingRegionCancel"]
error = '''
pending region cancelled due to stream disconnecting
'''

["CDC:ErrPipelineTryAgain"]
error = '''
pipeline is full, please try again. Internal use only, report a bug if seen externally
'''

["CDC:ErrPrewriteNotMatch"]
error = '''
prewrite not match, key: %s, start-ts: %d, commit-ts: %d, type: %s, optype: %s
'''

["CDC:ErrProcessorDuplicateOperations"]
error = '''
table processor duplicate operation, table-id: %d
'''

["CDC:ErrProcessorEtcdWatch"]
error = '''
etcd watch returns error
'''

["CDC:ErrProcessorSortDir"]
error = '''
sort dir error
'''

["CDC:ErrProcessorTableNotFound"]
error = '''
table not found in processor cache
'''

["CDC:ErrProcessorUnknown"]
error = '''
processor running unknown error
'''

["CDC:ErrPulsarNewProducer"]
error = '''
new pulsar producer
'''

["CDC:ErrPulsarSendMessage"]
error = '''
pulsar send message failed
'''

["CDC:ErrReachMaxTry"]
error = '''
reach maximum try: %s, error: %s
'''

["CDC:ErrReactorFinished"]
error = '''
the reactor has done its job and should no longer be executed
'''

["CDC:ErrRedoConfigInvalid"]
error = '''
redo log config invalid
'''

["CDC:ErrRedoDownloadFailed"]
error = '''
redo log down load to local failed
'''

["CDC:ErrRedoFileOp"]
error = '''
redo file operation
'''

["CDC:ErrRedoMetaFileNotFound"]
error = '''
no redo meta file found in dir: %s
'''

["CDC:ErrRedoMetaInitialize"]
error = '''
initialize meta for redo log
'''

["CDC:ErrRedoWriterStopped"]
error = '''
redo log writer stopped
'''

["CDC:ErrRegionWorkerExit"]
error = '''
region worker exited
'''

["CDC:ErrRegionsNotCoverSpan"]
error = '''
regions not completely left cover span, span %v regions: %v
'''

["CDC:ErrReplicationSetInconsistent"]
error = '''
replication set inconsistent: %s
'''

["CDC:ErrReplicationSetMultiplePrimaryError"]
error = '''
replication set multiple primary: %s
'''

["CDC:ErrResolveLocks"]
error = '''
resolve locks failed
'''

["CDC:ErrRewindRequestBodyError"]
error = '''
failed to seek to the beginning of request body
'''

["CDC:ErrS3StorageAPI"]
error = '''
s3 storage api
'''

["CDC:ErrS3StorageInitialize"]
error = '''
new s3 storage for redo log
'''

["CDC:ErrScanLockFailed"]
error = '''
scan lock failed
'''

["CDC:ErrSchedulerRequestFailed"]
error = '''
scheduler request failed, %s
'''

["CDC:ErrSchemaSnapshotNotFound"]
error = '''
can not found schema snapshot, ts: %d
'''

["CDC:ErrSchemaStorageGCed"]
error = '''
can not found schema snapshot, the specified ts(%d) is less than gcTS(%d)
'''

["CDC:ErrSchemaStorageTableMiss"]
error = '''
table %d not found
'''

["CDC:ErrSchemaStorageUnresolved"]
error = '''
can not found schema snapshot, the specified ts(%d) is more than resolvedTs(%d)
'''

["CDC:ErrSendToClosedPipeline"]
error = '''
pipeline is closed, cannot send message
'''

["CDC:ErrServeHTTP"]
error = '''
serve http error
'''

["CDC:ErrServerNewPDClient"]
error = '''
server creates pd client failed
'''

["CDC:ErrServiceSafepointLost"]
error = '''
service safepoint lost. current safepoint is %d, please remove all changefeed(s) whose checkpoints are behind the current safepoint
'''

["CDC:ErrSinkInvalidConfig"]
error = '''
sink config invalid
'''

["CDC:ErrSinkURIInvalid"]
error = '''
sink uri invalid
'''

["CDC:ErrSnapshotLostByGC"]
error = '''
fail to create or maintain changefeed due to snapshot loss caused by GC. checkpoint-ts %d is earlier than or equal to GC safepoint at %d
'''

["CDC:ErrSnapshotSchemaExists"]
error = '''
schema %s(%d) already exists
'''

["CDC:ErrSnapshotSchemaNotFound"]
error = '''
schema %d not found in schema snapshot
'''

["CDC:ErrSnapshotTableExists"]
error = '''
table %s.%s already exists
'''

["CDC:ErrSnapshotTableNotFound"]
error = '''
table %d not found in schema snapshot
'''

["CDC:ErrSorterClosed"]
error = '''
sorter is closed
'''

["CDC:ErrStartAStoppedLevelDBSystem"]
error = '''
start a stopped leveldb system
'''

["CDC:ErrStartTsBeforeGC"]
error = '''
fail to create changefeed because start-ts %d is earlier than GC safepoint at %d
'''

["CDC:ErrSupportGetOnly"]
error = '''
this api supports GET method only
'''

["CDC:ErrSupportPostOnly"]
error = '''
this api supports POST method only
'''

["CDC:ErrTCPServerClosed"]
error = '''
The TCP server has been closed
'''

["CDC:ErrTableIneligible"]
error = '''
some tables are not eligible to replicate(%v), if you want to ignore these tables, please set ignore_ineligible_table to true
'''

["CDC:ErrTableListenReplicated"]
error = '''
A table(%d) is being replicated by at least two processors(%s, %s), please report a bug
'''

["CDC:ErrTableProcessorStoppedSafely"]
error = '''
table processor stopped safely
'''

["CDC:ErrTargetTsBeforeStartTs"]
error = '''
fail to create changefeed because target-ts %d is earlier than start-ts %d
'''

["CDC:ErrTaskPositionNotExists"]
error = '''
task position not exists, %s
'''

["CDC:ErrTaskStatusNotExists"]
error = '''
task status not exists, %s
'''

["CDC:ErrTiKVEventFeed"]
error = '''
tikv event feed failed
'''

["CDC:ErrToTLSConfigFailed"]
error = '''
generate tls config failed
'''

["CDC:ErrURLFormatInvalid"]
error = '''
url format is invalid
'''

["CDC:ErrUnexpectedSnapshot"]
error = '''
unexpected snapshot, table %d
'''

["CDC:ErrUnifiedSorterBackendTerminating"]
error = '''
unified sorter backend is terminating
'''

["CDC:ErrUnifiedSorterIOError"]
error = '''
unified sorter IO error. Make sure your sort-dir is configured correctly by passing a valid argument or toml file to `cdc server`, or if you use TiUP, review the settings in `tiup cluster edit-config`. Details: %s
'''

["CDC:ErrUnimplemented"]
error = '''
unimplemented %s
'''

["CDC:ErrUnknownKVEventType"]
error = '''
unknown kv optype: %s, entry: %v
'''

["CDC:ErrUnknownMetaType"]
error = '''
unknown meta type %v
'''

["CDC:ErrUnknownSortEngine"]
error = '''
unknown sort engine %s
'''

["CDC:ErrUnmarshalFailed"]
error = '''
unmarshal failed
'''

["CDC:ErrUpdateServiceSafepointFailed"]
error = '''
updating service safepoint failed
'''

["CDC:ErrUpstreamNotFound"]
error = '''
upstream not found, cluster-id: %d
'''

["CDC:ErrVersionIncompatible"]
error = '''
version is incompatible: %s
'''

["CDC:ErrWaitHandleOperationTimeout"]
error = '''
waiting processor to handle the operation finished timeout
'''

["CDC:ErrWorkerPoolGracefulUnregisterTimedOut"]
error = '''
workerpool handle graceful unregister timed out
'''

["CDC:ErrWorkerPoolHandleCancelled"]
error = '''
workerpool handle is cancelled
'''

["CDC:ErrWriteTsConflict"]
error = '''
write ts conflict
'''

["CDC:ErrWrongTableInfo"]
error = '''
wrong table info in unflatten, table id %d, index table id: %d
'''

["CDC:ErrZeroLengthResponseBody"]
error = '''
0-length response with status code: %d
'''

["DFLOW:ErrBuildJobFailed"]
error = '''
build job failed
'''

["DFLOW:ErrCleaningLocalTempFiles"]
error = '''
errors is encountered when cleaning local temp files
'''

["DFLOW:ErrClusterResourceNotEnough"]
error = '''
cluster resource is not enough, please scale out the cluster
'''

["DFLOW:ErrCreateLocalFileDirectoryFailed"]
error = '''
creating local file resource directory failed
'''

["DFLOW:ErrDatasetEntryNotFound"]
error = '''
dataset entry not found. Key: %s
'''

["DFLOW:ErrDecodeEtcdKeyFail"]
error = '''
failed to decode etcd key: %s
'''

["DFLOW:ErrDecodeEtcdValueFail"]
error = '''
failed to decode etcd value: %s
'''

["DFLOW:ErrDiscoveryDuplicateWatch"]
error = '''
service discovery can't be watched multiple times
'''

["DFLOW:ErrDuplicateResourceID"]
error = '''
duplicate resource ID: %s
'''

["DFLOW:ErrDuplicateWorkerID"]
error = '''
duplicate worker ID encountered: %s, report a bug
'''

["DFLOW:ErrEtcdAPIError"]
error = '''
etcd api returns error
'''

["DFLOW:ErrEtcdLeaderChanged"]
error = '''
etcd leader has changed
'''

["DFLOW:ErrExecutorConfigInvalidFlag"]
error = '''
'%s' is an invalid flag
'''

["DFLOW:ErrExecutorConfigParseFlagSet"]
error = '''
parse config flag set failed
'''

["DFLOW:ErrExecutorConfigUnknownItem"]
error = '''
master config contains unknown configuration options: %s
'''

["DFLOW:ErrExecutorConfirmDispatchFailed"]
error = '''
ConfirmDispatch failed
'''

["DFLOW:ErrExecutorDecodeConfigFile"]
error = '''
decode config file failed
'''

["DFLOW:ErrExecutorDupRegister"]
error = '''
executor %s has been registered
'''

["DFLOW:ErrExecutorEtcdConnFail"]
error = '''
executor conn inner etcd fail
'''

["DFLOW:ErrExecutorNotFoundForMessage"]
error = '''
cannot find the executor for p2p messaging
'''

["DFLOW:ErrExecutorPreDispatchFailed"]
error = '''
PreDispatchTask failed
'''

["DFLOW:ErrExecutorSessionDone"]
error = '''
executor %s session done
'''

["DFLOW:ErrFailToCreateExternalStorage"]
error = '''
failed to create external storage
'''

["DFLOW:ErrGrpcBuildConn"]
error = '''
dial grpc connection to %s failed
'''

["DFLOW:ErrHeartbeat"]
error = '''
heartbeat error type: %s
'''

["DFLOW:ErrIllegalResourcePath"]
error = '''
resource path is illegal: %s
'''

["DFLOW:ErrInvalidCliParameter"]
error = '''
invalid cli parameters
'''

["DFLOW:ErrInvalidJobType"]
error = '''
invalid job type: %s
'''

["DFLOW:ErrInvalidMasterMessage"]
error = '''
invalid master message: %s
'''

["DFLOW:ErrInvalidMetaStoreKey"]
error = '''
invalid metastore key %s
'''

["DFLOW:ErrInvalidMetaStoreKeyTp"]
error = '''
invalid metastore key type %s
'''

["DFLOW:ErrInvalidResourceHandle"]
error = '''
using an invalid resource handle
'''

["DFLOW:ErrInvalidServerMasterID"]
error = '''
invalid server master id: %s
'''

["DFLOW:ErrInvalidWorkerType"]
error = '''
invalid worker type: %s
'''

["DFLOW:ErrLeaderCtxCanceled"]
error = '''
leader context is canceled
'''

["DFLOW:ErrLocalFileDirNotWritable"]
error = '''
local resource directory not writable
'''

["DFLOW:ErrMasterCampaignLeader"]
error = '''
master campaign to be leader failed
'''

["DFLOW:ErrMasterClosed"]
error = '''
master has been closed explicitly: master ID %s
'''

["DFLOW:ErrMasterConcurrencyExceeded"]
error = '''
master has reached concurrency quota
'''

["DFLOW:ErrMasterConfigInvalidFlag"]
error = '''
'%s' is an invalid flag
'''

["DFLOW:ErrMasterConfigParseFlagSet"]
error = '''
parse config flag set failed
'''

["DFLOW:ErrMasterConfigUnknownItem"]
error = '''
master config contains unknown configuration options: %s
'''

["DFLOW:ErrMasterDecodeConfigFile"]
error = '''
decode config file failed
'''

["DFLOW:ErrMasterEtcdCreateSessionFail"]
error = '''
failed to create Etcd session
'''

["DFLOW:ErrMasterEtcdElectionCampaignFail"]
error = '''
failed to campaign for leader
'''

["DFLOW:ErrMasterEtcdEpochFail"]
error = '''
server master generate epoch fail
'''

["DFLOW:ErrMasterGenEmbedEtcdConfigFail"]
error = '''
master gen embed etcd config failed: %s
'''

["DFLOW:ErrMasterInterfaceNotFound"]
error = '''
basemaster interface not found
'''

["DFLOW:ErrMasterInvalidMeta"]
error = '''
invalid master meta data: %s
'''

["DFLOW:ErrMasterJoinEmbedEtcdFail"]
error = '''
failed to join embed etcd: %s
'''

["DFLOW:ErrMasterNewServer"]
error = '''
master create new server failed
'''

["DFLOW:ErrMasterNoLeader"]
error = '''
server master has no leader
'''

["DFLOW:ErrMasterNotFound"]
error = '''
master is not found: master ID %s
'''

["DFLOW:ErrMasterNotInitialized"]
error = '''
master is not initialized
'''

["DFLOW:ErrMasterParseURLFail"]
error = '''
failed to parse URL %s
'''

["DFLOW:ErrMasterRPCNotForward"]
error = '''
server grpc is not forwarded to leader
'''

["DFLOW:ErrMasterScheduleMissTask"]
error = '''
task %d is not found after scheduling
'''

["DFLOW:ErrMasterSessionDone"]
error = '''
master session is done
'''

["DFLOW:ErrMasterStartEmbedEtcdFail"]
error = '''
failed to start embed etcd
'''

["DFLOW:ErrMasterTooManyPendingEvents"]
error = '''
master has too many pending events
'''

["DFLOW:ErrMessageClientNotFoundForWorker"]
error = '''
peer message client is not found for worker: worker ID %s
'''

["DFLOW:ErrMetaCommittedTxn"]
error = '''
meta already committed txn
'''

["DFLOW:ErrMetaEmptyKey"]
error = '''
meta empty key
'''

["DFLOW:ErrMetaEntryAlreadyExists"]
error = '''
meta entry already exists
'''

["DFLOW:ErrMetaEntryNotFound"]
error = '''
meta entry not found
'''

["DFLOW:ErrMetaNestedTxn"]
error = '''
meta unsupported nested txn
'''

["DFLOW:ErrMetaNewClientFail"]
error = '''
create meta client fail
'''

["DFLOW:ErrMetaOpFail"]
error = '''
meta operation fail
'''

["DFLOW:ErrMetaOptionConflict"]
error = '''
WithRange/WithPrefix/WithFromKey, more than one option are used
'''

["DFLOW:ErrMetaOptionInvalid"]
error = '''
meta option invalid
'''

["DFLOW:ErrMetaParamsInvalid"]
error = '''
meta params invalid:%s
'''

["DFLOW:ErrMetaRevisionUnmatch"]
error = '''
meta revision unmatch
'''

["DFLOW:ErrMetaStoreIDDuplicate"]
error = '''
metastore id duplicated
'''

["DFLOW:ErrMetaStoreUnfounded"]
error = '''
metastore unfounded:%s
'''

["DFLOW:ErrNoRPCClient"]
error = '''
no available RPC client
'''

["DFLOW:ErrOperatorUnknown"]
error = '''
operator type %d is unknown
'''

["DFLOW:ErrPlannerDAGDepthExceeded"]
error = '''
dag depth exceeded: %d
'''

["DFLOW:ErrReadLocalFileDirectoryFailed"]
error = '''
reading local file resource directory failed
'''

["DFLOW:ErrRemovingLocalResource"]
error = '''
removing a local resource file directory has failed
'''

["DFLOW:ErrResourceDoesNotExist"]
error = '''
resource does not exists: %s
'''

["DFLOW:ErrRuntimeClosed"]
error = '''
runtime has been closed
'''

["DFLOW:ErrRuntimeDuplicateTaskID %s"]
error = '''
trying to add a task with the same ID as an existing one
'''

["DFLOW:ErrRuntimeIncomingQueueFull"]
error = '''
runtime has too many pending CreateWorker requests
'''

["DFLOW:ErrRuntimeInitQueuingTimeOut"]
error = '''
a task has waited too long to be initialized
'''

["DFLOW:ErrRuntimeIsClosed"]
error = '''
runtime has been closed
'''

["DFLOW:ErrRuntimeReachedCapacity"]
error = '''
runtime has reached its capacity %d
'''

["DFLOW:ErrSendingMessageToTombstone"]
error = '''
trying to send message to a tombstone worker handle: %s
'''

["DFLOW:ErrSubJobFailed"]
error = '''
executor %s job %d
'''

["DFLOW:ErrTaskNotFound"]
error = '''
task %d is not found
'''

["DFLOW:ErrTombstoneExecutor"]
error = '''
executor %s has been dead
'''

["DFLOW:ErrTooManyStatusUpdates"]
error = '''
there are too many pending worker status updates: %d
'''

["DFLOW:ErrUnexpectedResourcePath"]
error = '''
unexpected resource path: %s
'''

["DFLOW:ErrUnknownExecutorID"]
error = '''
cannot find executor ID: %s
'''

["DFLOW:ErrWorkerFinish"]
error = '''
worker finished and exited
'''

["DFLOW:ErrWorkerHalfExit"]
error = '''
the worker is in half-exited state
'''

["DFLOW:ErrWorkerNoMeta"]
error = '''
worker metadata does not exist
'''

["DFLOW:ErrWorkerNotFound"]
error = '''
worker is not found: worker ID %s
'''

["DFLOW:ErrWorkerOffline"]
error = '''
worker is offline: workerID: %s, error message: %s
'''

["DFLOW:ErrWorkerStop"]
error = '''
worker is stopped
'''

["DFLOW:ErrWorkerSuicide"]
error = '''
worker has committed suicide due to master(%s) having timed out
'''

["DFLOW:ErrWorkerTimedOut"]
error = '''
worker heartbeat timed out: workerID %s
'''

["DFLOW:ErrWorkerTypeNotFound"]
error = '''
worker type is not found: type %d
'''

["DFLOW:ErrWorkerUpdateStatusTryAgain"]
error = '''
worker should try again in updating the status
'''

["DLFOW:ErrResourceManagerNotReady"]
error = '''
resource manager is not ready
'''

["ErrConflictingFileLocks"]
error = '''
file lock conflict: %s
'''

["ErrRequestForwardErr"]
error = '''
request forward error, an request can only forward to owner one time
'''

["ErrSortDirLockError"]
error = '''
error encountered when locking sort-dir
'''