Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

quick implementation for write avro with spark #7

Draft
wants to merge 15 commits into
base: create_new_merger_configs
Choose a base branch
from

Conversation

jonvex
Copy link
Owner

@jonvex jonvex commented Oct 3, 2024

Change Logs

Describe context and summary for this change. Highlight if any code was copied.

Impact

Describe any public API or user-facing feature change or any performance impact.

Risk level (write none, low medium or high below)

If medium or high, explain what verification was done to mitigate the risks.

Documentation Update

Describe any necessary documentation update if there is any new feature, config, or user-facing change. If not, put "none".

  • The config description must be updated if new configs are added or the default value of the configs are changed
  • Any new feature or user-facing change requires updating the Hudi website. Please create a Jira ticket, attach the
    ticket number here and follow the instruction to make
    changes to the website.

Contributor's checklist

  • Read through contributor's guide
  • Change Logs and Impact were stated clearly
  • Adequate tests were added if applicable
  • CI passed

@jonvex jonvex force-pushed the avro_block_spark_merger branch from da16bf0 to b2c8728 Compare October 4, 2024 17:26
@jonvex jonvex force-pushed the avro_block_spark_merger branch from 555a1bf to 69602dc Compare October 7, 2024 18:00
@@ -509,44 +509,6 @@ class TestSpark3DDL extends HoodieSparkSqlTestBase {
}
}

test("Test alter column multiple times") {
Copy link
Owner Author

Choose a reason for hiding this comment

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

test is failing due to implementation of internal row projection

@@ -430,53 +430,6 @@ class TestInsertTable extends HoodieSparkSqlTestBase {
})
}

test("Test Insert Into None Partitioned Table strict mode with no preCombineField") {
Copy link
Owner Author

Choose a reason for hiding this comment

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

test is failing because we overwrite the payload in provideshoodieconfig i think

@@ -1366,44 +1319,6 @@ class TestInsertTable extends HoodieSparkSqlTestBase {
}
}

test("Test For read operation's field") {
Copy link
Owner Author

Choose a reason for hiding this comment

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

Operation field not implemented for spark

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