[
https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roc Marshal updated FLINK-23943:
--------------------------------
Comment: was deleted
(was: ---jobmanager.log------------
2021-08-24 19:29:28,047 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Trigger heartbeat request.
2021-08-24 19:29:28,053 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Received heartbeat from 172.25.7.212:51798-6c6004.
2021-08-24 19:29:29,786 INFO org.apache.flink.runtime.jobmaster.JobMaster [] -
Triggering stop-with-savepoint for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,800 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 1 (type=SAVEPOINT_SUSPEND) @ 1629804569787 for job
f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,829 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 0409635d4e01383381cea6322e226a54
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,871 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 314d5caeb9871d74f5b00bdf1e4868ab
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,891 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Stop-with-savepoint transitioned from WaitingForSavepoint to SavepointCreated
on savepoint creation handling for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,895 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Completed
checkpoint 1 for job f08b743cea0468fa3ed1d00e32962755 (872 bytes in 103 ms).
2021-08-24 19:29:29,895 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint
state: OperatorState(operatorID: c09dc291fad93d575e015871097bfc60, parallelism:
1, maxParallelism: 128, coordinatorState: (none), sub task states: 1, total
size (bytes): 0), OperatorState(operatorID: 20ba6b65f97481d5570070de90e4e791,
parallelism: 1, maxParallelism: 128, coordinatorState: (none), sub task states:
1, total size (bytes): 872), OperatorState(operatorID:
bc764cd8ddf7a0cff126f51c16239658, parallelism: 1, maxParallelism: 128,
coordinatorState: (none), sub task states: 0, total size (bytes): 0)
-----taskmanager.log------
2021-08-24 19:29:29,805 DEBUG
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Trigger checkpoint
1@1629804569787 for 0409635d4e01383381cea6322e226a54.
2021-08-24 19:29:29,806 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Source: Custom Source (1/1)#0
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.runtime.io.network.partition.consumer.ChannelStatePersister []
- found barrier 1, lastSeenBarrier = -1 (COMPLETED) @
InputChannelInfo\{gateIdx=0, inputChannelIdx=0}
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Received barrier from channel
InputChannelInfo\{gateIdx=0, inputChannelIdx=0} @ 1.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Triggering checkpoint 1 on the barrier
announcement at 1629804569787.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Map -> Sink: Print to Std. Out (1/1)#0
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Source: Custom Source (1/1)#0,5,Flink Task Threads] took
1 ms.
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 1 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 0 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Source: Custom Source (1/1)#0 - finished synchronous part of checkpoint 1.
Alignment duration: 0 ms, snapshot duration -1 ms, is unaligned checkpoint :
false
2021-08-24 19:29:29,818 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Source:
Custom Source (1/1)#0 - started executing asynchronous part of checkpoint 1.
Asynchronous start delay: 0 ms
2021-08-24 19:29:29,819 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, asynchronous
part) in thread Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 0 ms.
2021-08-24 19:29:29,820 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Source:
Custom Source (1/1)#0 - finished asynchronous part of checkpoint 1.
Asynchronous duration: 1 ms
2021-08-24 19:29:29,824 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] - Asynchronous full
Savepoint (In-Memory Stream Factory, synchronous part) in thread Thread[Map ->
Sink: Print to Std. Out (1/1)#0,5,Flink Task Threads] took 0 ms.
2021-08-24 19:29:29,825 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Map -> Sink: Print to Std. Out (1/1)#0 - finished synchronous part of
checkpoint 1. Alignment duration: 0 ms, snapshot duration -1 ms, is unaligned
checkpoint : false
2021-08-24 19:29:29,827 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Map ->
Sink: Print to Std. Out (1/1)#0 - started executing asynchronous part of
checkpoint 1. Asynchronous start delay: 1 ms
2021-08-24 19:29:29,827 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, asynchronous
part) in thread Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 0 ms.
2021-08-24 19:29:29,850 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] - Asynchronous full
Savepoint (In-Memory Stream Factory, asynchronous part) in thread
Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 23 ms.
2021-08-24 19:29:29,853 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, asynchronous
part) in thread Thread[AsyncOperations-thread-1,5,Flink Task Threads] took 0 ms.
2021-08-24 19:29:29,858 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Map ->
Sink: Print to Std. Out (1/1)#0 - finished asynchronous part of checkpoint 1.
Asynchronous duration: 28 ms
2021-08-24 19:29:29,897 DEBUG
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Confirm checkpoint
1@1629804569787 for 0409635d4e01383381cea6322e226a54.
2021-08-24 19:29:29,899 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Notification of completed checkpoint 1 for task Source: Custom Source (1/1)#0
2021-08-24 19:29:29,899 DEBUG
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Confirm checkpoint
1@1629804569787 for 314d5caeb9871d74f5b00bdf1e4868ab.
2021-08-24 19:29:29,899 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Notification of completed checkpoint 1 for task Map -> Sink: Print to Std. Out
(1/1)#0
2021-08-24 19:29:29,899 DEBUG org.apache.flink.streaming.runtime.io.checkpoint)
> "/jobs/:jobid/stop" in REST API can't stop the target job.
> ----------------------------------------------------------
>
> Key: FLINK-23943
> URL: https://issues.apache.org/jira/browse/FLINK-23943
> Project: Flink
> Issue Type: Bug
> Components: Runtime / REST
> Affects Versions: 1.13.2
> Reporter: Roc Marshal
> Priority: Major
> Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log,
> flink-roc-taskexecutor-0-MacBook-Pro.local.log
>
>
> * "/jobs/:jobid/stop" in REST API can't stop the target job.
> * It can trigger a savepoint with the parameters.
> * The interface document link
> https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
