TyrantLucifer commented on issue #3043:
URL:
https://github.com/apache/incubator-seatunnel/issues/3043#issuecomment-1306765331
According to the disscuss result that in Oct.25 meeting, SeaTunnel
connector modules will use error code when throwing exception.
After the current code of statistics, summarized the following error code:
- seatunnel-api
| code | description |
| ----------------------------- | ------------------------------------ |
| CONFIG_VALIDATION_FAILED | Configuration item validation failed |
| OPTION_VALIDATION_FAILED | Option item validation failed |
| CATALOG_INITIALIZED_FAILED | Catalog initialized failed |
| DATABASE_NOT_EXISTED | Database not existed |
| TABLE_NOT_EXISTED | Table not existed |
| FACTORY_INITIALIZATION_FAILED | Factory initialization failure |
- seatunnel-common
| code | description
|
| ------------------------------ |
------------------------------------------------------------ |
| ENUM_ILLEGAL | This enum is not supported by SeaTunnel
|
| FILE_OPERATION_FAILED | File operation failed, such as
(read,list,write,move,copy,sync) etc... |
| JSON_OPERATION_FAILED | Json covert/parse operation failed
|
| REFLECT_CLASS_OPERATION_FAILED | Reflect class operation failed
|
| SERIALIZE_OPERATION_FAILED | Serialize class operation failed
|
| UNSUPPORTED_OPERATION | Unsupported operation
|
| ILLEGAL_ARGUMENT | Illegal argument
|
| UNSUPPORTED_DATA_TYPE | Unsupported data type
|
| SQL_OPERATION_FAILED | Sql operation failed, such as
(exceute,addBatch,close) etc... |
| TABLE_SCHEMA_GET_FAILED | Get table schema from clickhouse failed
|
| FLUSH_DATA_FAILED | Flush batch data to sink connector failed
|
| WRITER_OPERATION_FAILED | Sink writer operation failed, such as
(open, close) etc... |
| READER_OPERATION_FAILED | Source reader operation failed, such as
(open, close) etc... |
- connector-assert
> AssertConnectorException
| code | description |
| ---------------------- | ---------------------- |
| RULE_VALIDATION_FAILED | Rule validation failed |
- connector-clickhouse
> ClickhouseConnectorException
| code | description
|
| -------------------------------- |
------------------------------------------------------------ |
| TABLE_NOT_FOUND | Cannot get distributed table from
clickhouse |
| TABLE_SCHEMA_GET_FAILED | Get table schema from clickhouse failed
|
| CLUSTER_LIST_GET_FAILED | Get cluster list from clickhouse failed
|
| FIELD_NOT_EXIST_IN_TABLE | Field not exist in table
|
| TABLE_ENGINE_NOT_SUPPORTED | Table engine is not supported
|
| SQL_OPERATION_FAILED | Sql operation failed, such as
(exceute,addBatch,close) etc... |
| SHARD_KEY_NOT_FOUND | Shard key not found in table
|
| PASSWORD_NOT_FOUND_IN_SHARD_NODE | Can’t find password of shard node
|
| FLUSH_DATA_TO_FILE_FAILED | Flush data into clickhouse file failed
|
| FILE_OPERATION_FAILED | File operation failed, such as
(read,list,write,move,copy,sync) etc... |
| SSH_LOGIN_FAILED | Ssh login server failed
|
| UNSUPPORTED_DATA_TYPE | Unsupported data type
|
| JSON_OPERATION_FAILED | Json covert/parse operation failed
|
- connector-amazondynamodb
> AmazonDynamoDBConnectorException
| code | description |
| --------------------- | ----------------------------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| FLUSH_DATA_FAILED | Flush batch data to amazondynamodb failed |
- connector-elasticsearch
> ElasticSearchConnectorException
| code | description
|
| --------------------------- | --------------------------------------------
|
| BULK_RESPONSE_ERROR | Bulk response error
|
| SCROLL_REQUEST_ERROR | Scroll request error
|
| ILLEGAL_ARGUMENT | Illegal argument
|
| UNSUPPORTED_DATA_TYPE | Unsupported data type
|
| JSON_OPERATION_FAILED | Json covert/parse operation failed
|
| GET_ES_VERSION_FAILED | Get elsticsearch version failed
|
| GET_INDEX_DOCS_COUNT_FAILED | Get elsticsearch document index count failed
|
- connector-email
> EmailConnectorException
| code | description
|
| --------------------- |
------------------------------------------------------------ |
| SEND_EMAIL_FAILED | Send email failed
|
| FILE_OPERATION_FAILED | File operation failed, such as
(read,list,write,move,copy,sync) etc... |
- connector-fake
> FakeConnectorException
| code | description |
| --------------------- | --------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
- connector-file
> FileConnectorException
| code | description
|
| ----------------------- |
------------------------------------------------------------ |
| UNSUPPORTED_OPERATION | Unsupported operation
|
| ILLEGAL_ARGUMENT | Illegal argument
|
| FILE_OPERATION_FAILED | File operation failed, such as
(read,list,write,move,copy,sync) etc... |
| UNSUPPORTED_DATA_TYPE | Unsupported data type
|
| WRITER_OPERATION_FAILED | Orc or Parquet writer operation failed, such as
(open, close) etc... |
- connector-hive
> HiveConnectorException
| code | description |
| -------------------- | --------------------------------------- |
| ILLEGAL_ARGUMENT | Illegal argument |
| GET_HDFS_HOST_FAILED | Get hdfs host from hive metadata failed |
| GET_HIVE_META_FAILED | Get hive metadata failed |
- connector-http
> HttpConnectorException
| code | description |
| ---------------- | ---------------- |
| ILLEGAL_ARGUMENT | Illegal argument |
- connector-hudi
> HudiConnectorException
| code | description
|
| -------------------------- |
------------------------------------------------------------ |
| ILLEGAL_ARGUMENT | Illegal argument
|
| WRITER_OPERATION_FAILED | Parquet writer operation failed, such as
(open, close) etc... |
| READ_PARQUET_META_FAILED | Read metadata from parquet file failed
|
| KERBEROS_AUTHORIZED_FAILED | Kerberos authorized failed
|
- connector-iceberg
> IcebergConnectorException
| code | description |
| -------------------------- | ------------------------------------------ |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| ILLEGAL_ARGUMENT | Illegal argument |
| SCAN_ICEBERG_SPLITS_FAILED | Failed to scan iceberg splits from a table |
| UNSUPPORTED_OPERATION | Unsupported operation |
| INVALID_RECORD_OFFSET | Invalid record offset |
- connector-influxdb
> InfluxDBConnectorException
| code | description |
| ----------------------- | --------------------------------------- |
| CONNECT_INFLUXDB_FAILED | Connect influxdb failed |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| GET_COLUMN_INDEX_FAILED | Get column index of query result failed |
| ILLEGAL_ARGUMENT | Illegal argument |
| UNSUPPORTED_OPERATION | Unsupported operation |
- connector-iotdb
> IotDBConnectorException
| code | description |
| --------------------- | ---------------------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| ILLEGAL_ARGUMENT | Illegal argument |
| CONNECT_IOTDB_FAILED | Connect iotdb failed |
| CLOSE_IOTDB_FAILED | Close iotdb failed |
| FLUSH_DATA_FAILED | Flush batch data to iotdb failed |
| RETRY_TIME_EXCEED | The number of retries was exceeded |
| ILLEGAL_ARGUMENT | Illegal argument |
| UNSUPPORTED_OPERATION | Unsupported operation |
- connector-jdbc
> JdbcConnectorException
| code | description
|
| ------------------------------ |
------------------------------------------------------------ |
| CONNECT_DATABASE_FAILED | Connector database failed
|
| GET_DATABASE_LIST_FAILED | Get database list failed
|
| DATABASE_NOT_EXISTED | Database not existed
|
| TABLE_NOT_EXISTED | Table not existed
|
| UNSUPPORTED_DATA_TYPE | Unsupported data type
|
| REFLECT_CLASS_OPERATION_FAILED | Reflect class operation failed
|
| NO_SUITABLE_DRIVER | No suitable driver found
|
| SQL_OPERATION_FAILED | Sql operation failed, such as
(exceute,addBatch,close) etc... |
| XA_EXCEPTION | Xa operation failed, such as (commit,
rollback) etc... |
- connector-kafka
> KafkaConnectorException
| code | description
|
| ------------------------------ |
-------------------------------------------- |
| REFLECT_CLASS_OPERATION_FAILED | Reflect class operation failed
|
| CLOSE_KAFKA_SENDER_FAILED | Close kafka sender failed
|
| ILLEGAL_ARGUMENT | Illegal argument
|
| GENERATE_KAFKA_SPLIT_FAILED | Failed to generate kafka source split
failed |
- connector-kudu
> KuduConnectorException
| code | description |
| ------------------------ | --------------------------------------------- |
| ILLEGAL_ARGUMENT | Illegal argument |
| TABLE_SCHEMA_GET_FAILED | Get table schema from kudu failed |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| GET_KUDU_SCAN_FAILED | Get the Kuduscan object for each split failed |
| CLOSE_KUDU_CLIENT_FAILED | Close kudu client failed |
| OPEN_KUDU_CLIENT_FAILED | Open kudu client failed |
- connector-mongo
> MongoConectorException
| code | description |
| --------------------- | --------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| UNSUPPORTED_OPERATION | Unsupported operation |
- connector-neo4j
> Neo4jConnectorException
| code | desciption |
| --------------------- | --------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
- connector-pulsar
> PulsarConnectorException
| code | description
|
| ---------------------------- |
------------------------------------------------------------ |
| OPEN_PULSAR_ADMIN_FAILED | Open pulsar client failed
|
| OPEN_PULSAR_CLIENT_FAILED | Open pulsar admin failed
|
| PLUSAR_AUTHENTICATION_FAILED | Pulsar authentication failed
|
| SUSCRIBE_TOPIC_FAILED | Subscribe topic from pulsar failed
|
| GET_LAST_CURSOR_FAILED | Get last cursor of pulsar topic failed
|
| GET_TOPIC_PARTITION_FAILED | Get partition information of pulsar topic
failed |
| UNSUPPORTED_OPERATION | Unsupported operation
|
| READER_OPERATION_FAILED | Source reader operation failed, such as
(open, close) etc... |
- connector-redis
> RedisConnectorException
| code | description |
| --------------------- | --------------------- |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
| UNSUPPORTED_OPERATION | Unsupported operation |
| ILLEGAL_ARGUMENT | Illegal argument |
- connector-socket
> SocketConnectorException
| code | description |
| ------------------- | ----------------------------------------- |
| FLUSH_DATA_FAILED | Flush batch data to sink connector failed |
| OPEN_SOCKET_FAILED | Open socket client failed |
| CLOSE_SOCKET_FAILED | Close socket client failed |
- connector-starrocks
> StarRocksConnectorException
| code | description |
| --------------------- | ----------------------------------------- |
| FLUSH_DATA_FAILED | Flush batch data to sink connector failed |
| ILLEGAL_ARGUMENT | Illegal argument |
| UNSUPPORTED_DATA_TYPE | Unsupported data type |
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]