使用cdc 整库同步 从sqlserver到doris,建表语句出现DEFAULT '('')'

Viewed 71

①flink 异常:
The program finished with the following exception:

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: SQL query could not be executed: CREATE TABLE IF NOT EXISTS finebi.PM_P_Transfer(Id VARCHAR(192) COMMENT '',UserId VARCHAR(192) COMMENT '',IntoFactory VARCHAR(192) COMMENT '',IntoDpt VARCHAR(192) COMMENT '',IntoPost VARCHAR(192) COMMENT '',IntoPostId VARCHAR(192) COMMENT '',OutFactory VARCHAR(192) COMMENT '',OutDpt VARCHAR(192) COMMENT '',OutPost VARCHAR(192) COMMENT '',OutPostId VARCHAR(192) COMMENT '',Reason VARCHAR(768) COMMENT '',TransferDate DATETIMEV2(3) COMMENT '',ContractNature VARCHAR(192) COMMENT '',IntoJobType VARCHAR(192) COMMENT '',IntoDptId VARCHAR(192) COMMENT '',OutJobType VARCHAR(192) COMMENT '',OutDptId VARCHAR(192) COMMENT '',CreateDate DATETIMEV2(3) COMMENT '',CreateId VARCHAR(192) COMMENT '',ApprovalState VARCHAR(192) COMMENT '',AttendGroupId VARCHAR(192) COMMENT '',ApprovalDate DATETIMEV2(3) DEFAULT '('')' COMMENT '',TransferType VARCHAR(192) COMMENT '',Remark VARCHAR(765) COMMENT '' ) UNIQUE KEY(Id) DISTRIBUTED BY HASH(Id) BUCKETS AUTO PROPERTIES ('replication_num'='1','light_schema_change'='true')
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1878)
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
Caused by: org.apache.doris.flink.exception.DorisSystemException: SQL query could not be executed: CREATE TABLE IF NOT EXISTS finebi.PM_P_Transfer(Id VARCHAR(192) COMMENT '',UserId VARCHAR(192) COMMENT '',IntoFactory VARCHAR(192) COMMENT '',IntoDpt VARCHAR(192) COMMENT '',IntoPost VARCHAR(192) COMMENT '',IntoPostId VARCHAR(192) COMMENT '',OutFactory VARCHAR(192) COMMENT '',OutDpt VARCHAR(192) COMMENT '',OutPost VARCHAR(192) COMMENT '',OutPostId VARCHAR(192) COMMENT '',Reason VARCHAR(768) COMMENT '',TransferDate DATETIMEV2(3) COMMENT '',ContractNature VARCHAR(192) COMMENT '',IntoJobType VARCHAR(192) COMMENT '',IntoDptId VARCHAR(192) COMMENT '',OutJobType VARCHAR(192) COMMENT '',OutDptId VARCHAR(192) COMMENT '',CreateDate DATETIMEV2(3) COMMENT '',CreateId VARCHAR(192) COMMENT '',ApprovalState VARCHAR(192) COMMENT '',AttendGroupId VARCHAR(192) COMMENT '',ApprovalDate DATETIMEV2(3) DEFAULT '('')' COMMENT '',TransferType VARCHAR(192) COMMENT '',Remark VARCHAR(765) COMMENT '' ) UNIQUE KEY(Id) DISTRIBUTED BY HASH(Id) BUCKETS AUTO PROPERTIES ('replication_num'='1','light_schema_change'='true')
at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:131)
at org.apache.doris.flink.catalog.doris.DorisSystem.createTable(DorisSystem.java:122)
at org.apache.doris.flink.tools.cdc.DatabaseSync.build(DatabaseSync.java:145)
at org.apache.doris.flink.tools.cdc.CdcTools.syncDatabase(CdcTools.java:146)
at org.apache.doris.flink.tools.cdc.CdcTools.createSqlServerSyncDatabase(CdcTools.java:101)
at org.apache.doris.flink.tools.cdc.CdcTools.main(CdcTools.java:60)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
... 12 more
Caused by: java.sql.SQLException: errCode = 2, detailMessage = date literal [(')] is invalid: null
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:763)
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648)
at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:128)
... 22 more

