本文為您介紹離線同步的相關問題。
文檔概述
問題分類 | 相關文檔 |
離線同步任務營運常見問題 | |
非外掛程式報錯原因及解決方案 | |
具體外掛程式報錯原因及解決方案 | |
離線同步情境及解決方案 |
|
報錯資訊及解決方案 |
|
為什麼資料來源測試連通性成功，但是離線同步任務執行失敗？
如果您之前測試連通性通過，請重新測試連通性，確認資源群組與資料庫當前是可聯通狀態（確認資料庫端無變更）。
請檢查測試連通性成功的資源群組和任務執行所用的資源群組是不是同一個。
查看任務運行資源：
任務運行在預設的資源群組上，日誌中會出現如下資訊：
running in Pipeline[basecommon_ group_xxxxxxxxx]。任務運行在Data Integration自訂資源群組上，日誌中會出現如下資訊：
running in Pipeline[basecommon_xxxxxxxxx]。任務運行在獨享Data Integration資源上，日誌中會出現如下資訊：
running in Pipeline[basecommon_S_res_group_xxx]。
如果淩晨任務調度時偶爾失敗，但重跑又能成功，請檢查資料庫在報錯時間點的負載情況。
如何切換Data Integration任務執行資源組？
您可以在DataStudio修改Data Integration任務調試所用的資源群組，同時，也支援您在營運中心修改任務調度時所使用的Data Integration任務執行資源組。配置詳情請參見：新增和使用獨享Data Integration資源群組。
髒資料如何排查和定位？
髒資料定義：單條資料寫入目標資料來源過程中發生了異常，則此條資料為髒資料。 因此只要是寫入失敗的資料均被歸類於髒資料。
髒資料影響：髒資料將不會成功寫入目的端。您可以控制是否允許髒資料產生，並且支援控制髒資料條數，Data Integration預設允許髒資料產生，您可以在同步任務配置時指定髒資料產生條數。詳情可參考：通過嚮導模式配置離線同步任務。
任務設定允許髒資料：當髒資料產生時，任務繼續執行，但髒資料將會被捨棄，不寫入目的端。
任務控制允許產生的髒資料條數：
設定髒資料允許條數為0條，則當髒資料產生時，任務將失敗退出。
設定髒資料允許條數為x條，則當髒資料產生條數超過x條時，任務將失敗退出，當髒資料產生條數小於x條時，任務將繼續運行，但髒資料將會被捨棄，不寫入目的端。
髒資料即時情境分析：
情境一：
報錯現象：
{"message":"寫入 ODPS 目的表時遇到了髒資料: 第[3]個欄位的資料出現錯誤，請檢查該資料並作出修改或者您可以增大閾值，忽略這條記錄.","record":[{"byteSize":0,"index":0,"type":"DATE"},{"byteSize":0,"index":1,"type":"DATE"},{"byteSize":1,"index":2,"rawData":0,"type":"LONG"},{"byteSize":0,"index":3,"type":"STRING"},{"byteSize":1,"index":4,"rawData":0,"type":"LONG"},{"byteSize":0,"index":5,"type":"STRING"},{"byteSize":0,"index":6,"type":"STRING"}。如何處理：該日誌中可以看出髒資料的欄位，第三個欄位異常。
髒資料是writer端報的，要檢查下writer端的建表語句。odps端該表欄位指定的欄位大小小於MySQL端該欄位資料大小 。
資料同步原則：來源端資料來源的資料要能寫入目的端資料來源（來源端和目的端類型需要匹配，欄位定義的大小需要匹配），即源端資料類型需要與寫端資料類型匹配，源端是VARCHAR類型的資料不可寫到INT類型的目標列中；目標端的資料類型定義的大小需要可以接收源端映射欄位實際資料大小，源端是long、varchar 、double等類型的資料，目的端均可用string、text等大範圍類型接納。
髒資料報錯不清晰時，需要複製出列印出的髒資料的一整條，觀察其中的資料，和目的端資料類型比較，看哪一條或哪一些不合規範。
比如：
{"byteSize":28,"index":25,"rawData":"ohOM71vdGKqXOqtmtriUs5QqJsf4","type":"STRING"}byteSize：位元組數；index:25，第26個欄位；rawData：具體值（即value）；type：資料類型。
情境二：
報錯現象：DataX讀取MySQL中有空值時報髒資料。
如何處理：請檢查源端存在空值的欄位將寫入目標端什麼類型的欄位中，如果類型不一致將會報錯。例如，string類型的null寫入目標端int類型欄位時會報錯。
如何查看髒資料？
你可以進入日誌詳情頁，單擊日誌中Detail log url擷取具體查看離線同步處理記錄以及髒資料資訊。
如果離線同步傳輸資料時，髒資料超出限制，是否所有資料都不會同步？
當髒資料數量超出限制時，任務立即停止，此前傳輸了多少條資料就是多少條。髒資料限制設定為多少就是不允許有多少條髒資料，若限制為0即在發現第一條髒資料時就會停止任務，此時有可能已經傳幾條資料了，或者沒有傳輸資料（髒資料在所有資料中位於第一條時）。
如何排查離線同步任務已耗用時間長的問題？
可能原因1：執行時間過長
前置語句或後置語句（例如：preSql和postSql）在資料庫執行耗時過長，導致任務運行慢。
未合理配置切分鍵，導致任務運行慢。
離線同步會根據切分鍵（splitPk）來對進行資料分區，資料同步根據此配置啟動並發任務進行資料同步，提高資料同步的效能。（具體外掛程式是否需要配置切分鍵，請參考具體外掛程式文檔）。
解決方案1：
若配置前置或後置語句，建議使用添加了索引的欄位進行資料過濾。
支援設定切分鍵的情境下，建議合理配置切分鍵。以MySQL Reader外掛程式切分鍵配置為例：
推薦splitPk使用者使用表主鍵，因為表主鍵通常情況下比較均勻，因此切分出來的分區也不容易出現資料熱點。
目前splitPk僅支援整型資料切分，不支援字串、浮點和日期等其他類型 。如果指定其他非支援類型，將使用單通道進行同步。
如果不填寫splitPk，包括不提供splitPk或者splitPk值為空白，資料同步視作使用單通道同步該表資料 。
可能原因2：等待Data Integration任務執行資源
解決方案2：若日誌出現長時間WAIT狀態，說明當前任務運行所使用的獨享Data Integration資源群組剩餘可啟動並執行並發數不足以運行當前任務。具體原因及解決方案詳情請參見：為什麼Data Integration任務一直顯示wait？。
由於離線同步任務通過調度資源群組下發到Data Integration執行資源組上執行，所以一個離線同步任務將同時耗費一個調度資源，若離線同步任務長時間運行未釋放資源，除了阻塞其他離線任務運行外，可能還將阻塞其他類型的調度任務運行。
如何處理編碼格式設定/亂碼問題導致的髒資料報錯？
報錯現象：
如果資料中包括Emoji，在同步過程中可能會報錯髒資料：
[13350975-0-0-writer] ERROR StdoutPluginCollector - 髒資料 {"exception":"Incorrect string value: '\\xF0\\x9F\\x98\\x82\\xE8\\xA2...' for column 'introduction' at row 1","record":[{"byteSize":8,"index":0,"rawData":9642,"type":"LONG"}],"type":"writer"}。可能原因：
資料庫相關編碼未設定為utf8mb4，導致同步Emoji報錯。
源端的資料本身就是亂碼。
資料庫和用戶端的編碼不一樣。
瀏覽器編碼不一樣，導致預覽失敗或亂碼。
解決方案：
針對產生亂碼的不同原因，選擇相應的解決方案：
如果您的未經處理資料亂碼，需首先處理好未經處理資料，再進行同步任務。
資料庫和用戶端編碼格式不一致，需先修改編碼格式。
瀏覽器編碼和資料庫或用戶端編碼格式不一致，需先統一編碼格式，然後進行資料預覽。
您可以嘗試以下操作：
JDBC格式添加的資料來源修改utf8mb4：
jdbc:mysql://xxx.x.x.x:3306/database?com.mysql.jdbc.faultInjection.serverCharsetIndex=45。執行個體ID形式添加資料來源：在資料庫名後拼接，格式為
database?com.mysql.jdbc.faultInjection.serverCharsetIndex=45。修改資料庫相關的編碼格式為utf8mb4。例如，在RDS控制台修改RDS的資料庫編碼格式。
說明設定RDS資料來源編碼格式命令：
set names utf8mb4。查看RDS資料庫編碼格式命令：show variables like 'char%'。
任務存在SSRF攻擊Task have SSRF attacks如何處理？
目前基於資料庫內網的資料來源，請更換使用獨享Data Integration資源群組運行任務，獨享Data Integration資源群組的使用詳情可參見文檔：新增和使用獨享Data Integration資源群組。
離線同步任務執行偶爾成功偶爾失敗
出現離線同步任務偶爾執行失敗的情況，可能是因為白名單配置不全導致的，您需要檢查資料庫白名單是否配置完全。
使用獨享Data Integration資源群組時：
如果您此前已經將獨享Data Integration資源群組的彈性網卡IP添加到了資料來源的白名單中，後續如果資源群組有擴容，您需要及時更新資料來源的白名單，將擴容後的資源群組的彈性網卡IP添加到資料來源白名單中。
為了避免出現資源群組擴容後需要再次添加白名單的情況，建議您直接添加獨享Data Integration資源群組綁定的交換器網段作為資料庫白名單。詳情請參見添加白名單。
如果白名單無異常，請確認資料庫負載是否過高導致串連中斷。
離線同步源表有加列（修改）如何處理？
進入同步任務配置頁面，修改欄位的映射後，即可將變化的欄位更新在任務配置中，完成後，您需要重新提交執行任務後變更才會生效。
添加MongoDB資料來源時，使用root使用者時報錯
使用root使用者添加MongoDB資料來源時報錯，是因為添加MongoDB資料來源時，必須使用使用者需要同步的表所在的資料庫建立的使用者名稱，不可以使用root使用者。
例如需要匯入name表，name表在test庫，則此處資料庫名稱為test，需要使用test資料庫中建立的使用者的使用者名稱。
讀取MongoDB時，如何在query參數中使用timestamp實現增量同步處理？
可以使用賦值節點先對date類型時間處理成timestamp，將該值作為MongoDB資料同步的入參，詳情請參考文檔：MongoDB時間戳記類型欄位如何?增量同步處理？
MongoDB同步至資料目的端資料來源後，時區加了8個小時，如何處理？
你需要在MongoDB Reader配置中設定時區，詳情請參見MongoDB Reader。
讀取MongoDB資料期間，源端有更新記錄，但未同步至目的端，如何處理？
您可以間隔一段時間後重啟任務，query條件不變，即將同步任務的執行時間延遲，配置不變。
讀取OSS檔案是否有檔案數限制？
OSSreader外掛程式讀取OSS執行時間超過RDS側允許的最大檔案數datax本身沒有限制，主要看任務配置的jvm參數，但是不建議object參數配置*，容易導致記憶體溢出。
寫入DataHub時，一次性寫入資料超限導致寫入失敗如何處理？
報錯現象：
ERROR JobContainer - Exception when job runcom.alibaba.datax.common.exception.DataXException: Code:[DatahubWriter-04], Description:[寫資料失敗.]. - com.aliyun.datahub.exception.DatahubServiceException: Record count 12498 exceed max limit 10000 (Status Code: 413; Error Code: TooLargePayload; Request ID: 20201201004200a945df0bf8e11a42)可能原因：
報錯原因為datax一次性提交到DataHub的資料量超過DataHub的限制。影響提交到DataHub資料量的配置參數主要為：
maxCommitSize：表示datax累積的buffer資料，待積累的資料大小達到maxCommitSize 大小（單位MB）時，批量提交到目的端。預設是 1MB，即 1,048,576位元組。
batchSize：DataX-On-Flume積累的Buffer資料條數，待積累的資料條數達到batchSize大小（單位條數）時，批量提交至目的端。
解決方案：
調小maxCommitSize和batchSize的參數值。
使用lindorm bulk方式寫入資料，是否每次都會替換掉歷史資料？
和API方式寫入邏輯一致，同行同列會被覆蓋，其他資料不變。
如何查詢一個ES索引下的所有欄位？
通過curl命令擷取ES索引Mapping，從Mapping中提取所有欄位。
查詢Shell命令：
//es7 curl -u username:password --request GET 'http://esxxx.elasticsearch.aliyuncs.com:9200/indexname/_mapping' //es6 curl -u username:password --request GET 'http://esxxx.elasticsearch.aliyuncs.com:9200/indexname/typename/_mapping'結果擷取欄位：
{ "indexname": { "mappings": { "typename": { "properties": { "field1": { "type": "text" }, "field2": { "type": "long" }, "field3": { "type": "double" } } } } } }返回結果中properties下就是索引所有的欄位和屬性定義。如上索引包含field1、field2、field3三個欄位。
資料從ES離線同步至其他資料來源中時，每天同步的索引名稱不一樣，如何配置？
索引配置時可以加入日期調度變數，根據不同的日期計算出索引字串，實現Elasticsearch Reades索引名的自動變化，配置過程包含如下三步：定義日期變數、配置索引變數、任務發布與執行。
定義日期變數：在同步任務的調度配置中，選擇新增參數定義日期變數。如下var1配置表示任務執行時間（當天），var2表示任務的業務日期（前一天）。
配置索引變數：將任務轉為指令碼模式，配置Elasticsearch Reader的索引，配置方式為：${變數名}，如下圖所示。
任務發布與執行：執行驗證後，將任務提交發布至營運中心，以周期調度或補資料的方式運行。
單擊帶參運行按鈕直接運行任務進行驗證，帶參運行會將任務配置中使用的調度系統參數進行替換，執行後查看日誌同步索引是否符合預期。
說明注意在帶參運行時直接輸入參數值進行替換測試。
如果上一步驗證符合預期，則任務配置已經完成，此時可以依次單擊儲存和提交按鈕將同步任務提交到生產環境。
如果是標準專案，需要單擊發布按鈕進入發布中心才能將同步任務發布到生產環境。
結果：如下是配置與實際啟動並執行索引結果。
指令碼索引配置為：
"index": "esstress_1_${var1}_${var2}"。運行索引替換為：
esstress_1_20230106_20230105。
離線同步任務如何自訂表格名？
如果您表名較規律，例如orders_20170310、orders_20170311和orders_20170312，按天區分表名稱，且表結構一致。您可以結合調度參數通過指令碼模式配置離線同步任務自訂表格名，實現每天淩晨自動從來源資料庫讀取前一天表資料。
例如，今天是2017年3月15日，自動從來源資料庫中讀取orders_20170314的表的資料匯入，以此類推。
在指令碼模式中，修改來源表的表名為變數，例如orders_${tablename}。由於按天區分表名稱，且需要每天讀取前一天的資料，所以在任務的參數配置中，為變數賦值為tablename=${yyyymmdd}。
更多調度參數的使用問題請參考文檔調度參數支援的格式
配置離線同步節點時，無法查看全部的表，該如何處理？
您在配置離線同步節點時，選擇來源地區僅預設顯示所選資料來源中的前25張表。如果數量過大，您可以輸入表名進行搜尋或使用指令碼模式開發。
讀取MaxCompute（ODPS）表資料時，添加一行注意事項
可以輸入常量，輸入的值需要使用英文單引號包括，例如'abc'、'123'等。
可以配合調度參數使用，如'${bizdate}' 等，調度參數具體使用請參考文檔調度參數支援的格式。
可以輸入你要同步的分區列，如分區列有pt等。
如果您輸入的值無法解析，則類型顯示為'自訂'。
不支援配置odps函數。
如果您手工編輯添加的列顯示自訂（例如添加了MaxCompute分區列，LogHub資料預覽未預覽到的列），不會影響實際任務執行。
讀取MaxCompute（ODPS）表資料時，如何同步分區欄位？
請在欄位對應處選擇添加一行，輸入分區列名，如分區列有pt等；
讀取MaxCompute（ODPS）表資料時，如何同步多個分區資料？
讀取資料所在的分區資訊。
ODPS的分區配置支援Linux shell萬用字元，*表示0個或多個字元，？表示任意一個字元。
預設情況下，讀取的分區必須存在，如果分區不存在則啟動並執行任務會報錯。如果您希望當分區不存在時任務仍然執行成功，則可以切換至指令碼模式執行任務，並在ODPS的Parameter中添加
"successOnNoPartition": true配置。
例如，分區表test包含pt=1,ds=hangzhou、pt=1,ds=shanghai、pt=2,ds=hangzhou、pt=2,ds=beijing四個分區，則讀取不同分區資料的配置如下：
如果您需要讀取pt=1,ds=hangzhou分區的資料，則分區資訊的配置為
"partition":"pt=1,ds=hangzhou”。如果您需要讀取pt=1中所有分區的資料，則分區資訊的配置為
"partition":"pt=1,ds=*”。如果您需要讀取整個test表所有分區的資料，則分區資訊的配置為
"partition":"pt=*,ds=*"。
此外，您還可以根據實際需求設定分區資料的擷取條件（以下操作需要轉指令碼模式配置任務）：
如果您需要指定最大分區，則可以添加
/*query*/ ds=(select MAX(ds) from DataXODPSReaderPPR)配置資訊。如果需要按條件過濾，則可以添加相關條件
/*query*/ pt+運算式配置。例如/*query*/ pt>=20170101 and pt<20170110表示擷取pt分區中，20170101日期之後（包含20170101日期），至20170110日期之前（不包含20170110日期）的所有資料。
/*query*/表示將其後填寫的內容識別為一個where條件。
如何處理表列名有關鍵字導致同步任務失敗的情況？
報錯原因：column中含有保留欄位，或者 column配置中含有數字開頭的欄位。
解決方案：Data Integration同步任務轉指令碼模式配置，對column配置中的特殊欄位添加進行轉義。指令碼模式配置任務請參考：通過指令碼模式配置離線同步任務。
MySQL的轉義符為
`關鍵字`。Oracle和PostgreSQL的轉義符為
"關鍵字"。SQlServer的轉義符為
[關鍵字]。
MySQL為情境樣本：
以MySQL資料來源為例：
執行下述語句，建立一張表aliyun。
create table aliyun (`table` int ,msg varchar(10));執行下述語句，建立視圖，為table列取別名。
create view v_aliyun as select `table` as col1,msg as col2 from aliyun;說明table是MySQL的關鍵字，在資料同步時，拼接出來的代碼會報錯。因此需要通過建立視圖，為table列起別名。
不建議使用關鍵字作為表的列名。
通過執行上述語句，為有關鍵字的列取列名。在配置同步任務時，選擇v_aliyun視圖代替aliyun表即可。
讀取Loghub同步某欄位有資料但是同步過來為空白
此外掛程式欄位大小寫敏感，請檢查loghub reader的column配置。
讀取Loghub同步少資料
Data Integration取的是資料進入loghub的時間，請在Loghub控制台檢查資料中繼資料欄位receive_time是否在任務配置的時間區間內。
讀取Loghub欄位對應時讀到的欄位不符合預期
如果出現此現象請在介面手動編輯column。
讀取kafka配置了endDateTime來指定所要同步的資料的截止範圍，但是在目的資料來源中發現了超過這個時間的資料
kafka Reader在讀資料的時候，是以batch的形式進行的，在讀到的一批資料中，如果有超過endDateTime的，則停止同步，但是超出endDateTime的這部分資料也會被寫入到目的端資料來源。
您也可以通過skipExceedRecord配置項來指定是否同步超出的資料。詳細使用方法見Kafka Reader。【不建議設定為不同步，會有造成丟資料】
您可以通過配置kafka的max.poll.records配置項來指定一次拉取資料的量，結合并發數，來控制可能超出的資料量。超出的資料量 < max.poll.records * 並發數
Kafka中資料量少，但是任務出現長時間不讀取資料也不結束，一直運行中的現象是為什嗎？
分析原因：
這種情況通常是因為指定了同步結束策略未到達指定結束位點，此時對於所有讀到位點處於讀取起始位點和讀取結束位點之間資料的分區，全部需要讀到至少一條位點大於或等於指定結束位點的記錄，任務才會退出，否則會一直重試拉取資料。
解決辦法：
這種情況下建議減少Kafka分區數量，或者定時往Kafka每個分區寫入一條心跳記錄協助同步任務滿足結束條件。
寫入OSS出現隨機字串如何去除？
OSS Writer寫入的檔案名稱，OSS使用檔案名稱類比目錄的實現。OSS對於Object的名稱有以下限制：使用"object": "datax"，寫入的Object以datax開頭，尾碼添加隨機字串。檔案數由實際切分的任務數有關。
如果您不需要尾碼隨機UUID，建議您配置"writeSingleObject" : "true"，詳情請參見OSS Writer文檔的writeSingleObject說明。
詳情請參考文檔：[OSS writer]（OSS Writer）
MySQL分庫分表如何將分表同步到一張MaxCompute中
您可以參考MySQLreader外掛程式文檔進行任務配置：MySQL Reader
資料同步任務where條件沒有索引，導致全表掃描同步變慢
情境樣本
執行的SQL如下所示。
select bid,inviter,uid,createTime from `relatives` where createTime>='2016-10-2300:00:00'and reateTime<'2016-10-24 00:00:00';從2016-10-25 11:01:24.875開始執行，到2016-10-25 11:11:05.489開始返回結果。同步程式在等待資料庫返回SQL查詢結果，MaxCompute需等待很久才能執行。
分析原因
where條件查詢時，createTime列沒有索引，導致查詢全表掃描。
解決方案
建議where條件使用有索引相關的列，提高效能，索引也可以補充添加。
目的端MySQL表字元集為utf8mb4時，同步到MySQL中的中文字元出現亂碼時，如何處理？
選擇通過串連串的方式添加資料來源，建議JDBC格式修改為：jdbc:mysql://xxx.x.x.x:3306/database?com.mysql.jdbc.faultInjection.serverCharsetIndex=45，詳情請參見配置MySQL資料來源。
使用API方式同步的時候，支援使用來源端的（例如MaxCompute）函數做彙總嗎？例如源表有a、b兩列作為Lindorm的主鍵
API方式同步不支援使用來源端函數，需要先在來源端函數上處理好後再匯入資料。
同步的資料表，是否只能使用Alter方式來修改TTL?
TTL是在表上設定的，同步任務配置時沒有此選項。
Elasticsearch Reader如何同步對象Object或Nested欄位的屬性？（例如同步object.field1）
需要同步對象欄位屬性，只支援使用指令碼模式，指令碼模式下配置如下multi，column按屬性.子屬性進行配置。
"multi":{
"multi":true
}可以參看如下範例進行配置：
#例子：
##es內的資料
"hits": [
{
"_index": "mutiltest_1",
"_type": "_doc",
"_id": "7XAOOoMB4GR_1Dmrrust",
"_score": 1.0,
"_source": {
"level1": {
"level2": [
{
"level3": "testlevel3_1"
},
{
"level3": "testlevel3_2"
}
]
}
}
}
]
##reader配置
"parameter": {
"column": [
"level1",
"level1.level2",
"level1.level2[0]"
],
"multi":{
"multi":true
}
}
##寫端結果：1行資料3列，列順序同reader配置，
COLUMN VALUE
level1: {"level2":[{"level3":"testlevel3_1"},{"level3":"testlevel3_2"}]}
level1.level2: [{"level3":"testlevel3_1"},{"level3":"testlevel3_2"}]
level1.level2[0]: {"level3":"testlevel3_1"}儲存在ODPS的string類型同步至ES後，兩側缺少引號，如何處理？源端JSON類型的string是否可以同步為ES中的NESTED對象？
顯示字元前後多兩個雙引號為“Kibana”工具顯示問題，實際資料並沒有前後雙引號，請使用curl命令或postman查看實際資料情況。擷取資料curl命令如下：
//es7 curl -u username:password --request GET 'http://esxxx.elasticsearch.aliyuncs.com:9200/indexname/_mapping' //es6 curl -u username:password --request GET 'http://esxxx.elasticsearch.aliyuncs.com:9200/indexname/typename/_mapping'
可以配置ES寫入欄位type為nested類型，以同步ODPS中JSON類型的string資料至ES儲存為nested形式。如下同步name欄位到es中為nested格式。
同步配置：配置name的type為nested。
同步結果：name是nested物件類型。
源端資料為string "[1,2,3,4,5]"，如何以數組形式同步至ES中儲存？
ES期望寫入數群組類型有兩種配置方式，您可以按照源端資料形式，選擇對應的同步方式進行配置。
寫入ES為數群組類型以JSON格式解析源端資料。例如，源端資料為"[1,2,3,4,5]"，配置
json_array=true解析源端資料，以數組形式寫入ES欄位，配置ColumnList為json_array=true。嚮導模式配置：
指令碼模式配置：
"column":[ { "name":"docs", "type":"keyword", "json_array":true } ]
寫入ES為數群組類型以分隔字元解析源端資料。例如，源端資料為”1,2,3,4,5“，配置分隔字元splitter=”,”解析以數組形式寫入ES欄位。
限制：
一個任務僅支援配置一種分隔字元，分隔字元（splitter）全域唯一，不支援多Array欄位配置不同的分隔字元，例如，字源端列col1="1,2,3,4,5" , col2="6-7-8-9-10", splitter無法針對每列單獨配置使用。
splitter可以配置為正則，例如，源端列值為"6-,-7-,-8+,*9-,-10", 可以配置splitter:".,."，支援嚮導模式。
嚮導模式配置：
splitter: 預設為"-,-"指令碼模式配置：
"parameter" : { "column": [ { "name": "col1", "array": true, "type": "long" } ], "splitter":"," }
自建的索引中nested的屬性類型type為keyword，為什麼自動產生之後類型會變成 keyword？（自動產生是指配置cleanup=true執行同步任務）
#原來mappings
{
"name":"box_label_ret",
"properties":{
"box_id":{
"type":"keyword"
}
}
#cleanup=true重建之後，變成了
{
"box_label_ret": {
"properties": {
"box_id": {
"type": "text",
"fields": {
"keyword": {
"type": "keyword",
"ignore_above": 256
}}}}
}分析原因：
對於nested類型，Elasticsearch Writer在處理的時候只採用最上層的mappings，使ES自適應下面的複合類型，屬性type改成text ，添加fields：keyword 是ES自適應行為，不會影響ES的使用。如果在意這個mappings的格式，可參見Data Integration側同步任務能力說明。
解決方案：
您需要同步前先建立預期的ES索引mappings，再修改ES同步任務cleanup為false後執行同步任務。
向ES寫入資料時，會做一次無使用者名稱的提交，但仍需驗證使用者名稱，導致提交失敗，因此提交的所有請求資料都被記錄，導致審計日誌每天都會有很多，如何處理？
分析原因：
HttpClient事先規定每次建立通訊時會先走一次無許可權請求，返回授權需求後（根據返回指定鑒權方式）再進行帶授權請求。每次ES寫入資料時需要建立通訊，所以每次寫入資料都會有一次無許可權請求。導致每次資料寫入都會記錄到審計日誌中。
解決方案：
您需要在指令碼模式下添加
"preemptiveAuth":true配置。
Elasticsearch writer配置了Settings，為什麼在建立索引時不生效？
問題原因：
#錯誤配置 "settings": { "index": { "number_of_shards": 1, "number_of_replicas": 0 } } #正確配置 "settings": { "number_of_shards": 1, "number_of_replicas": 0 }解決方案：
Settings設定只在建立索引時才會生效，建立索引包括：索引不存在和
cleanup=true兩種情況，當cleanup=true時，Settings的配置不需要使用“index" 。
如何同步至ES中為Date日期類型？
有如下兩種方式配置日期寫入，您可以按需求進行選擇。
根據reader端讀取欄位的內容直接寫入ES Date欄位：
配置origin:true，讀取內容直接寫入ES。
配置"format"表示在通過ES寫入建立Mapping時，欄位需要設定的format屬性。
"parameter" : { "column": [ { "name": "col_date", "type": "date", "format": "yyyy-MM-dd HH:mm:ss", "origin": true } ] }
時區轉換：如果需要Data Integration協助您進行時區轉換，則添加Timezone參數。
"parameter" : { "column": [ { "name": "col_date", "type": "date", "format": "yyyy-MM-dd HH:mm:ss", "Timezone": "UTC" } ] }
Elasticsearch Writer指定外部version導致寫入失敗，如何處理？
配置了type：version，目前es不支援指定外部version功能。
"column":[ { "name":"id", "type":"version" }, ]解決方案：
需要取消 type":"version"配置，Elasticsearch Writer暫不支援外部version指定。
非結構化資料來源，單擊資料預覽欄位無法映射，如何處理？
問題現象：
在使用者單擊資料預覽時，出現如下提示，大致含義是欄位的位元組數超長。
問題原因：為了避免OOM，資料來源服務在處理資料預覽的請求時會判斷欄位的長度，如果單個列超過1000位元組，則會出現上述提示，此提示並不會影響任務的正常運行，可以忽略該錯誤直接運行DataX任務。
說明在檔案存在且連通性正常的情況下，導致資料預覽失敗的情況還有：
檔案單行位元組數超限制，限制為10MB。此時不顯示資料，類似於上述提示。
檔案單行列數超限制，限制為1000列。此時僅顯示前1000列，並在第1001列給出提示。
MongoDB Reader是否大小寫敏感？
在資料讀取時，使用者配置的Column.name為大小寫敏感，如配置有誤，會導致讀出資料為null。例如：
MongoDB來源資料為：
{ "MY_NAME": "zhangsan" }同步任務的Column配置為：
{ "column": [ { "name": "my_name" } ] }
則由於同步任務的配置與來源資料大小寫不一致，會導致資料讀取異常。
怎麼配置MongoDB Reader逾時時間長度？
逾時時間長度的配置參數為cursorTimeoutInMs，預設為600000ms（10分鐘），參數含義為MongoDB Server執行Query總耗時，不包含資料轉送時間長度。若全量讀取的資料較大，可能導致報錯：MongoDBReader$Task - operation exceeded time limitcom.mongodb.MongoExecutionTimeoutException: operation exceeded time limit。
MaxCompute如何?列篩選、重排序和補空等
通過配置MaxCompute Writer，可以實現MaxCompute本身不支援的列篩選、重排序和補空等操作。例如需要匯入的欄位列表，當匯入全部欄位時，可以配置為"column": ["*"]。
MaxCompute表有a、b和c三個欄位，您只同步c和b兩個欄位，可以將列配置為"column": ["c","b"]，表示會把Reader的第一列和第二列匯入MaxCompute的c欄位和b欄位，而MaxCompute表中新插入的a欄位會被置為null。
MaxCompute列配置錯誤的處理
為保證寫入資料的可靠性，避免多餘列資料丟失造成資料品質故障。對於寫入多餘的列，MaxCompute Writer將報錯。例如MaxCompute表欄位為a、b和c，如果MaxCompute Writer寫入的欄位多於三列，MaxCompute Writer將報錯。
MaxCompute分區配置注意事項
MaxCompute Writer僅提供寫入到最後一級分區的功能，不支援寫入按照某個欄位進行分區路由等功能。假設表一共有三級分區，在分區配置中必須指明寫入至某個三級分區。例如，寫入資料至一個表的第三級分區，可以配置為pt=20150101, type=1, biz=2，但不能配置為pt=20150101, type=1或者pt=20150101。
MaxCompute任務重跑和failover
MaxCompute Writer通過配置"truncate": true，保證寫入的等冪性。即當出現寫入失敗再次運行時，MaxCompute Writer將清理前述資料，並匯入新資料，以保證每次重跑之後的資料都保持一致。如果在運行過程中，因為其他的異常導致任務中斷，便不能保證資料的原子性，資料不會復原也不會自動重跑，需要您利用等冪性的特點進行重跑，以確保資料的完整性。
truncate為true的情況下，會將指定分區或表的資料全部清理，請謹慎使用。
源表有預設值，通過Data Integration建立的目標表，預設值、非空屬性等會保留嗎？
建立目標表時候，DataWorks只會保留源表的列名、資料類型、注釋等資訊，不會保留源表的預設值、約束（包含非空約束、索引等）。
離線整合任務配置切分鍵時，聯合主鍵是否可以作為切分鍵？
離線整合任務不支援將聯合主鍵作為切分鍵。
向包含主鍵自增列的目標表寫入資料，需要如何配置OTS Writer？
OTS Writer的配置中必須包含以下兩條：
"newVersion": "true", "enableAutoIncrement": "true",OTS Writer中不需要配置主鍵自增列的列名。
OTS Writer中配置的primaryKey條數+column條數需要等於上遊OTS Reader資料的列數。
在時序模型的配置中，如何理解_tag和is_timeseries_tag兩個欄位？
樣本：某條資料共有三個標籤，標籤為：【手機=小米，記憶體=8G，鏡頭=萊卡】。
資料匯出樣本（OTS Reader）
如果想將上述標籤合并到一起作為一列匯出，則配置為：
"column": [ { "name": "_tags", } ],DataWorks會將標籤匯出為一列資料，形式如下：
["phone=xiaomi","camera=LEICA","RAM=8G"]如果希望匯出
phone標籤和camera標籤，並且每個標籤單獨作為一列匯出，則配置為："column": [ { "name": "phone", "is_timeseries_tag":"true", }, { "name": "camera", "is_timeseries_tag":"true", } ],DataWorks會匯出兩列資料，形式如下：
xiaomi, LEICA
資料匯入樣本（OTS Writer）
現在上遊資料來源（Reader）有兩列資料：
一列資料為：
["phone=xiaomi","camera=LEICA","RAM=8G"]。另一列資料為：6499。
現希望將這兩列資料都添加到標籤裡面，預期的寫入後標籤欄位格式如下所示：
則配置為："column": [ { "name": "_tags", }, { "name": "price", "is_timeseries_tag":"true", }, ],第一列配置將
["phone=xiaomi","camera=LEICA","RAM=8G"]整體匯入標籤欄位。第二列配置將
price=6499單獨匯入標籤欄位。
日期時間類型資料寫入文本時，如何保留毫秒或者指定自訂日期時間格式？
同步任務轉指令碼模式後，在配置任務頁面的"setting"部分增加以下配置項：
"common": {
"column": {
"dateFormat": "yyyyMMdd",
"datetimeFormatInNanos": "yyyyMMdd HH:mm:ss.SSS"
}
}
其中：
dateFormat表示源端DATE（不帶時分秒）類型轉文本時的日期格式。
datetimeFormatInNanos表示源端DATETIME/TIMESTAMP（帶時分秒）類型轉文本時的日期格式，最多可指定到毫秒。
報錯資訊及解決方案
資料同步報錯：[TASK_MAX_SLOT_EXCEED]:Unable to find a gateway that meets resource requirements. 20 slots are requested, but the maximum is 16 slots.
可能原因：
設定並發數太大導致沒有足夠的資源。
解決方案：
減小離線同步任務的並發數設定。
如果您使用嚮導模式配置離線同步任務，需要調小配置通道控制中的任務期望最大並發數，詳情可參見通過嚮導模式配置離線同步任務。
如果您使用指令碼模式配置離線同步任務，需要調小配置通道控制中的concurrent參數，詳情可參見通過指令碼模式配置離線同步任務。
資料同步報錯：OutOfMemoryError: Java heap space
出現上述報錯後，您需要：
如果外掛程式配置支援的參數中有batchsize或者maxfilesize，可以調小對應的值。
您可以查看各外掛程式是否支援上述參數，進入支援的資料來源與讀寫外掛程式文檔後，單擊對應外掛程式查看參數詳情。
調小並發數。
如果您使用嚮導模式配置離線同步任務，需要調小配置通道控制中的任務期望最大並發數，詳情可參見通過嚮導模式配置離線同步任務。
如果您使用指令碼模式配置離線同步任務，需要調小配置通道控制中的concurrent參數，詳情可參見通過指令碼模式配置離線同步任務。
如果是檔案同步，例如同步OSS檔案等，請減少讀取的檔案數。
讀取OSS資料報錯：AccessDenied The bucket you access does not belong to you.
資料來源配置的ak使用者沒有該bucket的許可權，請為OSS資料來源配置的ak使用者授予該bucket相應許可權。
寫入Redis使用hash模式儲存資料時，報錯：Code:[RedisWriter-04], Description:[Dirty data]. - source column number is in valid!
產生原因：
Redis在使用hash模式儲存時，hash的attribute和value要成對出現。例如：
odpsReader: "column":[ "id", "name", "age", "address", ]，目標端在配置RedisWriter: "keyIndexes":[ 0 ,1]，在Redis中，id和name將作為key，age將作為attribute，address將作為value存到Redis中的hash類型的Redis中，如果odps源端只配置了兩列，則不可以使用hash模式去存Redis緩衝，會報該異常。解決方案：
假如只想用兩列，那就配置Redis的String模式去存資訊，如果必須要用hash存，源端至少配置三列。
讀取PostgreSQL資料報錯：org.postgresql.util.PSQLException: FATAL: terminating connection due to conflict with recovery
問題情境：離線同步工具同步PostgreSQL資料時，報錯如下：
org.postgresql.util.PSQLException: FATAL: terminating connection due to conflict with recovery可能原因：出現該情況的原因是從資料庫中拉取資料的時間較長，請增加max_standby_archive_delay和max_standby_streaming_delay的參數值，詳情請參見Standby Server Events
寫入/讀取MySQL報錯：Application was streaming results when the connection failed. Consider raising value of 'net_write_timeout/net_read_timeout、' on the server.
報錯原因：
net_read_timeout：datax將RDS MySQL根據splitpk對MySQL的資料進行拆分成數條等量的取數sql（select取數語句），執行時某條sql執行時間超過RDS側允許的最大已耗用時間。
net_write_timeout：等待將一個block發送給用戶端的逾時時間過小導致。
解決方案：
在資料來源URL的串連上增加該參數，net_write_timeout/net_read_timeout設定稍微大一些，或者在RDS控制台調整該參數。
改進建議：
如果任務可以重跑建議設定任務自動重跑。
例如：jdbc:mysql://192.168.1.1:3306/lizi?useUnicode=true&characterEncoding=UTF8&net_write_timeout=72000
離線同步至MySQL報錯：[DBUtilErrorCode-05]ErrorMessage: Code:[DBUtilErrorCode-05]Description:[往您配置的寫入表中寫入資料時失敗.]. - com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: No operations allowed after connection closed
報錯原因：
MySQL中參數wait_timeout預設時間為8小時，當達到預設時間時，如果仍然在擷取這數，會導致同步任務中斷。
解決方案：
修改MySQL的設定檔my.cnf（Windows系統下是my.ini）,在MySQL模組下面加上參數單位（秒），設定為：wait_timeout=2592000 interactive_timeout=2592000，再重啟登入MySQL，輸入如下語句：show variables like ‘%wait_time%’，查看是否設定成功。
讀取MySQL資料庫報錯：The last packet successfully received from the server was 902,138 milliseconds ago
CPU使用正常，記憶體使用量較高可能導致串連被斷開。
如果您確認可以自動重跑的話，建議您設定任務出錯自動重跑，詳情參考文檔：時間屬性配置說明
離線同步報錯：Communications link failure
讀取報錯
問題現象：
讀取資料時，報錯如下：
Communications link failure The last packet successfully received from the server was 7,200,100 milliseconds ago. The last packet sent successfully to the server was 7,200,100 milliseconds ago. - com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure可能原因：
資料庫執行SQL查詢速度慢，導致MySQL讀逾時。
解決方案：
排查是否設定了where過濾條件，以確保篩選欄位已添加索引。
排查來源資料表的資料是否太多。如果資料太多，建議拆分為多個任務。
查詢日誌找到執行阻塞的SQL，諮詢資料庫管理員解決。
寫入報錯
問題現象：
寫入資料時，報錯如下：
Caused by: java.util.concurrent.ExecutionException: ERR-CODE: [TDDL-4614][ERR_EXECUTE_ON_MYSQL] Error occurs when execute on GROUP 'xxx' ATOM 'dockerxxxxx_xxxx_trace_shard_xxxx': Communications link failure The last packet successfully received from the server was 12,672 milliseconds ago. The last packet sent successfully to the server was 12,013 milliseconds ago. More...可能原因：
慢查詢導致SocketTimeout。TDDL預設串連資料的SocketTimeout是12秒，如果一個SQL在MySQL端執行超過12秒仍未返回，會報4614的錯誤。當資料量較大或服務端繁忙時，會偶爾出現該錯誤。
解決方案：
建議資料庫穩定後，重新運行同步任務。
聯絡資料庫管理員調整該逾時時間。
離線同步報錯：Duplicate entry 'xxx' for key 'uk_uk_op'
報錯現象：
Error updating database. Cause: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry 'cfc68cd0048101467588e97e83ffd7a8-0' for key 'uk_uk_op'。可能原因：Data Integration同步任務不允許同一時間運行相同節點的不同執行個體（即相同JSON配置的同步任務不能同一時間運行多個，例如5分鐘為周期的同步任務，由於上遊延遲，在0點5分時調起了原本0點0分的執行個體和0點5分的執行個體，這樣會導致其中一個執行個體無法調起，或者任務執行個體在運行時又進行了補資料、重跑等操作）。
解決方案：錯開執行個體已耗用時間，如果為小時任務建議設定自依賴。
離線同步報錯：plugin xx does not specify column
出現上述報錯，有可能是因為同步任務的欄位對應配置不正確，或者是外掛程式沒有正確配置column。
檢查是否有做欄位對應。
檢查外掛程式是否有正確配置column。
讀取MaxCompute（ODPS）表資料報錯：The download session is expired.
報錯現象：
Code:DATAX_R_ODPS_005:讀取ODPS資料失敗, Solution:[請聯絡ODPS管理員]. RequestId=202012091137444331f60b08cda1d9, ErrorCode=StatusConflict, ErrorMessage=The download session is expired.可能原因：
離線同步讀取MaxCompute資料時，使用的是MaxCompute的tunnel命令來進行上傳下載資料。Tunnel的Session在服務端的生命週期為24小時，所以離線同步任務如果執行超過24小時任務會失敗退出，關於tunnel介紹詳情請參見使用說明。
解決方案：
您可以適當調大離線同步任務並發數，合理規劃同步的資料量確保任務在24小時內同步完成。
寫入MaxCompute(ODPS）報錯block失敗：Error writing request body to server
報錯現象：
Code:[OdpsWriter-09], Description:[寫入資料到 ODPS 目的表失敗.]. - ODPS 目的表寫 block:0 失敗， uploadId=[202012081517026537dc0b0160354b]. 請聯絡 ODPS 管理員處理. - java.io.IOException: Error writing request body to server。可能原因：
可能原因1：資料類型異常，即來來源資料不符合odps資料類型規範。比如4.2223這個資料值寫入odps的decimal（18,10）資料類型的情境。
可能原因2：odps塊/通訊異常等
解決方案：
請轉換資料類型，使用符合資料類型規範的資料。
RestAPI Writer報錯：通過path:[] 找到的JSON串格式不是數群組類型
RestAPI Writer提供兩種寫入模式，當同步多條資料的時候需要將dataMode配置為multiData，詳情請參見RestAPI Writer，同時需要在RestAPI Writer指令碼中新增參數dataPath:"data.list"。
配置Column時不需要加“data.list ”首碼。
離線同步源端是亞馬遜的RDS時報錯：Host is blocked
串連亞馬遜的RDS返回Host is blocked時，您需要關閉亞馬遜負載平衡健全狀態檢查，關閉後就不會再報出block問題。
讀取MongoDB報錯：no master
目前DataWorks同步任務暫不支援從庫讀取資料， 如果您配置從庫讀取，將會報該錯誤：no master。
讀取MongoDB報錯：MongoExecutionTimeoutException: operation exceeded time limit
分析原因：
遊標逾時引起。
解決方案：
調大參數cursorTimeoutInMs的值。
離線同步讀取MongoDB報錯：DataXException: operation exceeded time limit
需要通過增大任務並發數和讀取的BatchSize數。
離線同步讀取Elasticsearch報錯：ERROR ESReaderUtil - ES_MISSING_DATE_FORMAT, Unknown date value. please add "dataFormat". sample value:
分析原因：
Elasticsearch Reader無法對date類型欄位日期格式解析，因為對應es資料來源中有date欄位的mapping沒有配置format。
解決方案：
配置dateFomat參數，格式與ES date欄位的format相同，採用“||”進行分隔，format需要包含所用date類型的格式。如下所示：
"parameter" : { "column": [ "dateCol1", "dateCol2", "otherCol" ], "dateFormat" : "yyyy-MM-dd||yyyy-MM-dd HH:mm:ss", }將ES資料庫中的所有date欄位，mapping設定為format格式。
離線同步讀取Elasticsearch報錯：com.alibaba.datax.common.exception.DataXException: Code:[Common-00], Describe:[您提供的設定檔存在錯誤資訊，請檢查您的作業配置 .] - 配置資訊錯誤. 您提供的配置資訊不是合法的JSON格式: illegal ref, [ . 請按照標準json格式提供配置資訊.
分析原因：
受fastjson關鍵字的限制，可能在索引或者列中存在$ref這類關鍵字。
解決方案：
Elasticsearch Reader暫不支援同步欄位中帶有關鍵字$ref的索引，詳情請參見Elasticsearch Reader。
離線同步寫入Elasticsearch報錯：version_conflict_engine_exception.
分析原因：
觸發了ES的樂觀鎖的機制，目前的版本號應該是xxx，但是更新命令傳過來的版本號碼是另一個，所以才會出現版本衝突，update的時候，同時有人在刪索引資料。
解決方案：
檢查確認是否有刪資料的行為。
任務同步方式將Update寫改為Index。
離線同步寫入Elasticsearch報錯：illegal_argument_exception.
分析原因：
Column欄位在配置similarity、properties等進階屬性時，需要other_params才能讓外掛程式識別。
解決方案：
Column裡配置
other_params，other_params裡增加similarity，如下所示：{"name":"dim2_name",...,"other_params":{"similarity":"len_similarity"}}
ODPS Array欄位類型資料離線同步至Elasticsearch報錯：dense_vector
分析原因：
目前離線同步寫入Elasticsearch不支暫不支援
dense_vector類型，類型，僅支援如下類型：ID,PARENT,ROUTING,VERSION,STRING,TEXT,KEYWORD,LONG, INTEGER,SHORT,BYTE,DOUBLE,FLOAT,DATE,BOOLEAN,BINARY, INTEGER_RANGE,FLOAT_RANGE,LONG_RANGE,DOUBLE_RANGE,DATE_RANGE, GEO_POINT,GEO_SHAPE,IP,IP_RANGE,COMPLETION,TOKEN_COUNT,OBJECT,NESTED;解決方案：
針對Elasticsearch writer不支援的類型，處理方式如下：
不建議使用Elasticsearch writer建立索引mapping，需要使用客戶自建的mapping。
對應的類型改成NESTED。
修改配置為：
dynamic = true，cleanup=false。
離線同步資料至本地Hive報錯：Could not get block locations.
分析原因：
可能存在mapred.task.timeout參數設定時間過短，Hadoop將任務終止，並清理臨時目錄，則後續將找不到臨時資料。
解決方案：
可以調大mapred.task.timeout參數值。
MongoDB同步任務運行報錯：no such cmd splitVector
可能原因：
在同步任務運行時，預設優先使用
splitVector命令進行任務分區，在部分MongoDB版本中，不支援splitVector命令，進而會導致報錯no such cmd splitVector。解決方案：
進入同步任務配置頁面後，單擊頂部的轉換指令碼
按鈕。將任務修改為指令碼模式。在MongoDB的parameter配置中，增加參數
"useSplitVector" : false以避免使用
splitVector。
MongoDB離線同步報錯：After applying the update, the (immutable) field '_id' was found to have been altered to _id: "2"
報錯現象：
同步任務中，以嚮導模式為例，當配置了寫入模式（是否覆蓋）為是，且配置了非
_id欄位作為業務主鍵，可能會出現此問題。
可能原因：
寫入資料中，存在_id與配置的業務主鍵（如上述配置樣本的
my_id）不匹配的資料。解決方案：
方案一：修改離線同步任務，確保配置的業務主鍵與_id一致。
方案二：進行資料同步時，將_id作為業務主鍵。
離線任務，運行報錯：MongoDBReader$Task - operation exceeded time limitcom.mongodb.MongoExecutionTimeoutException: operation exceeded time limit.
報錯內容：資料同步任務時，任務運行失敗，錯誤提示為
MongoDBReader$Task - operation exceeded time limitcom.mongodb.MongoExecutionTimeoutException: operation exceeded time limit。可能原因：全量拉取資料過大導致的。
如何處理：
加大並發。
減小BatchSize。
Reader端parameter參數中，增加
cursorTimeoutInMs配置，可以嘗試設定大些，例如3600000ms。