时刻 | 数据量 | 缓存区数 | Flink | Flink-N | 传输情况 | ||
实际传输 | W1 | 实际传输 | W2 | ||||
t1 | 8 | 10 | 8 | 6 | 8 | 8 | Flink在t1时剩2块数据; Flink-N全部传输 |
t2 | 4 | 4 | 6 | 6 | 4 | 4 | Flink发生第1次阻塞; Flink-N全部传输 |
t3 | 8 | 10 | 8 | 6 | 8 | 7 | Flink处于第1次阻塞中; Flink-N剩余1块 |
t4 | 4 | 4 | 12 | 6 | 5 | 4 | Flink发生第2次阻塞; Flink-N剩余1块 |
t5 | 8 | 10 | 14 | 6 | 9 | 7 | Flink处于第2次阻塞中; Flink-N剩余2块 |
t6 | 0 | 4 | 14 | 6 | 2 | 2 | Flink发生第3次阻塞; Flink-N完成任务 |
t7 | 0 | 10 | 8 | 6 | -- | -- | Flink处于第3次阻塞中; Flink-N完成任务 |
t8 | 0 | 4 | 8 | 6 | -- | -- | Flink发生第4次阻塞; Flink-N完成任务 |
t9 | 0 | 10 | 2 | 6 | -- | -- | Flink处于第4次阻塞中; Flink-N完成任务 |
t10 | 0 | 4 | 2 | 6 | -- | -- | Flink完成任务; Flink-N完成任务 |