API tools faq
paste
Advertisement
Guest User

flink-logs

a guest
Dec 10th, 2019
289
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.92 KB | None | 0 0
raw download clone embed print report
  1. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5723 (max part counter=0).
  2. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5723.
  3. [Async calls on dasher-activity -> Filter -> Sink: Unnamed (1/2)] INFO org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 0/2 - checkpoint 5723 complete, committing transaction TransactionHolder{handle=KafkaTransactionState [transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1576027305276} from checkpoint 5723
  4. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5724 (max part counter=0).
  5. [Async calls on dasher-activity -> Filter -> Sink: Unnamed (1/2)] INFO org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 0/2 - checkpoint 5724 complete, committing transaction TransactionHolder{handle=KafkaTransactionState [transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1576027320277} from checkpoint 5724
  6. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5724.
  7. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5725 (max part counter=0).
  8. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5725.
  9. [Async calls on dasher-activity -> Filter -> Sink: Unnamed (1/2)] INFO org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 0/2 - checkpoint 5725 complete, committing transaction TransactionHolder{handle=KafkaTransactionState [transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1576027335276} from checkpoint 5725
  10. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5726 (max part counter=0).
  11. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5726.
  12. [Async calls on dasher-activity -> Filter -> Sink: Unnamed (1/2)] INFO org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 0/2 - checkpoint 5726 complete, committing transaction TransactionHolder{handle=KafkaTransactionState [transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1576027350367} from checkpoint 5726
  13. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5727 (max part counter=0).
  14. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5727.
  15. [Async calls on dasher-activity -> Filter -> Sink: Unnamed (1/2)] INFO org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction - FlinkKafkaProducer 0/2 - checkpoint 5727 complete, committing transaction TransactionHolder{handle=KafkaTransactionState [transactionalId=null, producerId=-1, epoch=-1], transactionStartTime=1576027365276} from checkpoint 5727
  16. [Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 checkpointing for checkpoint with id=5728 (max part counter=0).
  17. [Async calls on Sink: my-s3-sink (1/1)] INFO org.apache.flink.streaming.api.functions.sink.filesystem.Buckets - Subtask 0 received completion notification for checkpoint with id=5728.
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!