flink 1.18.1 jar package conflicts: okhttp3 version

[fishTsai20]

Jar Package Conflicts

After importing 4.9.8 into the maven project, there is no problem when running locally, but jar package conflicts will occur when running on the flink1.18.1 cluster.
The flink-dist-1.18.1.jar and flink-shaded-hadoop-2-uber-2.8.3-10.0.jar that come with the flink1.18.1 environment both have okhttp dependencies that conflict with web3j.

Steps To Reproduce

1. Confirmed that there is okhttp in my jar package
   /opt/flink/lib# jar -tf ./runner-1.0-SNAPSHOT.jar | grep TaskRunner okhttp3/internal/concurrent/TaskRunner.class okhttp3/internal/concurrent/TaskRunner$Companion.class okhttp3/internal/concurrent/TaskRunner$RealBackend.class okhttp3/internal/concurrent/TaskRunner$Backend.class okhttp3/internal/concurrent/TaskRunner$runnable$1.class
2. The flink-dist-1.18.1.jar and flink-shaded-hadoop-2-uber-2.8.3-10.0.jar that come with the flink1.18.1 environment both have okhttp dependencies that conflict with web3j.

Expected behavior

A clear and concise description of what you expected to happen.

Actual behavior

A description of the actual behavior occurring.

Environment

Describe the environment in which the issue occurs

• Web3j version
  4.9.8

• Java or Android version
  8

• Operating System
  flink 1.18.1

