Apache Spark SQL get_json_object java.lang.String 无法转换为 org.apache.spark.unsafe.types.UTF8String

2023-12-09

我正在尝试使用结构化流从 Apache Spark 中的 MQTT 代理读取 json 流，读取传入 json 的一些属性并将它们输出到控制台。我的代码看起来像这样：

val spark = SparkSession
  .builder()
  .appName("BahirStructuredStreaming")
  .master("local[*]")
  .getOrCreate()

import spark.implicits._

val topic = "temp"
val brokerUrl = "tcp://localhost:1883"
val lines = spark.readStream
  .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider")
  .option("topic", topic).option("persistence", "memory")
  .load(brokerUrl)
  .toDF().withColumn("payload", $"payload".cast(StringType))

val jsonDF = lines.select(get_json_object($"payload", "$.eventDate").alias("eventDate"))

    val query = jsonDF.writeStream
      .format("console")
      .start()

    query.awaitTermination()

但是，当 json 到达时，我收到以下错误：

Exception in thread "main" org.apache.spark.sql.streaming.StreamingQueryException: Writing job aborted.
=== Streaming Query ===
Identifier: [id = 14d28475-d435-49be-a303-8e47e2f907e3, runId = b5bd28bb-b247-48a9-8a58-cb990edaf139]
Current Committed Offsets: {MQTTStreamSource[brokerUrl: tcp://localhost:1883, topic: temp clientId: paho7247541031496]: -1}
Current Available Offsets: {MQTTStreamSource[brokerUrl: tcp://localhost:1883, topic: temp clientId: paho7247541031496]: 0}

Current State: ACTIVE
Thread State: RUNNABLE

Logical Plan:
Project [get_json_object(payload#22, $.id) AS eventDate#27]
+- Project [id#10, topic#11, cast(payload#12 as string) AS payload#22, timestamp#13]
   +- StreamingExecutionRelation MQTTStreamSource[brokerUrl: tcp://localhost:1883, topic: temp clientId: paho7247541031496], [id#10, topic#11, payload#12, timestamp#13]

    at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:300)
    at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:189)
Caused by: org.apache.spark.SparkException: Writing job aborted.
    at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.doExecute(WriteToDataSourceV2Exec.scala:92)
    at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:131)
    at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:155)
    at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
    at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:152)
    at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:127)
    at org.apache.spark.sql.execution.SparkPlan.getByteArrayRdd(SparkPlan.scala:247)
    at org.apache.spark.sql.execution.SparkPlan.executeCollect(SparkPlan.scala:296)
    at org.apache.spark.sql.Dataset.collectFromPlan(Dataset.scala:3384)
    at org.apache.spark.sql.Dataset.$anonfun$collect$1(Dataset.scala:2783)
    at org.apache.spark.sql.Dataset.$anonfun$withAction$2(Dataset.scala:3365)
    at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId$1(SQLExecution.scala:78)
    at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:125)
    at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:73)
    at org.apache.spark.sql.Dataset.withAction(Dataset.scala:3365)
    at org.apache.spark.sql.Dataset.collect(Dataset.scala:2783)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runBatch$15(MicroBatchExecution.scala:537)
    at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId$1(SQLExecution.scala:78)
    at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:125)
    at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:73)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runBatch$14(MicroBatchExecution.scala:533)
    at org.apache.spark.sql.execution.streaming.ProgressReporter.reportTimeTaken(ProgressReporter.scala:351)
    at org.apache.spark.sql.execution.streaming.ProgressReporter.reportTimeTaken$(ProgressReporter.scala:349)
    at org.apache.spark.sql.execution.streaming.StreamExecution.reportTimeTaken(StreamExecution.scala:58)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.runBatch(MicroBatchExecution.scala:532)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runActivatedStream$2(MicroBatchExecution.scala:198)
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
    at org.apache.spark.sql.execution.streaming.ProgressReporter.reportTimeTaken(ProgressReporter.scala:351)
    at org.apache.spark.sql.execution.streaming.ProgressReporter.reportTimeTaken$(ProgressReporter.scala:349)
    at org.apache.spark.sql.execution.streaming.StreamExecution.reportTimeTaken(StreamExecution.scala:58)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runActivatedStream$1(MicroBatchExecution.scala:166)
    at org.apache.spark.sql.execution.streaming.ProcessingTimeExecutor.execute(TriggerExecutor.scala:56)
    at org.apache.spark.sql.execution.streaming.MicroBatchExecution.runActivatedStream(MicroBatchExecution.scala:160)
    at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:279)
    ... 1 more
