SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1012398593
##
core/src/main/resources/error/error-classes.json:
##
@@ -29,12 +44,22 @@
],
"sqlState" : "22007"
},
+ "CANNOT_LOAD_PROTOBUF_CLASS" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1010721467
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -178,46 +176,73 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1010092402
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -177,47 +175,75 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008467821
##
core/src/main/resources/error/error-classes.json:
##
@@ -792,6 +887,21 @@
"Unable to acquire bytes of memory, got "
]
},
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008467248
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008463500
##
core/src/main/resources/error/error-classes.json:
##
@@ -65,6 +70,11 @@
],
"sqlState" : "22005"
},
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417281
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417312
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417281
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417312
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417312
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008417281
##
core/src/main/resources/error/error-classes.json:
##
@@ -706,6 +736,66 @@
],
"sqlState" : "42000"
},
+ "PROTOBUF_CLASS_LOAD_ERROR" : {
+
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008228337
##
sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryCompilationErrors.scala:
##
@@ -3210,4 +3211,190 @@ private[sql] object QueryCompilationErrors
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008228857
##
sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryCompilationErrors.scala:
##
@@ -3210,4 +3211,190 @@ private[sql] object QueryCompilationErrors
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1008228200
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/ProtobufSerializer.scala:
##
@@ -215,10 +217,12 @@ private[sql] class ProtobufSerializer(
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1007058916
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/ProtobufDataToCatalyst.scala:
##
@@ -98,13 +92,9 @@ private[protobuf] case class
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006277470
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006211573
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006197896
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006187850
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006187850
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006190485
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006187850
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,30 +194,52 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1006028333
##
sql/catalyst/src/main/scala/org/apache/spark/sql/errors/QueryCompilationErrors.scala:
##
@@ -3210,4 +3211,189 @@ private[sql] object QueryCompilationErrors
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1004099495
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/SchemaConverters.scala:
##
@@ -62,14 +63,18 @@ object SchemaConverters {
case
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003984608
##
connector/protobuf/src/test/scala/org/apache/spark/sql/protobuf/ProtobufSerdeSuite.scala:
##
@@ -163,18 +163,22 @@ class ProtobufSerdeSuite extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003984608
##
connector/protobuf/src/test/scala/org/apache/spark/sql/protobuf/ProtobufSerdeSuite.scala:
##
@@ -163,18 +163,22 @@ class ProtobufSerdeSuite extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003984452
##
connector/protobuf/src/test/resources/protobuf/timestamp.proto:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003983288
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/utils/ProtobufUtils.scala:
##
@@ -196,27 +194,31 @@ private[sql] object ProtobufUtils extends
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003686011
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003653232
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003632674
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003632674
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1003623154
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1002913803
##
connector/protobuf/src/main/scala/org/apache/spark/sql/protobuf/ProtobufDeserializer.scala:
##
@@ -244,7 +239,13 @@ private[sql] class ProtobufDeserializer(
SandishKumarHN commented on code in PR #38344:
URL: https://github.com/apache/spark/pull/38344#discussion_r1002913637
##
connector/protobuf/pom.xml:
##
@@ -123,6 +123,7 @@
com.google.protobuf:protoc:${protobuf.version}
36 matches
Mail list logo