• pom.xml
  `
  
  4.0.0

  manuscript
  runner
  1.0-SNAPSHOT
  jar

  Flink Quickstart Job

  UTF-8 1.18.1 1.8 2.12 ${target.java.version} ${target.java.version} 2.17.1 2.14.2 apache.snapshots Apache Development Snapshot Repository https://repository.apache.org/content/repositories/snapshots/ false true

    <!-- These dependencies are provided, because they should not be packaged into the JAR file. -->
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-streaming-java</artifactId>
    	<version>${flink.version}</version>
    	<scope>provided</scope>
    </dependency>
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-clients</artifactId>
    	<version>${flink.version}</version>
    	<scope>provided</scope>
    </dependency>
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-table-api-java</artifactId>
    	<version>${flink.version}</version>
    	<scope>provided</scope>
    </dependency>
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-table-api-java-bridge</artifactId>
    	<version>${flink.version}</version>
    	<scope>provided</scope>
    </dependency>
    <dependency>
    	<groupId>org.yaml</groupId>
    	<artifactId>snakeyaml</artifactId>
    	<version>1.29</version>
    </dependency>
    <!-- Add connector dependencies here. They must be in the default scope (compile). -->
  
    <!-- Example:
  
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-connector-kafka</artifactId>
    	<version>3.0.0-1.17</version>
    </dependency>
    -->
  
    <!-- Add logging framework, to produce console output when running in the IDE. -->
    <!-- These dependencies are excluded from the application JAR by default. -->
    <dependency>
    	<groupId>org.apache.logging.log4j</groupId>
    	<artifactId>log4j-slf4j-impl</artifactId>
    	<version>${log4j.version}</version>
    	<scope>runtime</scope>
    </dependency>
    <dependency>
    	<groupId>org.apache.logging.log4j</groupId>
    	<artifactId>log4j-api</artifactId>
    	<version>${log4j.version}</version>
    	<scope>runtime</scope>
    </dependency>
    <dependency>
    	<groupId>org.apache.logging.log4j</groupId>
    	<artifactId>log4j-core</artifactId>
    	<version>${log4j.version}</version>
    	<scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.36</version>
    </dependency>
    <dependency>
    	<groupId>com.esaulpaugh</groupId>
    	<artifactId>headlong</artifactId>
    	<version>9.2.0</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind -->
    <dependency>
    	<groupId>com.fasterxml.jackson.core</groupId>
    	<artifactId>jackson-databind</artifactId>
    	<version>2.14.2</version>
    </dependency>
    <dependency>
    	<groupId>org.apache.flink</groupId>
    	<artifactId>flink-shaded-jackson</artifactId>
    	<version>2.14.2-17.0</version>
    </dependency>
    <dependency>
    	<groupId>org.web3j</groupId>
    	<artifactId>abi</artifactId>
    	<version>4.9.8</version>
    </dependency>
    <dependency>
    	<groupId>org.web3j</groupId>
    	<artifactId>core</artifactId>
    	<version>4.9.8</version>
    </dependency>
    <dependency>
    	<groupId>com.google.guava</groupId>
    	<artifactId>guava</artifactId>
    	<version>31.0.1-jre</version>
    </dependency>
    <dependency>
    	<groupId>org.projectlombok</groupId>
    	<artifactId>lombok</artifactId>
    	<version>1.18.30</version>
    </dependency>
    <!--		render transform sql-->
    <dependency>
    	<groupId>org.freemarker</groupId>
    	<artifactId>freemarker</artifactId>
    	<version>2.3.31</version> <!-- 选择最新版本 -->
    </dependency>
    <dependency>
    	<groupId>org.junit.jupiter</groupId>
    	<artifactId>junit-jupiter</artifactId>
    	<version>RELEASE</version>
    	<scope>test</scope>
    </dependency>
  

    	<!-- Java Compiler -->
    	<plugin>
    		<groupId>org.apache.maven.plugins</groupId>
    		<artifactId>maven-compiler-plugin</artifactId>
    		<version>3.1</version>
    		<configuration>
    			<source>9</source>
    			<target>9</target>
    		</configuration>
    	</plugin>
  
    	<!-- We use the maven-shade plugin to create a fat jar that contains all necessary dependencies. -->
    	<!-- Change the value of <mainClass>...</mainClass> if your program entry point changes. -->
    	<plugin>
    		<groupId>org.apache.maven.plugins</groupId>
    		<artifactId>maven-shade-plugin</artifactId>
    		<version>3.1.1</version>
    		<executions>
    			<!-- Run shade goal on package phase -->
    			<execution>
    				<phase>package</phase>
    				<goals>
    					<goal>shade</goal>
    				</goals>
    				<configuration>
    					<createDependencyReducedPom>false</createDependencyReducedPom>
    					<artifactSet>
    						<excludes>
    							<exclude>org.apache.flink:flink-shaded-force-shading</exclude>
    							<exclude>com.google.code.findbugs:jsr305</exclude>
    							<exclude>org.slf4j:*</exclude>
    							<exclude>org.apache.logging.log4j:*</exclude>
    						</excludes>
    					</artifactSet>
    					<filters>
    						<filter>
    							<!-- Do not copy the signatures in the META-INF folder.
    							Otherwise, this might cause SecurityExceptions when using the JAR. -->
    							<artifact>*:*</artifact>
    							<excludes>
    								<exclude>META-INF/*.SF</exclude>
    								<exclude>META-INF/*.DSA</exclude>
    								<exclude>META-INF/*.RSA</exclude>
    							</excludes>
    						</filter>
    					</filters>
    					<transformers>
    						<transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
    						<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
    							<mainClass>manuscript.DataStreamJob</mainClass>
    						</transformer>
    					</transformers>
    				</configuration>
    			</execution>
    		</executions>
    	</plugin>
    </plugins>
  
    <pluginManagement>
    	<plugins>
  
    		<!-- This improves the out-of-the-box experience in Eclipse by resolving some warnings. -->
    		<plugin>
    			<groupId>org.eclipse.m2e</groupId>
    			<artifactId>lifecycle-mapping</artifactId>
    			<version>1.0.0</version>
    			<configuration>
    				<lifecycleMappingMetadata>
    					<pluginExecutions>
    						<pluginExecution>
    							<pluginExecutionFilter>
    								<groupId>org.apache.maven.plugins</groupId>
    								<artifactId>maven-shade-plugin</artifactId>
    								<versionRange>[3.1.1,)</versionRange>
    								<goals>
    									<goal>shade</goal>
    								</goals>
    							</pluginExecutionFilter>
    							<action>
    								<ignore/>
    							</action>
    						</pluginExecution>
    						<pluginExecution>
    							<pluginExecutionFilter>
    								<groupId>org.apache.maven.plugins</groupId>
    								<artifactId>maven-compiler-plugin</artifactId>
    								<versionRange>[3.1,)</versionRange>
    								<goals>
    									<goal>testCompile</goal>
    									<goal>compile</goal>
    								</goals>
    							</pluginExecutionFilter>
    							<action>
    								<ignore/>
    							</action>
    						</pluginExecution>
    					</pluginExecutions>
    				</lifecycleMappingMetadata>
    			</configuration>
    		</plugin>
    	</plugins>
    </pluginManagement>
  

`

Additional context

Add any other context about the problem here.

