header write fix for overwrite argument

Tagar · Jul 31, 2018 · 708d140 · 708d140
1 parent 5bab5e2
commit 708d140
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/abalon/spark/sparkutils.py b/abalon/spark/sparkutils.py
@@ -483,7 +483,7 @@ def dataframeToHDFSfile (dataframe, dst_file, overwrite=False
         header_record = delimiter.join(dataframe.columns)
         header_filename = "{}/--00_header.csv".format(dst_dir)  # have to make sure header filename is 1st in
                                                                 # alphabetical order
-        HDFSwriteString(header_filename, header_record, compression)
+        HDFSwriteString(dst_file=header_filename, content=header_record, compression=compression)
 
     HDFScopyMerge(dst_dir, dst_file, overwrite, deleteSource=True)
 

diff --git a/abalon/version.py b/abalon/version.py
@@ -12,6 +12,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-version = '2.2.8'
+version = '2.2.9'