已有1人关注此标签
如何在Scala中向数组添加元素，并找到变量类型？
作者： 社区小助手
802人浏览
1人回答
如何在Scala中向数组添加元素，并找到变量类型？我有下面的Scala代码块作为我的数据处理管道的一部分。形成我目前所理解的，UDF接受一个file_contents类型String类型的参数。然后UDF进行一堆字符串处理，包括a spl…
阿里云rds数据库使用limit报错
作者： 1772431990870999
382人浏览
1人回答
项目之前都是没事的，最近测试的时候发现很多接口都报错了，看了报错原因发现都是同一个，如下：com.aliyun.kepler.rc.flink.rel.LimitOffsetReducer; uncategorized SQLExcept…
如何从kubernetes中的默认命名空间中删除LimitRange？
作者： k8s小能手
379人浏览
1人回答
对于其中一个要求，我使用下面的yaml文件在我的默认名称空间上创建了一个新的pod apiVersion: v1 kind: LimitRange metadata: name: mem-min-max-demo-lr1 spec: li…
如何解析kubectl描述输出并获取所需的字段值
作者： k8s小能手
383人浏览
1人回答
我正在尝试使用kubectl describe命令从特定的pod中获取Nodeport。我尝试使用以下方式，但我没有获得所需的价值 kubectl -n core describe svc/pg-debugName: …
除了通过入口将它们暴露在外之外，还可以在k8s集群内部访问服务
作者： k8s小能手
371人浏览
1人回答
我已经配置了两个服务，都是NodePort。 服务1kind: ServiceapiVersion: v1metadata: name: bitcoinrpc-dev-service namespace: devspec: sele…
K8s Go客户端将对象转换为kubectl资源yamls
作者： k8s小能手
398人浏览
1人回答
我不确定标题是否是正确的术语。但我基本上想要使用go-client并获得符合kubectl的对象（yamls）。 即部署资源将是： apiVersion: apps/v1kind: Deploymentmetadata: name: n…
将Google Cloud SQL凭据连接到Kubernetes Secret
作者： k8s小能手
282人浏览
1人回答
我正在浏览google-github-repo和stcox-gke-wordpress 我对这个secret提供什么感到非常困惑cloudsql-instance-credentials。在完成更多文档之后，我最终创建了一个服务帐户并下载…
关于Qt调用COM组件参数类型不匹配
作者： comic-_-||
433人浏览
0人回答
COM组件的函数代码（通过dumpcpp导出的代码）：inline bool Core::ReadSDO(int Index, QVariantList*& Buffer, int Count){ bool qax_result;…
使用DataFrame类型在scala中定义函数
作者： 社区小助手
469人浏览
1人回答
我会有一个简单的问题......我尝试使用一个将数据帧作为参数的函数并返回另一个数据帧 我做： val get_nb_previous_offre : ((DataFrame) => (DataFrame)) = (arg1: Da…
Scala [type1，type2]
作者： 社区小助手
265人浏览
1人回答
以下是使用Either的一个工作示例： val a: Either[Int, String] = {if (true) Left(42) // return an Int else Right("Hello, world") // ret…
Apache Spark：Kafka以自定义格式编写
作者： 社区小助手
1182人浏览
1人回答
我正在构建一个使用Kafka主题的Spark SQL应用程序，转换一些数据，然后使用特定的JSON对象写回单独的Kafka主题。 现在我能够查询/转换我想要的内容并编写它： Dataset reader = myData.getRecor…
ES：索引模板不会从UNIX时间戳转换为日期
作者： 社区小助手
521人浏览
1人回答
我将来自Apache Spark的文档通过Structured Streaming插入到ES中。 但是Spark-ES连接器中存在一个未解决的错误（https://github.com/elastic/elasticsearch-hado…
Flink窗口：聚合和输出到接收器
作者： 社区小助手
611人浏览
1人回答
我们有一个数据流，其中每个元素都是这种类型： id: Stringtype: Typeamount: Integer我们希望聚合此流并输出amount每周一次的总和。 当前解决方案 示例flink管道将如下所示： stream.keyBy…
flink解析复杂protobuf，注册成table遇到问题
作者： 学习flink
602人浏览
1人回答
目标：kafka protobuf--》row--》table--》sql--》hdfs。问题：protobuf是嵌套结构，转成row时，制定type出现问题。第一步：自定义反序列化方式，将protobuf转成row第二步：for循环放入r…
如何将自定义表源和自定义表接收器与SQL客户端集成？
作者： flink小助手
290人浏览
1人回答
假设我们定义了一个自定义的TableSource和TableSink，那么如何与SQL Client集成？我是否需要手动注册下面的自定义TableSource Sink名称？如果不手动注册，连接器类型custom1 map 如何与cus…
使用Table AggregateFunction和ResultTypeQueryable时的ValidationException
作者： flink小助手
438人浏览
1人回答
我正在使用配置为使用flink-tablejar 的本地Flink 1.6集群（意味着我的程序的jar不包括在内flink-table）。使用以下代码 import org.apache.flink.api.common.typeinfo…
kafka.common.KafkaException：错误的请求类型18
作者： 社区小助手
764人浏览
1人回答
我正在运行这段代码。streamingInputDF是Kafka主题的readStream。我正在运行spark 2.4.0和Kafka 0.10.2 val activityQuery = streamingInputDF.writeS…
在Scala Spark中以编程方式将所有特定数据类型列转换为其他数据类型
作者： 社区小助手
501人浏览
1人回答
我正在以编程方式尝试转换列的数据类型并遇到一些编码问题。 我修改了这里使用的代码。 数据>>任何数字都被读作字符串。 代码>> import org.apache.spark.sqlraw_data.schema.…
flink表api异常
作者： flink小助手
1182人浏览
4人回答
"我正在使用flink表api，使用kafka作为输入源，使用json作为表模式。提交程序时出现此错误：`程序完成以下异常： org.apache.flink.client.program.ProgramInvocationExcepti…
