You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/09/27 15:37:07 UTC
[flink] 02/06: [FLINK-13386][web]: Fix job subtask sort
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit fca47cddab357702c56ec00c2980e59c60df1dc1
Author: vthinkxie <ya...@alibaba-inc.com>
AuthorDate: Sat Jul 27 15:33:22 2019 +0800
[FLINK-13386][web]: Fix job subtask sort
---
flink-runtime-web/web-dashboard/src/app/services/job.service.ts | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-runtime-web/web-dashboard/src/app/services/job.service.ts b/flink-runtime-web/web-dashboard/src/app/services/job.service.ts
index 4da2b70..48f32a1 100644
--- a/flink-runtime-web/web-dashboard/src/app/services/job.service.ts
+++ b/flink-runtime-web/web-dashboard/src/app/services/job.service.ts
@@ -264,6 +264,8 @@ export class JobService {
});
}
});
+ const listOfVerticesId = job.vertices.map(item => item.id);
+ nodes.sort((pre, next) => listOfVerticesId.indexOf(next.id) - listOfVerticesId.indexOf(pre.id));
}
return {
...job,