回答情况：
提问时间：
问题标签：
1回答
我正在尝试将Spark Streaming设置为读取MQTT源，但当我收到第二条消息时，它会启动一个异常。(Lorg/apache/spark/sql/execution/streaming/Offset;)V
at org.apache.spark.sql.execution.streaming.StreamExecutionat org.apache.spark.sql.execution.streaming.StreamExecution$$anon
浏览 10修改于2018-10-27得票数 1
回答已采纳
1回答
SELECT streaming_transactions.account_id, streaming_transactions_detail.transactions_id,
浏览 1修改于2009-10-02得票数 1
回答已采纳
INFO:edgetpuvision.streaming.server:Listening on port tcp: 4665，web: 4664，附件: 4666 INFO:edgetpuvision.streaming.server:New INFO:edgetpuvision.streaming.server:New线程完成INFO:edgetpuvision.streaming.server:New Tx线程完成INFO:edgetpuvision.streaming.server活动客户端的IN
浏览 4提问于2021-04-06得票数 0
回答已采纳
published streaming-reconciler_2.10 to /Users/myuser/.ivy2/local/com.mycomp/streaming-reconciler_2.10/0.1.0-SNAPSHOT/poms/streaming-reconciler_2.10.pom
published streaming-reconciler_2.10 to /Users/myuser&
浏览 3修改于2016-07-20得票数 6
回答已采纳
streaming@172.17.102.128:7000] - Starting up...11:27:45.715 INFO [main] Cluster(akka://streaming) - Cluster Node [akka.tcp://streaming@172.17.102.128-5] Cluster(akka://
浏览 4修改于2014-07-01得票数 0
回答已采纳
:410)at org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider$$anonfun$org$apache$$anonfun$org$apache$spark$sql$execution$streaming$state$HDFSBack
浏览 7修改于2018-10-27得票数 5
我在MS excel表格中有如下数据：1 AAA Number of ABC3 Explanation5 Streaming Call7 Explanation9 StreamingABC BBB Number of ABC
5 Streaming Call BBB Number
浏览 3修改于2013-12-16得票数 0
回答已采纳
format("hive-streaming"). option("db", "test").queryName("socket-hive-streaming").这将导致以下运行时错误。ERROR streaming.MicroBatchExecution: Query socket-hive-str
浏览 0修改于2018-05-24得票数 1
回答已采纳
我有以下组件 import React, { useState } from 'react';
const [streaming, setStreamingsetStreaming(true); } const process = () => { } retu
浏览 6提问于2020-09-22得票数 1
回答已采纳
listenerdef streaming(): print ("Starting Streaming")
streaming_api.sample, 'Encountered
浏览 0提问于2019-09-08得票数 0
_2.10-1.6.0.jar spark-streaming-flume-sink_2.10-1.6.0.jar
spark-streaming-flume/1.6.0/spark-streaming-f
浏览 3提问于2016-08-11得票数 0
var streaming = new webkitSpeechRecognition();streaming.continuous = true;streaming.interimResults = true;
l_pos = event.results.length- 1 ;
console.log(event.results[l_pos]
浏览 1修改于2016-03-12得票数 3
回答已采纳
(Bucket.java:137) ~[flink-streaming-java_2.11-1.7.0.jar:1.7.0] at org.apache.flink.streaming.api.functions.sink.fil
浏览 25修改于2019-11-12得票数 0
> configurestreaming-commons> buildstreaming-commons> [ 5 of 17stre
浏览 0修改于2020-03-29得票数 2
cannot be cast to org.apache.spark.sql.sources.v2.reader.streaming.Offset
at org.apache.spark.sql.execution.streaming.MicroBatchExecution$$anonfun$org$apache$spark$sql$execution$streaming$MicroBatchExecution$$runBatch$1$$anonfun$apply$9.apply(MicroBatchExecution.sc
浏览 10修改于2020-04-10得票数 0
但是我得到了以下错误 at org.apache.flink.streaming.runtime.tasks.SourceStreamTask(SourceStreamTask.java:132)
at org.apache.flink.streaming
浏览 6提问于2020-02-29得票数 0
<init>(Buckets.java:112) ~[flink-streaming-java_2.11-1.7.0.jar:1.7.0] at org.apache.flink.streaming.util.functions.Streami
浏览 3提问于2019-12-03得票数 1
回答已采纳
-0-10/2.2.0/spark-streaming-kafka-0-10-2.2.0.pom
C:\Users\james\.ivy2\local\org.apache.spark\spark-streaming-kafka.maven.org/maven2/org/
浏览 22提问于2018-08-27得票数 6
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号