HunterXHunter
HunterXHunter
spark.shuffle.consolidateFiles是在使用HashShuffleManager的时候建议开启。spark2.x已经弃用了HashShuffleManager
在sql预校验部分使用flink自由的calcite做sql校验,可以得出逻辑计算树,方便分析sql。
When I execute it for the first time, I need to select a database.
Support user to customize jobname when submitting job,Currently, the sql statement is used as the jobname by default, which will cause the jobname to be too long. I have already...
Add trigger savepoint handler to support user trigger savepoint,Also store the location of the savepoint so that it can be restored from the savepoint next time
Exception Msg: Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.CatalogFactory' in Reason for error : ExecutionContext.createCatalog and FactoryUtil.createCatalog are implemented differently. It works fine after I...
Currently, only the application_id parameter of the configuration file can be read when starting the sqlgateway server, which causes all users to use the same yarn-session, which causes a single...
Solve the 1.13 version api conflict problem. Can be used normally online.