You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ra...@apache.org on 2026/06/14 16:09:30 UTC
(storm) branch master updated (85a5cbc35 -> 6f8b94dc4)
This is an automated email from the ASF dual-hosted git repository.
reiabreu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from 85a5cbc35 Merge pull request #8783 from GGraziadei/8710-flux-component-conf
add a7295cc21 test: add Y2038 heartbeat overflow regression tests
add 9b979c588 fix: add long-based clock methods to Time, deprecate int epoch-seconds
add 7a98b4461 fix: promote heartbeat time_secs to i64 in thrift schema
add 707e5200a fix: write heartbeat timestamps from the long-based clock
add c94daf01d fix: widen heartbeat timeout state and consumers to long
add b562a741b docs: document i64 heartbeat timestamps and upgrade implications
new 6f8b94dc4 Merge pull request #8788 from dpol1/fix/7897
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/Cluster-State-Serialization.md | 31 +++
.../jvm/org/apache/storm/cluster/ClusterUtils.java | 2 +-
.../jvm/org/apache/storm/cluster/ExecutorBeat.java | 6 +-
.../storm/cluster/PaceMakerStateStorage.java | 2 +-
.../jvm/org/apache/storm/daemon/worker/Worker.java | 2 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 26 +--
.../apache/storm/generated/LSWorkerHeartbeat.java | 26 +--
.../storm/generated/SupervisorWorkerHeartbeat.java | 26 +--
.../org/apache/storm/stats/ClientStatsUtil.java | 4 +-
.../src/jvm/org/apache/storm/utils/Time.java | 31 +++
storm-client/src/py/storm/ttypes.py | 30 +--
storm-client/src/storm.thrift | 6 +-
.../apache/storm/daemon/nimbus/HeartbeatCache.java | 22 +--
.../org/apache/storm/daemon/supervisor/Slot.java | 4 +-
.../supervisor/timer/SupervisorHeartbeat.java | 4 +-
.../java/org/apache/storm/stats/StatsUtil.java | 2 +-
.../storm/daemon/nimbus/Y2038HeartbeatTest.java | 211 +++++++++++++++++++++
.../storm/daemon/logviewer/utils/LogCleaner.java | 4 +-
.../storm/daemon/logviewer/utils/WorkerLogs.java | 6 +-
.../daemon/logviewer/utils/LogCleanerTest.java | 2 +-
20 files changed, 360 insertions(+), 87 deletions(-)
create mode 100644 storm-server/src/test/java/org/apache/storm/daemon/nimbus/Y2038HeartbeatTest.java
(storm) 01/01: Merge pull request #8788 from dpol1/fix/7897
Posted by ra...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
reiabreu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
commit 6f8b94dc4cfbb6551b63eafb1dbf707f1abf0142
Merge: 85a5cbc35 b562a741b
Author: reiabreu <ru...@gmail.com>
AuthorDate: Sun Jun 14 17:09:24 2026 +0100
Merge pull request #8788 from dpol1/fix/7897
Fix Y2038 worker heartbeat overflow by migrating timestamps to i64
docs/Cluster-State-Serialization.md | 31 +++
.../jvm/org/apache/storm/cluster/ClusterUtils.java | 2 +-
.../jvm/org/apache/storm/cluster/ExecutorBeat.java | 6 +-
.../storm/cluster/PaceMakerStateStorage.java | 2 +-
.../jvm/org/apache/storm/daemon/worker/Worker.java | 2 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 26 +--
.../apache/storm/generated/LSWorkerHeartbeat.java | 26 +--
.../storm/generated/SupervisorWorkerHeartbeat.java | 26 +--
.../org/apache/storm/stats/ClientStatsUtil.java | 4 +-
.../src/jvm/org/apache/storm/utils/Time.java | 31 +++
storm-client/src/py/storm/ttypes.py | 30 +--
storm-client/src/storm.thrift | 6 +-
.../apache/storm/daemon/nimbus/HeartbeatCache.java | 22 +--
.../org/apache/storm/daemon/supervisor/Slot.java | 4 +-
.../supervisor/timer/SupervisorHeartbeat.java | 4 +-
.../java/org/apache/storm/stats/StatsUtil.java | 2 +-
.../storm/daemon/nimbus/Y2038HeartbeatTest.java | 211 +++++++++++++++++++++
.../storm/daemon/logviewer/utils/LogCleaner.java | 4 +-
.../storm/daemon/logviewer/utils/WorkerLogs.java | 6 +-
.../daemon/logviewer/utils/LogCleanerTest.java | 2 +-
20 files changed, 360 insertions(+), 87 deletions(-)