xuyangzhong commented on code in PR #27111:
URL: https://github.com/apache/flink/pull/27111#discussion_r2454376151
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDeltaJoin.java:
##########
@@ -117,6 +119,9 @@ public class StreamExecDeltaJoin extends
ExecNodeBase<RowData>
"lookupRightTableJoinSpec";
Review Comment:
Actually, I'm not entirely sure either. 🧐 I referenced
`CommonExecLookupJoin` and `CommonExecSink`, and I noticed that the
transformations use "-" as separators, while the field names for JSON are in
camel case. So, I decided to follow that convention as well.
--
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]