Caused by: org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1.0 failed 1 times, most recent failure: Lost task 0.0 in stage 1.0 (TID 8, localhost, executor driver): java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.spark.unsafe.types.UTF8String
    at org.apache.spark.sql.catalyst.expressions.BaseGenericInternalRow.getUTF8String(rows.scala:46)
    at org.apache.spark.sql.catalyst.expressions.BaseGenericInternalRow.getUTF8String$(rows.scala:46)
    at org.apache.spark.sql.catalyst.expressions.GenericInternalRow.getUTF8String(rows.scala:195)
    at org.apache.spark.sql.catalyst.expressions.GeneratedClass$GeneratedIteratorForCodegenStage1.processNext(Unknown Source)
    at org.apache.spark.sql.execution.BufferedRowIterator.hasNext(BufferedRowIterator.java:43)
    at org.apache.spark.sql.execution.WholeStageCodegenExec$$anon$1.hasNext(WholeStageCodegenExec.scala:619)
    at scala.collection.Iterator$$anon$10.hasNext(Iterator.scala:460)
    at org.apache.spark.sql.execution.datasources.v2.DataWritingSparkTask$.$anonfun$run$2(WriteToDataSourceV2Exec.scala:117)
    at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1394)
    at org.apache.spark.sql.execution.datasources.v2.DataWritingSparkTask$.run(WriteToDataSourceV2Exec.scala:116)
    at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.$anonfun$doExecute$2(WriteToDataSourceV2Exec.scala:67)
    at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
    at org.apache.spark.scheduler.Task.run(Task.scala:121)
    at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:405)
    at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
    at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:408)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

Driver stacktrace:
    at org.apache.spark.scheduler.DAGScheduler.failJobAndIndependentStages(DAGScheduler.scala:1887)
    at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2(DAGScheduler.scala:1875)
    at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2$adapted(DAGScheduler.scala:1874)
    at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
    at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
    at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
    at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1874)
    at org.apache.spark.scheduler.DAGScheduler.$anonfun$handleTaskSetFailed$1(DAGScheduler.scala:926)
    at org.apache.spark.scheduler.DAGScheduler.$anonfun$handleTaskSetFailed$1$adapted(DAGScheduler.scala:926)
    at scala.Option.foreach(Option.scala:407)
    at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:926)
    at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:2108)
    at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2057)
    at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:2046)
    at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:49)
    at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:737)
    at org.apache.spark.SparkContext.runJob(SparkContext.scala:2061)
    at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.doExecute(WriteToDataSourceV2Exec.scala:64)
    ... 34 more
Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.spark.unsafe.types.UTF8String
    at org.apache.spark.sql.catalyst.expressions.BaseGenericInternalRow.getUTF8String(rows.scala:46)
    at org.apache.spark.sql.catalyst.expressions.BaseGenericInternalRow.getUTF8String$(rows.scala:46)
    at org.apache.spark.sql.catalyst.expressions.GenericInternalRow.getUTF8String(rows.scala:195)
    at org.apache.spark.sql.catalyst.expressions.GeneratedClass$GeneratedIteratorForCodegenStage1.processNext(Unknown Source)
    at org.apache.spark.sql.execution.BufferedRowIterator.hasNext(BufferedRowIterator.java:43)
    at org.apache.spark.sql.execution.WholeStageCodegenExec$$anon$1.hasNext(WholeStageCodegenExec.scala:619)
    at scala.collection.Iterator$$anon$10.hasNext(Iterator.scala:460)
    at org.apache.spark.sql.execution.datasources.v2.DataWritingSparkTask$.$anonfun$run$2(WriteToDataSourceV2Exec.scala:117)
    at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1394)
    at org.apache.spark.sql.execution.datasources.v2.DataWritingSparkTask$.run(WriteToDataSourceV2Exec.scala:116)
    at org.apache.spark.sql.execution.datasources.v2.WriteToDataSourceV2Exec.$anonfun$doExecute$2(WriteToDataSourceV2Exec.scala:67)
    at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
    at org.apache.spark.scheduler.Task.run(Task.scala:121)
    at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:405)
    at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
    at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:408)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

我使用 mosquitto 代理发送 JSON 记录，它们如下所示：