• Logs
  manuscript-flink-demo-jobmanager-1 | 2024-11-28 03:05:08,379 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: contracts[1] -> Calc[2] -> ConstraintEnforcer[3] -> Sink: ethereum_token_metas_sink_pg[3] (1/1) (9c94fbfc8db48f0a661b2d258924233e_cbc357ccb763df2852fee8c4fc7d55f2_0_187) switched from RUNNING to FAILED on 172.19.0.4:40833-265326 @ manuscript-flink-demo-taskmanager-1.manuscript-flink-demo_ms_network (dataPort=39335). manuscript-flink-demo-jobmanager-1 | java.lang.NoClassDefFoundError: Could not initialize class okhttp3.internal.concurrent.TaskRunner manuscript-flink-demo-jobmanager-1 | at okhttp3.ConnectionPool.<init>(ConnectionPool.kt:41) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.ConnectionPool.<init>(ConnectionPool.kt:47) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.OkHttpClient$Builder.<init>(OkHttpClient.kt:471) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.getOkHttpClientBuilder(HttpService.java:132) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.createOkHttpClient(HttpService.java:139) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.<init>(HttpService.java:112) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:155) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:146) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at java.util.HashMap.computeIfAbsent(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.getWeb3jClientInstance(GetTokenMeta.java:30) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.invoke(GetTokenMeta.java:58) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.lambda$eval$0(GetTokenMeta.java:45) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.lambda$computeIfAbsent$0(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$LoadingValueReference.compute(LocalCache.java:3566) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$Segment.compute(LocalCache.java:2242) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.compute(LocalCache.java:4197) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.computeIfAbsent(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.chainbase.common.cached.LRUCache.computeIfAbsent(LRUCache.java:22) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:43) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:54) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement_split1(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask$AsyncDataOutputToOutput.emitRecord(SourceOperatorStreamTask.java:309) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks.collect(SourceOutputWithWatermarks.java:110) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.paimon.flink.source.FlinkRecordsWithSplitIds.emitRecord(FlinkRecordsWithSplitIds.java:118) ~[paimon-flink-1.18-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at org.apache.paimon.flink.source.FileStoreSourceReader.lambda$new$1(FileStoreSourceReader.java:60) ~[paimon-flink-1.18-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:160) ~[flink-connector-files-1.18.0.jar:1.18.0] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:419) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:562) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at java.lang.Thread.run(Unknown Source) ~[?:?]
manuscript-flink-demo-jobmanager-1 | java.lang.NoSuchFieldError: Companion manuscript-flink-demo-jobmanager-1 | at okhttp3.internal.Util.<clinit>(Util.kt:72) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.internal.concurrent.TaskRunner.<clinit>(TaskRunner.kt:309) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.ConnectionPool.<init>(ConnectionPool.kt:41) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.ConnectionPool.<init>(ConnectionPool.kt:47) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at okhttp3.OkHttpClient$Builder.<init>(OkHttpClient.kt:471) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.getOkHttpClientBuilder(HttpService.java:132) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.createOkHttpClient(HttpService.java:139) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at org.web3j.protocol.http.HttpService.<init>(HttpService.java:112) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:155) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:146) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at java.util.HashMap.computeIfAbsent(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.getWeb3jClientInstance(GetTokenMeta.java:30) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.invoke(GetTokenMeta.java:58) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.lambda$eval$0(GetTokenMeta.java:45) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.lambda$computeIfAbsent$0(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$LoadingValueReference.compute(LocalCache.java:3566) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$Segment.compute(LocalCache.java:2242) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.compute(LocalCache.java:4197) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.computeIfAbsent(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.chainbase.common.cached.LRUCache.computeIfAbsent(LRUCache.java:22) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:43) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:54) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement_split1(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask$AsyncDataOutputToOutput.emitRecord(SourceOperatorStreamTask.java:309) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks.collect(SourceOutputWithWatermarks.java:110) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.paimon.flink.source.FlinkRecordsWithSplitIds.emitRecord(FlinkRecordsWithSplitIds.java:118) ~[paimon-flink-1.18-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at org.apache.paimon.flink.source.FileStoreSourceReader.lambda$new$1(FileStoreSourceReader.java:60) ~[paimon-flink-1.18-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:160) ~[flink-connector-files-1.18.0.jar:1.18.0] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:419) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:562) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:932) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.18.1.jar:1.18.1] manuscript-flink-demo-jobmanager-1 | at java.lang.Thread.run(Unknown Source) ~[?:?]
2024-11-28 08:50:42,133 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: contracts[1] -> Calc[2] -> ConstraintEnforcer[3] -> Sink: ethereum_token_metas_sink_pg[3] (1/1) (f294f1a87fa6a8fa42659f342ae89855_cbc357ccb763df2852fee8c4fc7d55f2_0_26) switched from RUNNING to FAILED on 172.25.0.4:35975-ddb6a4 @ manuscript-flink-demo-taskmanager-1.manuscript-flink-demo_ms_network (dataPort=43741). manuscript-flink-demo-jobmanager-1 | java.lang.NoClassDefFoundError: okhttp3/Interceptor manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:155) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.evm.Web3jClient.<init>(Web3jClient.java:146) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at java.util.HashMap.computeIfAbsent(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.getWeb3jClientInstance(GetTokenMeta.java:30) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.invoke(GetTokenMeta.java:58) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.lambda$eval$0(GetTokenMeta.java:45) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.lambda$computeIfAbsent$0(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$LoadingValueReference.compute(LocalCache.java:3566) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache$Segment.compute(LocalCache.java:2242) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.compute(LocalCache.java:4197) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.google.common.cache.LocalCache.computeIfAbsent(LocalCache.java:4204) ~[paimon-oss-impl-0.8.1.jar:0.8.1] manuscript-flink-demo-jobmanager-1 | at com.chainbase.common.cached.LRUCache.computeIfAbsent(LRUCache.java:22) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:43) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at com.chainbase.udf.GetTokenMeta.eval(GetTokenMeta.java:54) ~[runner-1.0-SNAPSHOT.jar:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement_split1(Unknown Source) ~[?:?] manuscript-flink-demo-jobmanager-1 | at StreamExecCalc$66.processElement(Unknown Source) ~[?:?]
• Sample code and/or code snippets
• Unit/integration tests to highlight the issue
• etherscan references