Follow these steps to run the Spark Pi example:

- Login as user **‘spark’**.
- When the job runs, the library can now use **MinIO** during intermediate processing.
- Navigate to a node with the Spark client and access the spark2-client directory:

```
cd /usr/hdp/current/spark2-client
su spark
```

     * @param file the actual file containing the dictionary content
     * @throws DictionaryException if the file was updated by another process,
     *         if the file doesn't exist, or if there's an error during storage
     */
    public void store(final DictionaryFile<? extends DictionaryItem> dictFile, final File file) {
        getDictionaryFile(dictFile.getId()).ifPresent(currentFile -> {

   * {@link #peek()} methods on this instance; if it does, an {@code IllegalStateException} will
   * result.
   *
   * @return the next element if there was one. If {@code endOfData} was called during execution,
   *     the return value will be ignored.
   * @throws RuntimeException if any unrecoverable error happens. This exception will propagate

     * @param cred the authentication credentials to use for the session
     * @throws SmbException if an SMB protocol error occurs
     * @throws GeneralSecurityException if a security error occurs during authentication
     */
    public SmbComSessionSetupAndX(final CIFSContext tc, final SmbComNegotiateResponse negotiated, final ServerMessageBlock andx,
            final Object cred) throws SmbException, GeneralSecurityException {

/// info

Note that the `TestClient` receives data that can be converted to JSON, not Pydantic models.

If you have a Pydantic model in your test and you want to send its data to the application during testing, you can use the `jsonable_encoder` described in [JSON Compatible Encoder](encoder.md).

///

## Run it { #run-it }

After that, you just need to install `pytest`.

 * <p>
 * This service handles character mapping management including CRUD operations
 * and list retrieval. Character mappings are used for text normalization
 * and character substitution during document processing and search operations.
 * </p>
 */
public class CharMappingService {

    /**
     * Creates a new instance of CharMappingService.
     */
    public CharMappingService() {

     * Rewrites the query using the provided rewrite context.
     *
     * @param queryShardContext the query rewrite context
     * @return the rewritten query builder
     * @throws IOException if an I/O error occurs during rewriting
     */
    @Override
    public QueryBuilder rewrite(final QueryRewriteContext queryShardContext) throws IOException {
        return queryBuilder.rewrite(queryShardContext);
    }

    @Override

        // sure interpolation of the directories below uses translated paths.
        // Afterward, we'll double back and translate any paths that weren't covered during interpolation via the
        // code below...
        translatedPrefixes.add("build.directory");
        translatedPrefixes.add("build.outputDirectory");
        translatedPrefixes.add("build.testOutputDirectory");

	}
	for _, g := range pickRelevantGoroutines() {
		snapshot.relevantRoutines[g] = true
	}
	return snapshot
}

// CompareCurrentSnapshot - Compares the initial relevant stack trace with the current one (during the time of invocation).
func (initialSnapShot LeakDetect) CompareCurrentSnapshot() []string {
	var stackDiff []string
	for _, g := range pickRelevantGoroutines() {

            // Then
            assertTrue(result);
            verify(transportPool).close();
        }

        @Test
        @DisplayName("Should handle exception during close")
        void testClosePoolException() throws CIFSException {
            // Given
            when(transportPool.close()).thenThrow(new CIFSException("Close failed"));

            // When & Then