Skip to content

Conversation

scottsand-db
Copy link
Collaborator

@scottsand-db scottsand-db commented Aug 21, 2025

🥞 Stacked PR

Use this link to review incremental changes.


Which Delta project/connector is this regarding?

  • Spark
  • Standalone
  • Flink
  • Kernel
  • Other (fill in here)

Description

How was this patch tested?

Does this PR introduce any user-facing changes?

@scottsand-db scottsand-db changed the title done first pass [Test Only] E2E UC reads and writes Aug 21, 2025
@@ -128,18 +127,20 @@ public List<String> getPartitionColumnNames() {
*/
@Override
public long getTimestamp(Engine engine) {
if (IN_COMMIT_TIMESTAMPS_ENABLED.fromMetadata(metadata)) {
if (!inCommitTimestampOpt.isPresent()) {
Optional<CommitInfo> commitInfoOpt = CommitInfo.getCommitInfoOpt(engine, logPath, version);
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this is hardcoded to look at 0000.json. We need to fix that.

@@ -139,8 +139,7 @@ private FileStatus writeStagedCommitFile(
.writeJsonFileAtomically(
stagedCommitFilePath, finalizedActions, true /* overwrite */);

// TODO: [delta-io/delta#5021] Use FileSystemClient::getFileStatus API instead
return FileStatus.of(stagedCommitFilePath);
return engine.getFileSystemClient().getFileStatus(stagedCommitFilePath);
Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

UC requires valid file status (e.g. size in bytes)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant