NShiftKey

• NullSafe Field Not Nullable

  • Description : Detected if a field is not annotated with @nullable and is set to Null or is checked
    • Target Code : accumulo/core/src/main/java/org/apache/accumulo/core/crypto/CryptoEnvironmentImpl.java [view change history] [ignore this]
      

      accumulo/core/src/main/java/org/apache/accumulo/core/crypto/CryptoEnvironmentImpl.java

      Lines 43 to 45 in 3c1c253

      	this.scope = Objects.requireNonNull(scope);
      	this.tableId = tableId;
      	this.decryptionParams = decryptionParams;

      
        
    • Target Code : accumulo/core/src/main/java/org/apache/accumulo/core/crypto/CryptoEnvironmentImpl.java [view change history] [ignore this]
      

      accumulo/core/src/main/java/org/apache/accumulo/core/crypto/CryptoEnvironmentImpl.java

      Lines 44 to 46 in 3c1c253

      	this.tableId = tableId;
      	this.decryptionParams = decryptionParams;
      	}

      
        

• Thread Safety Violation

  • Description : Data trace can occur if the same member field is accessed at the same time
    • Target Code : accumulo/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchReaderIterator.java [view change history] [ignore this]
      

      accumulo/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchReaderIterator.java

      Lines 455 to 457 in 3c1c253

      	} catch (AccumuloSecurityException e) {
      	e.setTableInfo(getTableInfo());
      	log.debug("AccumuloSecurityException thrown", e);

      
        
    • Target Code : accumulo/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchReaderIterator.java [view change history] [ignore this]
      

      accumulo/core/src/main/java/org/apache/accumulo/core/clientImpl/TabletServerBatchReaderIterator.java

      Lines 490 to 492 in 3c1c253

      	} catch (AccumuloSecurityException e) {
      	e.setTableInfo(getTableInfo());
      	log.debug("{}", e.getMessage(), e);

      
        
    • Target Code : accumulo/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java [view change history] [ignore this]
      

      accumulo/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java

      Lines 710 to 712 in 3c1c253

      	} catch (Exception t) {
      	TraceUtil.setException(span, t, false);
      	log.error("Error balancing tablets, will wait for {} (seconds) and then retry ",

      
        
    • Target Code : accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/AssignmentHandler.java [view change history] [ignore this]
      

      accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/AssignmentHandler.java

      Lines 183 to 185 in 3c1c253

      	new Assignment(extent, server.getTabletSession(), tabletMetadata.getLast());
      	TabletStateStore.setLocation(server.getContext(), assignment);

      
        
    • Target Code : accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java [view change history] [ignore this]
      

      accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java

      Lines 65 to 67 in 3c1c253

      	} catch (Exception e) {
      	TraceUtil.setException(span2, e, true);
      	throw e;

      
        
    • Target Code : accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java [view change history] [ignore this]
      

      accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java

      Lines 106 to 108 in 3c1c253

      	} catch (Exception e) {
      	TraceUtil.setException(span3, e, true);
      	throw e;

      
        
    • Target Code : accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java [view change history] [ignore this]
      

      accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java

      Lines 116 to 118 in 3c1c253

      	} catch (Exception e) {
      	TraceUtil.setException(span4, e, true);
      	throw e;

      
        
    • Target Code : accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java [view change history] [ignore this]
      

      accumulo/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/MinorCompactionTask.java

      Lines 126 to 128 in 3c1c253

      	} catch (Exception e) {
      	TraceUtil.setException(span, e, true);
      	throw e;

      
        
    • Target Code : accumulo/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java [view change history] [ignore this]
      

      accumulo/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java

      Lines 1209 to 1211 in 3c1c253

      	for (ByteSequence row : changes) {
      	scanner.setRange(new Range(row.toString()));
      	Stats stats = new Stats(scanner.iterator());

      
        
    • Target Code : accumulo/test/src/main/java/org/apache/accumulo/test/functional/ConcurrencyIT.java [view change history] [ignore this]
      

      accumulo/test/src/main/java/org/apache/accumulo/test/functional/ConcurrencyIT.java

      Lines 61 to 63 in 3c1c253

      	IteratorSetting slow = new IteratorSetting(30, "slow", SlowIterator.class);
      	SlowIterator.setSleepTime(slow, time);
      	scanner.addScanIterator(slow);

      
        
    • Target Code : accumulo/test/src/main/java/org/apache/accumulo/test/util/SlowOps.java [view change history] [ignore this]
      

      accumulo/test/src/main/java/org/apache/accumulo/test/util/SlowOps.java

      Lines 157 to 159 in 3c1c253

      	IteratorSetting slow = new IteratorSetting(30, "slow", SlowIterator.class);
      	SlowIterator.setSleepTime(slow, SLOW_SCAN_SLEEP_MS);