| 일 | 월 | 화 | 수 | 목 | 금 | 토 |
|---|---|---|---|---|---|---|
| 1 | 2 | 3 | 4 | 5 | 6 | |
| 7 | 8 | 9 | 10 | 11 | 12 | 13 |
| 14 | 15 | 16 | 17 | 18 | 19 | 20 |
| 21 | 22 | 23 | 24 | 25 | 26 | 27 |
| 28 | 29 | 30 |
- pyspark
- cloudera
- Spark structured streaming
- hadoop
- 데이터엔지니어
- spark
- 하둡에코시스템
- kafka
- 개발자
- eks
- dataengineer
- 데이터엔지니어링
- 빅데이터
- apache spark
- scala
- 블로그
- 하둡
- DataEngineering
- BigData
- Terraform
- 스파크
- kubernetes
- Data engineering
- 클라우데라
- AWS
- 빅데이터플랫폼
- 개발자혜성
- Python
- hdfs
- IT블로그
- Today
- Total
목록Data engineering (2)
Hyesung Oh
Deep Dive - Spark JDBC to Other devices feat. Connection Pool
개요 Spark에서는 JDBC api를 통해 접근할 수 있는 datasource(dbms)를 지원합니다. jdbc datasource를 사용하기 위해선 JDBC interface를 구현한 Driver class가 필요합니다. *현재 사용 중인 mysql-connector-java-8.0.23을 기준으로 작성했습니다. spark.read.jdbc option으로 driver class path를 아래와 같이 설정해주면 됩니다. driver class path: com.mysql.cj.jdbc.Driver # Read from MySQL Table df = spark.read \ .format("jdbc") \ .option("url", "jdbc:mysql://localhost:3306/emp") \ .o..
Long running Spark Job Problem: NodeManager is unhealthy
EMR Core node의 hdfs (disk)의 점유율이 90% (default threshold 90%) 이상이 되어 해당 node가 unhealthy 상태인 것을 확인할 수 있습니다. If the node remains unhealthy for 45 minutes, Amazon EMR marks the associated Amazon EC2 instance for termination as FAILED_BY_MASTER.When all Amazon EC2 instances associated with core nodes are marked for termination, the cluster terminates with the status NO_SLAVE_LEFT because there are no..