A | B | C | D | |
---|---|---|---|---|
1 | @timestamp | machineIdentifier | logger_name | message |
2 | Jan 18, 2022 @ 10:24:01.518 | i-073cca80f22a29805 | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
3 | Jan 18, 2022 @ 10:24:05.984 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
4 | Jan 18, 2022 @ 10:24:05.984 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001979, shardId-000000001912, shardId-000000001956, shardId-000000001889, shardId-000000001966, shardId-000000001999, shardId-000000001976, shardId-000000001876, shardId-000000001953, shardId-000000001886, shardId-000000001996, shardId-000000001852, shardId-000000001896, shardId-000000001962, shardId-000000002006, shardId-000000002059, shardId-000000001892, shardId-000000002002, shardId-000000002046, shardId-000000002056, shardId-000000002022, shardId-000000002062, shardId-000000001916 |
5 | Jan 18, 2022 @ 10:24:19.987 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=23, largestPoolSize=36, maximumPoolSize=2147483647) |
6 | Jan 18, 2022 @ 10:24:22.578 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=22, largestPoolSize=29, maximumPoolSize=2147483647) |
7 | Jan 18, 2022 @ 10:24:28.131 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.PeriodicShardSyncManager | WorkerId i-0b7f310fbf75d6d58 is leader, running the periodic shard sync task |
8 | Jan 18, 2022 @ 10:24:28.138 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.PeriodicShardSyncManager | Skipping shard sync for ophan-raw-submissions due to the reason - Hash Ranges are complete for ophan-raw-submissions |
9 | Jan 18, 2022 @ 10:24:29.160 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=2, coreThreads=0, leasesOwned=23, largestPoolSize=25, maximumPoolSize=2147483647) |
10 | Jan 18, 2022 @ 10:24:44.585 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001936, shardId-000000001969, shardId-000000001869, shardId-000000001946, shardId-000000001846, shardId-000000001932, shardId-000000002009, shardId-000000001942, shardId-000000002019, shardId-000000001952, shardId-000000001972, shardId-000000002016, shardId-000000002049, shardId-000000001872, shardId-000000001882, shardId-000000002036, shardId-000000002012, shardId-000000002032, shardId-000000001909, shardId-000000001906, shardId-000000001939, shardId-000000001926 |
11 | Jan 18, 2022 @ 10:24:44.585 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
12 | Jan 18, 2022 @ 10:24:50.032 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=23, largestPoolSize=36, maximumPoolSize=2147483647) |
13 | Jan 18, 2022 @ 10:24:52.587 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=22, largestPoolSize=29, maximumPoolSize=2147483647) |
14 | Jan 18, 2022 @ 10:24:53.165 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
15 | Jan 18, 2022 @ 10:24:53.165 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001859, shardId-000000001902, shardId-000000001879, shardId-000000001989, shardId-000000001856, shardId-000000001922, shardId-000000001866, shardId-000000001899, shardId-000000001986, shardId-000000002029, shardId-000000002039, shardId-000000001862, shardId-000000001982, shardId-000000002026, shardId-000000001992, shardId-000000002042, shardId-000000002052, shardId-000000002063, shardId-000000001919, shardId-000000001929, shardId-000000001949, shardId-000000001849, shardId-000000001959 |
16 | Jan 18, 2022 @ 10:24:54.842 | i-07d4b5acb83d03c0e | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
17 | Jan 18, 2022 @ 10:24:55.916 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
18 | Jan 18, 2022 @ 10:24:59.178 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=23, largestPoolSize=25, maximumPoolSize=2147483647) |
19 | Jan 18, 2022 @ 10:25:01.518 | i-073cca80f22a29805 | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
20 | Jan 18, 2022 @ 10:25:07.036 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001979, shardId-000000001912, shardId-000000001956, shardId-000000001889, shardId-000000001966, shardId-000000001999, shardId-000000001976, shardId-000000001876, shardId-000000001953, shardId-000000001886, shardId-000000001996, shardId-000000001852, shardId-000000001896, shardId-000000001962, shardId-000000002006, shardId-000000002059, shardId-000000001892, shardId-000000002002, shardId-000000002046, shardId-000000002056, shardId-000000002022, shardId-000000002062, shardId-000000001916 |
21 | Jan 18, 2022 @ 10:25:07.036 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
22 | Jan 18, 2022 @ 10:25:20.039 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=23, largestPoolSize=36, maximumPoolSize=2147483647) |
23 | Jan 18, 2022 @ 10:25:22.596 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=22, largestPoolSize=29, maximumPoolSize=2147483647) |
24 | Jan 18, 2022 @ 10:25:29.185 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=23, largestPoolSize=25, maximumPoolSize=2147483647) |
25 | Jan 18, 2022 @ 10:25:45.603 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001936, shardId-000000001969, shardId-000000001869, shardId-000000001946, shardId-000000001846, shardId-000000001932, shardId-000000002009, shardId-000000001942, shardId-000000002019, shardId-000000001952, shardId-000000001972, shardId-000000002016, shardId-000000002049, shardId-000000001872, shardId-000000001882, shardId-000000002036, shardId-000000002012, shardId-000000002032, shardId-000000001909, shardId-000000001906, shardId-000000001939, shardId-000000001926 |
26 | Jan 18, 2022 @ 10:25:45.604 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
27 | Jan 18, 2022 @ 10:25:50.066 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=23, largestPoolSize=36, maximumPoolSize=2147483647) |
28 | Jan 18, 2022 @ 10:25:52.605 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=22, largestPoolSize=29, maximumPoolSize=2147483647) |
29 | Jan 18, 2022 @ 10:25:54.193 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001859, shardId-000000001902, shardId-000000001879, shardId-000000001989, shardId-000000001856, shardId-000000001922, shardId-000000001866, shardId-000000001899, shardId-000000001986, shardId-000000002029, shardId-000000002039, shardId-000000001862, shardId-000000001982, shardId-000000002026, shardId-000000001992, shardId-000000002042, shardId-000000002052, shardId-000000002063, shardId-000000001919, shardId-000000001929, shardId-000000001949, shardId-000000001849, shardId-000000001959 |
30 | Jan 18, 2022 @ 10:25:54.193 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
31 | Jan 18, 2022 @ 10:25:54.842 | i-07d4b5acb83d03c0e | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
32 | Jan 18, 2022 @ 10:25:55.916 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
33 | Jan 18, 2022 @ 10:25:59.195 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=23, largestPoolSize=25, maximumPoolSize=2147483647) |
34 | Jan 18, 2022 @ 10:26:01.518 | i-073cca80f22a29805 | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
35 | Jan 18, 2022 @ 10:26:02.730 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Initializing LeaseCoordinator |
36 | Jan 18, 2022 @ 10:26:02.730 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Initialization attempt 1 |
37 | Jan 18, 2022 @ 10:26:03.038 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.LeaseCleanupManager | Starting lease cleanup thread. |
38 | Jan 18, 2022 @ 10:26:03.055 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Starting LeaseCoordinator |
39 | Jan 18, 2022 @ 10:26:03.062 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
40 | Jan 18, 2022 @ 10:26:03.255 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Scheduling periodicShardSync |
41 | Jan 18, 2022 @ 10:26:03.286 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Initialization complete. Starting worker loop. |
42 | Jan 18, 2022 @ 10:26:03.371 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a needed 17 leases but none were expired, so it will steal lease shardId-000000001912 from i-073cca80f22a29805 |
43 | Jan 18, 2022 @ 10:26:03.373 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a saw 68 total leases, 0 available leases, 4 workers. Target is 17 leases, I have 0 leases, I will take 1 leases |
44 | Jan 18, 2022 @ 10:26:03.458 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.DeterministicShuffleShardSyncLeaderDecider | Elected leaders: i-0b7f310fbf75d6d58 |
45 | Jan 18, 2022 @ 10:26:03.495 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a successfully took 1 leases: shardId-000000001912 |
46 | Jan 18, 2022 @ 10:26:04.518 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000001912, concurrencyToken=56f9525b-1902-48dc-b3a4-8e41b14d3975, parentShardIds=[shardId-000000001908, shardId-000000001910], checkpoint={SequenceNumber: 49621216055676902494015565737642460851222670980073682818,SubsequenceNumber: 2}) |
47 | Jan 18, 2022 @ 10:26:07.652 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.KinesisShardDetector | Stream ophan-raw-submissions: listing shards with list shards request ListShardsRequest(StreamName=ophan-raw-submissions) |
48 | Jan 18, 2022 @ 10:26:08.070 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Current stream shard assignments: shardId-000000001979, shardId-000000001956, shardId-000000001889, shardId-000000001966, shardId-000000001999, shardId-000000001976, shardId-000000001876, shardId-000000001953, shardId-000000001886, shardId-000000001996, shardId-000000001852, shardId-000000001896, shardId-000000001962, shardId-000000002006, shardId-000000002059, shardId-000000001892, shardId-000000002002, shardId-000000002046, shardId-000000002056, shardId-000000002022, shardId-000000002062, shardId-000000001916 |
49 | Jan 18, 2022 @ 10:26:08.071 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.Scheduler | Sleeping ... |
50 | Jan 18, 2022 @ 10:26:10.542 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Initializing LeaseCoordinator |
51 | Jan 18, 2022 @ 10:26:10.542 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Initialization attempt 1 |
52 | Jan 18, 2022 @ 10:26:10.706 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Initialization attempt 1 |
53 | Jan 18, 2022 @ 10:26:10.706 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Initializing LeaseCoordinator |
54 | Jan 18, 2022 @ 10:26:10.942 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.LeaseCleanupManager | Starting lease cleanup thread. |
55 | Jan 18, 2022 @ 10:26:10.945 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Starting LeaseCoordinator |
56 | Jan 18, 2022 @ 10:26:10.952 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
57 | Jan 18, 2022 @ 10:26:10.985 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.LeaseCleanupManager | Starting lease cleanup thread. |
58 | Jan 18, 2022 @ 10:26:10.994 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Starting LeaseCoordinator |
59 | Jan 18, 2022 @ 10:26:11.005 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.LeaseCleanupManager | Number of pending leases to clean before the scan : 0 |
60 | Jan 18, 2022 @ 10:26:11.051 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Scheduling periodicShardSync |
61 | Jan 18, 2022 @ 10:26:11.054 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Initialization complete. Starting worker loop. |
62 | Jan 18, 2022 @ 10:26:11.127 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Scheduling periodicShardSync |
63 | Jan 18, 2022 @ 10:26:11.141 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e saw 68 total leases, 0 available leases, 5 workers. Target is 14 leases, I have 0 leases, I will take 1 leases |
64 | Jan 18, 2022 @ 10:26:11.141 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e needed 14 leases but none were expired, so it will steal lease shardId-000000002026 from i-0b7f310fbf75d6d58 |
65 | Jan 18, 2022 @ 10:26:11.145 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Initialization complete. Starting worker loop. |
66 | Jan 18, 2022 @ 10:26:11.192 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.DeterministicShuffleShardSyncLeaderDecider | Elected leaders: i-0b7f310fbf75d6d58 |
67 | Jan 18, 2022 @ 10:26:11.231 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e successfully took 1 leases: shardId-000000002026 |
68 | Jan 18, 2022 @ 10:26:11.257 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.DeterministicShuffleShardSyncLeaderDecider | Elected leaders: i-0b7f310fbf75d6d58 |
69 | Jan 18, 2022 @ 10:26:11.309 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d saw 68 total leases, 0 available leases, 6 workers. Target is 12 leases, I have 0 leases, I will take 1 leases |
70 | Jan 18, 2022 @ 10:26:11.309 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d needed 12 leases but none were expired, so it will steal lease shardId-000000001939 from i-07d4b5acb83d03c0e |
71 | Jan 18, 2022 @ 10:26:11.396 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d successfully took 1 leases: shardId-000000001939 |
72 | Jan 18, 2022 @ 10:26:12.277 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000002026, concurrencyToken=ee78e505-2fbe-471c-b51d-18d5da59b6c6, parentShardIds=[shardId-000000002023, shardId-000000002024], checkpoint={SequenceNumber: 49617551834907222267981479698830404512948478370880978594,SubsequenceNumber: 1}) |
73 | Jan 18, 2022 @ 10:26:12.316 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000001939, concurrencyToken=c2110703-56b7-4dfb-953c-612d41f8291b, parentShardIds=[shardId-000000001935, shardId-000000001937], checkpoint={SequenceNumber: 49621216049499596074022583137665788249458452908581353778,SubsequenceNumber: 1}) |
74 | Jan 18, 2022 @ 10:26:15.349 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.KinesisShardDetector | Stream ophan-raw-submissions: listing shards with list shards request ListShardsRequest(StreamName=ophan-raw-submissions) |
75 | Jan 18, 2022 @ 10:26:15.459 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.KinesisShardDetector | Stream ophan-raw-submissions: listing shards with list shards request ListShardsRequest(StreamName=ophan-raw-submissions) |
76 | Jan 18, 2022 @ 10:26:20.074 | i-073cca80f22a29805 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=22, largestPoolSize=36, maximumPoolSize=2147483647) |
77 | Jan 18, 2022 @ 10:26:22.614 | i-07d4b5acb83d03c0e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=21, largestPoolSize=29, maximumPoolSize=2147483647) |
78 | Jan 18, 2022 @ 10:26:23.558 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a saw 68 total leases, 0 available leases, 6 workers. Target is 12 leases, I have 1 leases, I will take 1 leases |
79 | Jan 18, 2022 @ 10:26:23.558 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a needed 11 leases but none were expired, so it will steal lease shardId-000000001999 from i-073cca80f22a29805 |
80 | Jan 18, 2022 @ 10:26:23.570 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a successfully took 1 leases: shardId-000000001999 |
81 | Jan 18, 2022 @ 10:26:23.649 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000001999, concurrencyToken=71c129d2-38ce-4e7a-8b40-c95b12767a5a, parentShardIds=[shardId-000000001995, shardId-000000001997], checkpoint={SequenceNumber: 49619003781589566153637321424074094435107411728070114546,SubsequenceNumber: 2}) |
82 | Jan 18, 2022 @ 10:26:28.138 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.PeriodicShardSyncManager | WorkerId i-0b7f310fbf75d6d58 is leader, running the periodic shard sync task |
83 | Jan 18, 2022 @ 10:26:28.146 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.PeriodicShardSyncManager | Skipping shard sync for ophan-raw-submissions due to the reason - Hash Ranges are complete for ophan-raw-submissions |
84 | Jan 18, 2022 @ 10:26:29.205 | i-0b7f310fbf75d6d58 | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=22, largestPoolSize=25, maximumPoolSize=2147483647) |
85 | Jan 18, 2022 @ 10:26:31.293 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e needed 11 leases but none were expired, so it will steal lease shardId-000000001849 from i-0b7f310fbf75d6d58 |
86 | Jan 18, 2022 @ 10:26:31.297 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e saw 68 total leases, 0 available leases, 6 workers. Target is 12 leases, I have 1 leases, I will take 1 leases |
87 | Jan 18, 2022 @ 10:26:31.310 | i-0d5e264484a470d9e | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0d5e264484a470d9e successfully took 1 leases: shardId-000000001849 |
88 | Jan 18, 2022 @ 10:26:31.360 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000001849, concurrencyToken=8cba816a-0938-49b5-8d0e-5575e8f30351, parentShardIds=[shardId-000000001845, shardId-000000001847], checkpoint={SequenceNumber: 49624033579303571380602588626519379040413538613431661458,SubsequenceNumber: 3}) |
89 | Jan 18, 2022 @ 10:26:31.462 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d needed 11 leases but none were expired, so it will steal lease shardId-000000002036 from i-07d4b5acb83d03c0e |
90 | Jan 18, 2022 @ 10:26:31.462 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d saw 68 total leases, 0 available leases, 6 workers. Target is 12 leases, I have 1 leases, I will take 1 leases |
91 | Jan 18, 2022 @ 10:26:31.471 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-07ad2e8efa0b53d5d successfully took 1 leases: shardId-000000002036 |
92 | Jan 18, 2022 @ 10:26:31.652 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=2, largestPoolSize=2, maximumPoolSize=2147483647) |
93 | Jan 18, 2022 @ 10:26:32.455 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000002036, concurrencyToken=f7fbcf21-e205-49a2-804e-d1f95ffd6259, parentShardIds=[shardId-000000002033, shardId-000000002034], checkpoint={SequenceNumber: 49612820238922283618392672886344859656198006091661999938,SubsequenceNumber: 3}) |
94 | Jan 18, 2022 @ 10:26:40.364 | i-0d5e264484a470d9e | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=1, coreThreads=0, leasesOwned=2, largestPoolSize=2, maximumPoolSize=2147483647) |
95 | Jan 18, 2022 @ 10:26:40.458 | i-07ad2e8efa0b53d5d | software.amazon.kinesis.coordinator.DiagnosticEventLogger | Current thread pool executor state: ExecutorStateEvent(executorName=SchedulerThreadPoolExecutor, currentQueueSize=0, activeThreads=0, coreThreads=0, leasesOwned=2, largestPoolSize=2, maximumPoolSize=2147483647) |
96 | Jan 18, 2022 @ 10:26:43.631 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a needed 10 leases but none were expired, so it will steal lease shardId-000000001892 from i-073cca80f22a29805 |
97 | Jan 18, 2022 @ 10:26:43.633 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a saw 68 total leases, 0 available leases, 6 workers. Target is 12 leases, I have 2 leases, I will take 1 leases |
98 | Jan 18, 2022 @ 10:26:43.643 | i-0a936dab3583cdb0a | software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseTaker | Worker i-0a936dab3583cdb0a successfully took 1 leases: shardId-000000001892 |
99 | Jan 18, 2022 @ 10:26:43.657 | i-0a936dab3583cdb0a | software.amazon.kinesis.coordinator.Scheduler | Created new shardConsumer for : ShardInfo(streamIdentifierSerOpt=Optional.empty, shardId=shardId-000000001892, concurrencyToken=70788d00-aa74-4ce1-a1de-98122a5c2dd6, parentShardIds=[shardId-000000001888, shardId-000000001890], checkpoint={SequenceNumber: 49613246442557843702535796439625706163999575983207249474,SubsequenceNumber: 2}) |
100 | Jan 18, 2022 @ 10:26:45.730 | i-073cca80f22a29805 | software.amazon.kinesis.checkpoint.dynamodb.DynamoDBCheckpointer | Worker i-073cca80f22a29805 could not update checkpoint for shard shardId-000000001892 because it does not hold the lease |