②cdc自动生成的建表语句:
CREATE TABLE IF NOT EXISTS finebi.PM_P_Transfer (
Id VARCHAR ( 192 ) COMMENT '',
UserId VARCHAR ( 192 ) COMMENT '',
IntoFactory VARCHAR ( 192 ) COMMENT '',
IntoDpt VARCHAR ( 192 ) COMMENT '',
IntoPost VARCHAR ( 192 ) COMMENT '',
IntoPostId VARCHAR ( 192 ) COMMENT '',
OutFactory VARCHAR ( 192 ) COMMENT '',
OutDpt VARCHAR ( 192 ) COMMENT '',
OutPost VARCHAR ( 192 ) COMMENT '',
OutPostId VARCHAR ( 192 ) COMMENT '',
Reason VARCHAR ( 768 ) COMMENT '',
TransferDate DATETIMEV2 ( 3 ) COMMENT '',
ContractNature VARCHAR ( 192 ) COMMENT '',
IntoJobType VARCHAR ( 192 ) COMMENT '',
IntoDptId VARCHAR ( 192 ) COMMENT '',
OutJobType VARCHAR ( 192 ) COMMENT '',
OutDptId VARCHAR ( 192 ) COMMENT '',
CreateDate DATETIMEV2 ( 3 ) COMMENT '',
CreateId VARCHAR ( 192 ) COMMENT '',
ApprovalState VARCHAR ( 192 ) COMMENT '',
AttendGroupId VARCHAR ( 192 ) COMMENT '',
ApprovalDate DATETIMEV2 ( 3 ) DEFAULT '('')' COMMENT '',
TransferType VARCHAR ( 192 ) COMMENT '',
Remark VARCHAR ( 765 ) COMMENT ''
) UNIQUE KEY ( Id ) DISTRIBUTED BY HASH ( Id ) BUCKETS AUTO PROPERTIES ( 'replication_num' = '1', 'light_schema_change' = 'true' )

③sqlserver ddl:
CREATE TABLE [dbo].[PM_P_Transfer] (
[Id] nvarchar(64) COLLATE Chinese_PRC_CI_AS NOT NULL,
[UserId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoFactory] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoDpt] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoPost] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoPostId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutFactory] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutDpt] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutPost] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutPostId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[Reason] nvarchar(256) COLLATE Chinese_PRC_CI_AS NULL,
[TransferDate] datetime NULL,
[ContractNature] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoJobType] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[IntoDptId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutJobType] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[OutDptId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[CreateDate] datetime NULL,
[CreateId] nvarchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[ApprovalState] varchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[AttendGroupId] varchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[ApprovalDate] datetime DEFAULT '' NULL,
[TransferType] varchar(64) COLLATE Chinese_PRC_CI_AS NULL,
[Remark] varchar(255) COLLATE Chinese_PRC_CI_AS NULL,
CONSTRAINT [PK_PM_P_Transfer_Id] PRIMARY KEY CLUSTERED ([Id])
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)
ON [PRIMARY]
)
ON [PRIMARY]

2 Answers

原因主要是同步了Sql Server int default 格式不符合Doris int default格式导致的,解决办法:

  1. Sql Server去掉 default
  2. 升级到connector1.6.0以及以上,将不同步default 默认值

