venkata91 commented on code in PR #10832:
URL: https://github.com/apache/iceberg/pull/10832#discussion_r1727811554
##########
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSpeculativeExecutionSupport.java:
##########
@@ -144,9 +151,9 @@ public void testSpeculativeExecution() throws Exception {
private static class TestingMap extends RichMapFunction<Row, Row> {
@Override
public Row map(Row row) throws Exception {
- // Put the subtasks with the first attempt to sleep to trigger
speculative
- // execution
- if (getRuntimeContext().getTaskInfo().getAttemptNumber() <= 0) {
+ // Simulate slow subtask 0 with attempt 0
+ TaskInfo taskInfo = getRuntimeContext().getTaskInfo();
+ if (taskInfo.getIndexOfThisSubtask() == 0 && taskInfo.getAttemptNumber()
<= 0) {
Review Comment:
Interesting. Thanks for tagging me. Do you mean adding
`taskInfo.getIndexOfThisSubtask() == 0` solves the hang issue?
--
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: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
