Greedyu opened a new pull request, #4882: URL: https://github.com/apache/inlong/pull/4882
Handling exceptions: please declare primary key for sink table when query contains update/delete record. - Fixes #4814 Briefly describe ideas 1. The problem is that with flink JDBC SQL you have to specify the primary key.  2. When the Sort module sees the processing of primaryKey, it should be a problem with the parameters in the node. Gotta go check it out  3. Debug test locates that the primaryKey in the file read by sort is indeed empty <img width="1581" alt="image" src="https://user-images.githubusercontent.com/20356765/177348864-00113314-63bb-4c8c-a540-10cc42af4d9a.png";> 4. To query the source of assignment of GroupInfo.StreamInfo.nodes, there are only CreateSortConfigListenerV2 and CreateStreamSortConfigListener classes, and they are both created by the createNodesForStream() method.  5. Test after bug fixes <img width="1435" alt="image" src="https://user-images.githubusercontent.com/20356765/177351479-b449221e-0169-401a-8996-51f29a07cc99.png";> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
![https://user-images.githubusercontent.com/20356765/177348864-00113314-63bb-4c8c-a540-10cc42af4d9a.png"](https://user-images.githubusercontent.com/20356765/177348864-00113314-63bb-4c8c-a540-10cc42af4d9a.png"){kind=link}
![https://user-images.githubusercontent.com/20356765/177351479-b449221e-0169-401a-8996-51f29a07cc99.png"](https://user-images.githubusercontent.com/20356765/177351479-b449221e-0169-401a-8996-51f29a07cc99.png"){kind=link}