类似的异常还有:
① flink 提交 job报错:
java.sql.SQLException: errCode = 2, detailMessage = Invalid number format: ((0))

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error:
SQL query could not be executed: CREATE TABLE IF NOT EXISTS finebi.AR_ARBillHead(ID BIGINT COMMENT '',CreatedOn DATETIMEV2(3) COMMENT '',CreatedBy VARCHAR(150) COMMENT '',ModifiedOn DATETIMEV2(3) COMMENT '',ModifiedBy VARCHAR(150) COMMENT '',SysVersion BIGINT DEFAULT '((0))' COMMENT '',Org BIGINT COMMENT '',DocNo VARCHAR(150) COMMENT '',BusinessDate DATETIMEV2(3) COMMENT '',Version INT DEFAULT '((0))' COMMENT '',PrintAmount INT DEFAULT '((0))' COMMENT '',LatestPrintedDate DATETIMEV2(3) COMMENT '',Cancel_Canceled BOOLEAN DEFAULT '((0))' COMMENT '',Cancel_CancelDate DATETIMEV2(3) COMMENT '',Cancel_CancelReason VARCHAR(150) COMMENT '',Cancel_CancelUser VARCHAR(150) COMMENT '',WorkFlowID STRING COMMENT '',StateMachineID STRING COMMENT '',HoldReason BIGINT COMMENT '',HoldUser VARCHAR(150) COMMENT '',HoldDate DATETIMEV2(3) COMMENT '',ReleaseReason BIGINT COMMENT '',ReleaseUser VARCHAR(150) COMMENT '',ReleaseDate DATETIMEV2(3) COMMENT '',DescFlexField_PubDescSeg1 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg2 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg3 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg4 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg5 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg6 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg7 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg8 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg9 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg10 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg11 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg12 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg13 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg14 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg15 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg16 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg17 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg18 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg19 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg20 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg21 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg22 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg23 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg24 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg25 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg26 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg27 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg28 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg29 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg30 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg31 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg32 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg33 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg34 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg35 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg36 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg37 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg38 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg39 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg40 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg41 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg42 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg43 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg44 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg45 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg46 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg47 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg48 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg49 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg50 VARCHAR(3000) COMMENT '',DescFlexField_ContextValue VARCHAR(150) COMMENT '',DescFlexField_PrivateDescSeg1 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg2 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg3 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg4 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg5 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg6 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg7 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg8 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg9 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg10 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg11 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg12 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg13 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg14 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg15 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg16 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg17 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg18 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg19 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg20 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg21 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg22 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg23 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg24 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg25 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg26 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg27 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg28 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg29 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg30 VARCHAR(3000) COMMENT '',ARBillBatch BIGINT COMMENT '',SOB BIGINT COMMENT '',FC BIGINT COMMENT '',AccrueMode INT DEFAULT '((0))' COMMENT '',IsPeriodBegin BOOLEAN DEFAULT '((0))' COMMENT '',IsNetAccrue BOOLEAN DEFAULT '((0))' COMMENT '',AccrueDate DATETIMEV2(3) COMMENT '',PostPeriod BIGINT COMMENT '',RCR INT DEFAULT '((2))' COMMENT '',RCCondition BIGINT COMMENT '',IsCompleteRC BOOLEAN DEFAULT '((0))' COMMENT '',IsPromptRec BOOLEAN DEFAULT '((0))' COMMENT '',IsInstalment BOOLEAN DEFAULT '((0))' COMMENT '',DivisionDate DATETIMEV2(3) COMMENT '',AccrueCust_Customer BIGINT COMMENT '',AccrueCust_Code VARCHAR(765) COMMENT '',AccrueCust_ShortName VARCHAR(765) COMMENT '',AccrueCustSite_CustomerSite BIGINT COMMENT '',AccrueCustSite_Code VARCHAR(765) COMMENT '',PayCust_Customer BIGINT COMMENT '',PayCust_Code VARCHAR(765) COMMENT '',PayCust_ShortName VARCHAR(765) COMMENT '',PayCustSite_CustomerSite BIGINT COMMENT '',PayCustSite_Code VARCHAR(765) COMMENT '',AC BIGINT COMMENT '',ACToFCERType INT DEFAULT '((-1))' COMMENT '',ACToFCExRate DECIMALV3(24,9) DEFAULT '((1))' COMMENT '',CreditControlSite BIGINT COMMENT '',TaxSchedule BIGINT COMMENT '',IsTaxPrice BOOLEAN DEFAULT '((0))' COMMENT '',AROCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanEnjoyDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanEnjoyDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',EnjoyedDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',EnjoyedDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',UnEnjoyDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',UnEnjoyDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',PriorityGrade INT DEFAULT '((4))' COMMENT '',BusinessType INT DEFAULT '((0))' COMMENT '',SrcType INT DEFAULT '((-1))' COMMENT '',SrcBillID BIGINT DEFAULT '((0))' COMMENT '',SrcOrg BIGINT COMMENT '',RCRIntalAccrue INT DEFAULT '((0))' COMMENT '',IsFirstAccrue BOOLEAN DEFAULT '((1))' COMMENT '',DocStatus INT DEFAULT '((0))' COMMENT '',AROCMoneyBalance_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingReqFund DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCommissionRec DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingHold DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingBadDebt DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCT DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingAdjust DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCA DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingApply DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCancelQA DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanDisposeMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AccrueBy BIGINT COMMENT '',SrcBusinessType INT DEFAULT '((0))' COMMENT '',DocDirect INT DEFAULT '((0))' COMMENT '',IsFIClose BOOLEAN DEFAULT '((0))' COMMENT '',DoingApplyCM DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DocumentType BIGINT COMMENT '',NetAccrueApplyBill BIGINT COMMENT '',InvoicedARFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',Dept BIGINT COMMENT '',Transactor BIGINT COMMENT '',Receiver BIGINT COMMENT '',AccrueTerm BIGINT COMMENT '',RecTerm BIGINT COMMENT '',Project BIGINT COMMENT '',Task BIGINT COMMENT '',CreditControlSiteType INT DEFAULT '((0))' COMMENT '',SrcBillNum VARCHAR(150) COMMENT '',ApprovedBy VARCHAR(150) COMMENT '',ApprovedOn DATETIMEV2(3) COMMENT '',CancelApprovedBy VARCHAR(150) COMMENT '',CancelApprovedOn DATETIMEV2(3) COMMENT '',VoucherType BIGINT COMMENT '',VoucherID BIGINT DEFAULT '((0))' COMMENT '',VoucherNum VARCHAR(150) COMMENT '',WFCurrentState INT DEFAULT '((-1))' COMMENT '',WFOriginalState INT DEFAULT '((-1))' COMMENT '',PromptRecStr VARCHAR(12000) COMMENT '',InvoiceOrg BIGINT COMMENT '',InvoiceBase BIGINT COMMENT '',InvoiceNum VARCHAR(3000) COMMENT '',InvoiceDate DATETIMEV2(3) COMMENT '',ReceiveInvoiceDate DATETIMEV2(3) COMMENT '',TaxCtrlInvoiceNum VARCHAR(3000) COMMENT '',PromptRecBillID BIGINT DEFAULT '((-1))' COMMENT '',PromptRecBillNo VARCHAR(150) COMMENT '',IsQuickEditable BOOLEAN DEFAULT '((0))' COMMENT '',IsTransToGL BOOLEAN DEFAULT '((0))' COMMENT '',IsTransedToGL BOOLEAN DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',IsReversed BOOLEAN DEFAULT '((0))' COMMENT '',BizOrg BIGINT COMMENT '',SettleOrg BIGINT COMMENT '',DivisionNum INT DEFAULT '((0))' COMMENT '',IsGernerTBD BOOLEAN DEFAULT '((0))' COMMENT '',AAIStatus INT DEFAULT '((0))' COMMENT '',IsNeedGenAAI BOOLEAN DEFAULT '((1))' COMMENT '',IsGenAAI BOOLEAN DEFAULT '((0))' COMMENT '',IsCtlAfterProcess BOOLEAN DEFAULT '((0))' COMMENT '',IsMainBill BOOLEAN DEFAULT '((1))' COMMENT '',SrcTypeTag INT DEFAULT '((0))' COMMENT '',AAIMainBill_EntityID BIGINT DEFAULT '((0))' COMMENT '',AAIMainBill_EntityType VARCHAR(300) COMMENT '',RedFlushBill BIGINT COMMENT '',RedReverseBillForCM BIGINT COMMENT '',RedFlushStatus INT DEFAULT '((-1))' COMMENT '',ARInsideApplyHead BIGINT DEFAULT '((0))' COMMENT '',ARInsideApplyHeadForDiscount BIGINT DEFAULT '((0))' COMMENT '',FlowInstance BIGINT COMMENT '',IsSrcInvoiceAppore BOOLEAN DEFAULT '((0))' COMMENT '' ) UNIQUE KEY(ID) DISTRIBUTED BY HASH(ID) BUCKETS AUTO PROPERTIES ('replication_num'='1','light_schema_change'='true')
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1878)
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
Caused by: org.apache.doris.flink.exception.DorisSystemException: SQL query could not be executed: CREATE TABLE IF NOT EXISTS finebi.AR_ARBillHead(ID BIGINT COMMENT '',CreatedOn DATETIMEV2(3) COMMENT '',CreatedBy VARCHAR(150) COMMENT '',ModifiedOn DATETIMEV2(3) COMMENT '',ModifiedBy VARCHAR(150) COMMENT '',SysVersion BIGINT DEFAULT '((0))' COMMENT '',Org BIGINT COMMENT '',DocNo VARCHAR(150) COMMENT '',BusinessDate DATETIMEV2(3) COMMENT '',Version INT DEFAULT '((0))' COMMENT '',PrintAmount INT DEFAULT '((0))' COMMENT '',LatestPrintedDate DATETIMEV2(3) COMMENT '',Cancel_Canceled BOOLEAN DEFAULT '((0))' COMMENT '',Cancel_CancelDate DATETIMEV2(3) COMMENT '',Cancel_CancelReason VARCHAR(150) COMMENT '',Cancel_CancelUser VARCHAR(150) COMMENT '',WorkFlowID STRING COMMENT '',StateMachineID STRING COMMENT '',HoldReason BIGINT COMMENT '',HoldUser VARCHAR(150) COMMENT '',HoldDate DATETIMEV2(3) COMMENT '',ReleaseReason BIGINT COMMENT '',ReleaseUser VARCHAR(150) COMMENT '',ReleaseDate DATETIMEV2(3) COMMENT '',DescFlexField_PubDescSeg1 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg2 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg3 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg4 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg5 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg6 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg7 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg8 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg9 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg10 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg11 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg12 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg13 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg14 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg15 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg16 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg17 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg18 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg19 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg20 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg21 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg22 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg23 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg24 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg25 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg26 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg27 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg28 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg29 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg30 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg31 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg32 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg33 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg34 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg35 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg36 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg37 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg38 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg39 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg40 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg41 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg42 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg43 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg44 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg45 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg46 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg47 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg48 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg49 VARCHAR(3000) COMMENT '',DescFlexField_PubDescSeg50 VARCHAR(3000) COMMENT '',DescFlexField_ContextValue VARCHAR(150) COMMENT '',DescFlexField_PrivateDescSeg1 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg2 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg3 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg4 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg5 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg6 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg7 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg8 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg9 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg10 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg11 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg12 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg13 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg14 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg15 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg16 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg17 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg18 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg19 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg20 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg21 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg22 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg23 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg24 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg25 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg26 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg27 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg28 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg29 VARCHAR(3000) COMMENT '',DescFlexField_PrivateDescSeg30 VARCHAR(3000) COMMENT '',ARBillBatch BIGINT COMMENT '',SOB BIGINT COMMENT '',FC BIGINT COMMENT '',AccrueMode INT DEFAULT '((0))' COMMENT '',IsPeriodBegin BOOLEAN DEFAULT '((0))' COMMENT '',IsNetAccrue BOOLEAN DEFAULT '((0))' COMMENT '',AccrueDate DATETIMEV2(3) COMMENT '',PostPeriod BIGINT COMMENT '',RCR INT DEFAULT '((2))' COMMENT '',RCCondition BIGINT COMMENT '',IsCompleteRC BOOLEAN DEFAULT '((0))' COMMENT '',IsPromptRec BOOLEAN DEFAULT '((0))' COMMENT '',IsInstalment BOOLEAN DEFAULT '((0))' COMMENT '',DivisionDate DATETIMEV2(3) COMMENT '',AccrueCust_Customer BIGINT COMMENT '',AccrueCust_Code VARCHAR(765) COMMENT '',AccrueCust_ShortName VARCHAR(765) COMMENT '',AccrueCustSite_CustomerSite BIGINT COMMENT '',AccrueCustSite_Code VARCHAR(765) COMMENT '',PayCust_Customer BIGINT COMMENT '',PayCust_Code VARCHAR(765) COMMENT '',PayCust_ShortName VARCHAR(765) COMMENT '',PayCustSite_CustomerSite BIGINT COMMENT '',PayCustSite_Code VARCHAR(765) COMMENT '',AC BIGINT COMMENT '',ACToFCERType INT DEFAULT '((-1))' COMMENT '',ACToFCExRate DECIMALV3(24,9) DEFAULT '((1))' COMMENT '',CreditControlSite BIGINT COMMENT '',TaxSchedule BIGINT COMMENT '',IsTaxPrice BOOLEAN DEFAULT '((0))' COMMENT '',AROCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanEnjoyDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanEnjoyDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',EnjoyedDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',EnjoyedDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',UnEnjoyDiscount_OCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',UnEnjoyDiscount_FCMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedAROCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',PriorityGrade INT DEFAULT '((4))' COMMENT '',BusinessType INT DEFAULT '((0))' COMMENT '',SrcType INT DEFAULT '((-1))' COMMENT '',SrcBillID BIGINT DEFAULT '((0))' COMMENT '',SrcOrg BIGINT COMMENT '',RCRIntalAccrue INT DEFAULT '((0))' COMMENT '',IsFirstAccrue BOOLEAN DEFAULT '((1))' COMMENT '',DocStatus INT DEFAULT '((0))' COMMENT '',AROCMoneyBalance_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AROCMoneyBalance_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingReqFund DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCommissionRec DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingHold DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingBadDebt DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCT DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingAdjust DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCA DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingApply DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DoingCancelQA DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanDisposeMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',AccrueBy BIGINT COMMENT '',SrcBusinessType INT DEFAULT '((0))' COMMENT '',DocDirect INT DEFAULT '((0))' COMMENT '',IsFIClose BOOLEAN DEFAULT '((0))' COMMENT '',DoingApplyCM DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',DocumentType BIGINT COMMENT '',NetAccrueApplyBill BIGINT COMMENT '',InvoicedARFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',InvoicedARFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoneyBalance_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',ARFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',Dept BIGINT COMMENT '',Transactor BIGINT COMMENT '',Receiver BIGINT COMMENT '',AccrueTerm BIGINT COMMENT '',RecTerm BIGINT COMMENT '',Project BIGINT COMMENT '',Task BIGINT COMMENT '',CreditControlSiteType INT DEFAULT '((0))' COMMENT '',SrcBillNum VARCHAR(150) COMMENT '',ApprovedBy VARCHAR(150) COMMENT '',ApprovedOn DATETIMEV2(3) COMMENT '',CancelApprovedBy VARCHAR(150) COMMENT '',CancelApprovedOn DATETIMEV2(3) COMMENT '',VoucherType BIGINT COMMENT '',VoucherID BIGINT DEFAULT '((0))' COMMENT '',VoucherNum VARCHAR(150) COMMENT '',WFCurrentState INT DEFAULT '((-1))' COMMENT '',WFOriginalState INT DEFAULT '((-1))' COMMENT '',PromptRecStr VARCHAR(12000) COMMENT '',InvoiceOrg BIGINT COMMENT '',InvoiceBase BIGINT COMMENT '',InvoiceNum VARCHAR(3000) COMMENT '',InvoiceDate DATETIMEV2(3) COMMENT '',ReceiveInvoiceDate DATETIMEV2(3) COMMENT '',TaxCtrlInvoiceNum VARCHAR(3000) COMMENT '',PromptRecBillID BIGINT DEFAULT '((-1))' COMMENT '',PromptRecBillNo VARCHAR(150) COMMENT '',IsQuickEditable BOOLEAN DEFAULT '((0))' COMMENT '',IsTransToGL BOOLEAN DEFAULT '((0))' COMMENT '',IsTransedToGL BOOLEAN DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceOCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_NonTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_Tax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_GoodsTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_FeeTax DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_Fee DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',CanInvoiceFCMoney_TotalMoney DECIMALV3(24,9) DEFAULT '((0))' COMMENT '',IsReversed BOOLEAN DEFAULT '((0))' COMMENT '',BizOrg BIGINT COMMENT '',SettleOrg BIGINT COMMENT '',DivisionNum INT DEFAULT '((0))' COMMENT '',IsGernerTBD BOOLEAN DEFAULT '((0))' COMMENT '',AAIStatus INT DEFAULT '((0))' COMMENT '',IsNeedGenAAI BOOLEAN DEFAULT '((1))' COMMENT '',IsGenAAI BOOLEAN DEFAULT '((0))' COMMENT '',IsCtlAfterProcess BOOLEAN DEFAULT '((0))' COMMENT '',IsMainBill BOOLEAN DEFAULT '((1))' COMMENT '',SrcTypeTag INT DEFAULT '((0))' COMMENT '',AAIMainBill_EntityID BIGINT DEFAULT '((0))' COMMENT '',AAIMainBill_EntityType VARCHAR(300) COMMENT '',RedFlushBill BIGINT COMMENT '',RedReverseBillForCM BIGINT COMMENT '',RedFlushStatus INT DEFAULT '((-1))' COMMENT '',ARInsideApplyHead BIGINT DEFAULT '((0))' COMMENT '',ARInsideApplyHeadForDiscount BIGINT DEFAULT '((0))' COMMENT '',FlowInstance BIGINT COMMENT '',IsSrcInvoiceAppore BOOLEAN DEFAULT '((0))' COMMENT '' ) UNIQUE KEY(ID) DISTRIBUTED BY HASH(ID) BUCKETS AUTO PROPERTIES ('replication_num'='1','light_schema_change'='true')
at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:131)
at org.apache.doris.flink.catalog.doris.DorisSystem.createTable(DorisSystem.java:122)
at org.apache.doris.flink.tools.cdc.DatabaseSync.build(DatabaseSync.java:145)
at org.apache.doris.flink.tools.cdc.CdcTools.syncDatabase(CdcTools.java:146)
at org.apache.doris.flink.tools.cdc.CdcTools.createSqlServerSyncDatabase(CdcTools.java:101)
at org.apache.doris.flink.tools.cdc.CdcTools.main(CdcTools.java:60)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
... 12 more
Caused by: java.sql.SQLException: errCode = 2, detailMessage = Invalid number format: ((0))
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:763)
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648)
at org.apache.doris.flink.catalog.doris.DorisSystem.execute(DorisSystem.java:128)
... 22 more

