You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@accumulo.apache.org by Josh Elser <jo...@gmail.com> on 2014/10/30 01:07:19 UTC

Fwd: New Defects reported by Coverity Scan for Accumulo

Do we want to set up Coverity to send these types of messages to 
dev@a.a.o automatically?

-------- Original Message --------
Subject: New Defects reported by Coverity Scan for Accumulo
Date: Wed, 29 Oct 2014 16:59:37 -0700
From: scan-admin@coverity.com
To: josh.elser@gmail.com


Hi,

Please find the latest report on new defect(s) introduced to Accumulo 
found with Coverity Scan.

4 new defect(s) introduced to Accumulo found with Coverity Scan.
18 defect(s), reported by Coverity Scan earlier, were marked fixed in 
the recent build analyzed by Coverity Scan.

New defect(s) Reported-by: Coverity Scan
Showing 4 of 4 defect(s)


** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java: 
852 in 
org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.getMiniDfs()()

** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)

** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
/server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java: 
109 in 
org.apache.accumulo.server.util.RandomizeVolumes.randomize(org.apache.accumulo.core.client.Connector, 
java.lang.String)()

** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java: 
176 in 
org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String, 
java.util.List, int)()


________________________________________________________________________________________________________
*** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
/minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java: 
852 in 
org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.getMiniDfs()()
846           }
847         }
848         return stats;
849       }
850
851       public MiniDFSCluster getMiniDfs() {
>>>     CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>     Accessing "this.miniDFS" without holding lock "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
852         return this.miniDFS;
853       }

________________________________________________________________________________________________________
*** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
/fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java: 36 
in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
30         this.startWait = startWait;
31         this.maxWait = maxWait;
32         this.waitIncrement = waitIncrement;
33       }
34
35       public Retry create() {
>>>     CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>     The positions of arguments in the constructor for "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering of the parameters:
* "maxWait" is passed to "waitIncrement"
* "waitIncrement" is passed to "maxWait"
36         return new Retry(maxRetries, startWait, maxWait, waitIncrement);
37       }

