类似的异常还有:
① 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