• 关于

    Streaming

    的搜索结果

回答

java.lang.RuntimeExceptionat org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110) at org.apache.flink.streaming.runtime.io.RecordWriterOutput....
游客dzclyts7d3ubw 2019-12-01 19:37:13 806 浏览量 回答数 1

回答

at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:734)~[flink-streaming-java_2.11-1.11.2.jar:1.11.2] at org.apache.flink.streaming....
moonlightdisco 2021-12-02 14:13:17 4 浏览量 回答数 1

回答

使用的是事件时间java.lang.RuntimeException:Buffer pool is destroyed.at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:104) at org.apache.flink....
ryan_wfa 2019-12-01 19:30:30 2308 浏览量 回答数 2

回答

org.apache.flink.util.FlinkRuntimeException:Error while retrieving data from RocksDB at org.apache.flink.contrib.streaming.state.RocksDBListState.getInternal(RocksDBListState.java:121)at org.apache....
彗星halation 2021-12-02 11:31:02 3 浏览量 回答数 1

回答

at org.apache.flink.contrib.streaming.state.RocksDBStateDownloader.downloadDataForStateHandle(RocksDBStateDownloader.java:131) at org.apache.flink.contrib.streaming.state.RocksDBStateDownloader.lambda...
JimmyWang 2020-05-29 21:40:45 0 浏览量 回答数 1

回答

295)at org.apache.spark.sql.execution.streaming.StreamExecution$anon$1.run(StreamExecution.scala:189)Caused by:java.lang.ClassCastException:org.apache.spark.sql.execution.streaming.SerializedOffset ...
社区小助手 2019-12-01 19:29:59 1407 浏览量 回答数 2

回答

有人配置过 spark.streaming.dynamicAllocation.enabled这个参数吗,这个参数对spark streaming会生效,但是没找到文档说spark structured streaming 是否会生效
社区小助手 2019-12-01 19:40:25 373 浏览量 回答数 1

回答

org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:715) at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput....
彗星halation 2021-12-02 11:27:44 0 浏览量 回答数 0

回答

at org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(SinkFunction.java:52) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) at org.apache.flink...
灰灰fly 2019-12-01 19:32:34 789 浏览量 回答数 1

回答

但是taskmanager一直起不来 java.lang.RuntimeException:Buffer pool is destroyed.at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110)at org.apache....
黄一刀 2020-06-03 20:31:52 5 浏览量 回答数 1

回答

at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.run(StreamTaskActionExecutor.java:87) at org.apache.flink.streaming.runtime.tasks.mailbox.Mail...
2021-12-03 18:50:30 3 浏览量 回答数 1

回答

(Timestamps/Watermarks,Timestamps/Watermarks)(4/4)to checkpoint state stream.at org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:466)at org....
qygxwy 2020-11-20 10:46:31 9 浏览量 回答数 0

回答

94)at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:843)at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:803)at...
游客x4cjij3rss7ok 2020-07-28 22:30:43 3 浏览量 回答数 0

回答

入湖引擎使用了阿里云 EMR 团队自研的 Spark Streaming SQL 以及 EMR Spark 引擎&xff0c;Streaming SQL 基于 Spark Structured Streaming&xff0c;提供了相对完善的 Streaming SQL 语法&xff0c;极大简化了实时计算的开发...
Lee_tianbai 2021-01-07 16:15:44 0 浏览量 回答数 0

回答

209)at org.apache.flink.streaming.api.functions.sink.filesystem.Bucket.write(Bucket.java:200)at org.apache.flink.streaming.api.functions.sink.filesystem.Buckets.onElement(Buckets.java:282)at org....
2021-12-07 11:22:10 5 浏览量 回答数 1

回答

209)at org.apache.flink.streaming.api.functions.sink.filesystem.Bucket.write(Bucket.java:200)at org.apache.flink.streaming.api.functions.sink.filesystem.Buckets.onElement(Buckets.java:282)at org....
小阿怪 2021-12-07 11:22:56 0 浏览量 回答数 0

回答

150)at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:715)at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)at org....
小阿矿 2021-12-06 15:29:16 4 浏览量 回答数 1

回答

135)at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:304)at org.apache.flink.streaming.api.operators....
2021-12-03 18:48:33 3 浏览量 回答数 1

回答

373)at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.invoke(FlinkKafkaProducer010.java:350)at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56)...
flink小助手 2019-12-01 19:24:32 1000 浏览量 回答数 1

回答

at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.checkErroneous(FlinkKafkaProducer.java:1225) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.invoke...
2021-12-06 17:25:18 3 浏览量 回答数 1

回答

128)at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:69)at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:...
2021-12-03 18:59:46 4 浏览量 回答数 1

回答

94)at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:860)at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:793)at org....
2021-12-06 21:41:30 2 浏览量 回答数 1

回答

at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:195) at org.apache.flink.streaming.api.operators....
2021-12-02 18:14:30 4 浏览量 回答数 1

回答

37)at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:639)at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput...
黄一刀 2020-06-23 15:15:56 0 浏览量 回答数 1

回答

550)18-05-2020 16:27:14 CST INFO-at org.apache.flink.streaming.runtime.tasks.OperatorChain$ChainingOutput.collect(OperatorChain.java:527)18-05-2020 16:27:14 CST INFO-at org.apache.flink.streaming....
雪哥哥 2021-12-05 10:44:29 0 浏览量 回答数 0

回答

at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:52)~[flink-dist_2.11-1.11.2.jar:1.11.2]at org.apache.flink.streaming.api.operators.CountingOutput.collect...
2021-12-06 13:25:24 5 浏览量 回答数 1

回答

at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:173) at org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput....
小阿矿 2021-12-06 16:47:32 3 浏览量 回答数 1

回答

Arijit Tarafdar and Nan Zhu在Spark Summit 2017上做了主题为《Building Structured Streaming Connector for Continous Applications》的演讲&xff0c;就什么是移动应用&xff0c;介绍 Structured Streaming&xff0c;在...
福利达人 2019-12-01 21:12:53 422 浏览量 回答数 0

回答

107)at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:142)at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:78)at org.apache.flink.streaming....
李博 bluemind 2019-12-01 20:27:19 510 浏览量 回答数 1

回答

Miklos Christine分享了题为《Paddling Up the Stream:Lessons Learned using Apache Spark Streaming》&xff0c;就Databricks介绍&xff0c;决策架构优化&xff0c;Spark Streaming vs Structure Streaming等方面的内容做了...
福利达人 2019-12-01 21:23:20 402 浏览量 回答数 0

云产品推荐

视频直播 大数据计算服务 MaxCompute 国内短信套餐包 ECS云服务器安全配置相关的云产品 开发者问答 阿里云建站 新零售智能客服 万网 小程序开发制作 视频内容分析 视频集锦 代理记账服务 阿里云AIoT 阿里云科技驱动中小企业数字化