1. 云栖社区>
  2. 全部标签>
  3. #scala#
scala

#scala#

已有1人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

java/scala 获取一个类继承父类的泛型所属类和类型后,怎么将这个类或者字符串转化成一个泛型

java/scala 获取一个类继承父类的泛型所属类和类型后,怎么将这个类或者字符串转化成一个泛型?

java DB scala flink

[职业生涯] Java工程师发展问题

您好,我做Java工程师大约有4个年头了,4年除Java外还学习了python、scala、hadoop、spark、这些东西,但都没有实战,这些年技术用的很多也很杂。我现在遇到了问题,很多技术仅仅局限在会用的基础上,对于原理并不是很清楚,…

云栖社区 python 帮助 Java核心技术 java hadoop spark scala

Flink on Yarn 出现 Container Removed 问题

甭管什么任务,有的单机跑一个月都很稳定的任务,Yarn模式下只要运行几分钟或者十几分钟就会出现: org.apache.flink.util.FlinkException: The assigned slot container_1540…

RPC 大数据 java Apache runtime scala Akka flink

Flink jobmanager报错: ERROR akka.remote.Remoting - Association to [akka.tcp://flink@xxxxx:42895] with UID [-205381938] irrecoverably failed. Quarantining address

我们的flink程序运行一段时间之后jobmanager就会有这种错误信息,但是taskmanager并没有报错信息,网上也查了这个报错信息,但是得不到准确的答案和解决办法,请赐教有没有好的解决办法,谢谢!2018-11-18 23:24…

java scala Akka class flink

如何在Scala中使用Flink的KafkaSource?

尝试用Flink的KafkaSource运行一个简单的测试程序,内容如下:Flink 0.9Scala 2.10.4Kafka 0.8.2.1import org.apache.flink.streaming.api.scala._imp…

云栖社区 Apache 测试 scala API string stream test type flink

【Flink】FailOver显示TaskManager lost/killed

问题描述如果遇到如下的异常: java.lang.Exception: The assigned slot: SimpleSlot (1) - container_e05_1505041177764_25978_01_000033 @ h…

RPC java native Apache runtime scala Akka flink 实时计算

[@墨玖tao][¥20]Java的语法和内存管理方面的进化是不是越来越向scala靠拢了

函数是一等公民,java是不是也在往这方面结合

编程语言 Java核心技术 java 函数 scala

Flink上执行storm拓扑,在yarn模式提交job时,找不到jobmanager

问题描述:Flink上执行storm拓扑,在yarn模式提交job时,找不到jobmanager -- 需求:storm的任务迁移到flink上,为了减少改动量,使用的flink兼容storm。-- 参考:https://flink.ap…

java native storm Apache runtime scala API Akka class Security SUN flink

spark项目运行时报错java.io.IOException: Cannot run program "/usr/lib/transwarp/scripts/rack_map.sh"

spark在服务器上刚运行时就报错2018-10-18 14:17:37 PM Thread: dispatcher-event-loop-6WARN:Exception running /usr/lib/transwarp/script…

RPC java hadoop Apache shell cluster spark scala netty thread

大神,请教一下阿里的Blink平台业务方使用是强制要求只能写sql和udf么?

转自钉钉群21789141:大神,请教一下阿里的Blink平台业务方使用是强制要求只能写sql和udf么?这么设计的出发点和目的是啥。我们公司也在研发基于Flink的流计算平台,从使用方的角度来说,会不会出现sql表达力不够和排错困难问题。…

python 大数据 程序员 SQL 钉钉 scala UDF 流计算 Blink flink 实时计算

flink的源码大多数是java 吗?还是以scala ?

转自钉钉群21789141:flink的源码大多数是java 吗?还是以scala ?

大数据 java 源码 钉钉 scala 流计算 flink 实时计算

scala编译的时候报错unclosed character literal

求老师来解答:scala编译的时候报错regexp_replace(regexp_replace(regexp_replace(p_parameters,'""','"'),'\"\{','{'),'}"','}') as p_para…

大数据 scala

表格存储批量插入数据本地测试可以,spark集群测试报错

根据阿里文档编写批量插入数据程序,本地local模式测试成功,spark集群测试失败,报错如下:java.lang.UnsupportedOperationException: This is supposed to be overrid…

java Apache 集群 测试 spark scala Core google 表格存储 thread

java.lang.ClassNotFoundException: com.aliyun.oss.OSSClient 求解答

我的命令 :./bin/spark-submit --jars /opt/aliyun-sdk-oss-2.8.2.jar,/opt/aliyun-sdk-mns-1.1.8.jar,/opt/emr-mns_2.11-1.4.1.j…

云栖社区 java OSS hadoop Apache spark scala aliyun list SUN

kafka 添加kerberos认证

kafka版本:kafka_2.11-0.9.0.1zookeeper版本:zookeeper-3.5.3 ./kafka-console-consumer.sh --zookeeper node1:2181 --topic test -…

云栖社区 cluster scala Consumer class test zookeeper

EMR集群spark出现Tez相关类找不到

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/tez/dag/api/SessionNotRunning at org.apache.hadoo…

java native hadoop SQL Apache 集群 spark scala API e-mapreduce exception EMR Hive Tez

E-MR spark对ODPS分区表的scala例子

有用scala写的,E-MR spark读取ODPS分区表的例子吗?

大数据 odps spark scala 分区表

Scala问答集锦

Scala是一门多范式的编程语言,一种类似java的编程语言,设计初衷是实现可伸缩的语言、并集成面向对象编程和函数式编程的各种特性。Scala把Erlang风格的基于actor的并发带进了JVM。开发者可以利用Scala的actor模型在…

云栖社区 编程语言 java HTTPS c++ 面向对象编程 问答 spark scala aliyun ask

E-mapreduce中用spark streaming 读取Loghub的问题

大家好。我在测试使用E-mapreduce中的spark streaming来采集Loghub的数据时,遇到点问题。我用Loghub监控一个文本文件,采用的是极简模式。该文本文件,每隔三秒生成一个1到10的随机数,如下图所示。 我修改了E…

监控 HTTPS 集群 测试 spark scala e-mapreduce EMR sparkstreaming loghub

9
GO