vivekkoya opened a new pull request, #4152:
URL: https://github.com/apache/cassandra/pull/4152
Thanks for sending a pull request! Here are some tips if you're new here:
* Ensure you have added or run the [appropriate
tests](https://cassandra.apache.org/_/development/testing.html) for your PR.
* Be sure to keep the PR description updated to reflect all changes.
* Write your PR title to summarize what this PR proposes.
* If possible, provide a concise example to reproduce the issue for a
faster review.
* Read our [contributor
guidelines](https://cassandra.apache.org/_/development/index.html)
* If you're making a documentation change, see our [guide to documentation
contribution](https://cassandra.apache.org/_/development/documentation.html)
Commit messages should follow the following format:
```
Fix streaming issue while bootstrapping/joining node
<Optional lengthier description (context on patch)>
patch by <Authors>; reviewed by <Reviewers> for CASSANDRA-#####
Co-authored-by: Name1 <email1>
Co-authored-by: Name2 <email2>
```
```bash
Buildfile: /workspaces/cassandra/build.xml
[echo] Non default JDK version used: 17
init:
_resolver_download:
resolver-init:
[resolver:resolve] Resolving artifacts
[resolver:resolve] Resolving artifacts
[resolver:resolve] Resolving artifacts
[resolver:resolve] Resolving artifacts
[resolver:resolve] Resolving artifacts
write-poms:
resolver-retrieve-build:
[resolver:resolve] Resolving artifacts
[resolver:resolve] Resolving artifacts
[unzip] Expanding:
/home/codespace/.m2/repository/org/jacoco/org.jacoco.agent/0.8.8/org.jacoco.agent-0.8.8.jar
into /workspaces/cassandra/build/lib/jars
check-gen-cql3-grammar:
gen-cql3-grammar:
generate-cql-html:
generate-jflex-java:
build-project:
[echo] apache-cassandra: /workspaces/cassandra/build.xml
[echo] Non default JDK version used: 17
_build_java:
[echo] Compiling for Java 17...
[javac] Compiling 2142 source files to
/workspaces/cassandra/build/classes/main
[javac] Note: Processing compiler hints annotations
[javac] Note: Processing compiler hints annotations
[javac] Note: Writing compiler command file at META-INF/hotspot_compiler
[javac] Note: Done processing compiler hints annotations
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/ParameterizedClass.java:81:
warning: [unchecked] unchecked cast
[javac] K instance = (K)
constructor.newInstance(parameterizedClass.parameters);
[javac] ^
[javac] required: K
[javac] found: CAP#1
[javac] where K is a type-variable:
[javac] K extends Object declared in method
<K>newInstance(ParameterizedClass,List<String>)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ?
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/ParameterizedClass.java:92:
warning: [unchecked] unchecked cast
[javac] K instance = (K) constructor.newInstance();
[javac] ^
[javac] required: K
[javac] found: CAP#1
[javac] where K is a type-variable:
[javac] K extends Object declared in method
<K>newInstance(ParameterizedClass,List<String>)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ?
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/MergeIterator.java:363:
warning: [unchecked] unchecked cast
[javac] this.lowerBound = iter instanceof
IteratorWithLowerBound ? ((IteratorWithLowerBound<In>)iter).lowerBound() : null;
[javac]
^
[javac] required: IteratorWithLowerBound<In>
[javac] found: Iterator<CAP#1>
[javac] where In is a type-variable:
[javac] In extends Object declared in class Candidate
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends In from capture of ? extends In
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/pager/AbstractQueryPager.java:76:
warning: [unchecked] unchecked method invocation: method apply in class
Transformation is applied to given types
[javac] return
Transformation.apply(readQuery.execute(consistency, clientState, requestTime),
pager);
[javac] ^
[javac] required: PartitionIterator,Transformation<? super RowIterator>
[javac] found: PartitionIterator,AbstractQueryPager.Pager
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/pager/AbstractQueryPager.java:76:
warning: [unchecked] unchecked conversion
[javac] return
Transformation.apply(readQuery.execute(consistency, clientState, requestTime),
pager);
[javac]
^
[javac] required: Transformation<? super RowIterator>
[javac] found: AbstractQueryPager.Pager
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/Terms.java:113:
warning: [unchecked] unchecked conversion
[javac] return UNSET_LIST;
[javac] ^
[javac] required: List<ByteBuffer>
[javac] found: List
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/Terms.java:127:
warning: [unchecked] unchecked conversion
[javac] return UNSET_LIST;
[javac] ^
[javac] required: List<Terminal>
[javac] found: List
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/Operation.java:389:
warning: [unchecked] unchecked method invocation: method getInstance in class
SetType is applied to given types
[javac]
SetType.getInstance(((MapType)receiver.type).getKeysType(), false));
[javac]
^
[javac] required: AbstractType<T>,boolean
[javac] found: AbstractType,boolean
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/Operation.java:389:
warning: [unchecked] unchecked conversion
[javac]
SetType.getInstance(((MapType)receiver.type).getKeysType(), false));
[javac]
^
[javac] required: AbstractType<T>
[javac] found: AbstractType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/ListType.java:63:
warning: [unchecked] unchecked conversion
[javac] ListType<T> t = internMap.get(elements);
[javac] ^
[javac] required: ListType<T>
[javac] found: ListType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/ListType.java:65:
warning: [unchecked] unchecked conversion
[javac] ? internMap.computeIfAbsent(elements, k -> new
ListType<>(k, isMultiCell))
[javac] ^
[javac] required: ListType<T>
[javac] found: ListType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/memory/BufferPool.java:1326:
warning: [unchecked] unchecked cast
[javac] return ((DirectBufferRef<Chunk>)
attachment).get();
[javac] ^
[javac] required: DirectBufferRef<Chunk>
[javac] found: Object
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/memory/BufferPool.java:1346:
warning: [unchecked] unchecked cast
[javac] ((DirectBufferRef<Chunk>) attachment).release();
[javac] ^
[javac] required: DirectBufferRef<Chunk>
[javac] found: Object
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/AsyncFuture.java:154:
warning: [unchecked] unchecked conversion
[javac] return AsyncAwaitable.await(waitingUpdater,
Future::isDone, this);
[javac] ^
[javac] required: AsyncFuture<V>
[javac] found: AsyncFuture
[javac] where V is a type-variable:
[javac] V extends Object declared in class AsyncFuture
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java:167:
warning: [unchecked] unchecked cast
[javac] return reverse((T) this);
[javac] ^
[javac] required: T
[javac] found: IntrusiveStack<T>
[javac] where T is a type-variable:
[javac] T extends IntrusiveStack<T> declared in class IntrusiveStack
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java:188:
warning: [unchecked] unchecked cast
[javac] forEach((T)this, forEach);
[javac] ^
[javac] required: T
[javac] found: IntrusiveStack<T>
[javac] where T is a type-variable:
[javac] T extends IntrusiveStack<T> declared in class IntrusiveStack
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java:203:
warning: [unchecked] unchecked cast
[javac] return new Itr<>((T) this);
[javac] ^
[javac] required: T
[javac] found: IntrusiveStack<T>
[javac] where T is a type-variable:
[javac] T extends IntrusiveStack<T> declared in class IntrusiveStack
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:52:
warning: [unchecked] unchecked assignment to variable next as member of raw
type IntrusiveStack
[javac] result.next = next;
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:53:
warning: [unchecked] unchecked assignment to variable next as member of raw
type IntrusiveStack
[javac] next.next = prev == NOTIFYING ? null : prev;
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:56:
warning: [unchecked] unchecked assignment to variable next as member of raw
type IntrusiveStack
[javac] next.next = prev;
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:69:
warning: [unchecked] unchecked method invocation: method push in class
IntrusiveStack is applied to given types
[javac] IntrusiveStack.push(updater, in, newListener,
ListenerList::pushHead);
[javac] ^
[javac] required:
AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>
[javac] found:
AtomicReferenceFieldUpdater<CAP#1,ListenerList>,T#2,ListenerList,BiFunction<ListenerList,ListenerList,ListenerList>
[javac] where O,T#1,T#2 are type-variables:
[javac] O extends Object declared in method
<O,T#1>push(AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>)
[javac] T#1 extends IntrusiveStack<T#1> declared in method
<O,T#1>push(AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>)
[javac] T#2 extends Object declared in method
<T#2>push(AtomicReferenceFieldUpdater<? super
T#2,ListenerList>,T#2,ListenerList)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object super: T#2 from capture of ? super T#2
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:81:
warning: [unchecked] unchecked method invocation: method pushExclusive in
class IntrusiveStack is applied to given types
[javac] IntrusiveStack.pushExclusive(updater, in, newListener,
ListenerList::pushHead);
[javac] ^
[javac] required:
AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>
[javac] found:
AtomicReferenceFieldUpdater<CAP#1,ListenerList>,T#2,ListenerList,BiFunction<ListenerList,ListenerList,ListenerList>
[javac] where O,T#1,T#2 are type-variables:
[javac] O extends Object declared in method
<O,T#1>pushExclusive(AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>)
[javac] T#1 extends IntrusiveStack<T#1> declared in method
<O,T#1>pushExclusive(AtomicReferenceFieldUpdater<O,T#1>,O,T#1,BiFunction<T#1,T#1,T#1>)
[javac] T#2 extends Object declared in method
<T#2>pushExclusive(AtomicReferenceFieldUpdater<? super
T#2,ListenerList>,T#2,ListenerList)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object super: T#2 from capture of ? super T#2
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:88:
warning: [unchecked] unchecked conversion
[javac] ListenerList<V> listeners = updater.get(in);
[javac] ^
[javac] required: ListenerList<V>
[javac] found: ListenerList
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V,T>notify(AtomicReferenceFieldUpdater<? super T,ListenerList>,T)
[javac] T extends Future<V> declared in method
<V,T>notify(AtomicReferenceFieldUpdater<? super T,ListenerList>,T)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:100:
warning: [unchecked] unchecked conversion
[javac] listeners = updater.getAndSet(in, NOTIFYING);
[javac] ^
[javac] required: ListenerList<V>
[javac] found: ListenerList
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V,T>notify(AtomicReferenceFieldUpdater<? super T,ListenerList>,T)
[javac] T extends Future<V> declared in method
<V,T>notify(AtomicReferenceFieldUpdater<? super T,ListenerList>,T)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:190:
warning: [unchecked] unchecked method invocation: method notifyListener in
class ListenerList is applied to given types
[javac] notifyListener(notifyExecutor, listener, future);
[javac] ^
[javac] required: Executor,GenericFutureListener<F>,F
[javac] found:
Executor,GenericFutureListener,org.apache.cassandra.utils.concurrent.Future<V>
[javac] where F,V are type-variables:
[javac] F extends io.netty.util.concurrent.Future<?> declared in
method <F>notifyListener(Executor,GenericFutureListener<F>,F)
[javac] V extends Object declared in class GenericFutureListenerList
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/ListenerList.java:190:
warning: [unchecked] unchecked conversion
[javac] notifyListener(notifyExecutor, listener, future);
[javac] ^
[javac] required: GenericFutureListener<F>
[javac] found: GenericFutureListener
[javac] where F is a type-variable:
[javac] F extends Future<?> declared in method
<F>notifyListener(Executor,GenericFutureListener<F>,F)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/WeightedQueue.java:266:
warning: [unchecked] unchecked method invocation: constructor <init> in class
WeightedQueue is applied to given types
[javac] this(maxWeight, newBlockingQueue(), NATURAL_WEIGHER);
[javac] ^
[javac] required: int,BlockingQueue<T>,Weigher<T>
[javac] found: int,BlockingQueue<T>,Weigher
[javac] where T is a type-variable:
[javac] T extends Object declared in class WeightedQueue
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/WeightedQueue.java:266:
warning: [unchecked] unchecked conversion
[javac] this(maxWeight, newBlockingQueue(), NATURAL_WEIGHER);
[javac] ^
[javac] required: Weigher<T>
[javac] found: Weigher
[javac] where T is a type-variable:
[javac] T extends Object declared in class WeightedQueue
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/auth/jmx/AuthenticationProxy.java:102:
warning: [removal] AccessController in java.security has been deprecated and
marked for removal
[javac]
AccessController.doPrivileged((PrivilegedAction<Void>) () -> {
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/auth/jmx/AuthorizationProxy.java:157:
warning: [removal] AccessControlContext in java.security has been deprecated
and marked for removal
[javac] AccessControlContext acc = AccessController.getContext();
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/auth/jmx/AuthorizationProxy.java:157:
warning: [removal] AccessController in java.security has been deprecated and
marked for removal
[javac] AccessControlContext acc = AccessController.getContext();
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/auth/jmx/AuthorizationProxy.java:158:
warning: [removal] getSubject(AccessControlContext) in Subject has been
deprecated and marked for removal
[javac] Subject subject = Subject.getSubject(acc);
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/Converters.java:139:
warning: [unchecked] unchecked cast
[javac] this.convert = (Function<Object, Object>) convert;
[javac] ^
[javac] required: Function<Object,Object>
[javac] found: Function<Old,New>
[javac] where Old,New are type-variables:
[javac] Old extends Object declared in constructor
<Old,New>Converters(Class<Old>,Class<New>,Function<Old,New>,Function<New,Old>)
[javac] New extends Object declared in constructor
<Old,New>Converters(Class<Old>,Class<New>,Function<Old,New>,Function<New,Old>)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/Converters.java:140:
warning: [unchecked] unchecked cast
[javac] this.reverseConvert = (Function<Object, Object>)
reverseConvert;
[javac] ^
[javac] required: Function<Object,Object>
[javac] found: Function<New,Old>
[javac] where New,Old are type-variables:
[javac] New extends Object declared in constructor
<Old,New>Converters(Class<Old>,Class<New>,Function<Old,New>,Function<New,Old>)
[javac] Old extends Object declared in constructor
<Old,New>Converters(Class<Old>,Class<New>,Function<Old,New>,Function<New,Old>)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/YamlConfigurationLoader.java:242:
warning: [unchecked] unchecked cast
[javac] Class<T> klass = (Class<T>) obj.getClass();
[javac] ^
[javac] required: Class<T>
[javac] found: Class<CAP#1>
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>updateFromMap(Map<String,?>,boolean,T)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ? extends Object
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/config/YamlConfigurationLoader.java:267:
warning: [unchecked] unchecked cast
[javac] T value = (T) constructor.getSingleData(klass);
[javac] ^
[javac] required: T
[javac] found: Object
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>updateFromMap(Map<String,?>,boolean,T)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/statements/ListRolesStatement.java:130:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw
type AbstractType
[javac]
result.addColumnValue(optionsType.decompose(roleManager.getCustomOptions(role)));
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/statements/PropertyDefinitions.java:102:
warning: [unchecked] unchecked cast
[javac] return (Map<String, String>)val;
[javac] ^
[javac] required: Map<String,String>
[javac] found: Object
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/Json.java:273:
warning: [unchecked] unchecked conversion
[javac] Map<String, Object> valueMap =
JsonUtils.JSON_OBJECT_MAPPER.readValue(jsonString, Map.class);
[javac]
^
[javac] required: Map<String,Object>
[javac] found: Map
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/cql3/statements/DescribeStatement.java:735:
warning: [unchecked] unchecked cast
[javac]
builder.add(rangeOwnershipType.decompose((Map<String, List<String>>)
elements.get(RANGE_OWNERSHIPS_INDEX)));
[javac]
^
[javac] required: Map<String,List<String>>
[javac] found: Object
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/MapType.java:71:
warning: [unchecked] unchecked conversion
[javac] MapType<K, V> t = internMap.get(p);
[javac] ^
[javac] required: MapType<K,V>
[javac] found: MapType
[javac] where K,V are type-variables:
[javac] K extends Object declared in method
<K,V>getInstance(AbstractType<K>,AbstractType<V>,boolean)
[javac] V extends Object declared in method
<K,V>getInstance(AbstractType<K>,AbstractType<V>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/MapType.java:73:
warning: [unchecked] unchecked conversion
[javac] ? internMap.computeIfAbsent(p, k -> new
MapType<>(k.left, k.right, isMultiCell))
[javac] ^
[javac] required: MapType<K,V>
[javac] found: MapType
[javac] where K,V are type-variables:
[javac] K extends Object declared in method
<K,V>getInstance(AbstractType<K>,AbstractType<V>,boolean)
[javac] V extends Object declared in method
<K,V>getInstance(AbstractType<K>,AbstractType<V>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/reads/DigestResolver.java:90:
warning: [unchecked] unchecked method invocation: constructor <init> in class
DataResolver is applied to given types
[javac] = new DataResolver<>(command, replicaPlan,
NoopReadRepair.instance, requestTime);
[javac] ^
[javac] required: ReadCommand,Supplier<? extends
P#1>,ReadRepair<E#1,P#1>,RequestTime
[javac] found:
ReadCommand,Supplier<CAP#1>,NoopReadRepair,RequestTime
[javac] where P#1,E#1,P#2,E#2 are type-variables:
[javac] P#1 extends ForRead<E#1,P#1> declared in class DataResolver
[javac] E#1 extends Endpoints<E#1> declared in class DataResolver
[javac] P#2 extends ForRead<E#2,P#2> declared in class DigestResolver
[javac] E#2 extends Endpoints<E#2> declared in class DigestResolver
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends P#2 from capture of ? extends P#2
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/reads/DigestResolver.java:90:
warning: [unchecked] unchecked conversion
[javac] = new DataResolver<>(command, replicaPlan,
NoopReadRepair.instance, requestTime);
[javac]
^
[javac] required: ReadRepair<E,P>
[javac] found: NoopReadRepair
[javac] where E,P are type-variables:
[javac] E extends Endpoints<E> declared in class DataResolver
[javac] P extends ForRead<E,P> declared in class DataResolver
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/reads/DigestResolver.java:90:
warning: [unchecked] unchecked conversion
[javac] = new DataResolver<>(command, replicaPlan,
NoopReadRepair.instance, requestTime);
[javac] ^
[javac] required: DataResolver<E,P>
[javac] found: DataResolver
[javac] where E,P are type-variables:
[javac] E extends Endpoints<E> declared in class DigestResolver
[javac] P extends ForRead<E,P> declared in class DigestResolver
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/Accumulator.java:123:
warning: [unchecked] unchecked cast
[javac] return (E) values[p++];
[javac] ^
[javac] required: E
[javac] found: Object
[javac] where E is a type-variable:
[javac] E extends Object declared in class Accumulator
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/concurrent/Accumulator.java:138:
warning: [unchecked] unchecked cast
[javac] return (E) values[i];
[javac] ^
[javac] required: E
[javac] found: Object
[javac] where E is a type-variable:
[javac] E extends Object declared in class Accumulator
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/SetType.java:59:
warning: [unchecked] unchecked conversion
[javac] SetType<T> t = internMap.get(elements);
[javac] ^
[javac] required: SetType<T>
[javac] found: SetType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/SetType.java:61:
warning: [unchecked] unchecked conversion
[javac] ? internMap.computeIfAbsent(elements, k -> new
SetType<>(k, isMultiCell))
[javac] ^
[javac] required: SetType<T>
[javac] found: SetType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>,boolean)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/VectorType.java:165:
warning: [unchecked] Possible heap pollution from parameterized vararg type T
[javac] public ByteBuffer decompose(T... values)
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in class VectorType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/AbstractReadCommandBuilder.java:135:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw
type AbstractType
[javac] return value instanceof ByteBuffer ? (ByteBuffer)value :
((AbstractType)type).decompose(value);
[javac]
^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/CBuilder.java:142:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw type
AbstractType
[javac] return
add(((AbstractType)type.subtype(size)).decompose(value));
[javac]
^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/MessageParams.java:55:
warning: [unchecked] unchecked cast
[javac] return (T) get().get(key);
[javac] ^
[javac] required: T
[javac] found: Object
[javac] where T is a type-variable:
[javac] T extends Object declared in method <T>get(ParamType)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/security/CipherFactory.java:73:
warning: [unchecked] unchecked cast
[javac] Class<KeyProvider> keyProviderClass =
(Class<KeyProvider>)Class.forName(options.key_provider.class_name);
[javac]
^
[javac] required: Class<KeyProvider>
[javac] found: Class<CAP#1>
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ?
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/rows/BTreeRow.java:764:
warning: [unchecked] unchecked cast
[javac] Arrays.sort(cells, lb, ub, (Comparator<Object>)
column.cellComparator());
[javac]
^
[javac] required: Comparator<Object>
[javac] found: Comparator<CAP#1>
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object super: Cell<?> from capture of ? super
Cell<?>
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/SimpleBuilders.java:91:
warning: [unchecked] unchecked cast
[javac] return (T)this;
[javac] ^
[javac] required: T
[javac] found: AbstractBuilder<T>
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractBuilder
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/SimpleBuilders.java:97:
warning: [unchecked] unchecked cast
[javac] return (T)this;
[javac] ^
[javac] required: T
[javac] found: AbstractBuilder<T>
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractBuilder
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/SimpleBuilders.java:103:
warning: [unchecked] unchecked cast
[javac] return (T)this;
[javac] ^
[javac] required: T
[javac] found: AbstractBuilder<T>
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractBuilder
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/SimpleBuilders.java:481:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw type
AbstractType
[javac] return ((AbstractType)type).decompose(value);
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/compaction/AbstractStrategyHolder.java:93:
warning: [unchecked] unchecked conversion
[javac] groups = new Set[holder.numTokenPartitions];
[javac] ^
[javac] required: Set<SSTableReader>[]
[javac] found: Set[]
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/AsymmetricOrdering.java:130:
warning: [unchecked] reverse() in AsymmetricOrdering.Reversed overrides
<S>reverse() in Ordering
[javac] public AsymmetricOrdering<T1, T2> reverse()
[javac] ^
[javac] return type requires unchecked conversion from
AsymmetricOrdering<T1,T2> to Ordering<S>
[javac] where T1,T2,S,T are type-variables:
[javac] T1 extends Object declared in class AsymmetricOrdering
[javac] T2 extends Object declared in class AsymmetricOrdering
[javac] S extends T declared in method <S>reverse()
[javac] T extends Object declared in class Ordering
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/AsymmetricOrdering.java:136:
warning: [unchecked] reverse() in AsymmetricOrdering overrides <S>reverse() in
Ordering
[javac] public AsymmetricOrdering<T1, T2> reverse()
[javac] ^
[javac] return type requires unchecked conversion from
AsymmetricOrdering<T1,T2> to Ordering<S>
[javac] where T1,T2,S,T are type-variables:
[javac] T1 extends Object declared in class AsymmetricOrdering
[javac] T2 extends Object declared in class AsymmetricOrdering
[javac] S extends T declared in method <S>reverse()
[javac] T extends Object declared in class Ordering
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:42:
warning: [unchecked] unchecked call to Interval(C,C,D) as a member of the raw
type Interval
[javac] return new Interval(min, max, data);
[javac] ^
[javac] where C,D are type-variables:
[javac] C extends Object declared in class Interval
[javac] D extends Object declared in class Interval
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:42:
warning: [unchecked] unchecked conversion
[javac] return new Interval(min, max, data);
[javac] ^
[javac] required: Interval<C,D>
[javac] found: Interval
[javac] where C,D are type-variables:
[javac] C extends Object declared in method <C,D>create(C,C,D)
[javac] D extends Object declared in method <C,D>create(C,C,D)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:73:
warning: [unchecked] unchecked call to compareTo(T) as a member of the raw type
Comparable
[javac] return left.min.compareTo(right);
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in interface Comparable
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:78:
warning: [unchecked] unchecked call to compareTo(T) as a member of the raw type
Comparable
[javac] return i1.min.compareTo(i2.min);
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in interface Comparable
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:87:
warning: [unchecked] unchecked call to compareTo(T) as a member of the raw type
Comparable
[javac] return left.max.compareTo(right);
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in interface Comparable
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:92:
warning: [unchecked] unchecked call to compareTo(T) as a member of the raw type
Comparable
[javac] return i1.max.compareTo(i2.max);
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in interface Comparable
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:100:
warning: [unchecked] unchecked conversion
[javac] return (AsymmetricOrdering) minOrdering;
[javac] ^
[javac] required: AsymmetricOrdering<Interval<C,V>,C>
[javac] found: AsymmetricOrdering
[javac] where C,V are type-variables:
[javac] C extends Comparable<? super C> declared in method
<C,V>minOrdering()
[javac] V extends Object declared in method <C,V>minOrdering()
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/utils/Interval.java:105:
warning: [unchecked] unchecked conversion
[javac] return (AsymmetricOrdering) maxOrdering;
[javac] ^
[javac] required: AsymmetricOrdering<Interval<C,V>,C>
[javac] found: AsymmetricOrdering
[javac] where C,V are type-variables:
[javac] C extends Comparable<? super C> declared in method
<C,V>maxOrdering()
[javac] V extends Object declared in method <C,V>maxOrdering()
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/compaction/LeveledGenerations.java:75:
warning: [unchecked] unchecked conversion
[javac] private final TreeSet<SSTableReader> [] levels = new
TreeSet[MAX_LEVEL_COUNT - 1];
[javac] ^
[javac] required: TreeSet<SSTableReader>[]
[javac] found: TreeSet[]
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/compaction/LeveledGenerations.java:302:
warning: [unchecked] unchecked conversion
[javac] Set<SSTableReader> [] levelsCopy = new Set[levelCount()];
[javac] ^
[javac] required: Set<SSTableReader>[]
[javac] found: Set[]
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/diag/DiagnosticEventService.java:183:
warning: [unchecked] unchecked conversion
[javac] subscriber =
((TypedConsumerWrapper)subscriber).wrapped;
[javac] ^
[javac] required: Consumer<DiagnosticEvent>
[javac] found: Consumer
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/diag/DiagnosticEventService.java:205:
warning: [unchecked] unchecked conversion
[javac] subscriber = ((TypedConsumerWrapper)
subscriber).wrapped;
[javac]
^
[javac] required: Consumer<DiagnosticEvent>
[javac] found: Consumer
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/diag/DiagnosticEventService.java:322:
warning: [unchecked] unchecked cast
[javac] wrapped.accept((E)e);
[javac] ^
[javac] required: E
[javac] found: DiagnosticEvent
[javac] where E is a type-variable:
[javac] E extends Object declared in class TypedConsumerWrapper
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/lifecycle/Tracker.java:299:
warning: [unchecked] unchecked generic array creation for varargs parameter of
type Set<SSTableReader>[]
[javac] Set<SSTableReader> toremove =
copyOf(filter(view.sstables, and(remove, notIn(view.compacting))));
[javac]
^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/CompositeType.java:320:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw
type AbstractType
[javac] ByteBuffer buffer = ((AbstractType)
types.get(i)).decompose(objects[i]);
[javac]
^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/CompositeType.java:405:
warning: [unchecked] unchecked call to isCompatibleWith(AbstractType<?>) as a
member of the raw type AbstractType
[javac] if (!tnew.isCompatibleWith(tprev))
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/CompositeType.java:429:
warning: [unchecked] unchecked call to isValueCompatibleWith(AbstractType<?>)
as a member of the raw type AbstractType
[javac] if (!tnew.isValueCompatibleWith(tprev))
[javac] ^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/DynamicCompositeType.java:394:
warning: [unchecked] unchecked call to decompose(T) as a member of the raw
type AbstractType
[javac] values.add(type.decompose(e.getValue()));
[javac] ^
[javac] where T is a type-variable:
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/ReversedType.java:47:
warning: [unchecked] unchecked cast
[javac] return getInstance((AbstractType<T>) types.get(0));
[javac] ^
[javac] required: AbstractType<T>
[javac] found: AbstractType<CAP#1>
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(TypeParser)
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ?
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/ReversedType.java:52:
warning: [unchecked] unchecked conversion
[javac] ReversedType<T> t = instances.get(baseType);
[javac] ^
[javac] required: ReversedType<T>
[javac] found: ReversedType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/marshal/ReversedType.java:54:
warning: [unchecked] unchecked conversion
[javac] ? instances.computeIfAbsent(baseType,
ReversedType::new)
[javac] ^
[javac] required: ReversedType<T>
[javac] found: ReversedType
[javac] where T is a type-variable:
[javac] T extends Object declared in method
<T>getInstance(AbstractType<T>)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/memtable/ShardedSkipListMemtable.java:229:
warning: [unchecked] unchecked conversion
[javac] Iterator<AtomicBTreePartition>[] iters = new
Iterator[rightShard - leftShard + 1];
[javac] ^
[javac] required: Iterator<AtomicBTreePartition>[]
[javac] found: Iterator[]
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/tries/InMemoryTrie.java:90:
warning: [unchecked] unchecked method invocation: constructor <init> in class
InMemoryReadTrie is applied to given types
[javac] super(new UnsafeBuffer[31 - BUF_START_SHIFT], // last
one is 1G for a total of ~2G bytes
[javac] ^
[javac] required: UnsafeBuffer[],AtomicReferenceArray<T>[],int
[javac] found: UnsafeBuffer[],AtomicReferenceArray[],int
[javac] where T is a type-variable:
[javac] T extends Object declared in class InMemoryReadTrie
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/tries/InMemoryTrie.java:91:
warning: [unchecked] unchecked conversion
[javac] new AtomicReferenceArray[29 -
CONTENTS_START_SHIFT], // takes at least 4 bytes to write pointer to one
content -> 4 times smaller than buffers
[javac] ^
[javac] required: AtomicReferenceArray<T>[]
[javac] found: AtomicReferenceArray[]
[javac] where T is a type-variable:
[javac] T extends Object declared in class InMemoryReadTrie
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/FailureRecordingCallback.java:116:
warning: [unchecked] unchecked cast
[javac] (Iterator<?>)
FailureResponses.iterator(head);
[javac] ^
[javac] required:
Iterator<Entry<InetAddressAndPort,RequestFailureReason>>
[javac] found: Iterator<CAP#1>
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object from capture of ?
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/Paxos.java:1050:
warning: [unchecked] unchecked call to DataResolver(ReadCommand,Supplier<?
extends P>,ReadRepair<E,P>,RequestTime) as a member of the raw type DataResolver
[javac] DataResolver<?, ?> resolver = new
DataResolver(query, success.participants, NoopReadRepair.instance, new
Dispatcher.RequestTime(query.creationTimeNanos()));
[javac] ^
[javac] where P,E are type-variables:
[javac] P extends ForRead<E,P> declared in class DataResolver
[javac] E extends Endpoints<E> declared in class DataResolver
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosKeyState.java:142:
warning: [unchecked] Possible heap pollution from parameterized vararg type
CloseableIterator<PaxosKeyState>
[javac] public static CloseableIterator<PaxosKeyState>
mergeUncommitted(CloseableIterator<PaxosKeyState>... iterators)
[javac]
^
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java:272:
warning: [unchecked] unchecked method invocation: method compose in class
AbstractType is applied to given types
[javac] String tableName =
UTF8Type.instance.compose(clustering.get(0), clustering.accessor());
[javac]
^
[javac] required: V,ValueAccessor<V>
[javac] found: Object,ValueAccessor
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V>compose(V,ValueAccessor<V>)
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java:272:
warning: [unchecked] unchecked conversion
[javac] String tableName =
UTF8Type.instance.compose(clustering.get(0), clustering.accessor());
[javac]
^
[javac] required: ValueAccessor<V>
[javac] found: ValueAccessor
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V>compose(V,ValueAccessor<V>)
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java:277:
warning: [unchecked] unchecked method invocation: method compose in class
AbstractType is applied to given types
[javac] List<ByteBuffer> points =
listType.compose(pointsCell.value(), pointsCell.accessor());
[javac]
^
[javac] required: V,ValueAccessor<V>
[javac] found: Object,ValueAccessor
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V>compose(V,ValueAccessor<V>)
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java:277:
warning: [unchecked] unchecked conversion
[javac] List<ByteBuffer> points =
listType.compose(pointsCell.value(), pointsCell.accessor());
[javac]
^
[javac] required: ValueAccessor<V>
[javac] found: ValueAccessor
[javac] where V,T are type-variables:
[javac] V extends Object declared in method
<V>compose(V,ValueAccessor<V>)
[javac] T extends Object declared in class AbstractType
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/service/paxos/uncommitted/PaxosStateTracker.java:277:
warning: [unchecked] unchecked conversion
[javac] List<ByteBuffer> points =
listType.compose(pointsCell.value(), pointsCell.accessor());
[javac]
^
[javac] required: List<ByteBuffer>
[javac] found: List
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/tries/CollectionMergeTrie.java:141:
warning: [unchecked] unchecked conversion
[javac] heap = new Cursor[count - 1];
[javac] ^
[javac] required: Cursor<T>[]
[javac] found: Cursor[]
[javac] where T is a type-variable:
[javac] T extends Object declared in class CollectionMergeCursor
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/db/view/TableViews.java:59:
warning: [unchecked] unchecked conversion
[javac] private final List<View> views = new CopyOnWriteArrayList();
[javac] ^
[javac] required: List<View>
[javac] found: CopyOnWriteArrayList
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/net/OutboundConnectionInitiator.java:522:
error: Result<SuccessType> cannot be safely cast to SuccessType
[javac] if (this instanceof SuccessType t)
[javac] ^
[javac] where SuccessType is a type-variable:
[javac] SuccessType extends Success declared in class Result
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/net/OutboundConnectionInitiator.java:532:
warning: [unchecked] unchecked conversion
[javac] static <SuccessType extends Success> Result<SuccessType>
incompatible(int closestSupportedVersion, int maxMessagingVersion) { return new
Incompatible(closestSupportedVersion, maxMessagingVersion); }
[javac]
^
[javac] required: Result<SuccessType>
[javac] found: Incompatible
[javac] where SuccessType is a type-variable:
[javac] SuccessType extends Success declared in method
<SuccessType>incompatible(int,int)
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/net/OutboundConnection.java:1234:
warning: [unchecked] unchecked cast
[javac]
onCompletedHandshake((Result<MessagingSuccess>) future.getNow());
[javac]
^
[javac] required: Result<MessagingSuccess>
[javac] found: CAP#1
[javac] where CAP#1 is a fresh type-variable:
[javac] CAP#1 extends Object super: Result<MessagingSuccess> from
capture of ? super Result<MessagingSuccess>
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/repair/RepairCoordinator.java:526:
warning: [unchecked] unchecked conversion
[javac] HashSet<UUID>[] seen = new HashSet[]{ new
HashSet<>(), new HashSet<>() };
[javac] ^
[javac] required: HashSet<UUID>[]
[javac] found: HashSet[]
[javac]
/workspaces/cassandra/src/java/org/apache/cassandra/index/SecondaryIndexManager.java:1782:
warning: [unchecked] unchecked method invocation: method addCallback in
interface Future is applied to given types
[javac] if (callback != null) f.addCallback(callback);
[javac] ^
[javac] required: FutureCallback<? super V>
[javac] found: FutureCallback
[javac] where V is a type-variable:
[javac] V extends Object declared in interface Future
[javac] Note: Some input files use or override a deprecated API.
[javac] Note: Recompile with -Xlint:deprecation for details.
[javac] Note: Some input files additionally use or override a deprecated
API that is marked for removal.
[javac] Note: Some input files additionally use unchecked or unsafe
operations.
[javac] 1 error
[javac] 100 warnings
BUILD FAILED
/workspaces/cassandra/build.xml:545: The following error occurred while
executing this line:
/workspaces/cassandra/build.xml:529: Compile failed; see the compiler error
output for details.
Total time: 23 seconds
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
