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