You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by "oscerd (via GitHub)" <gi...@apache.org> on 2023/07/19 15:26:19 UTC
[GitHub] [camel] oscerd commented on pull request #10733: integrate multi-shard consumer with async client
oscerd commented on PR #10733:
URL: https://github.com/apache/camel/pull/10733#issuecomment-1642302225
Test is failing:
```
[INFO] Using the SmartBuilder implementation with a thread count of 2
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] ----------------< org.apache.camel:camel-aws2-kinesis >-----------------
[camel-aws2-kinesis] [INFO] Building Camel :: AWS2 Kinesis 4.0.0-SNAPSHOT [1/28]
[camel-aws2-kinesis] [INFO] from pom.xml
[camel-aws2-kinesis] [INFO] --------------------------------[ jar ]---------------------------------
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- build-helper:3.4.0:add-source (default) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Source directory: /home/runner/work/camel/camel/components/camel-aws/camel-aws2-kinesis/src/generated/java added.
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- build-helper:3.4.0:add-resource (default) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- license:4.2:format (license-format) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [WARN] Parameter 'legacyConfigExcludes' (user property 'license.excludes') is deprecated: use LicenseSet.excludes
[camel-aws2-kinesis] [WARN] Parameter 'legacyConfigHeader' (user property 'license.header') is deprecated: use LicenseSet.header
[camel-aws2-kinesis] [INFO] Updating license headers...
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- formatter:2.23.0:format (format) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Processed 51 files in 1s735ms (Formatted: 1, Skipped: 0, Unchanged: 50, Failed: 0, Readonly: 0)
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- impsort:1.9.0:sort (sort-imports) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Processed 51 files in 00:00.590 (Already Sorted: 50, Needed Sorting: 1)
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- resources:3.3.1:resources (default-resources) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] skip non existing resourceDirectory /home/runner/work/camel/camel/components/camel-aws/camel-aws2-kinesis/src/main/resources
[camel-aws2-kinesis] [INFO] Copying 13 resources from src/generated/resources to target/classes
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- flatten:1.5.0:flatten (default-cli) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Generating flattened POM of project org.apache.camel:camel-aws2-kinesis:jar:4.0.0-SNAPSHOT...
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- compiler:3.11.0:compile (default-compile) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Changes detected - recompiling the module! :source
[camel-aws2-kinesis] [INFO] Compiling 41 source files with javac [debug deprecation release 17] to target/classes
[camel-aws2-kinesis] [INFO] /home/runner/work/camel/camel/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java: Some input files use unchecked or unsafe operations.
[camel-aws2-kinesis] [INFO] /home/runner/work/camel/camel/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/firehose/KinesisFirehose2Producer.java: Recompile with -Xlint:unchecked for details.
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- camel-package:4.0.0-SNAPSHOT:generate (generate) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Stale files detected, re-generating.
[camel-aws2-kinesis] [INFO] Stale files detected, re-generating index.
[camel-aws2-kinesis] [INFO] Building index...
[camel-aws2-kinesis] [INFO] Generated components containing 2 Camel components: aws2-kinesis aws2-kinesis-firehose
[camel-aws2-kinesis] [INFO] Validation complete
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- compiler:3.11.0:compile (recompile) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Nothing to compile - all classes are up to date
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- resources:3.3.1:testResources (default-testResources) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Copying 1 resource from src/test/resources to target/test-classes
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- compiler:3.11.0:testCompile (default-testCompile) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Changes detected - recompiling the module! :dependency
[camel-aws2-kinesis] [INFO] Compiling 17 source files with javac [debug deprecation release 17] to target/test-classes
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] --- surefire:3.1.2:test (default-test) @ camel-aws2-kinesis ---
[camel-aws2-kinesis] [INFO] Surefire report directory: /home/runner/work/camel/camel/components/camel-aws/camel-aws2-kinesis/target/surefire-reports
[camel-aws2-kinesis] [INFO] Using auto detected provider org.apache.maven.surefire.junitplatform.JUnitPlatformProvider
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] -------------------------------------------------------
[camel-aws2-kinesis] [INFO] T E S T S
[camel-aws2-kinesis] [INFO] -------------------------------------------------------
[INFO] Running org.apache.camel.component.aws2.firehose.KinesisFirehoseClientFactoryTest
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.559 s -- in org.apache.camel.component.aws2.firehose.KinesisFirehoseClientFactoryTest
[INFO] Running org.apache.camel.component.aws2.firehose.KinesisFirehoseComponentConfigurationTest
[INFO] Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.305 s -- in org.apache.camel.component.aws2.firehose.KinesisFirehoseComponentConfigurationTest
[INFO] Running org.apache.camel.component.aws2.firehose.KinesisFirehoseComponentVerifierExtensionTest
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.275 s -- in org.apache.camel.component.aws2.firehose.KinesisFirehoseComponentVerifierExtensionTest
[INFO] Running org.apache.camel.component.aws2.firehose.KinesisFirehoseEndpointTest
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.655 s -- in org.apache.camel.component.aws2.firehose.KinesisFirehoseEndpointTest
[INFO] Running org.apache.camel.component.aws2.kinesis.KinesisClientFactoryTest
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.030 s -- in org.apache.camel.component.aws2.kinesis.KinesisClientFactoryTest
[INFO] Running org.apache.camel.component.aws2.kinesis.KinesisComponentConfigurationTest
[INFO] Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.077 s -- in org.apache.camel.component.aws2.kinesis.KinesisComponentConfigurationTest
[INFO] Running org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithFailTest
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.200 s -- in org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithFailTest
[INFO] Running org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest
[ERROR] Tests run: 5, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 0.093 s <<< FAILURE! -- in org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest
[ERROR] org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest.itUsesTheShardIteratorOnSubsiquentPolls -- Time elapsed: 0.016 s <<< FAILURE!
org.mockito.exceptions.verification.TooManyActualInvocations:
kinesisClient.getShardIterator(
<any software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest>
);
Wanted 1 time:
-> at org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest.itUsesTheShardIteratorOnSubsiquentPolls(KinesisConsumerClosedShardWithSilentTest.java:163)
But was 2 times:
-> at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.getShardIterator(Kinesis2Consumer.java:182)
-> at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.getShardIterator(Kinesis2Consumer.java:182)
at org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest.itUsesTheShardIteratorOnSubsiquentPolls(KinesisConsumerClosedShardWithSilentTest.java:163)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:147)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:127)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:90)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:55)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:102)
at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:54)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
at org.apache.maven.surefire.junitplatform.LazyLauncher.execute(LazyLauncher.java:56)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:184)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:148)
at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:122)
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:385)
at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:507)
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:495)
[INFO] Running org.apache.camel.component.aws2.kinesis.KinesisEndpointTest
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.051 s -- in org.apache.camel.component.aws2.kinesis.KinesisEndpointTest
[INFO] Running org.apache.camel.component.aws2.kinesis.RecordStringConverterTest
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.009 s -- in org.apache.camel.component.aws2.kinesis.RecordStringConverterTest
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [INFO] Results:
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [ERROR] Failures:
[camel-aws2-kinesis] [ERROR] KinesisConsumerClosedShardWithSilentTest.itUsesTheShardIteratorOnSubsiquentPolls:163
kinesisClient.getShardIterator(
<any software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest>
);
Wanted 1 time:
-> at org.apache.camel.component.aws2.kinesis.KinesisConsumerClosedShardWithSilentTest.itUsesTheShardIteratorOnSubsiquentPolls(KinesisConsumerClosedShardWithSilentTest.java:163)
But was 2 times:
-> at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.getShardIterator(Kinesis2Consumer.java:182)
-> at org.apache.camel.component.aws2.kinesis.Kinesis2Consumer.getShardIterator(Kinesis2Consumer.java:182)
[camel-aws2-kinesis] [INFO]
[camel-aws2-kinesis] [ERROR] Tests run: 33, Failures: 1, Errors: 0, Skipped: 0
[camel-aws2-kinesis] [INFO]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org