Daniel Duan

Start azkaban exec server got error ERROR MySQLDataSource:103

10

In my conf/azkaban.properties the mysql configuration info as below. database.type=mysql mysql.port=3306 mysql.host=dnode04 mysql.database=azkaban mysql.user=azkaban mysql.password=password mysql.numconnections=100 but when I try start azkaban exec server , I got error 2018-04-17 10:39:13...

a typo

在HotItems.java中当点击数量总数少于topSize时，会报数据越界错误

1

在HotItems.java中当点击数量总数少于topSize时，会报数据越界错误 在模拟数据中，当一段时间内的点击数量只有1条，设置的topSize为3时 ItemViewCount currentItem = allItems.get(i); 会数组越界 ``` Caused by: java.lang.IndexOutOfBoundsException: Index: 1, Size: 1 at java.util.ArrayList.rangeCheck(ArrayList.java:657) at java.util.ArrayList.get(ArrayList.java:433) at com.app.java.myflink.HotItems$TopNHotItems.onTimer(HotItems.java:140) at org.apache.flink.streaming.api.operators.KeyedProcessOperator.invokeUserFunction(KeyedProcessOperator.java:94) at org.apache.flink.streaming.api.operators.KeyedProcessOperator.onEventTime(KeyedProcessOperator.java:72) at org.apache.flink.streaming.api.operators.InternalTimerServiceImpl.advanceWatermark(InternalTimerServiceImpl.java:251) at org.apache.flink.streaming.api.operators.InternalTimeServiceManager.advanceWatermark(InternalTimeServiceManager.java:128) at...

Add rack concept like Hadoop

2

## Feature request **Is your feature request related to a problem? Please describe.** No **Describe the solution you'd like** Each Fe and BE has it's own rack properties. **Describe alternatives...

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version JDK1.8 ### Scala Version 2.12.x ### StreamPark Version 1. release-2.1.4...

[Bug] Write paimon table with hive engine by MR got exeception

11

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 0.9 ### Compute Engine hive: 2.1-cdh-6.3-1 ### Minimal reproduce step create paimon...

Fix [#8995](https://github.com/apache/seatunnel/issues/8995)

Azakaban Version: master Issue: If scheduler a one-time workflow, it will loop execute after the scheduled time. Everytime call `azkaban.scheduler.Schedule#getNextExecTime`, it will return a time after now(). But if the...