errors.toml

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

["CDC:ErrAPIGetPDClientFailed"]
error = '''
failed to get PDClient to connect PD, please recheck
'''

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

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

["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:ErrAvroInvalidMessage"]
error = '''
avro invalid message format, %s
'''

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

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

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

["CDC:ErrCSVDecodeFailed"]
error = '''
csv decode failed
'''

["CDC:ErrCSVEncodeFailed"]
error = '''
csv encode failed
'''

["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:ErrChangeFeedDeletionUnfinished"]
error = '''
changefeed exists after deletion, %s
'''

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

["CDC:ErrChangefeedUnretryable"]
error = '''
changefeed is in unretryable state, please check the error message, and you should manually handle it
'''

["CDC:ErrChangefeedUpdateFailed"]
error = '''
changefeed update failed due to unexpected etcd transaction failure: %s
'''

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

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

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

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

["CDC:ErrCliAborted"]
error = '''
command '%s' is aborted by user
'''

["CDC:ErrCliCheckpointTsIsInFuture"]
error = '''
the overwrite-checkpoint-ts %d must be smaller than current TSO
'''

["CDC:ErrCliInvalidCheckpointTs"]
error = '''
invalid overwrite-checkpoint-ts %s, overwrite-checkpoint-ts only accept 'now' or a valid timestamp in integer
'''

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

["CDC:ErrClusterIsUnhealthy"]
error = '''
TiCDC cluster is unhealthy
'''

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

["CDC:ErrCodecInvalidConfig"]
error = '''
Codec invalid config
'''

["CDC:ErrCompressionFailed"]
error = '''
Compression failed
'''

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

["CDC:ErrConvertDDLToEventTypeFailed"]
error = '''
failed to convert ddl '%s' to filter event type
'''

["CDC:ErrCorruptedDataMutation"]
error = '''
Changefeed %s.%s stopped due to corrupted data mutation received. Corrupted mutation detail information %+v
'''

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

["CDC:ErrDDLSchemaNotFound"]
error = '''
cannot find mysql.tidb_ddl_job schema
'''

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

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

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

["CDC:ErrDiskFull"]
error = '''
failed to preallocate file because disk is full
'''

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

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

["CDC:ErrEtcdMigrateFailed"]
error = '''
etcd meta data migrate failed:%s
'''

["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:ErrExchangePartition"]
error = '''
exchange partition failed, %s
'''

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

["CDC:ErrExpressionColumnNotFound"]
error = '''
invalid filter expression(s). Cannot find column '%s' from table '%s' in: %s
'''

["CDC:ErrFailedToFilterDML"]
error = '''
failed to filter dml event: %v, please report a bug
'''

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

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

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

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

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

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

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

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

["CDC:ErrHandleDDLFailed"]
error = '''
handle ddl failed, job: %s, query: %s, startTs: %d. If you want to skip this DDL and continue with replication, you can manually execute this DDL downstream. Afterwards, add `ignore-txn-start-ts=[%d]` to the changefeed in the filter configuration.
'''

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

["CDC:ErrIncompatibleConfig"]
error = '''
incompatible configuration
'''

["CDC:ErrIncompatibleSinkConfig"]
error = '''
incompatible configuration in sink uri(%s) and config file(%s), please try to update the configuration only through sink uri
'''

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

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

["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:ErrInvalidCheckpointTs"]
error = '''
checkpointTs(%v) should not larger than resolvedTs(%v)
'''

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

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

["CDC:ErrInvalidFilterExpression"]
error = '''
invalid filter expressions. There is a syntax error in: '%s'
'''

["CDC:ErrInvalidGlueSchemaRegistryConfig"]
error = '''
invalid glue schema registry config, %s
'''

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

["CDC:ErrInvalidIgnoreEventType"]
error = '''
invalid ignore event type: '%s'
'''

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

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

