-
Notifications
You must be signed in to change notification settings - Fork 28.7k
[SPARK-6917] [SQL] DecimalType is not read back when non-native type exists #6558
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
Conversation
Regression test? |
Yeah, let's add a test. |
regression test added. |
Test build #33917 has finished for PR 6558 at commit
|
Test build #33927 has finished for PR 6558 at commit
|
@@ -244,7 +244,7 @@ private[parquet] abstract class CatalystConverter extends GroupConverter { | |||
* Read a decimal value from a Parquet Binary into "dest". Only supports decimals that fit in | |||
* a long (i.e. precision <= 18) | |||
*/ | |||
protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Unit = { | |||
protected[parquet] def readDecimal(dest: Decimal, value: Binary, ctype: DecimalType): Decimal = { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
oh, I just realized that when we reuse the Decimal value, we do not really need to use the returned value. But, we have another place that needs the returned value. Can we add a comment at here?
@yhuai fixed. |
Test build #33937 has finished for PR 6558 at commit
|
Test build #33938 has finished for PR 6558 at commit
|
…exists cc yhuai Author: Davies Liu <[email protected]> Closes #6558 from davies/decimalType and squashes the following commits: c877ca8 [Davies Liu] Update ParquetConverter.scala 48cc57c [Davies Liu] Update ParquetConverter.scala b43845c [Davies Liu] add test 3b4a94f [Davies Liu] DecimalType is not read back when non-native type exists (cherry picked from commit bcb47ad) Signed-off-by: Reynold Xin <[email protected]>
…exists cc yhuai Author: Davies Liu <[email protected]> Closes apache#6558 from davies/decimalType and squashes the following commits: c877ca8 [Davies Liu] Update ParquetConverter.scala 48cc57c [Davies Liu] Update ParquetConverter.scala b43845c [Davies Liu] add test 3b4a94f [Davies Liu] DecimalType is not read back when non-native type exists
…exists cc yhuai Author: Davies Liu <[email protected]> Closes apache#6558 from davies/decimalType and squashes the following commits: c877ca8 [Davies Liu] Update ParquetConverter.scala 48cc57c [Davies Liu] Update ParquetConverter.scala b43845c [Davies Liu] add test 3b4a94f [Davies Liu] DecimalType is not read back when non-native type exists
cc @yhuai