我想使用Apache POI读取一个非常大的excel文件。但是它抛出了堆大小超出内存的错误。我没有机会增加堆size.Are，有任何其他的解决方案。
浏览 26提问于2020-07-26得票数 1
1回答
Nginx不识别子文件夹
、、、
', methods=['GET', 'POST'])def streaming_events(): streaming_events = api.get_streaming
浏览 33提问于2021-04-05得票数 0
=tweepy.API(auth)
def on_status(self, status)_start(async) return True
streaming_api = tweepy.streaming.Stream157009365','16686144','68044757&
浏览 4提问于2014-05-27得票数 0
回答已采纳
问题
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction对于窗口操作，就像在org.apache.flink.streaming.<
浏览 1提问于2019-07-07得票数 0
我可以在HBase上使用.NET中的thrift使用Hadoop Streaming来运行MapReduce作业吗？或者，有没有其他方法可以从.NET在HBase上运行MapReduce作业？
浏览 1提问于2011-02-02得票数 2
回答已采纳
(HeapInternalTimerService.java:431)at org.apache.flink.streaming.api.operators.HeapInternalTimerService.getProcessingTimeT
浏览 2提问于2018-07-17得票数 1
该功能已经作为REST API提供，并在Cloudfoundry上运行。我们希望提供对使用Spark Streaming和kafka摄取时间序列数据的支持，以便解决方案更具可扩展性和健壮性。从spark streaming内部调用REST API在spark中原生构建功能有什么缺点？
浏览 8提问于2017-02-16得票数 0
我正在做的事情是：:require flink-connector-kafka-base_2.11-1.7.1[T] => Unit)(implicit evidence$10: org.apache.flink.api.common.typeinfo.TypeInformation[T])org.apache.flink.streaming.api.scala.DataStream[T] <and>
[T]
浏览 0提问于2019-03-11得票数 1
回答已采纳
2回答
我是Apache Spark的新手，我正在尝试运行Spark Streaming + Kafka集成直接方法示例(JavaDirectKafkaWordCount.java)。java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;at kafka.a
浏览 2提问于2016-05-04得票数 0
在需要做什么方面有什么帮助是非常感谢的，以使这一工作？<init>(Buckets.java:112) ~[flink-streaming-java_2.11-1.7.0.jar:1.7.0] at org.apache.flink.streaming.api.functions.sin
浏览 3提问于2019-12-03得票数 1
回答已采纳
我不知道为什么会发生这种情况，以及解决办法是什么。谢谢!JSON.parse(response.data.alerts));
const { data = [], error } = useSWR("/api/streaming/getAlerts", fetcher, { });
const onClose = (data) => {axios.pos
浏览 5提问于2022-06-04得票数 0
以下是例外情况at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:727)
at org.apache.
浏览 0提问于2019-11-19得票数 0
尝试在Scala2.10.4中使用0.10.0Flink版本的流api。在试图编译这个第一个版本时：import org.apache.flink.streaming.api.scala.DataStreamimport org.apache.flink.streaming.api.windowing.time._
浏览 16提问于2015-11-15得票数 3
回答已采纳
当我导入时'flink-streaming-scala_2.11'我可以运行如下代码：谢谢。
浏览 6提问于2017-07-23得票数 0
回答已采纳
不幸的是，我在实现Apache Flink文档中使用的基本ProcessWindowFunction时已经失败了。这是我的代码：import org.apache.flink.streaming.api.scala.{NgsiEvent, OrionSource}
import org.apache.flink.streaming.api.functions.windowing
浏览 1提问于2018-11-30得票数 6
org.apache.flink.streaming.api.TimeCharacteristicimport org.apache.flink.streaming.api.wind
浏览 26提问于2020-06-26得票数 0
回答已采纳
1回答
以下是代码： val env = StreamExecutionEnvironment.getExecutionEnvironment(FlinkKinesisProducer.java:248) at org.apache.flink.stream
浏览 1提问于2018-06-13得票数 0
回答已采纳
1回答
但是由于http客户端是在open方法中创建的，所以我没有办法提供它，并在我的集成测试中模拟它。我试图在构造函数中重构它，但我总是得到序列化错误。提前感谢:)
浏览 28提问于2020-06-01得票数 2
以下是守则： for (int i = 1; i <= 50; ++env.execute();Error:(36, 22) java: cannot access org.apache.flink.streaming.api.scala.DataStreamclass file for org
浏览 2提问于2018-03-24得票数 4
回答已采纳
com.accengage.bigdata.flink.streaming.sinks.FlumeSink.invoke(FlumeSink.java:25)lorg.apache.flink.streaming.api.collector.selector.DirectedOutput.collect(DirectedOutput.java:35)
org.apach
浏览 4提问于2016-10-19得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
