腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
搜索
搜索
关闭
发布
搜索
关闭
文章
问答
(87)
视频
开发者手册
清单
用户
专栏
沙龙
全部问答
原创问答
Stack Exchange问答
更多筛选
回答情况:
全部
有回答
回答已采纳
提问时间:
不限
一周内
一月内
三月内
一年内
问题标签:
未找到与 相关的标签
筛选
重置
1
回答
使用kafka 0.8运行
camus
示例
-0.1.0-SNAPSHOT.jar com.linkedin.
camus
.etl.kafka.CamusJob -P /root/Desktop/
camus
-workspace/
camus
-master/
camus
-example/target/
camus
.properties jar包含所有依赖项,如阴影文件。/
camus
-master/
camus
-example/
浏览 3
修改于2017-02-26
得票数 2
回答已采纳
1
回答
设置
Camus
作业的频率
我计划每小时运行一次
camus
作业。我们每小时会收到大约80000000条消息(平均大小约为4KB)。
浏览 0
提问于2015-11-05
得票数 0
0
回答
Camus
的预期提交/回滚行为是什么?
该团队在将他们的数据路由到kafka主题时犯了一些错误,这导致了当
Camus
将这些主题的有效负载反序列化到avro时出现错误。
Camus
作业由于超过“其他失败”错误阈值而失败。我们注意到,当
Camus
作业由于超过'failed other‘阈值而失败时,我们注意到了这种行为: 1.所有映射器任务都成功了,因此TaskAttempt被允许提交-这意味着
Camus
写入的所有数据都被复制到了最终的谢谢~马特etl.destination.path=/user/
浏览 0
提问于2016-07-10
得票数 1
1
回答
防止
camus
增加偏移值
有没有什么方法可以防止
camus
增加偏移值,并使其始终读取前一个值?
浏览 0
修改于2014-11-28
得票数 0
1
回答
Camus
迁移- Kafka HDFS连接不会从设置偏移开始
我目前正在使用汇合HDFS Sink连接器(v4.0.0)来取代
Camus
。我们正在处理敏感数据,因此我们需要在连接到连接器的过程中保持偏移的一致性。使用/usr/bin/kafka-consumer-groups脚本,我能够将连接器使用者组kafka主题分区的当前偏移量设置为所需的值(即最后一次偏移量
Camus
编写的+ 1)。我期望hdfs文件名类似于: hdfs_kafka_topic_name+kafkapartition+
Camus
_offset+
Camus
_offset_plus_f
浏览 0
修改于2019-06-11
得票数 1
回答已采纳
1
回答
使用
camus
属性将纪元时间戳转换为日期时间格式
"someDate1":1512725505000, "ABC":"XYZ",} 当使用
camus
浏览 8
修改于2018-02-22
得票数 0
1
回答
如何在使用Hadoop时解析NoClassDefFoundError?
我得到了 hadoop jar
camus
-etl-kafka-0.1.0-SNAPSHOT.jar Exception in thread
浏览 2
修改于2016-04-29
得票数 0
4
回答
加缪-卡夫卡的例子
用于DummyLogKafkaProducerClient的代码片段import com.linkedin.
camus
.example.records.DummyLog; import com.li
浏览 6
修改于2016-11-07
得票数 2
1
回答
Oozie中的MapReduce作业可以从文件中读取吗?
为了记录在案,我的文件的内容看起来如下: /data/kafka/4/
camus
/DATA.TRADE.ORDERHISTORY/daily/2015/07/18,/data/kafka/4/
camus
,/data/kafka/4/
camus
/DATA.TRADE.ORDERHISTORY/daily/2015/07/21
浏览 3
修改于2015-08-05
得票数 1
回答已采纳
1
回答
在尝试运行加缪时使用java.lang.ClassNotFoundException
我下载了confluent包,其中包括
camus
jars,并按照在线的说明进行操作。hadoop jar confluent-
camus
-1.0.jar com.linkedin.
camus
.etl.kafka.CamusJob Exception in thread "main" java.lang.ClassNotFoundE
浏览 0
提问于2015-04-17
得票数 0
1
回答
使用Kafka将apache服务器日志加载到HDFS
/kafka-console-consumer.sh --zookeeper 10.25.3.207:2181 --topic lognew --from-beginning etl.execution.base.path=/user/root/exec #
camus
.message.decoder.clas
浏览 2
修改于2018-08-17
得票数 0
4
回答
awk镜像(反转)行
cat dummy Dumas所需输出如下所示:Dumas samuD这可能是用awk做的最简单的事情,但是perl oneliner
浏览 0
提问于2013-01-26
得票数 2
回答已采纳
1
回答
手柄火花DataFrame结构
假设我们有以下两个表|AUTHOR_ID| NAME | | 102 |
Camus
||AUTHOR_ID| BOOK_ID + BOOK_NAME | | 1 |
Camus
浏览 0
修改于2022-02-16
得票数 -1
回答已采纳
1
回答
合流模式注册表创建id值以外的架构。
目前,我们正在使用
camus
模式注册中心,并且我们正在从
camus
模式注册中心迁移到聚合模式注册中心。加缪拥有价值22的最新身份证明。我可以直接与id 22一起创建模式,而不是1。
浏览 1
修改于2021-12-24
得票数 0
1
回答
如何将Gobblin输出划分为30分钟的分区?
在
Camus
中,我们使用了下面提到的配置: etl.partitioner.class=com.linkedin.
camus
.etl.kafka.partitioner.TimeBasedPartitioner
浏览 0
修改于2020-01-16
得票数 0
1
回答
Neo4j - ruby查询翻译
下面是Ruby代码: => #<Author name: "Albert
Camus
"> 2.1.5
浏览 3
提问于2015-02-10
得票数 1
回答已采纳
3
回答
按键值排序JSON响应
restoration.jpg" "983": { "ns": 0, "length": 53639, "fullurl": "https://en.wikipedia.o
浏览 0
修改于2018-01-26
得票数 4
回答已采纳
1
回答
如何在vdos中的exe文件中设置autoexec.txt
exe和数据库路径如下: USE C: C:\Util\cd
CAMUS
.EXE rem switch
浏览 14
提问于2022-07-09
得票数 0
2
回答
导航栏和书签问题,垂直对齐表格内容
"> </tr> <th>Original title</th>
浏览 3
提问于2017-01-25
得票数 0
3
回答
在WPF中更改自定义CheckBox的图像
Width="16" Source="F:\
Camus
imageCheckBox" Value="F:\
Camus
imageCheckBox"
浏览 2
修改于2013-08-30
得票数 9
回答已采纳
第 2 页
第 3 页
第 4 页
第 5 页
点击加载更多
领券