You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/03/27 13:30:17 UTC
(pulsar) 03/07: [fix][ml]Expose ledger timestamp (#22338)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5e9582806565412d1eb5ad6ef783da9e3b9444bc
Author: 道君 <da...@apache.org>
AuthorDate: Wed Mar 27 14:08:39 2024 +0800
[fix][ml]Expose ledger timestamp (#22338)
(cherry picked from commit cd49defc1383175ef32e18c7f0905567f734318c)
---
.../org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java | 1 +
.../org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java | 5 +++++
2 files changed, 6 insertions(+)
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java
index ce76717942d..31896769e8e 100644
--- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java
+++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java
@@ -736,6 +736,7 @@ public class ManagedLedgerFactoryImpl implements ManagedLedgerFactory {
ledgerInfo.ledgerId = pbLedgerInfo.getLedgerId();
ledgerInfo.entries = pbLedgerInfo.hasEntries() ? pbLedgerInfo.getEntries() : null;
ledgerInfo.size = pbLedgerInfo.hasSize() ? pbLedgerInfo.getSize() : null;
+ ledgerInfo.timestamp = pbLedgerInfo.hasTimestamp() ? pbLedgerInfo.getTimestamp() : null;
ledgerInfo.isOffloaded = pbLedgerInfo.hasOffloadContext();
if (pbLedgerInfo.hasOffloadContext()) {
MLDataFormats.OffloadContext offloadContext = pbLedgerInfo.getOffloadContext();
diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java
index 8695759c99f..4f2c3e17877 100644
--- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java
+++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryTest.java
@@ -19,6 +19,7 @@
package org.apache.bookkeeper.mledger.impl;
import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertNotNull;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@@ -60,6 +61,10 @@ public class ManagedLedgerFactoryTest extends MockedBookKeeperTestCase {
assertEquals(info.ledgers.get(2).ledgerId, 5);
assertEquals(info.ledgers.get(3).ledgerId, 6);
+ for (ManagedLedgerInfo.LedgerInfo linfo : info.ledgers) {
+ assertNotNull(linfo.timestamp);
+ }
+
assertEquals(info.cursors.size(), 1);
CursorInfo cursorInfo = info.cursors.get("c1");