Skip to content

Instantly share code, notes, and snippets.

java.lang.NoClassDefFoundError: javax/cache/Cache
at java.lang.ClassLoader.defineClass1(Native Method) ~[na:1.8.0_92]
at java.lang.ClassLoader.defineClass(ClassLoader.java:763) ~[na:1.8.0_92]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[na:1.8.0_92]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467) ~[na:1.8.0_92]
at java.net.URLClassLoader.access$100(URLClassLoader.java:73) ~[na:1.8.0_92]
at java.net.URLClassLoader$1.run(URLClassLoader.java:368) ~[na:1.8.0_92]
at java.net.URLClassLoader$1.run(URLClassLoader.java:362) ~[na:1.8.0_92]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.8.0_92]
at java.net.URLClassLoader.findClass(URLClassLoader.java:361) ~[na:1.8.0_92]
@Test
public void groupedFluxCanBeLimited() {
int pages = 1000;
int fetchSize = 100_000;
int partitions = 4;
int size = 343;
Flux<Integer> flux = Flux.range(0, pages)
.concatMap(page -> Flux.range(page * fetchSize, fetchSize), 1);
Scheduler scheduler = Schedulers.newSingle("my-scheduler");
@tsachev
tsachev / SecretEnvironmentPostProcessor.java
Created April 7, 2020 10:13
spring-boot doker/k8s secrets support
/*
* Copyright 2016-2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software