gbguanbo
gbguanbo
看官方文档和代码只能找到一次性增加语料，如何动态增加呢？如
## 问题描述 (Description) 【企业微信】批量获取审批单号 get_approval_info 过滤参数少了s，造成过滤失效 data = optionaldict( {"starttime": str(start_time), "endtime": str(end_time), "cursor": cursor, "size": size, **"filter": filters**} ) data = optionaldict( {"starttime": str(start_time), "endtime": str(end_time), "cursor": cursor, "size":...
from pyalink.alink import * #ExecutionEnvironment、BatchTableEnvironment、StreamExecutionEnvironment 和 StreamTableEnvironment。 benv, btenv, senv, stenv = useRemoteEnv("localhost", 8081, 1) jars = "file:///home/guanbo/flink-1.13.3/lib/flink-csv-1.13.3.jar;" \ +"file:///home/guanbo/flink-1.13.3/lib/flink-dist_2.11-1.13.3.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/flink-json-1.13.3.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/flink-shaded-zookeeper-3.4.14.jar"\ +"file:///home/guanbo/flink-1.13.3/lib/flink-table_2.11-1.13.3.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/flink-table-blink_2.11-1.13.3.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/alink_core_flink-1.13_2.11-1.6.2.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/alink_python_flink-1.13_2.11-1.6.2.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/log4j-1.2-api-2.12.1.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/log4j-api-2.12.1.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/log4j-core-2.12.1.jar;"\ +"file:///home/guanbo/flink-1.13.3/lib/log4j-slf4j-impl-2.12.1.jar;"\...