Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[transactions] IllegalArgumentException #337

Open
je-ik opened this issue Jul 2, 2024 · 1 comment
Open

[transactions] IllegalArgumentException #337

je-ik opened this issue Jul 2, 2024 · 1 comment

Comments

@je-ik
Copy link
Collaborator

je-ik commented Jul 2, 2024 

java.lang.IllegalArgumentException: null
	at cz.o2.proxima.internal.com.google.common.base.Preconditions.checkArgument(Preconditions.java:129) ~[proxima-vendor-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.createCachedTransaction(TransactionResourceManager.java:803) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$getOrCreateCachedTransaction$17(TransactionResourceManager.java:858) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708) ~[?:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.getOrCreateCachedTransaction(TransactionResourceManager.java:857) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$createTransactionUpdateConsumer$cd75872e$1(TransactionResourceManager.java:555) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView.onCache(LocalCachedPartitionedView.java:121) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:155) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:142) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.io.kafka.ElementConsumers$BulkConsumer.consumeWithConfirm(ElementConsumers.java:217) ~[proxima-direct-io-kafka-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.io.kafka.KafkaLogReader.lambda$submitConsumerWithObserver$7(KafkaLogReader.java:479) ~[proxima-direct-io-kafka-0.15-SNAPSHOT.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1583) ~[?:?]
2024-07-02 15:25:24.772 ERROR LocalCachedPartitionedView - Failed to prefetch data
java.lang.IllegalArgumentException: null
	at cz.o2.proxima.internal.com.google.common.base.Preconditions.checkArgument(Preconditions.java:129) ~[proxima-vendor-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.createCachedTransaction(TransactionResourceManager.java:803) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$getOrCreateCachedTransaction$17(TransactionResourceManager.java:858) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708) ~[?:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.getOrCreateCachedTransaction(TransactionResourceManager.java:857) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$createTransactionUpdateConsumer$cd75872e$1(TransactionResourceManager.java:555) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView.onCache(LocalCachedPartitionedView.java:121) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:155) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:142) ~[proxima-direct-core-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.io.kafka.ElementConsumers$BulkConsumer.consumeWithConfirm(ElementConsumers.java:217) ~[proxima-direct-io-kafka-0.15-SNAPSHOT.jar:?]
	at cz.o2.proxima.direct.io.kafka.KafkaLogReader.lambda$submitConsumerWithObserver$7(KafkaLogReader.java:479) ~[proxima-direct-io-kafka-0.15-SNAPSHOT.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	at java.lang.Thread.run(Thread.java:1583) ~[?:?]
2024-07-02 15:25:24.774 INFO TransactionManagerServer - TransactionManagerServer shutting down.
Exception in thread "main" java.lang.reflect.InvocationTargetException
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:118)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at cz.o2.proxima.core@0.15-SNAPSHOT/cz.o2.proxima.core.repository.JPMSMain.main(JPMSMain.java:70)
Caused by: java.lang.IllegalStateException: java.lang.IllegalArgumentException
	at cz.o2.proxima.core@0.15-SNAPSHOT/cz.o2.proxima.core.util.ExceptionUtils.rethrowAsIllegalStateException(ExceptionUtils.java:184)
	at java.base/java.util.Optional.ifPresent(Optional.java:178)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.view.LocalCachedPartitionedView.assign(LocalCachedPartitionedView.java:208)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$runObservations$9(TransactionResourceManager.java:532)
	at java.base/java.util.HashMap.computeIfAbsent(HashMap.java:1228)
	at java.base/java.util.Collections$SynchronizedMap.computeIfAbsent(Collections.java:2980)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$runObservations$10(TransactionResourceManager.java:527)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1708)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)
	at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.runObservations(TransactionResourceManager.java:514)
	at cz.o2.proxima.direct.transaction.manager@0.15-SNAPSHOT/cz.o2.proxima.direct.transaction.manager.TransactionLogObserver$1.runObservations(TransactionLogObserver.java:212)
	at cz.o2.proxima.direct.transaction.manager@0.15-SNAPSHOT/cz.o2.proxima.direct.transaction.manager.TransactionLogObserver.run(TransactionLogObserver.java:844)
	at cz.o2.proxima.direct.transaction.manager@0.15-SNAPSHOT/cz.o2.proxima.direct.transaction.manager.TransactionManagerServer.run(TransactionManagerServer.java:134)
	at cz.o2.proxima.direct.transaction.manager@0.15-SNAPSHOT/cz.o2.proxima.direct.transaction.manager.TransactionManagerServer.main(TransactionManagerServer.java:65)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	... 2 more
Caused by: java.lang.IllegalArgumentException
	at cz.o2.proxima.vendor@0.15-SNAPSHOT/cz.o2.proxima.internal.com.google.common.base.Preconditions.checkArgument(Preconditions.java:129)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.createCachedTransaction(TransactionResourceManager.java:803)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$getOrCreateCachedTransaction$17(TransactionResourceManager.java:858)
	at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1708)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.getOrCreateCachedTransaction(TransactionResourceManager.java:857)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.transaction.TransactionResourceManager.lambda$createTransactionUpdateConsumer$cd75872e$1(TransactionResourceManager.java:555)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.view.LocalCachedPartitionedView.onCache(LocalCachedPartitionedView.java:121)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:155)
	at cz.o2.proxima.direct.core@0.15-SNAPSHOT/cz.o2.proxima.direct.core.view.LocalCachedPartitionedView$1.onNext(LocalCachedPartitionedView.java:142)
	at cz.o2.proxima.direct.io.kafka@0.15-SNAPSHOT/cz.o2.proxima.direct.io.kafka.ElementConsumers$BulkConsumer.consumeWithConfirm(ElementConsumers.java:217)
	at cz.o2.proxima.direct.io.kafka@0.15-SNAPSHOT/cz.o2.proxima.direct.io.kafka.KafkaLogReader.lambda$submitConsumerWithObserver$7(KafkaLogReader.java:479)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1583)
@je-ik
Copy link
Collaborator Author

je-ik commented Jul 2, 2024

Transaction manager was not restarted upon this exception.

je-ik added a commit that referenced this issue Jul 8, 2024
@je-ik
[proxima-direct-transaction-manager] #337 ensure transaction server t…
503d6c9 
…erminates on errors
je-ik added a commit that referenced this issue Jul 8, 2024
@je-ik
Merge pull request #924: [proxima-direct-transaction-manager] #337 en…
5426299 
…sure transaction server terminates on errors
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@je-ik