________________________________________________________________________________________________________
*** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
/server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java: 
109 in 
org.apache.accumulo.server.util.RandomizeVolumes.randomize(org.apache.accumulo.core.client.Connector, 
java.lang.String)()
103             directory = oldLocation.substring(Path.SEPARATOR.length());
104           }
105           Key key = entry.getKey();
106           Mutation m = new Mutation(key.getRow());
107
108           String newLocation = 
vm.choose(ServerConstants.getBaseUris()) + Path.SEPARATOR + 
ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId + Path.SEPARATOR + 
directory;
>>>     CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>     Found reliance on default encoding: String.getBytes().
109           m.put(key.getColumnFamily(), key.getColumnQualifier(), new 
Value(newLocation.getBytes()));
110           if (log.isTraceEnabled()) {
111             log.trace("Replacing " + oldLocation + " with " + 
newLocation);
112           }
113           writer.addMutation(m);
114           try {

________________________________________________________________________________________________________
*** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
/server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java: 
176 in 
org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String, 
java.util.List, int)()
170               sortStop = System.currentTimeMillis();
171             }
172           }
173         }
174
175         private void writeBuffer(String destPath, 
List<Pair<LogFileKey,LogFileValue>> buffer, int part) throws IOException {
>>>     CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>     Dead store to part.
176           Path path = new Path(destPath, 
String.format("part-r-%05d", part++));
177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
178
179           @SuppressWarnings("deprecation")
180           MapFile.Writer output = new MapFile.Writer(ns.getConf(), 
ns, path.toString(), LogFileKey.class, LogFileValue.class);
181           try {


________________________________________________________________________________________________________
To view the defects in Coverity Scan visit, 
http://scan.coverity.com/projects/736?tab=overview

To unsubscribe from the email notification for new defects, 
http://scan5.coverity.com/cgi-bin/unsubscribe.py




Re: New Defects reported by Coverity Scan for Accumulo

Posted by Ted Yu <yu...@gmail.com>.
+1

On Oct 29, 2014, at 5:07 PM, Josh Elser <jo...@gmail.com> wrote:

> Do we want to set up Coverity to send these types of messages to dev@a.a.o automatically?
> 
> -------- Original Message --------
> Subject: New Defects reported by Coverity Scan for Accumulo
> Date: Wed, 29 Oct 2014 16:59:37 -0700
> From: scan-admin@coverity.com
> To: josh.elser@gmail.com
> 
> 
> Hi,
> 
> Please find the latest report on new defect(s) introduced to Accumulo found with Coverity Scan.
> 
> 4 new defect(s) introduced to Accumulo found with Coverity Scan.
> 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the recent build analyzed by Coverity Scan.
> 
> New defect(s) Reported-by: Coverity Scan
> Showing 4 of 4 defect(s)
> 
> 
> ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java: 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.getMiniDfs()()
> 
> ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> 
> ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java: 109 in org.apache.accumulo.server.util.RandomizeVolumes.randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> 
> ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java: 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String, java.util.List, int)()
> 
> 
> ________________________________________________________________________________________________________
> *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java: 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.getMiniDfs()()
> 846           }
> 847         }
> 848         return stats;
> 849       }
> 850
> 851       public MiniDFSCluster getMiniDfs() {
>>>>    CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>>    Accessing "this.miniDFS" without holding lock "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
> 852         return this.miniDFS;
> 853       }
> 
> ________________________________________________________________________________________________________
> *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java: 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
> 30         this.startWait = startWait;
> 31         this.maxWait = maxWait;
> 32         this.waitIncrement = waitIncrement;
> 33       }
> 34
> 35       public Retry create() {
>>>>    CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>>    The positions of arguments in the constructor for "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering of the parameters:
> * "maxWait" is passed to "waitIncrement"
> * "waitIncrement" is passed to "maxWait"
> 36         return new Retry(maxRetries, startWait, maxWait, waitIncrement);
> 37       }
> 
> ________________________________________________________________________________________________________
> *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java: 109 in org.apache.accumulo.server.util.RandomizeVolumes.randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> 103             directory = oldLocation.substring(Path.SEPARATOR.length());
> 104           }
> 105           Key key = entry.getKey();
> 106           Mutation m = new Mutation(key.getRow());
> 107
> 108           String newLocation = vm.choose(ServerConstants.getBaseUris()) + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId + Path.SEPARATOR + directory;
>>>>    CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>>    Found reliance on default encoding: String.getBytes().
> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(), new Value(newLocation.getBytes()));
> 110           if (log.isTraceEnabled()) {
> 111             log.trace("Replacing " + oldLocation + " with " + newLocation);
> 112           }
> 113           writer.addMutation(m);
> 114           try {
> 
> ________________________________________________________________________________________________________
> *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java: 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String, java.util.List, int)()
> 170               sortStop = System.currentTimeMillis();
> 171             }
> 172           }
> 173         }
> 174
> 175         private void writeBuffer(String destPath, List<Pair<LogFileKey,LogFileValue>> buffer, int part) throws IOException {
>>>>    CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>>    Dead store to part.
> 176           Path path = new Path(destPath, String.format("part-r-%05d", part++));
> 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
> 178
> 179           @SuppressWarnings("deprecation")
> 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(), ns, path.toString(), LogFileKey.class, LogFileValue.class);
> 181           try {
> 
> 
> ________________________________________________________________________________________________________
> To view the defects in Coverity Scan visit, http://scan.coverity.com/projects/736?tab=overview
> 
> To unsubscribe from the email notification for new defects, http://scan5.coverity.com/cgi-bin/unsubscribe.py
> 
> 
> 

Re: New Defects reported by Coverity Scan for Accumulo

Posted by Josh Elser <jo...@gmail.com>.
Yeah, I think coverity will actually mark in their UI when it's a 
findbugs item (at least I recall seeing something).

Christopher wrote:
> Are these issues ones that are not already possible to find with FindBugs?
> It seems to me that some of them probably do overlap with FindBugs. I
> wouldn't mind bumping up the sensitivity of FindBugs in the build if we can
> resolve the outstanding issues by doing so, as we go, to prevent new issues
> from being introduced.
>
>
> --
> Christopher L Tubbs II
> http://gravatar.com/ctubbsii
>
> On Wed, Oct 29, 2014 at 8:07 PM, Josh Elser<jo...@gmail.com>  wrote:
>
>> Do we want to set up Coverity to send these types of messages to dev@a.a.o
>> automatically?
>>
>> -------- Original Message --------
>> Subject: New Defects reported by Coverity Scan for Accumulo
>> Date: Wed, 29 Oct 2014 16:59:37 -0700
>> From: scan-admin@coverity.com
>> To: josh.elser@gmail.com
>>
>>
>> Hi,
>>
>> Please find the latest report on new defect(s) introduced to Accumulo
>> found with Coverity Scan.
>>
>> 4 new defect(s) introduced to Accumulo found with Coverity Scan.
>> 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the
>> recent build analyzed by Coverity Scan.
>>
>> New defect(s) Reported-by: Coverity Scan
>> Showing 4 of 4 defect(s)
>>
>>
>> ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
>> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
>> getMiniDfs()()
>>
>> ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>
>> ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
>> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
>> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>>
>> ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
>> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
>> java.util.List, int)()
>>
>>
>> ____________________________________________________________
>> ____________________________________________
>> *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
>> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
>> getMiniDfs()()
>> 846           }
>> 847         }
>> 848         return stats;
>> 849       }
>> 850
>> 851       public MiniDFSCluster getMiniDfs() {
>>
>>>      CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>>>      Accessing "this.miniDFS" without holding lock
>>>>> "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.
>>>>> minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with
>>>>> "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
>>>>>
>>>> 852         return this.miniDFS;
>> 853       }
>>
>> ____________________________________________________________
>> ____________________________________________
>> *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>> /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java:
>> 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
>> 30         this.startWait = startWait;
>> 31         this.maxWait = maxWait;
>> 32         this.waitIncrement = waitIncrement;
>> 33       }
>> 34
>> 35       public Retry create() {
>>
>>>      CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>>>      The positions of arguments in the constructor for
>>>>> "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering
>>>>> of the parameters:
>>>>>
>>>> * "maxWait" is passed to "waitIncrement"
>> * "waitIncrement" is passed to "maxWait"
>> 36         return new Retry(maxRetries, startWait, maxWait, waitIncrement);
>> 37       }
>>
>> ____________________________________________________________
>> ____________________________________________
>> *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
>> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
>> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>> 103             directory = oldLocation.substring(Path.
>> SEPARATOR.length());
>> 104           }
>> 105           Key key = entry.getKey();
>> 106           Mutation m = new Mutation(key.getRow());
>> 107
>> 108           String newLocation = vm.choose(ServerConstants.getBaseUris())
>> + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId +
>> Path.SEPARATOR + directory;
>>
>>>      CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>>>      Found reliance on default encoding: String.getBytes().
>>>>>
>>>> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(), new
>> Value(newLocation.getBytes()));
>> 110           if (log.isTraceEnabled()) {
>> 111             log.trace("Replacing " + oldLocation + " with " +
>> newLocation);
>> 112           }
>> 113           writer.addMutation(m);
>> 114           try {
>>
>> ____________________________________________________________
>> ____________________________________________
>> *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
>> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
>> java.util.List, int)()
>> 170               sortStop = System.currentTimeMillis();
>> 171             }
>> 172           }
>> 173         }
>> 174
>> 175         private void writeBuffer(String destPath, List<Pair<LogFileKey,LogFileValue>>
>> buffer, int part) throws IOException {
>>
>>>      CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>>>      Dead store to part.
>>>>>
>>>> 176           Path path = new Path(destPath,
>> String.format("part-r-%05d", part++));
>> 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
>> 178
>> 179           @SuppressWarnings("deprecation")
>> 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(), ns,
>> path.toString(), LogFileKey.class, LogFileValue.class);
>> 181           try {
>>
>>
>> ____________________________________________________________
>> ____________________________________________
>> To view the defects in Coverity Scan visit, http://scan.coverity.com/
>> projects/736?tab=overview
>>
>> To unsubscribe from the email notification for new defects,
>> http://scan5.coverity.com/cgi-bin/unsubscribe.py
>>
>>
>>
>>
>

Re: New Defects reported by Coverity Scan for Accumulo

Posted by Christopher <ct...@apache.org>.
Are these issues ones that are not already possible to find with FindBugs?
It seems to me that some of them probably do overlap with FindBugs. I
wouldn't mind bumping up the sensitivity of FindBugs in the build if we can
resolve the outstanding issues by doing so, as we go, to prevent new issues
from being introduced.


--
Christopher L Tubbs II
http://gravatar.com/ctubbsii

On Wed, Oct 29, 2014 at 8:07 PM, Josh Elser <jo...@gmail.com> wrote:

> Do we want to set up Coverity to send these types of messages to dev@a.a.o
> automatically?
>
> -------- Original Message --------
> Subject: New Defects reported by Coverity Scan for Accumulo
> Date: Wed, 29 Oct 2014 16:59:37 -0700
> From: scan-admin@coverity.com
> To: josh.elser@gmail.com
>
>
> Hi,
>
> Please find the latest report on new defect(s) introduced to Accumulo
> found with Coverity Scan.
>
> 4 new defect(s) introduced to Accumulo found with Coverity Scan.
> 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the
> recent build analyzed by Coverity Scan.
>
> New defect(s) Reported-by: Coverity Scan
> Showing 4 of 4 defect(s)
>
>
> ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> getMiniDfs()()
>
> ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>
> ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>
> ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> java.util.List, int)()
>
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> getMiniDfs()()
> 846           }
> 847         }
> 848         return stats;
> 849       }
> 850
> 851       public MiniDFSCluster getMiniDfs() {
>
>>     CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>>     Accessing "this.miniDFS" without holding lock
>>>> "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.
>>>> minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with
>>>> "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
>>>>
>>> 852         return this.miniDFS;
> 853       }
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java:
> 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
> 30         this.startWait = startWait;
> 31         this.maxWait = maxWait;
> 32         this.waitIncrement = waitIncrement;
> 33       }
> 34
> 35       public Retry create() {
>
>>     CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>>     The positions of arguments in the constructor for
>>>> "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering
>>>> of the parameters:
>>>>
>>> * "maxWait" is passed to "waitIncrement"
> * "waitIncrement" is passed to "maxWait"
> 36         return new Retry(maxRetries, startWait, maxWait, waitIncrement);
> 37       }
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> 103             directory = oldLocation.substring(Path.
> SEPARATOR.length());
> 104           }
> 105           Key key = entry.getKey();
> 106           Mutation m = new Mutation(key.getRow());
> 107
> 108           String newLocation = vm.choose(ServerConstants.getBaseUris())
> + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId +
> Path.SEPARATOR + directory;
>
>>     CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>>     Found reliance on default encoding: String.getBytes().
>>>>
>>> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(), new
> Value(newLocation.getBytes()));
> 110           if (log.isTraceEnabled()) {
> 111             log.trace("Replacing " + oldLocation + " with " +
> newLocation);
> 112           }
> 113           writer.addMutation(m);
> 114           try {
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> java.util.List, int)()
> 170               sortStop = System.currentTimeMillis();
> 171             }
> 172           }
> 173         }
> 174
> 175         private void writeBuffer(String destPath, List<Pair<LogFileKey,LogFileValue>>
> buffer, int part) throws IOException {
>
>>     CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>>     Dead store to part.
>>>>
>>> 176           Path path = new Path(destPath,
> String.format("part-r-%05d", part++));
> 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
> 178
> 179           @SuppressWarnings("deprecation")
> 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(), ns,
> path.toString(), LogFileKey.class, LogFileValue.class);
> 181           try {
>
>
> ____________________________________________________________
> ____________________________________________
> To view the defects in Coverity Scan visit, http://scan.coverity.com/
> projects/736?tab=overview
>
> To unsubscribe from the email notification for new defects,
> http://scan5.coverity.com/cgi-bin/unsubscribe.py
>
>
>
>

Re: Fwd: New Defects reported by Coverity Scan for Accumulo

Posted by Josh Elser <jo...@gmail.com>.
Thanks, Ted.

Ted Yu wrote:
> notifications@accumulo.apache.org has been added as notification recipient.
>
> On Wed, Oct 29, 2014 at 5:46 PM, Mike Drob<md...@mdrob.com>  wrote:
>
>> I would prefer notifications@ I think
>> On Oct 29, 2014 7:07 PM, "Josh Elser"<jo...@gmail.com>  wrote:
>>
>>> Do we want to set up Coverity to send these types of messages to
>> dev@a.a.o
>>> automatically?
>>>
>>> -------- Original Message --------
>>> Subject: New Defects reported by Coverity Scan for Accumulo
>>> Date: Wed, 29 Oct 2014 16:59:37 -0700
>>> From: scan-admin@coverity.com
>>> To: josh.elser@gmail.com
>>>
>>>
>>> Hi,
>>>
>>> Please find the latest report on new defect(s) introduced to Accumulo
>>> found with Coverity Scan.
>>>
>>> 4 new defect(s) introduced to Accumulo found with Coverity Scan.
>>> 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the
>>> recent build analyzed by Coverity Scan.
>>>
>>> New defect(s) Reported-by: Coverity Scan
>>> Showing 4 of 4 defect(s)
>>>
>>>
>>> ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>
>> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
>>> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
>>> getMiniDfs()()
>>>
>>> ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>
>>> ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>
>> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
>>> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
>>> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>>>
>>> ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>
>> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
>>> 176 in
>> org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
>>> java.util.List, int)()
>>>
>>>
>>> ____________________________________________________________
>>> ____________________________________________
>>> *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>
>> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
>>> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
>>> getMiniDfs()()
>>> 846           }
>>> 847         }
>>> 848         return stats;
>>> 849       }
>>> 850
>>> 851       public MiniDFSCluster getMiniDfs() {
>>>
>>>>      CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>>>>      Accessing "this.miniDFS" without holding lock
>>>>>> "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.
>>>>>> minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with
>>>>>> "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
>>>>>>
>>>>> 852         return this.miniDFS;
>>> 853       }
>>>
>>> ____________________________________________________________
>>> ____________________________________________
>>> *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>> /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java:
>>> 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
>>> 30         this.startWait = startWait;
>>> 31         this.maxWait = maxWait;
>>> 32         this.waitIncrement = waitIncrement;
>>> 33       }
>>> 34
>>> 35       public Retry create() {
>>>
>>>>      CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>>>>      The positions of arguments in the constructor for
>>>>>> "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering
>>>>>> of the parameters:
>>>>>>
>>>>> * "maxWait" is passed to "waitIncrement"
>>> * "waitIncrement" is passed to "maxWait"
>>> 36         return new Retry(maxRetries, startWait, maxWait,
>> waitIncrement);
>>> 37       }
>>>
>>> ____________________________________________________________
>>> ____________________________________________
>>> *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>
>> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
>>> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
>>> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>>> 103             directory = oldLocation.substring(Path.
>>> SEPARATOR.length());
>>> 104           }
>>> 105           Key key = entry.getKey();
>>> 106           Mutation m = new Mutation(key.getRow());
>>> 107
>>> 108           String newLocation =
>> vm.choose(ServerConstants.getBaseUris())
>>> + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId +
>>> Path.SEPARATOR + directory;
>>>
>>>>      CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>>>>      Found reliance on default encoding: String.getBytes().
>>>>>>
>>>>> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(),
>> new
>>> Value(newLocation.getBytes()));
>>> 110           if (log.isTraceEnabled()) {
>>> 111             log.trace("Replacing " + oldLocation + " with " +
>>> newLocation);
>>> 112           }
>>> 113           writer.addMutation(m);
>>> 114           try {
>>>
>>> ____________________________________________________________
>>> ____________________________________________
>>> *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>
>> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
>>> 176 in
>> org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
>>> java.util.List, int)()
>>> 170               sortStop = System.currentTimeMillis();
>>> 171             }
>>> 172           }
>>> 173         }
>>> 174
>>> 175         private void writeBuffer(String destPath,
>> List<Pair<LogFileKey,LogFileValue>>
>>> buffer, int part) throws IOException {
>>>
>>>>      CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>>>>      Dead store to part.
>>>>>>
>>>>> 176           Path path = new Path(destPath,
>>> String.format("part-r-%05d", part++));
>>> 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
>>> 178
>>> 179           @SuppressWarnings("deprecation")
>>> 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(),
>> ns,
>>> path.toString(), LogFileKey.class, LogFileValue.class);
>>> 181           try {
>>>
>>>
>>> ____________________________________________________________
>>> ____________________________________________
>>> To view the defects in Coverity Scan visit, http://scan.coverity.com/
>>> projects/736?tab=overview
>>>
>>> To unsubscribe from the email notification for new defects,
>>> http://scan5.coverity.com/cgi-bin/unsubscribe.py
>>>
>>>
>>>
>>>
>

Re: Fwd: New Defects reported by Coverity Scan for Accumulo

Posted by Ted Yu <yu...@gmail.com>.
notifications@accumulo.apache.org has been added as notification recipient.

On Wed, Oct 29, 2014 at 5:46 PM, Mike Drob <md...@mdrob.com> wrote:

> I would prefer notifications@ I think
> On Oct 29, 2014 7:07 PM, "Josh Elser" <jo...@gmail.com> wrote:
>
> > Do we want to set up Coverity to send these types of messages to
> dev@a.a.o
> > automatically?
> >
> > -------- Original Message --------
> > Subject: New Defects reported by Coverity Scan for Accumulo
> > Date: Wed, 29 Oct 2014 16:59:37 -0700
> > From: scan-admin@coverity.com
> > To: josh.elser@gmail.com
> >
> >
> > Hi,
> >
> > Please find the latest report on new defect(s) introduced to Accumulo
> > found with Coverity Scan.
> >
> > 4 new defect(s) introduced to Accumulo found with Coverity Scan.
> > 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the
> > recent build analyzed by Coverity Scan.
> >
> > New defect(s) Reported-by: Coverity Scan
> > Showing 4 of 4 defect(s)
> >
> >
> > ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> >
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> > 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> > getMiniDfs()()
> >
> > ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> >
> > ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> >
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> > 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> > randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> >
> > ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> >
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> > 176 in
> org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> > java.util.List, int)()
> >
> >
> > ____________________________________________________________
> > ____________________________________________
> > *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> >
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> > 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> > getMiniDfs()()
> > 846           }
> > 847         }
> > 848         return stats;
> > 849       }
> > 850
> > 851       public MiniDFSCluster getMiniDfs() {
> >
> >>     CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> >>>>     Accessing "this.miniDFS" without holding lock
> >>>> "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.
> >>>> minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with
> >>>> "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
> >>>>
> >>> 852         return this.miniDFS;
> > 853       }
> >
> > ____________________________________________________________
> > ____________________________________________
> > *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> > /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java:
> > 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
> > 30         this.startWait = startWait;
> > 31         this.maxWait = maxWait;
> > 32         this.waitIncrement = waitIncrement;
> > 33       }
> > 34
> > 35       public Retry create() {
> >
> >>     CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> >>>>     The positions of arguments in the constructor for
> >>>> "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering
> >>>> of the parameters:
> >>>>
> >>> * "maxWait" is passed to "waitIncrement"
> > * "waitIncrement" is passed to "maxWait"
> > 36         return new Retry(maxRetries, startWait, maxWait,
> waitIncrement);
> > 37       }
> >
> > ____________________________________________________________
> > ____________________________________________
> > *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> >
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> > 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> > randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> > 103             directory = oldLocation.substring(Path.
> > SEPARATOR.length());
> > 104           }
> > 105           Key key = entry.getKey();
> > 106           Mutation m = new Mutation(key.getRow());
> > 107
> > 108           String newLocation =
> vm.choose(ServerConstants.getBaseUris())
> > + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId +
> > Path.SEPARATOR + directory;
> >
> >>     CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> >>>>     Found reliance on default encoding: String.getBytes().
> >>>>
> >>> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(),
> new
> > Value(newLocation.getBytes()));
> > 110           if (log.isTraceEnabled()) {
> > 111             log.trace("Replacing " + oldLocation + " with " +
> > newLocation);
> > 112           }
> > 113           writer.addMutation(m);
> > 114           try {
> >
> > ____________________________________________________________
> > ____________________________________________
> > *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> >
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> > 176 in
> org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> > java.util.List, int)()
> > 170               sortStop = System.currentTimeMillis();
> > 171             }
> > 172           }
> > 173         }
> > 174
> > 175         private void writeBuffer(String destPath,
> List<Pair<LogFileKey,LogFileValue>>
> > buffer, int part) throws IOException {
> >
> >>     CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> >>>>     Dead store to part.
> >>>>
> >>> 176           Path path = new Path(destPath,
> > String.format("part-r-%05d", part++));
> > 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
> > 178
> > 179           @SuppressWarnings("deprecation")
> > 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(),
> ns,
> > path.toString(), LogFileKey.class, LogFileValue.class);
> > 181           try {
> >
> >
> > ____________________________________________________________
> > ____________________________________________
> > To view the defects in Coverity Scan visit, http://scan.coverity.com/
> > projects/736?tab=overview
> >
> > To unsubscribe from the email notification for new defects,
> > http://scan5.coverity.com/cgi-bin/unsubscribe.py
> >
> >
> >
> >
>

Re: Fwd: New Defects reported by Coverity Scan for Accumulo

Posted by Mike Drob <md...@mdrob.com>.
I would prefer notifications@ I think
On Oct 29, 2014 7:07 PM, "Josh Elser" <jo...@gmail.com> wrote:

> Do we want to set up Coverity to send these types of messages to dev@a.a.o
> automatically?
>
> -------- Original Message --------
> Subject: New Defects reported by Coverity Scan for Accumulo
> Date: Wed, 29 Oct 2014 16:59:37 -0700
> From: scan-admin@coverity.com
> To: josh.elser@gmail.com
>
>
> Hi,
>
> Please find the latest report on new defect(s) introduced to Accumulo
> found with Coverity Scan.
>
> 4 new defect(s) introduced to Accumulo found with Coverity Scan.
> 18 defect(s), reported by Coverity Scan earlier, were marked fixed in the
> recent build analyzed by Coverity Scan.
>
> New defect(s) Reported-by: Coverity Scan
> Showing 4 of 4 defect(s)
>
>
> ** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> getMiniDfs()()
>
> ** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>
> ** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
>
> ** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> java.util.List, int)()
>
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
> /minicluster/src/main/java/org/apache/accumulo/minicluster/impl/MiniAccumuloClusterImpl.java:
> 852 in org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl.
> getMiniDfs()()
> 846           }
> 847         }
> 848         return stats;
> 849       }
> 850
> 851       public MiniDFSCluster getMiniDfs() {
>
>>     CID 1250066:  Unguarded read  (GUARDED_BY_VIOLATION)
>>>>     Accessing "this.miniDFS" without holding lock
>>>> "MiniAccumuloClusterImpl.this". Elsewhere, "org.apache.accumulo.
>>>> minicluster.impl.MiniAccumuloClusterImpl.miniDFS" is accessed with
>>>> "MiniAccumuloClusterImpl.this" held 3 out of 4 times.
>>>>
>>> 852         return this.miniDFS;
> 853       }
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
> /fate/src/main/java/org/apache/accumulo/fate/zookeeper/RetryFactory.java:
> 36 in org.apache.accumulo.fate.zookeeper.RetryFactory.create()()
> 30         this.startWait = startWait;
> 31         this.maxWait = maxWait;
> 32         this.waitIncrement = waitIncrement;
> 33       }
> 34
> 35       public Retry create() {
>
>>     CID 1250064:  Arguments in wrong order  (SWAPPED_ARGUMENTS)
>>>>     The positions of arguments in the constructor for
>>>> "org.apache.accumulo.fate.zookeeper.Retry" do not match the ordering
>>>> of the parameters:
>>>>
>>> * "maxWait" is passed to "waitIncrement"
> * "waitIncrement" is passed to "maxWait"
> 36         return new Retry(maxRetries, startWait, maxWait, waitIncrement);
> 37       }
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
> /server/base/src/main/java/org/apache/accumulo/server/util/RandomizeVolumes.java:
> 109 in org.apache.accumulo.server.util.RandomizeVolumes.
> randomize(org.apache.accumulo.core.client.Connector, java.lang.String)()
> 103             directory = oldLocation.substring(Path.
> SEPARATOR.length());
> 104           }
> 105           Key key = entry.getKey();
> 106           Mutation m = new Mutation(key.getRow());
> 107
> 108           String newLocation = vm.choose(ServerConstants.getBaseUris())
> + Path.SEPARATOR + ServerConstants.TABLE_DIR + Path.SEPARATOR + tableId +
> Path.SEPARATOR + directory;
>
>>     CID 1250062:  Dm: Dubious method used  (FB.DM_DEFAULT_ENCODING)
>>>>     Found reliance on default encoding: String.getBytes().
>>>>
>>> 109           m.put(key.getColumnFamily(), key.getColumnQualifier(), new
> Value(newLocation.getBytes()));
> 110           if (log.isTraceEnabled()) {
> 111             log.trace("Replacing " + oldLocation + " with " +
> newLocation);
> 112           }
> 113           writer.addMutation(m);
> 114           try {
>
> ____________________________________________________________
> ____________________________________________
> *** CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
> /server/tserver/src/main/java/org/apache/accumulo/tserver/log/LogSorter.java:
> 176 in org.apache.accumulo.tserver.log.LogSorter$LogProcessor.writeBuffer(java.lang.String,
> java.util.List, int)()
> 170               sortStop = System.currentTimeMillis();
> 171             }
> 172           }
> 173         }
> 174
> 175         private void writeBuffer(String destPath, List<Pair<LogFileKey,LogFileValue>>
> buffer, int part) throws IOException {
>
>>     CID 1250058:  DLS: Dead local store  (FB.DLS_DEAD_LOCAL_STORE)
>>>>     Dead store to part.
>>>>
>>> 176           Path path = new Path(destPath,
> String.format("part-r-%05d", part++));
> 177           FileSystem ns = fs.getVolumeByPath(path).getFileSystem();
> 178
> 179           @SuppressWarnings("deprecation")
> 180           MapFile.Writer output = new MapFile.Writer(ns.getConf(), ns,
> path.toString(), LogFileKey.class, LogFileValue.class);
> 181           try {
>
>
> ____________________________________________________________
> ____________________________________________
> To view the defects in Coverity Scan visit, http://scan.coverity.com/
> projects/736?tab=overview
>
> To unsubscribe from the email notification for new defects,
> http://scan5.coverity.com/cgi-bin/unsubscribe.py
>
>
>
>