mosquitto_pub -m '{"eventDate": "2020-11-11T15:17:00.000+0200"}' -t "temp"

似乎来自 Bahir 流源提供商的每个字符串都会引发此错误。例如以下代码也会引发此错误：

spark.readStream
  .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider")
  .option("topic", topic).option("persistence", "memory")
  .load(brokerUrl)
  .select("topic")
  .writeStream
  .format("console")
  .start()

Spark 似乎无法识别来自 Bahir 的字符串，可能是某种奇怪的字符串类版本问题。我已尝试以下操作来使代码正常工作：

将java版本设置为8
将spark版本从2.4.0升级到2.4.7
将 scala 版本设置为 2.11.12
use decode函数具有所有可能的编码组合，而不是.cast(StringType)将列“payload”转换为字符串
use 子串在“有效负载”列上使用函数来重新创建兼容的字符串。

最后，我通过使用构造函数和数据集重新创建字符串来获得工作代码：

val lines = spark.readStream
  .format("org.apache.bahir.sql.streaming.mqtt.MQTTStreamSourceProvider")
  .option("topic", topic).option("persistence", "memory")
  .load(brokerUrl)
  .select("payload")
  .as[Array[Byte]]
  .map(payload => new String(payload))
  .toDF("payload")

这个解决方案相当丑陋，但至少它有效。

我相信问题中提供的代码没有任何问题，并且我怀疑 Bahir 或 Spark 方面存在错误，阻止 Spark 处理来自 Bahir 源的字符串。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

json

string

scala

apachespark

SparkStructuredStreaming

Apache Spark SQL get_json_object java.lang.String 无法转换为 org.apache.spark.unsafe.types.UTF8String 的相关文章

Swift 1.2 和 Swift 2.0 中的字符串长度[重复]

这个问题在这里已经有答案了在以前版本的 Swift 中我有以下代码 func myfunc mystr String if mystr utf16Count gt 3 使用最新版本的 Swift 1 2 我现在收到以下错误 utf16C
C++ 中的字符串到 LPCWSTR

我正在尝试从字符串转换为 LPCWSTR 我使用多位 1 例如 LPCWSTR ToLPCWSTR string text LPCWSTR sw LPCWSTR text c str return sw 2 返回中文字符 LPCWSTR T
将 JSON 字符串传递给 Django 模板

我一直在用头撞墙试图找出为什么我无法将从 Django 模型生成的 JSON 字符串传递到模板的 javascript 静态文件中事实证明问题不在模型级别使用serializers serialize 在脚本本身中放入相同的字符串将
将表类型添加到 JSON 编辑器

我想了解的代码这个 JSON 编辑器 http mb21 github io JSONedit 并修改它 In 指令 js https github com mb21 JSONedit blob gh pages js directives
string.empty 和 string[0] == '\0' 之间的区别

假设我们有一个字符串 std string str some value is assigned 有什么区别str empty and str 0 0 C 11 及更高版本 string variable 0 如果字符串为空则需要返回空字
在大文件中查找重复字符串

一个文件包含大量例如100亿字符串您需要查找重复的字符串您有 N 个可用系统您将如何找到重复项埃里克森的答案可能是提出这个问题的人所期望的您可以将 N 台机器中的每台机器用作哈希表中的一个存储桶对于每个字符串按顺序说出字符
性能方面插值（直接插入字符串）VS串联[关闭]

就目前情况而言这个问题不太适合我们的问答形式我们希望答案得到事实参考资料或专业知识的支持但这个问题可能会引发辩论争论民意调查或扩展讨论如果您觉得这个问题可以改进并可能重新开放访问帮助中心 help reopen questi
在python中将列表转换为字符串

我对 python 语言相当陌生我一直在寻找这个问题的答案我需要一个如下所示的列表 Kevin went to his computer He sat down He fell asleep 转换为如下字符串 Kevin went to
std::regex 转义正则表达式中使用的特殊字符

我是字符串来创建一个std regex FILE 作为单元测试的一部分检查一些打印文件名的异常输出在 Windows 上失败并显示 regex error error escape 表达式包含无效的转义字符或尾随转义因为 FILE 宏
如何在 ECMAScript 6 中导入 JSON 文件？

如何访问 ECMAScript 6 中的 JSON 文件以下不起作用 import config from config json 如果我尝试导入 JavaScript 文件这可以正常工作 https www stefanjudis c
使用 Javascript 删除字符串的最后一个字符

