Skip to content

flink 1.18.1 jar package conflicts: okhttp3 version #2118

New issue
New issue
Open
Open
flink 1.18.1 jar package conflicts: okhttp3 version#2118
Labels
bugA bug in behaviour or functionality
@fishTsai20

Description

@fishTsai20
fishTsai20
opened on Nov 29, 2024

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

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugA bug in behaviour or functionality

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions