我们在第一步:从kafka保存数据中构建流多维数据集失败，这是输出日志： Job Counters
Failed map tasks
浏览 0提问于2017-10-29得票数 0
我正在学习关于流立方体构建的教程。
但是在触发构建立方体的时候。它在步骤1中失败，从Kafka保存数据org.apache.kylin.engine.mr.exception.MapReduceException: no counters for job job多维数据集构建流。tmp/hadoop-
yarn/staging/history/done_intermediate/root/job_1547
浏览 0提问于2019-01-22得票数 0
我是Kylin的新手，也探索过同样的东西。如果有人能在以下几点上帮助我，那就太好了:-
事先谢谢，任何线索都会有帮助的。谢谢，拉胡尔·S
浏览 0提问于2019-03-01得票数 0
我正在尝试安装apache kylin 1.5.4.1，我遵循以下URL：
$kylin.sh start
cat: /usr/local/kyli: No such file or directory
cat: /conf/kylin.properties: No such fileopti
浏览 2提问于2016-10-18得票数 0
1回答
错误有时会发生，在重启kylin(kylin.sh停止，然后kylin.sh启动)后，它会找到conf目录的位置并通过此步骤。我使用的是Kylin版本"2.6.2"，并且已经正确设置了KYLIN_CONF="/opt/kylin/conf“。错误提示是不同的，因为我已经反驳了以下几点: 1. java.lang.RuntimeException: Failed to read kyli
浏览 30提问于2019-09-19得票数 0
我安装了Java、Hadoop、Hbase、Hive、Spark和Kylin。hadoop-3.0.3 hbase-1.2.6 apache-hive-2.3.3-bin spark-2.2.2-bin-hive hadoop apache-kylin-2.3.1-bin
如果有人能帮我安装和配置
浏览 0提问于2018-10-23得票数 0
1回答
我在码头容器上使用Apache，服务正常工作，但我在使用pyhive连接到Hive时遇到了一些问题。我想用下面的代码列出使用“显示数据库”的数据库，但是我得到了以下错误： File "hive.py", line 3, in <username="root")
conn.cl
浏览 26提问于2022-11-20得票数 0
2回答
我正在为使用Spark流和Kafka运行的应用程序设置功能测试。要完成的步骤如下
除了简单的bash脚本，其他专业的方法是什么？
浏览 2提问于2017-02-22得票数 0
回答已采纳
我是卡夫卡流的新手。我需要从配置文件动态创建kafka流，其中包含源和目标主题名称。是否有可能重新启动和停止卡夫卡流？我的目标是定期使用kafka流将消息从一个主题传送到另一个主题。我使用spring作业，尝试关闭和打开流，但是当我关闭流时，我不能再次启动它。我得到了这个错误->客户端要么已经启动要么已经停止，无法重新启动。
浏览 12提问于2022-11-20得票数 0
回答已采纳
我使用的是最新的Greenwich.SR1，包括spring云流(version: Fishtown.SR2)和本地启动的kafka客户端版本:2.2.0，使用kafka_2.12-2.2.0.jar我想使用最新的kafka客户端2.1或更高版本的spring云流，因为它包含一些重要的bug修复。但是当我运行我的spring应用程序时，它的日志上写着
INFO 37812 --- [main] o.a.kafka.c
浏览 0提问于2019-05-21得票数 0
1回答
我使用从上可用的源代码编译的Schema，使用：它一开始没有问题，并且有一个名为驱动程序的文件夹，它建议将所有附加的JDBC驱动程序复制到那里。我做到了，重新启动了工作台。问题是当我点击选项->连接..。没有Kylin驱动程序可供选择。有人让使用Kylin并定义了一个工作模式吗？
浏览 3提问于2019-04-29得票数 0
我只想处理流应用程序启动后收到的数据，而不是之前提交的偏移量。重启后忽略kafka流app旧记录的正确方式是什么？对于kafka consumer API，我通常使用seekToEnd()方法来跳转到最新的记录。是否有用于流的等效机制？我希望避免过滤自上次提交以来的所有消息，以忽略旧消息。
浏览 3提问于2017-11-15得票数 2
我正在为一个使用MySQL作为其数据存储的应用程序构建分析功能。我们有一个基于微服务的架构，也使用Kafka。我们的用例并不真正需要“实时”分析，但这可能会在以后添加。我的微服务将使用Avro模式注册表将事件推送到相关主题，然后报告微服务将使用这些事件并更新星型模式。
现在我的问题是:实现从Kafka到相关星型模式的事件转换的最佳方式是什么？可以编写代码来检查每个事件，然后更新事实表，但是考虑到我可能会在事实表中的数据桶上使用15到30分钟的窗口，有没有办法使用
浏览 0提问于2018-03-23得票数 3
我按照官方的安装指南在HDP沙箱2.6中安装了Apache
我能做些什么来纠正这个错误？
浏览 2提问于2019-03-07得票数 0
Lang.Thread.run(Thread.java:745)\n‘，)
mvn -Phadoop-2.6 -Dhadoop.version=2.7.2 -DskipTests clean package
这将导致外部/kafka-程序集/目标文件夹中的jar。
浏览 3提问于2016-02-26得票数 4
回答已采纳
我正在码头容器中运行一个Kafka流应用程序。出于测试目的，我有一个用于运行流应用程序、kafka的单个实例和动物园管理员的坞-撰写文件。卡夫卡和动物园管理员的配置以前都是有效的。为kafka流应用程序分配分区需要5分钟以上。如果我延迟运行流容器，直到kafka和zookeeper启动，并且流应用程序正在使用的主题已被正确实例化，那么它几乎立即得到其分配的分区。看起来kafka<e
浏览 0提问于2018-01-05得票数 5
回答已采纳
安装完成后，我测试了使用kafka-console-producer和kafka-console-consume发送和接收数据的Kafka。启动生产者，在新的终端窗口中发送消息--from-beginning
Good mornin
浏览 24提问于2016-09-27得票数 1
0回答
我需要从配置文件中动态创建kafka流，配置文件包含源主题名称和每个流的配置。App需要有数十个kafka流，每个环境(例如stage、prod)的流都会有所不同。使用spring-kafka库可以做到这一点吗？kafkaProperties.getSettings());}
而且我们需要实现spring SmartLifecycle接口，所以
浏览 21提问于2018-07-13得票数 2
回答已采纳
1回答
我正在尝试在Kafka中实现某种事件处理。我有一些生产者张贴事件到卡夫卡队列。我也有消费者，他们获取事件，处理它，并将处理后的数据保存在DB中。但是，我需要确保每个事件都已被处理和完成。我如何通知Kafka此特定事件仍未处理？有什么已知的模式吗？
浏览 13提问于2017-12-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