["CDC:ErrInvalidReplicaConfig"]
error = '''
invalid replica config, %s
'''

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

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

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

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

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

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

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

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

["CDC:ErrKafkaInvalidRequiredAcks"]
error = '''
invalid required acks %d, only support these values: 0(NoResponse),1(WaitForLocal) and -1(WaitForAll)
'''

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

["CDC:ErrKafkaNewProducer"]
error = '''
new kafka producer
'''

["CDC:ErrKafkaProducerClosed"]
error = '''
kafka producer closed
'''

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

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

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

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

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

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

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

["CDC:ErrMessageTooLarge"]
error = '''
message is too large
'''

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

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

["CDC:ErrMetaOpIgnored"]
error = '''
rows affected by the operation %s is unexpected: expected %d, got %d
'''

["CDC:ErrMultipleCDCClustersExist"]
error = '''
multiple TiCDC clusters exist while using --pd
'''

["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: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:ErrNotController"]
error = '''
not controller
'''

["CDC:ErrNotLeader"]
error = '''
%s is not leader
'''

["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:ErrOperateOnClosedNotifier"]
error = '''
operate on a closed notifier
'''

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

["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: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:ErrPrewriteNotMatch"]
error = '''
prewrite not match, key: %s, start-ts: %d, commit-ts: %d, type: %s, optype: %s
'''

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

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

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

["CDC:ErrPulsarBrokerConfigNotFound"]
error = '''
pulsar broker config item not found
'''

["CDC:ErrPulsarCreateTopic"]
error = '''
pulsar create topic failed
'''

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

["CDC:ErrPulsarInvalidClientID"]
error = '''
invalid pulsar client ID '%s'
'''

["CDC:ErrPulsarInvalidConfig"]
error = '''
pulsar config invalid
'''

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

["CDC:ErrPulsarInvalidVersion"]
error = '''
invalid pulsar version
'''

["CDC:ErrPulsarNewClient"]
error = '''
new pulsar client
'''

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

["CDC:ErrPulsarProducerClosed"]
error = '''
pulsar producer closed
'''

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

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

["CDC:ErrPulsarTopicNotExists"]
error = '''
pulsar topic not exists after creation
'''

["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:ErrRewindRequestBodyError"]
error = '''
failed to seek to the beginning of request body
'''

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

["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:ErrServeHTTP"]
error = '''
serve http error
'''

["CDC:ErrServerIsNotReady"]
error = '''
cdc server is not ready
'''

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

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

["CDC:ErrSinkUnknownProtocol"]
error = '''
unknown '%s' message protocol for sink
'''

["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:ErrStartTsBeforeGC"]
error = '''
fail to create or maintain changefeed because start-ts %d is earlier than or equal to GC safepoint at %d
'''

["CDC:ErrStorageInitialize"]
error = '''
fail to open storage for redo log
'''

["CDC:ErrStorageSinkInvalidConfig"]
error = '''
storage sink config invalid
'''

["CDC:ErrStorageSinkInvalidDateSeparator"]
error = '''
date separator in storage sink is invalid
'''

["CDC:ErrStorageSinkInvalidFileName"]
error = '''
filename in storage sink is invalid
'''

["CDC:ErrSyncRenameTableFailed"]
error = '''
table's old name is not in filter rule, and its new name in filter rule table id '%d', ddl query: [%s], it's an unexpected behavior, if you want to replicate this table, please add its old name to filter rule.
'''

["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:ErrTargetTsBeforeStartTs"]
error = '''
fail to create changefeed because target-ts %d is earlier than start-ts %d
'''

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

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

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

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

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

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

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

["CDC:ErrUpstreamClosed"]
error = '''
upstream has been closed
'''

["CDC:ErrUpstreamHasRunningImport"]
error = '''
upstream has running import tasks, upstream-id: %d
'''

["CDC:ErrUpstreamManagerNotReady"]
error = '''
upstream manager not ready
'''

