Toggle navigation
Home
org.apache.flink.runtime.blob.BlobKey to org.apache.flink.runtime.blob.TransientBlobKey
No. of Instances - 60
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Introduce Literal
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
false
to
TRANSIENT_BLOB
Rename Variable
put
to
putTransient
put
to
putTransient
put
to
putTransient
put
to
putTransient
put
to
putTransient
put
to
putTransient
put
to
putTransient
put
to
putTransient
Add or Remove Method invocation
CompletableFuture.supplyAsync(() -> { try { assertTrue(delete(cache,jobId,blobKey)); assertFalse(cache.getTransientBlobStore().getStorageLocation(jobId,blobKey).exists()); assertFalse(server.getStorageLocation(jobId,blobKey).exists()); return null; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
to
CompletableFuture.supplyAsync(() -> { try { assertTrue(delete(cache,jobId,blobKey)); assertFalse(cache.getTransientBlobService().getStorageLocation(jobId,blobKey).exists()); assertTrue(server.getStorageLocation(jobId,blobKey).exists()); return null; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.delete(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
to
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.deleteFromCache(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.delete(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
to
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.deleteFromCache(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.delete(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
to
blobKeyFuture.thenCombineAsync(cache,(blobKey,blobCache) -> { HashMap<String,TransientBlobKey> lastSubmittedFile=fileMode == FileMode.LOG ? lastSubmittedLog : lastSubmittedStdout; if (lastSubmittedFile.containsKey(taskManagerID)) { if (!Objects.equals(blobKey,lastSubmittedFile.get(taskManagerID))) { if (!blobCache.deleteFromCache(lastSubmittedFile.get(taskManagerID))) { throw new CompletionException(new FlinkException("Could not delete file for " + taskManagerID + '.')); } lastSubmittedFile.put(taskManagerID,blobKey); } } else { lastSubmittedFile.put(taskManagerID,blobKey); } try { return blobCache.getFile(blobKey).getAbsolutePath(); } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not retrieve blob for " + blobKey + '.',e)); } } ,executor)
Rename Method invocation
assertFalse
to
assertTrue
Cascading Type Change (Similar)
HashMap<String,BlobKey>
to
HashMap<String,TransientBlobKey>
HashMap<String,BlobKey>
to
HashMap<String,TransientBlobKey>
Cascading Type Change (Different)
HashMap<String,BlobKey>
to
HashMap<String,TransientBlobKey>