②cdc自动生成建表语句出现:
SysVersion BIGINT DEFAULT '((0))' COMMENT ''
CREATE TABLEIF NOT EXISTS finebi.AR_ARBillHead (
ID BIGINT COMMENT '',
CreatedOn DATETIMEV2 ( 3 ) COMMENT '',
CreatedBy VARCHAR ( 150 ) COMMENT '',
ModifiedOn DATETIMEV2 ( 3 ) COMMENT '',
ModifiedBy VARCHAR ( 150 ) COMMENT '',
SysVersion BIGINT DEFAULT '((0))' COMMENT '',
Org BIGINT COMMENT '',DocNo VARCHAR ( 150 ) COMMENT '',
BusinessDate DATETIMEV2 ( 3 ) COMMENT '',
Version INT DEFAULT '((0))' COMMENT '',
PrintAmount INT DEFAULT '((0))' COMMENT '',
....

③ sqlserver ddl:
[SysVersion] bigint DEFAULT 0 NULL

CREATE TABLE [dbo].[AR_ARBillHead] (
[ID] bigint NOT NULL,
[CreatedOn] datetime NULL,
[CreatedBy] nvarchar(50) COLLATE Chinese_PRC_CI_AS NULL,
[ModifiedOn] datetime NULL,
[ModifiedBy] nvarchar(50) COLLATE Chinese_PRC_CI_AS NULL,
[SysVersion] bigint DEFAULT 0 NULL,
[Org] bigint NOT NULL,
[DocNo] nvarchar(50) COLLATE Chinese_PRC_CI_AS NOT NULL,
[BusinessDate] datetime NOT NULL,
[Version] int DEFAULT 0 NULL,
[PrintAmount] int DEFAULT 0 NULL,
[LatestPrintedDate] datetime NULL,
[Cancel_Canceled] bit DEFAULT 0 NULL,
...

Ⅰ使用的命令为:
bin/flink run -t yarn-per-job -d -Dexecution.checkpointing.interval=10s -Dparallelism.default=1 -c org.apache.doris.flink.tools.cdc.CdcTools ./lib/flink-doris-connector-1.17-1.5.2.jar sqlserver-sync-database --database finebi --sqlserver-conf hostname=127.0.0.1 --sqlserver-conf port=1433 --sqlserver-conf username=root --sqlserver-conf password="123456" --sqlserver-conf database-name=1ysx --sqlserver-conf schema-name=dbo --including-tables "AR_ARBillHead|AR_ARBillLine|AR_ARDocType|AR_ARDocType_Trl|Base_Language|Base_SOBAccountingPeriod|CBO_Project" --sink-conf fenodes=hadoop131:8030 --sink-conf username=root --sink-conf password="123" --sink-conf jdbc-url=jdbc:mysql://hadoop131:9030 --sink-conf sink.label-prefix=label --table-conf replication_num=1


flink 版本为1.18.1
flink-connector-sqlserver-cdc版本为3.0.0