["CDC:ErrUpstreamMissMatch"]
error = '''
upstream missmatch,old: %d, new %d
'''

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

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

["CDC:ErrWaitFreeMemoryTimeout"]
error = '''
wait free memory timeout
'''

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

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

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

["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:ErrCreateWorkerNonTerminate"]
error = '''
create worker is not terminated
'''

["DFLOW:ErrCreateWorkerTerminate"]
error = '''
create worker is terminated
'''

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

["DFLOW:ErrDeserializeConfig"]
error = '''
deserialize config failed
'''

["DFLOW:ErrDispatchTaskRequestIDNotFound"]
error = '''
dispatch task request id %s not found
'''

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

["DFLOW:ErrElectionRecordConflict"]
error = '''
election record conflict
'''

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

["DFLOW:ErrExecutorAlreadyExists"]
error = '''
executor %s already exists
'''

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

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

["DFLOW:ErrExecutorNotFound"]
error = '''
executor %s not found
'''

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

["DFLOW:ErrExecutorWatcherClosed"]
error = '''
executor watcher is closed
'''

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

["DFLOW:ErrFilterNoResult"]
error = '''
filter % returns no result
'''

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

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

["DFLOW:ErrIncompatibleSchedulerRequest"]
error = '''
incompatible scheduler request: %s
'''

["DFLOW:ErrInvalidArgument"]
error = '''
invalid argument: %s
'''

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

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

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

["DFLOW:ErrJobAlreadyCanceled"]
error = '''
job %s is already canceled
'''

["DFLOW:ErrJobAlreadyExists"]
error = '''
job %s already exists
'''

["DFLOW:ErrJobManagerGetJobDetailFail"]
error = '''
failed to get job detail from job master
'''

["DFLOW:ErrJobNotFound"]
error = '''
job %s is not found
'''

["DFLOW:ErrJobNotRunning"]
error = '''
job %s is not running
'''

["DFLOW:ErrJobNotTerminated"]
error = '''
job %s is not terminated
'''

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

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

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

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

["DFLOW:ErrMasterCreateWorkerBackoff"]
error = '''
create worker is being backoff, retry later
'''

["DFLOW:ErrMasterCreateWorkerTerminate"]
error = '''
create worker is terminated, won't backoff any more
'''

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

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

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

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

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

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

["DFLOW:ErrMasterNotReady"]
error = '''
master is not ready
'''

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

["DFLOW:ErrMetaClientTypeNotSupport"]
error = '''
meta client type not support:%s
'''

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

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

["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:ErrMetaStoreIDDuplicate"]
error = '''
metastore id duplicated
'''

["DFLOW:ErrMetaStoreNotExists"]
error = '''
metastore %s does not exist
'''

["DFLOW:ErrNoQualifiedExecutor"]
error = '''
no executor is available for scheduling
'''

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

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

["DFLOW:ErrResourceAlreadyExists"]
error = '''
resource %s already exists
'''

["DFLOW:ErrResourceConflict"]
error = '''
resource % on executor %s conflicts with resource %s on executor %s
'''

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

["DFLOW:ErrResourceFilesNotFound"]
error = '''
resource files not found
'''

["DFLOW:ErrResourceMetastoreError"]
error = '''
resource metastore error
'''

["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:ErrRuntimeIsClosed"]
error = '''
runtime has been closed
'''

["DFLOW:ErrSelectorUnsatisfied"]
error = '''
selector %v is not satisfied
'''

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

["DFLOW:ErrTombstoneExecutor"]
error = '''
tombstone executor: %s
'''

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

["DFLOW:ErrUnknown"]
error = '''
unknown error
'''

["DFLOW:ErrUnknownExecutor"]
error = '''
unknown executor: %s
'''

["DFLOW:ErrWorkerCancel"]
error = '''
worker is canceled
'''

["DFLOW:ErrWorkerFailed"]
error = '''
worker is failed permanently
'''

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

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

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

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

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

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

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

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

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