Sqoop2: LoaderContext has the wrong Schema

        if (!isTest) {
          // Using the TO schema since the IDF returns data in TO schema
          schema = ConfigurationUtils.getConnectorSchema(Direction.TO, conf);
          ...
        }

        // Create loader context
        LoaderContext loaderContext = new LoaderContext(subContext, reader, schema);