Skip to content

[common] Fix ClassCastException when computing row size for blob fields - #9087

Open
ArnavBalyan wants to merge 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/blob-var-fix
Open

[common] Fix ClassCastException when computing row size for blob fields#9087
ArnavBalyan wants to merge 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/blob-var-fix

Conversation

@ArnavBalyan

Copy link
Copy Markdown
Member

Purpose

  • Flink writes check for each row's size in RangeShuffle to balance range partitions.
  • However for blog fields the size calculator wrongly reads blog with getVariant instead of getBlob, causing ClassCastException tables with blob columns.
  • Fix it by using getBlob instead

Tests

  • UT

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