我有一个DIV与一些字符如何在每次单击时删除文本中的最后一个字符DIV itself 删除第一个字符 div on click function this text function index text return text repl
如何从 mysql 数据库中提取数据并使用 D3.JS 进行可视化？

我有一个数据库MySQL我想在其中可视化D3 JS 为了做到这一点首先我想parse中的数据JSON格式然后编写一个基本代码从数据库中提取数据并使用D3 JS 我环顾四周但找不到我想要的东西因为我是新手D3 JS 我怎样才能做到这
如何使用 Zend 2 http 发送 json 数据？

我已经为此苦苦挣扎了几天我需要将一组以 json 编码的数据发送到 api 我正在尝试使用 Zend 2 http 来实现这一点但到目前为止我还没有运气以下是 api 手册的内容 Bulk Create Contacts This c
使用 Android 解析 JSON 的最有效方法

我编写了一些代码来解析我的 Android 程序收到的 Google 距离矩阵 JSON 响应我唯一感兴趣的数据是距离值节点我的代码可以工作但似乎必须有一种更简单的方法来做到这一点距离值节点在 JSON 中嵌套得很深但是真的
从 Spark 数据帧中过滤大量 ID

我有一个大型数据框其格式类似于 ID Cat date 12 A 201602 14 B 201601 19 A 201608 12 F 201605 11 G 201603 我需要根据大约 500 万个 Is 的列表来过滤行最直接的方
Node.js 中的 JSON Zip 响应

我对 node js 还很陌生我正在尝试发回包含 JSON 结果的 zip 文件我一直在尝试弄清楚如何去做但还没有达到预期的结果我正在使用 NodeJS ExpressJS LocomotiveJS Mongoose 和 Mongo
将类型信息传递给 Scala 中的函数

我有对 json 对象执行一些常见操作的代码即提取所以我想创建一个通用函数它接受哪个类的类型参数代码如下所示 def getMessageType T json JValue Either GenericError T try Ri
JSON 编码和大引号

我在 PHP 5 的本机实现中遇到了一个有趣的行为json encode 显然当将对象序列化为 json 字符串时编码器将清空包含卷曲引号的字符串的任何属性这种类型可能会在启用自动转换的情况下从 MS Word 文档中复制粘贴这
Windows Phone 的 JSON 反序列化

我正在尝试反序列化以下 JSON 但我真的不知道如何使用 JSON net 来完成这项工作我正在使用 C 和 JSON Net 库我的 JSON 如下 found 3 bounds 43 54919 172 62148 43 54487
Scalaz 状态 monad 示例

我还没有看到很多 scalaz 状态单子的例子有这个例子 http scalaz github com scalaz scalaz 2 9 1 6 0 2 doc sxr scalaz example ExampleState scala

随机推荐

Anaconda 更新后 Jupyter Notebook 内核失效

我遇到了以下问题更新 Anaconda 后因为我将 skimage io 导入 Jupyter Notebook 中的项目时出错出现了更大的错误 Dead Kernel 现在我无法启动一个项目因为 Jupyter 给出以下错误 Co
如何使用 iText\iTextSharp 创建圆角表格？ [复制]

这个问题在这里已经有答案了我必须创建一个具有圆角的表格如下所示我可以用 iTextSharp 做到这一点吗这是使用单元事件完成的请参阅我的书中的日历示例 Java C 确保您没有向单元格添加任何自动边框而是在单元格事件中自己
防止浮动 div 换行到下一行

首先这是我的网站您会注意到在页面中间的分隔栏下方有三列一列包含表单一列包含文本一列包含链接现在将窗口大小调整为稍微小一些右侧的 div 将下降到下一行有没有办法不显示它所以divs会调整我有一个液体布局到它们不适
如何使用 CSS 来换行而不是用空格换行？

使用以下标记是否可以以及如何实现如预览中所示的换行 Markup div class filled box h2 Hi there h2 p I am just a text with some words that want to
XSLT 与 XProc - 所需类型中的参数绑定

我正在尝试将调用 Saxon 版本 8 9 的批处理文件转换为 XProc 管道 Calabash 这是我的批量调用 java jar saxon8 jar o out xml in xml style xsl config config
如何将数据表中的记录分页发送到服务器类

