Modify the InputStreamEntity entity class to ByteArrayEntity

Author: caoliang-web

selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbCopyIntoObserver.java

@@ -206,15 +206,18 @@ public void executeCopy(String hostPort, String fileName) throws IOException{
             if(success){
                 LOG.info("commit success cost {}ms, response is {}, filename is {}", System.currentTimeMillis() - start, loadResult,fileName);
             }else{
-                throw new SelectdbWriterException("commit fail",true);
+                LOG.error("commit error with status {}, reason {}, response {}", statusCode, reasonPhrase, loadResult);
+                String copyErrMsg = String.format("commit error, status: %d, reason: %s, response: %s, copySQL: %s",
+                        statusCode, reasonPhrase, loadResult, copySQL);
+                throw new SelectdbWriterException(copyErrMsg,true);
             }
         }
     }
 
     public boolean handleCommitResponse(String loadResult) throws IOException {
-        BaseResponse<CopyIntoResp> baseResponse = OBJECT_MAPPER.readValue(loadResult, new TypeReference<BaseResponse<CopyIntoResp>>(){});
+        BaseResponse baseResponse = OBJECT_MAPPER.readValue(loadResult, new TypeReference<BaseResponse>(){});
         if(baseResponse.getCode() == SUCCESS){
-            CopyIntoResp dataResp = baseResponse.getData();
+            CopyIntoResp dataResp = OBJECT_MAPPER.convertValue(baseResponse.getData(),CopyIntoResp.class);
             if(FAIL.equals(dataResp.getDataCode())){
                 LOG.error("copy into execute failed, reason:{}", loadResult);
                 return false;