### 问题一：Flink 中 shuffle Partitioner 和 rebalance partitoner 有什么区别？

ShufflePartitioner:

public int selectChannel(SerializationDelegate record) { return random.nextInt(numberOfChannels); }

RebalancePartitioner public int selectChannel(SerializationDelegate record) { nextChannelToSendTo = (nextChannelToSendTo + 1) % numberOfChannels; return nextChannelToSendTo; }

### 问题二：关于pyflink LATERAL TABLE 问题请教

class myKerasMLP(ScalarFunction):

def eval(self, *args): ...

# 返回预测结果

return str(trueY[0][0]) + '|' + str(trueY[0][1])

class SplitStr(TableFunction): def eval(self, str_value): str_arr = str_value.split('|') yield str_arr[0], str_arr[1] yield str_arr[0], str_arr[1]

t_env.register_function('train_and_predict', myKerasMLP) t_env.register_function("splitStr", splitStr)

==================

==================== 报错 java.lang.IndexOutOfBoundsException: Index: 7, Size: 7 Traceback (most recent call last): File "C:/Users/Administrator.XTZ-02012091146/PycharmProjects/pythonProject/kerasTest/UdtfNtPredictPyFlink.py", line 280, in t_env.execute('NT重连预测参数') File "D:\tools\Python3.6.5\lib\site-packages\pyflink\table\table_environment.py", line 1057, in execute return JobExecutionResult(self._j_tenv.execute(job_name)) File "D:\tools\Python3.6.5\lib\site-packages\py4j\java_gateway.py", line 1286, in call answer, self.gateway_client, self.target_id, self.name) File "D:\tools\Python3.6.5\lib\site-packages\pyflink\util\exceptions.py", line 147, in deco return f(*a, **kw) File "D:\tools\Python3.6.5\lib\site-packages\py4j\protocol.py", line 328, in get_return_value format(target_id, ".", name), value) py4j.protocol.Py4JJavaError: An error occurred while calling o25.execute. : java.lang.IndexOutOfBoundsException: Index: 7, Size: 7 at java.util.ArrayList.rangeCheck(ArrayList.java:657)

==================== 这段SQL可以执行 t_env.sql_query(""" SELECT hotime , before_ta , before_rssi , after_ta , after_rssil , nb_tath , nb_rssith , train_and_predict(hotime, before_ta, before_rssi, after_ta, after_rssil, nb_tath, nb_rssith) predict FROM source """).insert_into("print_table")

### 问题三：1.12 yarn-per-job提交作业失败怎么办？

> 我在用这个命令提交的时候会报

> flink Application rejected by queue placement policy

> 这个应该是没有指定queue

> 但是我在命令中加了-yqu 这个参数，在web界面看quene 的时候，不是我指定的，而是default 。

### 问题五：PyFlink UDTF 运行一段时间后报 NullPointerException怎么办？

PyFlink UDTF 运行一段时间后报 NullPointerException怎么办？

Linux入门到精通

|
9天前
|

103 11
|
8天前
|
SQL Java API

21 0
|
1天前
|
Oracle 关系型数据库 MySQL

15 1
|
6天前
|
SQL Oracle 关系型数据库

20 3
|
7天前
|
SQL Oracle 关系型数据库

15 0
|
8天前
|
SQL 关系型数据库 数据处理

31 0
|
8天前
|

30 0
|
8天前
|

19 2
|
9天前
|

Apache Hudi + Flink作业运行指南
Apache Hudi + Flink作业运行指南
180 1
|
9天前
|
SQL 消息中间件 Kafka
521 0