davidradl commented on code in PR #25807:
URL: https://github.com/apache/flink/pull/25807#discussion_r1893999727
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalSort.java:
##########
@@ -119,9 +123,11 @@ protected Transformation<RowData> translateToPlanInternal(
RowType inputType = (RowType) inputEdge.getOutputType();
LogicalType timeType =
inputType.getTypeAt(sortSpec.getFieldSpec(0).getFieldIndex());
if (isRowtimeAttribute(timeType)) {
+ System.out.println("createSortRowTime");
Review Comment:
thanks @Au-Miner - what did you think about the logging idea, where you had
the stdouts. Mostly debug maybe some infos? As they were presumably helpful for
you when developing this change?
--
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]
