Merge pull request #164 from jfn6030217/spot-286-remove-optimization
(SPOT-286) Do not call org.apache.spark.sql.functions.broadcast() on …
diff --git a/spot-ingest/pipelines/flow/load_flow_avro_parquet.hql b/spot-ingest/pipelines/flow/load_flow_avro_parquet.hql
index c12f982..a8de425 100755
--- a/spot-ingest/pipelines/flow/load_flow_avro_parquet.hql
+++ b/spot-ingest/pipelines/flow/load_flow_avro_parquet.hql
@@ -79,7 +79,7 @@
, {"name": "fwd", "type":["int", "null"]}
, {"name": "stos", "type":["int", "null"]}
, {"name": "ipkt", "type":["bigint", "null"]}
- , {"name": "ibytt", "type":["bigint", "null"]}
+ , {"name": "ibyt", "type":["bigint", "null"]}
, {"name": "opkt", "type":["bigint", "null"]}
, {"name": "obyt", "type":["bigint", "null"]}
, {"name": "input", "type":["int", "null"]}
diff --git a/spot-ingest/pipelines/flow/worker.py b/spot-ingest/pipelines/flow/worker.py
index bb957a5..4f5d604 100755
--- a/spot-ingest/pipelines/flow/worker.py
+++ b/spot-ingest/pipelines/flow/worker.py
@@ -188,7 +188,7 @@
" , {{\"name\": \"fwd\", \"type\":[\"int\", \"null\"]}}\n"
" , {{\"name\": \"stos\", \"type\":[\"int\", \"null\"]}}\n"
" , {{\"name\": \"ipkt\", \"type\":[\"bigint\", \"null\"]}}\n"
- " , {{\"name\": \"ibytt\", \"type\":[\"bigint\", \"null\"]}}\n"
+ " , {{\"name\": \"ibyt\", \"type\":[\"bigint\", \"null\"]}}\n"
" , {{\"name\": \"opkt\", \"type\":[\"bigint\", \"null\"]}}\n"
" , {{\"name\": \"obyt\", \"type\":[\"bigint\", \"null\"]}}\n"
" , {{\"name\": \"input\", \"type\":[\"int\", \"null\"]}}\n"
