{"record":{"id":"55b47d29bf2bf8d6","repo":"apache/hadoop","slug":"flush-with-blockids-not-supported-on-dfs-endpoint","errorCode":null,"errorMessage":"Flush with blockIds not supported on DFS Endpoint","messagePattern":"Flush with blockIds not supported on DFS Endpoint","errorType":"exception","errorClass":"UnsupportedOperationException","httpStatus":null,"severity":"error","filePath":"hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsDfsClient.java","lineNumber":921,"sourceCode":"   * @param isClose whether this is the last flush operation to the file.\n   * @param cachedSasToken the SAS token to authenticate the operation.\n   * @param leaseId the lease ID, if an active lease exists on the path.\n   * @param eTag the ETag for concurrency control to ensure the flush is applied to the correct file version.\n   * @param contextEncryptionAdapter the adapter providing the encryption context.\n   * @param tracingContext the tracing context for tracking server calls.\n   * @param blobMd5 the MD5 hash of the blob for integrity verification.\n   * @throws UnsupportedOperationException if flush with blockIds is called on a DFS endpoint.\n   */\n  @Override\n  public AbfsRestOperation flush(byte[] buffer,\n      final String path,\n      boolean isClose,\n      final String cachedSasToken,\n      final String leaseId,\n      final String eTag,\n      final ContextEncryptionAdapter contextEncryptionAdapter,\n      final TracingContext tracingContext, String blobMd5) throws AzureBlobFileSystemException {\n    throw new UnsupportedOperationException(\n        \"Flush with blockIds not supported on DFS Endpoint\");\n  }\n\n  /**\n   * Get Rest Operation for API\n   * <a href=\"https://learn.microsoft.com/en-us/rest/api/storageservices/datalakestoragegen2/path/update\">\n   *   Path - Update</a>.\n   * Set the properties of a file or directory.\n   * @param path on which properties have to be set.\n   * @param properties list of metadata key-value pairs.\n   * @param tracingContext for tracing the server calls.\n   * @param contextEncryptionAdapter to provide encryption context.\n   * @return executed rest operation containing response from server.\n   * @throws AzureBlobFileSystemException if rest operation fails.\n   */\n  @Override\n  public AbfsRestOperation setPathProperties(final String path,\n      final Hashtable<String, String> properties,","sourceCodeStart":903,"sourceCodeEnd":939,"githubUrl":"https://github.com/apache/hadoop/blob/2add9630210752f88ceb1bb74eb65e37bf41da8e/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsDfsClient.java#L903-L939","documentation":"Error \"Flush with blockIds not supported on DFS Endpoint\" thrown in apache/hadoop.","triggerScenarios":"Application code calls a flush variant carrying block ids against an ABFS DFS-endpoint stream.","commonSituations":"See trigger scenarios.","solutions":["Do not pass block ids to flush() when using the DFS endpoint; use plain flush/hflush.","If block-id flush semantics are required, write through the Blob endpoint client instead."],"exampleFix":null,"handlingStrategy":null,"validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"2add9630210752f88ceb1bb74eb65e37bf41da8e","analyzedAt":"2026-08-22T19:55:07.957Z","schemaVersion":2},"datasetVersion":"2026-08-23T01:17:44.959Z"}