Fix compilation issue

trinodb · Sep 12, 2023 · ae7d1d4 · ae7d1d4
1 parent 029e1a0
commit ae7d1d4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...lta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/TransactionLogAccess.java b/...lta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/TransactionLogAccess.java
@@ -338,7 +338,7 @@ public Map<Class<?>, Object> getTransactionLogEntries(
         Stream<Object> entries = getEntries(
                 tableSnapshot,
                 entryTypes,
-                (checkpointStream, jsonStream) -> entryMapper.apply(Stream.concat(checkpointStream, jsonStream)),
+                (checkpointStream, jsonStream) -> entryMapper.apply(Stream.concat(checkpointStream, jsonStream.stream().map(Transaction::transactionEntries).flatMap(Collection::stream))),
                 session,
                 fileSystemFactory.create(session),
                 fileFormatDataSourceStats);