[Hotfix][SQL Transform] SQL transform plugin bug
Purpose of this pull request
Check list
- [ ] Code changed are covered with tests, or it does not need tests for reason:
- [ ] If any new Jar binary package adding in your PR, please add License Notice according New License Guide
- [ ] If necessary, please update the documentation to describe the new feature. https://github.com/apache/incubator-seatunnel/tree/dev/docs
- [ ] If you are contributing the connector code, please check that the following files are updated:
- Update change log that in connector document. For more details you can refer to connector-v2
- Update plugin-mapping.properties and add new connector information in it
- Update the pom file of seatunnel-dist
- [ ] Update the
release-note.
add set Table identifier, used for the source connector that @qianxkun
seaTunnelRow.setTableId(inputRow.getTableId());
PTAL: @liugddx @EricJoy2048 @rewerma
Issues:https://github.com/apache/seatunnel/issues/4784
add set Table identifier, used for the source connector that @qianxkun
seaTunnelRow.setTableId(inputRow.getTableId());PTAL: @liugddx @EricJoy2048 @rewerma
Can you add a test case?
@rewerma PTAL.
seaTunnelRow.setTableId(inputRow.getTableId());
Yes,add seaTunnelRow.setTableId(inputRow.getTableId()); is OK.
seaTunnelRow.setTableId(inputRow.getTableId());
Yes,add
seaTunnelRow.setTableId(inputRow.getTableId());is OK.
CC @qianxkun
rebase dev fix ci error
Fix:https://github.com/apache/seatunnel/pull/4819
This issue has already been fixed in https://github.com/apache/seatunnel/pull/4819.