benjobs
benjobs
8. ### #571  ## methods of resolution Dependency hierarchy, see where the log conflicts are fix udf log4j conflict ## Requirement or improvement（诉求 & 改进建议） add java parameter Start...
9. ### `Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in the classpath` ``` 2021-12-24T04:43:28.901627819Z Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in 2021-12-24T04:43:28.901630469Z...
10. ### window idea environment Could not submit Flink job to remote yarn cluster 动态修改提交job的入口参数， 入口点 YarnClientImpl类 , 方法 submitApplication， 提交点 this.rmClient.submitApplication(request); 对入参 request的 CLASSPATH and _FLINK_CLASSPATH 参数值的分隔符 windows is...
can you fix this bug? welcome to submit a PR.
The current version requires an insert operation so that the job can run
When stopping, if enable savepoint policy as follows: 1. Specifying the savepoint path will keep the savepoint to the path specified by the user 2. If the savepoint path is...
> Yes, it's better to do so. see Applicationserviceimpl.java 912 to 941 lines for more detail. ---- 可以, 这样做比较好, 具体代码可以看看 ApplicationServiceImpl.java 912 到 941 行
the key information of the error was not provided
> This problem seems to have not been solved in version 1.2.3 The latest code fixed this bug