search

dyrnq / cdc-vagrant

CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
https://nightlies.apache.org/flink/flink-cdc-docs-stable/
0 stars 0 forks source link

./bin/flink-cdc.sh -Dexecution.checkpointing.interval=3000 ~/mysql-to-doris.yaml #43

Open dyrnq opened 5 days ago

dyrnq commented 5 days ago 
Exception in thread "main" org.apache.flink.cdc.shaded.com.apache.commons.cli.UnrecognizedOptionException: Unrecognized option: -Dexecution.checkpointing.interval=3000
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.handleUnknownToken(DefaultParser.java:572)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.handleLongOptionWithEqual(DefaultParser.java:385)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.handleShortAndLongOption(DefaultParser.java:532)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.handleToken(DefaultParser.java:554)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.parse(DefaultParser.java:714)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.parse(DefaultParser.java:684)
        at org.apache.flink.cdc.shaded.com.apache.commons.cli.DefaultParser.parse(DefaultParser.java:665)
        at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:57)
dyrnq commented 5 days ago 
Exception in thread "main" java.lang.IllegalArgumentException: Cannot deserialize value of type `java.lang.String` from Object value (token `JsonToken.START_OBJECT`)
 at [Source: UNKNOWN; byte offset: #UNKNOWN] (through reference chain: java.util.LinkedHashMap["checkpointing"])
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._convert(ObjectMapper.java:4449)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.convertValue(ObjectMapper.java:4390)
        at org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser.toPipelineConfig(YamlPipelineDefinitionParser.java:309)
        at org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser.parse(YamlPipelineDefinitionParser.java:114)
        at org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser.parse(YamlPipelineDefinitionParser.java:95)
        at org.apache.flink.cdc.cli.CliExecutor.run(CliExecutor.java:85)
        at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:69)
Caused by: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type `java.lang.String` from Object value (token `JsonToken.START_OBJECT`)
 at [Source: UNKNOWN; byte offset: #UNKNOWN] (through reference chain: java.util.LinkedHashMap["checkpointing"])
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1746)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1520)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1425)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.extractScalarFromObject(DeserializationContext.java:937)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer._parseString(StdDeserializer.java:1421)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StringDeserializer.deserialize(StringDeserializer.java:48)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StringDeserializer.deserialize(StringDeserializer.java:11)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.MapDeserializer._readAndBindStringKeyMap(MapDeserializer.java:623)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:449)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:32)
        at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._convert(ObjectMapper.java:4444)
        ... 6 more
dyrnq commented 4 days ago

-Dexecution.checkpointing.interval=3000不能这样设置