{"record":{"id":"3d45776049abf645","repo":"apache/hadoop","slug":"failed-to-initialize-s-queues-for-the-provided-ke","errorCode":null,"errorMessage":"Failed to initialize %s queues for the provided keys.","messagePattern":"Failed to initialize (.+?) queues for the provided keys\\.","errorType":"exception","errorClass":"IOException","httpStatus":null,"severity":"error","filePath":"hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java","lineNumber":288,"sourceCode":"   * fill Method with \"numInitValues\" values\n   * @param keyNames Array of key Names\n   * @throws IOException if initialization fails for any provided keys\n   */\n  public void initializeQueuesForKeys(String... keyNames) throws IOException {\n    int successfulInitializations = 0;\n    ExecutionException lastException = null;\n\n    for (String keyName : keyNames) {\n      try {\n        keyQueues.get(keyName);\n        successfulInitializations++;\n      } catch (ExecutionException e) {\n        lastException = e;\n      }\n    }\n\n    if (keyNames.length > 0 && successfulInitializations != keyNames.length) {\n      throw new IOException(String.format(\"Failed to initialize %s queues for the provided keys.\",\n          keyNames.length - successfulInitializations), lastException);\n    }\n  }\n\n  /**\n   * This removes the value currently at the head of the Queue for the\n   * provided key. Will immediately fire the Queue filler function if key\n   * does not exist.\n   * If Queue exists but all values are drained, It will ask the generator\n   * function to add 1 value to Queue and then drain it.\n   * @param keyName String key name\n   * @return E the next value in the Queue\n   * @throws IOException raised on errors performing I/O.\n   * @throws ExecutionException executionException.\n   */\n  public E getNext(String keyName)\n      throws IOException, ExecutionException {\n    return getAtMost(keyName, 1).get(0);","sourceCodeStart":270,"sourceCodeEnd":306,"githubUrl":"https://github.com/apache/hadoop/blob/2add9630210752f88ceb1bb74eb65e37bf41da8e/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/crypto/key/kms/ValueQueue.java#L270-L306","documentation":"Error \"Failed to initialize %s queues for the provided keys.\" thrown in apache/hadoop.","triggerScenarios":"Raised at runtime when the documented precondition or configuration requirement for this operation is violated.","commonSituations":"Misconfigured or missing property, invalid user input, or calling the API before its prerequisites are met.","solutions":["The ValueQueue failed to initialize its per-key queues; check the wrapped cause and the queue/timeout configuration."],"exampleFix":"Verify kms client configuration and key names.","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"}