当我单击全选超链接选项时或者我想要将特定页面中的特定记录使用复选框发送到服务器类时我试图将 jQuery 数据表中的所有记录发送到服务器类但问题是当我单击表单提交按钮时即导出PDF 仅获取当前页面中的记录即使在 jquer
iOS 应用程序提交：删除 iPad 支持

我有一个 iPhone 应用程序不支持 iPad 布局在 App Store 中发布了一年我的客户希望从 iPad 的 App Store 中删除该应用程序我知道它需要更新应用程序但如何更改我的 plist 以反映更改苹果允许这
在 Linq 表达式主体中如何使用变量的值而不是对其的引用？

这是我的代码 IQueryable
在 JavaScript 中隐藏/欺骗引用者的最可靠方法是什么？

通常引荐来源网址可通过以下方式追踪 JavaScript 的document referrer 请求标头即PHP SERVER HTTP REFERER 我已经设置了一个键盘演示它显示了这些属性用于测试目的要求原始引用者应该有效地
Eclipse 2022-3 不再支持 CVS？

将Eclipse升级到最新版本2022 3后我发现官方软件源中似乎不再提供 Eclipse CVS Client 插件这是过去几个版本安装CVS支持的方式知道如何安装 CVS 支持吗 Update 对于最新的 Eclipse 版本请
ClassCastException：android.widget.TextView 无法转换为 android.widget.ListView

我不知道为什么我会得到这个类强制转换异常我已经做了几次 Project gt Clean 仍然没有成功请有人帮助我谢谢这是 ScheduleFragment java public class ScheduleFragment ex
GSM Modem如何处理送达报告？

我想在应用程序中出于某种目的使用 GSM 调制解调器我想要的是处理已发送短信列表的短信发送报告 GSM 调制解调器收件箱和发件箱仅限 15 件每次我阅读收件箱时 GSM 调制解调器都会返回一个列表并清除列表如何检查已从 GSM 调制解
使用 Jersey + hibernate RESTful Web 服务上传和下载图像

我决定将图像作为字节数组存储在数据库中我收到错误我的实体模型带有 getter 和 setter Entity Table name USER schema test XmlRootElement public class User
ValueError：logits 和标签必须具有相同的形状（（无，4）与（无，1））

我尝试制作一个卷积神经网络来对狗和猫进行分类我收到标题中提到的错误从我的搜索中有人说错误属于tensorflow和keras库的不同版本有人说这是语法错误我将把我的代码留在这里告诉我哪里出错了 IMPORTING LIBRARI
if else 语句和 if_else 的不同行为

我正在尝试创建一个函数将数据帧的数据类型转换为factor如果列的类型为char否则我不会改变任何东西但这里的问题是我可以做同样的事情if else声明但不使用if else陈述这是相同的代码注意我正在使用titanic数据集 c
在 PHP 中验证签名的 PDF 文档

我有一份已签名的 PDF 文档它是使用 TCPDF 进行签名的现在我想验证一下这是我的解决方案获取签名 pdf 的内容根据 ByRange字段获取原始内容和签名值从签名值中获取加密的摘要消息它是签名值末尾的八位字节字符串使用
如何将数字转换为文字？ [复制]

这个问题在这里已经有答案了如何使用 Javascript 将数字转换为单词显示需要印度卢比和派兹格式没有内置功能 function test skill var junkVal document getElementById rupe
如何从相机意图获取图像路径？

我使用 android 2 1 我想从相机意图结果中获取真实路径我读从 ACTION IMAGE CAPTURE Intent 获取图像路径但它适用于android 2 2 Override protected void onActivi
Android Facebook SDK FacebookDialog.shareDialogBuilder 不显示我的描述

我正在使用 Facebook Android SDK 从我的 Android 应用程序发布共享将链接设置为 Google Play url 但我想填写我自己的描述以显示当我从我的应用程序发布时我的描述会显示在预览中但是当它显示时所
Apache Spark SQL get_json_object java.lang.String 无法转换为 org.apache.spark.unsafe.types.UTF8String

我正在尝试使用结构化流从 Apache Spark 中的 MQTT 代理读取 json 流读取传入 json 的一些属性并将它们输出到控制台我的代码看起来像这样 val spark SparkSession builder appNam

Apache Spark SQL get_json_object java.lang.String 无法转换为 org.apache.spark.unsafe.types.UTF8String

Apache Spark SQL get_json_object java.lang.String 无法转换为 org.apache.spark.unsafe.types.UTF8String 的相关文章

随机推荐

热门标签