Flink1.12.x ExecutionGraph数据代码代码逻辑图
2021-04-25 17:44:38 0 举报Flink1.12.x ExecutionGraph数据代码代码逻辑图
作者其他创作
大纲/内容
ExecutionVertex producer
id : c196e533cb79dce00831e5a5f19b65a0
Collection<PartitionInfo> partitionInfos : 0
Sink: Print to Std. Out (1/1)
{ExecutionJobVertex@7391}
int partitionNumber : 2
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#3
3 = {IntermediateResultPartition@7434}
IntermediateResult[] producedDataSets
...................
int partitionNumber : 3
0 = {IntermediateResultPartition@7431}
IntermediateResultPartition #{IntermediateResultPartition@7432
id : c196e533cb79dce00831e5a5f19b65a0#2
600244ebcee416f3e96a7c165ca99777#2
Execution currentExecution
1 = {IntermediateResultPartition@7448}
id : 600244ebcee416f3e96a7c165ca99777
IntermediateResult totalResult
0 = ExecutionEdge [org.apache.flink.runtime.executiongraph.IntermediateResultPartition@47d4c7e0 <=> Sink: Print to Std. Out (1/1)]
{ScheduledThreadPoolExecutor@7331} [ pool size = 1 ]
ExecutionJobVertex@7394
ExecutionVertex target : Flat Map (2/4)
ea632d67b7d595e5b851708ae9ad79d6_3
0
ExecutionJobVertex jobVertex
ExecutionState state = CREATED
{ExecutionVertex@7422} \"Flat Map (4/4)\"
ExecutionEdge[][] inputEdges
List<IntermediateResult> inputs
ExecutionVertex target : Flat Map (4/4)
IntermediateResultPartition #{IntermediateResultPartition@7431
String taskNameWithSubtask
id : 5b6d28b85519babb501dc72c483ca530#0
ExecutionJobVertex@7391
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#0
int attemptNumber : 0
{ExecutionJobVertex@7394}
ExecutionVertexID executionVertexId
c196e533cb79dce00831e5a5f19b65a0
id : 600244ebcee416f3e96a7c165ca99777#1
0 = {ExecutionVertex@7435} \
{ExecutionVertex@7419} \"Flat Map (1/4)\"
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#1
0 = {ExecutionEdge@7565} \"ExecutionEdge [org.apache.flink.runtime.executiongraph.IntermediateResultPartition@7f27d18f <=> Flat Map (1/4)]\"
0 = IntermediateResult
ExecutionVertex vertex
id : 600244ebcee416f3e96a7c165ca99777#2
c9dec1b0a924c6bf41261931f1a38f3e
{ExecutionVertex@7441} \
2 = {IntermediateResultPartition@7449}
ea632d67b7d595e5b851708ae9ad79d6_1
ExecutionJobVertex@7381
ac05051d4396db28c7058c84b0bcfba4
1 = {ExecutionEdge@7566} \"ExecutionEdge [org.apache.flink.runtime.executiongraph.IntermediateResultPartition@7f27d18f <=> Flat Map (2/4)]\"
IntermediateResultPartition source : 5b6d28b85519babb501dc72c483ca530#0
ExecutionAttemptID attemptId
0a448493b4782967b150582570326227_3
ExecutionVertex[] taskVertices
{ExecutionVertex@7419} \"Flat Map (2/4)\"
Time rpcTimeout : 10000 ms
{ExecutionVertex@7421} \"Flat Map (3/4)\"
{ExecutionVertex@7489} \
{ExecutionVertex@7408} \"Source: Socket Stream (1/1)\"
Flat Map (2/4)
{ExecutionVertex@7447} \
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#3
03d45e31b0a16f104aefcc1e298df495
c196e533cb79dce00831e5a5f19b65a0#3
id : c196e533cb79dce00831e5a5f19b65a0
0a448493b4782967b150582570326227_2
List<List<ExecutionEdge>> consumers
1 = {ExecutionEdge@7471} \
3 = {IntermediateResultPartition@7450}
IntermediateResultPartition source : c196e533cb79dce00831e5a5f19b65a0#2
3 = {ExecutionEdge@7473} \
ExecutionJobVertex@7435
IntermediateResultPartition #{IntermediateResultPartition@7448
b61ca7ed9b23e400d0ead214752e6280
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#1
c9fa9d4b6f662b7f077eaac50ec6e71b
Executor executor
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#2
2 = {ExecutionVertex@7489} \
c1f635ea7dfc0fdae9b0ec1774e2108d
0a448493b4782967b150582570326227_1
ExecutionJobVertex@7465
id : 5b6d28b85519babb501dc72c483ca530
id : c196e533cb79dce00831e5a5f19b65a0#1
0 = {ExecutionEdge@7470} \
2 = {ExecutionEdge@7472} \
Flat Map (3/4)
2 = {ExecutionEdge@7567} \"ExecutionEdge [org.apache.flink.runtime.executiongraph.IntermediateResultPartition@7f27d18f <=> Flat Map (3/4)]\"
IntermediateResultPartition source : c196e533cb79dce00831e5a5f19b65a0#3
0 = {ExecutionVertex@7465} \"Sink: Print to Std. Out (1/1)\"
LogicalSlot assignedResource : null
IntermediateResultPartition[] partitions
long globalModVersion : 1
ea632d67b7d595e5b851708ae9ad79d6_0
{ExecutionVertex@7420} \"Flat Map (2/4)\"
ExecutionVertex target : Sink: Print to Std. Out (1/1)
0 = {ExecutionVertex@7408} \"Source: Socket Stream (1/1)\"
int partitionNumber : 0
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#2
6d2677a0ecc3fd8df0b72ec675edf8f4_0
748b00edf1b832c483fe7f790e627168
c196e533cb79dce00831e5a5f19b65a0#1
c196e533cb79dce00831e5a5f19b65a0#2
0 = {IntermediateResultPartition@7555}
{ExecutionVertex@7419} \"Flat Map (3/4)\"
id : c196e533cb79dce00831e5a5f19b65a0#3
600244ebcee416f3e96a7c165ca99777#0
{ExecutionVertex@7408} \"Sink: Print to Std. Out (1/1)\"
c196e533cb79dce00831e5a5f19b65a0#0
IntermediateResultPartition #{IntermediateResultPartition@7447
Source: Socket Stream (1/1)
600244ebcee416f3e96a7c165ca99777#1
Flat Map (1/4)
id : 600244ebcee416f3e96a7c165ca99777#3
2
{ExecutionJobVertex@7381}
3 = {ExecutionVertex@7447} \
1
3 = {ExecutionEdge@7568} \"ExecutionEdge [org.apache.flink.runtime.executiongraph.IntermediateResultPartition@7f27d18f <=> Flat Map (4/4)]\"
Flat Map (4/4)
0 = {ExecutionVertex@7422} \"Flat Map (4/4)\"
1 = {IntermediateResultPartition@7432}
{ExecutionVertex@7435} \
3 = {ExecutionEdge@7503} \
ExecutionVertex target : Flat Map (1/4)
49b63fe190c4537aa4ee7684a0168693
bc764cd8ddf7a0cff126f51c16239658_0
IntermediateResultPartition source : 600244ebcee416f3e96a7c165ca99777#0
{ExecutionVertex@7419} \"Flat Map (4/4)\"
空
0 = {ExecutionVertex@7421} \"Flat Map (3/4)\"
ExecutionVertex target : Flat Map (3/4)
int partitionNumber : 1
IntermediateResultPartition source : c196e533cb79dce00831e5a5f19b65a0#1
IntermediateResultPartition #{IntermediateResultPartition@7449
0 = {ExecutionVertex@7419} \"Flat Map (1/4)\"
5b6d28b85519babb501dc72c483ca530#0
0a448493b4782967b150582570326227_0
1 = {ExecutionVertex@7441} \
0 = {ExecutionEdge@7500} \
2 = {IntermediateResultPartition@7433}
0 = {ExecutionVertex@7420} \"Flat Map (2/4)\"
2 = {ExecutionEdge@7502} \
4
IntermediateResultPartition #{IntermediateResultPartition@7450
ExecutionJobVertex producer
IntermediateResultPartition #{IntermediateResultPartition@7555}
600244ebcee416f3e96a7c165ca99777#3
0 = {IntermediateResultPartition@7447}
1ed56549566537663900bb0667a53c4b
600244ebcee416f3e96a7c165ca99777
061a631cbc2006818dd1e627ed0bfaa2
id : c196e533cb79dce00831e5a5f19b65a0#0
IntermediateResultPartition #{IntermediateResultPartition@7434
ea632d67b7d595e5b851708ae9ad79d6_2
3
IntermediateResultPartition #{IntermediateResultPartition@7433
IntermediateResultPartition source : c196e533cb79dce00831e5a5f19b65a0#0
1 = {ExecutionEdge@7501} \
收藏
收藏
0 条评论
下一页
