[
https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141973#comment-17141973
]
Chesnay Schepler commented on FLINK-18347:
------------------------------------------
We can't selectively downgrade the cbor dataformat; then we'd be running into
FLINK-15868 again.
{{NO_INTS}} is a static field within jackson-core, which existed since 2.9.0.
If a user uses only the jackson dependencies that Flink declares (that is,
2.10.1 for everything), then you simply cannot run into a NoSuchMethodError.
The only way for this to be the case is if another jackson-core version is
being bundled.
At that point it very much is the users responsibility to ensure the
dependencies are not interfering with each other.
How this is done depends on the exact use-case, and there is strikingly little
we can do to solve this in general.
> kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS
> -----------------------------------------------------------------
>
> Key: FLINK-18347
> URL: https://issues.apache.org/jira/browse/FLINK-18347
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kinesis
> Affects Versions: 1.10.1
> Reporter: lining
> Assignee: Nicholas Jiang
> Priority: Major
> Labels: pull-request-available
>
> java.lang.NoSuchFieldError: NO_INTSjava.lang.NoSuchFieldError: NO_INTS at
> com.fasterxml.jackson.dataformat.cbor.CBORParser.<init>(CBORParser.java:285)
> ~[usercode.jar:?] at
> com.fasterxml.jackson.dataformat.cbor.CBORParserBootstrapper.constructParser(CBORParserBootstrapper.java:91)
> ~[usercode.jar:?] at
> com.fasterxml.jackson.dataformat.cbor.CBORFactory._createParser(CBORFactory.java:399)
> ~[usercode.jar:?] at
> com.fasterxml.jackson.dataformat.cbor.CBORFactory.createParser(CBORFactory.java:324)
> ~[usercode.jar:?] at
> com.fasterxml.jackson.dataformat.cbor.CBORFactory.createParser(CBORFactory.java:26)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.JsonResponseHandler.handle(JsonResponseHandler.java:109)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.JsonResponseHandler.handle(JsonResponseHandler.java:43)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.response.AwsResponseHandlerAdapter.handle(AwsResponseHandlerAdapter.java:70)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleResponse(AmazonHttpClient.java:1627)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1336)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1113)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:770)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:744)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:726)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:686)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:668)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:532)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:512)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.AmazonKinesisClient.doInvoke(AmazonKinesisClient.java:2809)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:2776)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.AmazonKinesisClient.invoke(AmazonKinesisClient.java:2765)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.AmazonKinesisClient.executeListShards(AmazonKinesisClient.java:1557)
> ~[usercode.jar:?] at
> org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.AmazonKinesisClient.listShards(AmazonKinesisClient.java:1528)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy.listShards(KinesisProxy.java:439)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy.getShardsOfStream(KinesisProxy.java:389)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.connectors.kinesis.proxy.KinesisProxy.getShardList(KinesisProxy.java:279)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher.discoverNewShardsToSubscribe(KinesisDataFetcher.java:686)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer.run(FlinkKinesisConsumer.java:287)
> ~[usercode.jar:?] at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
> ~[flink-dist_2.11-1.10-vvr-1.0.2-SNAPSHOT.jar:1.10-vvr-1.0.2-SNAPSHOT] at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
> ~[flink-dist_2.11-1.10-vvr-1.0.2-SNAPSHOT.jar:1.10-vvr-1.0.2-SNAPSHOT] at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:200)
> ~[flink-dist_2.11-1.10-vvr-1.0.2-SNAPSHOT.jar:1.10-vvr-1.0.2-SNAPSHOT]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
