osdir.com

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink with Docker: docker-compose and FLINK_JOB_ARGUMENT exception


Hi,

I'm trying to run flink with docker (docker-compose) and job arguments "config-dev.properties". But it seams that the job arguments are not available:

docker-compose.yml

version: '2'
services:
  job-cluster:
    image: ${FLINK_DOCKER_IMAGE_NAME:-timeseries-v1}
    ports:
      - '8081:8081'
    command: job-cluster --job-classname -Djobmanager.rpc.address=job-cluster -Dparallelism.default=1 --config config-dev.properties

  taskmanager:
    image: ${FLINK_DOCKER_IMAGE_NAME:-timeseries-v1}
    command: task-manager -Djobmanager.rpc.address=job-cluster
    scale: 1


Excpetion:

4:32 AMorg.apache.flink.runtime.entrypoint.FlinkParseException: Failed to parse the command line arguments.

12/7/2018 10:44:32 AM          at org.apache.flink.runtime.entrypoint.parser.CommandLineParser.parse(CommandLineParser.java:52)

12/7/2018 10:44:32 AM          at org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:143)

12/7/2018 10:44:32 AMCaused by: org.apache.commons.cli.MissingArgumentException: Missing argument for option: j

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.checkRequiredArgs(DefaultParser.java:211)

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.handleOption(DefaultParser.java:599)

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.handleShortAndLongOption(DefaultParser.java:548)

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.handleToken(DefaultParser.java:243)

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.parse(DefaultParser.java:120)

12/7/2018 10:44:32 AM          at org.apache.commons.cli.DefaultParser.parse(DefaultParser.java:81)

12/7/2018 10:44:32 AM          at org.apache.flink.runtime.entrypoint.parser.CommandLineParser.parse(CommandLineParser.java:50)

12/7/2018 10:44:32 AM          ... 1 more

12/7/2018 10:44:32 AMException in thread "main" java.lang.NoSuchMethodError: org.apache.flink.runtime.entrypoint.parser.CommandLineParser.printHelp()V

12/7/2018 10:44:32 AM          at org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:146)