Page History

ConfigOptions.key("sql-driver.sql-file")
                    .stringType()
                    .noDefaultValue()
                    .withDescription(
                            "File system path (URI) of file that contains SQLs to execute. " +
                            "URIs of Flink-supported filesystem are allowed. " + 
                            "Either `sql-driver.sql-file` or `sql-driver.json-plan` should be specified.");
ConfigOptions.key("sql-driver.json-plan")
                    .stringType()
                    .noDefaultValue()
                    .withDescription(
                            "File system path (URI) of json plan that the pipeline is built from. " + 
                            "URIs of Flink-supported filesystem are allowed. " +
                            "Either `sql-driver.sql-file` or `sql-driver.json-plan` should be specified.");  
ConfigOptions.key("sql-driver.init.-file")
                    .stringType()
                    .noDefaultValue()
                    .withDescription(
                            "Path of the local file that contains initial SQLs to prepare the environment. " + 
                            "For example, create catalogs and functions. URIs of Flink-supported filesystem are allowed.");
ConfigOptions.key("sql-driver.storage-dir")
                    .stringType()
                    .noDefaultValue()
                    .withDescription(
                            "File system path (URI) of the directory that stores resources. URIs of Flink-supported filesystem are allowed. " +
                            "When initialing, SQL Driver would localize the resources into the working directory. "
                            "This option is not effective for YARN setups, since YARN distributes resource files natively.");

 ./bin/flink run-application -t kubenetes-application \
      -Dsql-driver.init.-file hdfs:///tmp/init_sql \
      -Dsql-driver.sql-file file:///tmp/sql \
      -Dpipeline.jars=s3://mybucket.s3.example.com/myudf.jar