Data Eng Weekly


Hadoop Weekly Issue #220

18 June 2017

This is quite a monstrous double issue with coverage of announcements and releases from the recent DataWorks Summit and Spark Summit. In addition to all the news, there are great technical articles/presentations (be sure to send any others from the Summits my way) on Spark Streaming, Kafka, HBase, and more.

Technical

The Hortonworks blog has a post on some new features that are being added to HDFS to detect slow data nodes and slow disks.

https://hortonworks.com/blog/part-6-of-data-lake-3-0-a-self-diagnosing-data-lake/

Databricks is touting the throughput of Spark Streaming in a new benchmark, and they're proposing an enhancement to Spark Streaming for "continuous processing" that replaces microbatches and reduces end-to-end latency to the order of 1ms.

https://databricks.com/blog/2017/06/06/simple-super-fast-streaming-engine-apache-spark.html

You may have heard of the Apache Arrow project, which implements a cross-language in-memory columnar data format. While most devs won't deal with Arrow directly, it provides an under the hood mechanism to speed up a number of things like PySpark . This presentation gives a good overview of what Arrow is and how it helps achieve speedups.

https://www.slideshare.net/julienledem/improving-python-and-spark-performance-and-interoperability-with-apache-arrow

The Confluent blog has an introduction to the librdkafka-based Python APIs for Kafka. In short, the post shows how to use the APIs to produce and consume records from a Kafka cluster and how to setup a local development environment.

https://www.confluent.io/blog/introduction-to-apache-kafka-for-python-programmers/

The Google Cloud Platform team makes the argument that one-job-per-cluster is the right approach for Hadoop. The penalty for starting up a cluster is low on the Google Cloud (under 2 minutes), and you don't need to worry about optimizing for multitenancy like on a long-running Hadoop cluster.

https://cloud.google.com/blog/big-data/2017/06/fastest-track-to-apache-hadoop-and-spark-success-using-job-scoped-clusters-on-cloud-native-architecture

The Insight Data Science blog has a useful post showing how to spin up a set of AWS and Kafka services (a Postgres database on Amazon RDS, a EC2 instance running Kafka Connect, and an Amazon Redshift cluster) to perform near real-time change data capture to propagate changes from postgres to redshift.

https://blog.insightdatascience.com/from-postgresql-to-redshift-with-kafka-connect-111c44954a6a

Apache HBase has special support for "Medium Object Storage" or MOB, which separately stores files from references when a value is larger than a particular size. This post describes an enhancement (support for weekly and monthly partitioning) in the design which solves memory problems on the NameNode due to the number of MOB files that could be created.

http://blog.cloudera.com/blog/2017/06/introducing-apache-hbase-medium-object-storage-mob-compaction-partition-policies/

Netflix has written about the third generation of their Genie tool for executing (around 150k/day) queries on YARN and Presto clusters. New features include a redesigned job execution engine, cluster leadership (via ZooKeeper), security (via Spring Security), and dependency caching.

https://medium.com/netflix-techblog/evolving-the-netflix-data-platform-with-genie-3-598021604dda

Pinterest has written about about the process of and their experience in upgrading from a custom 0.94 build of HBase to version 1.2. The protocols and APIs between these versions aren't compatible, so the team had to jump through some extra hoops to ensure that data was replicated (using a custom, thrift-based solution), verify the status of replicated data, ensure their client could support both versions simultaneously, tune performance, and more. Pinterest has a non-trivial amount of data in HBase, so it's very interesting to see what they've done.

https://medium.com/@Pinterest_Engineering/upgrading-pinterest-to-hbase-1-2-from-0-94-e6e34c157783

The Databricks blog (and accompanying notebook) has a tutorial for using several of the built-in Spark SQL functions for processing JSON and nested structures.

https://databricks.com/blog/2017/06/13/five-spark-sql-utility-functions-extract-explore-complex-data-types.html

The Cloudera blog has a post on the evolution of Apache ZooKeeper's Four Letter Words support. For these admin commands, there isn't a good security solution (as a connection is over the normal ZK port). As an alternative, ZooKeeper provides support for JMX and as of the 3.5.x release an AdminServer on a separate port.

http://blog.cloudera.com/blog/2017/06/apache-zookeeper-four-letter-words-and-security/

News

Databricks and O'Reilly are providing free access (behind an email/phone num wall) to several chapters from the upcoming "Spark: The Definitive Guide."

https://databricks.com/blog/2017/06/05/sharing-knowledge-community-preview-apache-spark-definitive-guide.html

MapR-XD is a new product that provides data tiering by storing cold data in an object store like Amazon S3. It also supports flash storage for hot data.

http://www.zdnet.com/article/mapr-diversifies-to-cloud-storage-market/

Databricks has announced a push towards a managed, auto-scaling Spark service called Databricks Serverless. Their first step in that direction is Databricks Serverless Pools, in which compute and storage autoscale on a set of instances running within a customers own AWS account.

https://databricks.com/blog/2017/06/07/databricks-serverless-next-generation-resource-management-for-apache-spark.html

Hortonworks has announced a new type of support contract called a Hortonworks Flex Support Subscription, that allows a single subscription to support both cloud and on-prem deployments. This move seems to reflect the reality of the number of customers that are migrating or experimenting with hybrid clouds.

https://hortonworks.com/press-releases/hortonworks-introduces-flex-support/

The ODPi is doing a 6-month grant fund program to make improvements to Apache BigTop (including code, documentation, and more). Applications are due on July 14th.

http://www.prnewswire.com/news-releases/odpi-launches-apache-bigtop-grant-fund-program-300472753.html

Cloudera posted their first quarterly earnings report. Datanami has a good breakdown (revenue and GAAP losses were better than expected, but billings missed expectations).

https://www.datanami.com/2017/06/12/cloudera-shares-tumble-first-quarterly-report/

Confluent has posted slides and videos from the recent Kafka Summit NYC.

https://www.confluent.io/kafka-summit-nyc17/resource/

Videos for Spark Summit have also been posted.

https://spark-summit.org/2017/schedule/

Insight's Data Science, Data Engineering, Health Data, and AI programs are accepting applications through Monday, June 26th for the fall program. Insight's programs are free and over 900 alumni have already completed the 7-week program.

http://insightdatascience.com/apply

IBM and Hortonworks announced a partnership in which IBM will distributed HDP and HDF rather than IBM BigInsights. In turn, Hortonworks is including some items from the IBM distro including BigSQL.

https://www.datanami.com/2017/06/13/ibm-throws-hortonworks-hadoop/

Releases

Amazon EMR 5.6.0 includes new versions of Apache Spark, Apache HBase, Apache Flink, and Apache Mahout. The release also supports in-transit encryption for Apache Presto.

https://aws.amazon.com/about-aws/whats-new/2017/06/updates-to-apache-spark-and-in-transit-encryption-for-presto-in-amazon-emr-release-5-6-0/

Version 4.2 of the Cask Data Application Platform has been released. The new new version supports interactive Spark queries, event-driven workflows, change data capture for SQL Server and Oracle, several Azure services, and Amazon EMR.

http://blog.cask.co/2017/06/cdap-4-2-interactive-spark-enhanced-self-service-data-preparation-and-more/

Apache HBase 1.2.6 was released with several critical fixes.

https://lists.apache.org/thread.html/9918298346b508c9ac829a36ee2315acfda2c49ac6334de385eb66bb@%3Cannounce.apache.org%3E

Apache NiFi 1.3.0 and 0.7.4 were released to address two vulnerabilities—a cross frame scripting and a cross site scripting. The 1.3.0 release also includes major improvements and features related to clustering, UI/UX, and the core framework.

https://cwiki.apache.org/confluence/display/NIFI/Release+Notes#ReleaseNotes-Version1.3.0
https://cwiki.apache.org/confluence/display/NIFI/Release+Notes#ReleaseNotes-Version0.7.4

Hortonworks DataFlow 3.0 was released with a new Streaming Analytics Manager and Schema Registry. The post has screenshots of the Streaming Analytics Manager, which enables building of streaming applications without writing code.

https://hortonworks.com/blog/hortonworks-dataflow-3-0/

Version 2.6.0.0 of the StreamSets Data Collector includes a new automatic Data Drift Synchronization feature (which automatically updates schemas in Hive), improved speed of ingesting TCP payloads, support for Spark 2.0, and more.

https://streamsets.com/blog/announcing-data-collector-ver-2-6-0-0/

The 3.0 release of BlueData EPIC has a number of new features. These include, a new gateway service, cluster monitoring with Elasticsearch and Kibana, performance optimizations, improved deployment options and templates, and data science docker containers with support for R, Jupyter, etc. The release also includes a Kerberos Passthrough service, which enables secure hadoop features when compute and storage are separated across several clusters.

https://www.bluedata.com/blog/2017/06/introducing-bluedata-epic-3-0/

Apache Zeppelin 0.7.2 resolves over 40 issues, including a number of bug fixes and improvements (mostly with the Livy Spark job server integration).

https://zeppelin.apache.org/releases/zeppelin-release-0.7.2.html

Apache Kudu 1.4.0 was released. There are a number of new features (such as a new file system check util), many optimizations and improvements (including updaes to web interface and write performance).

https://kudu.apache.org/releases/1.4.0/

Apache Impala 2.9.0-incubating was released. The release includes a number of documentation updates and many other (over 350 resolved issues!) fixes and improvements.

https://lists.apache.org/thread.html/768f3784cec777e2fad4c4dfaa66c4a115148d8630adce4cd4636622@%3Cannounce.apache.org%3E

Events

Curated by Datadog ( http://www.datadog.com )

UNITED STATES

Pennsylvania

LVTech Meetup: Hadoop & Impala (Bethlehem) - Tuesday, June 20
https://www.meetup.com/lvtech/events/239307927/

New Jersey

Latest HDF Innovation: Schema Registry and More (Princeton) - Tuesday, June 20
https://www.meetup.com/futureofdata-princeton/events/239820709/

New York

MapR @ the New York Big Data Meetup (New York) - Tuesday, June 20
https://www.meetup.com/NYBigData/events/240471055/

COLOMBIA

Analytics with Azure Machine Learning Studio + Hadoop For Everyone (Medellin) - Thursday, June 22
https://www.meetup.com/ml-medellin/events/240197032/

UNITED KINGDOM

DIY Data Analytics with Apache Spark (London) - Thursday, June 22
https://www.meetup.com/Big-Data-Analytics-in-London/events/240245196/

Drivetribe’s Kappa Architecture with Apache Flink (London) - Thursday, June 22
https://www.meetup.com/Apache-Flink-London-Meetup/events/240728369/

Big Data, London v 9.0 (London) - Thursday, June 22
https://www.meetup.com/Data-Natives-London/events/238288831/

GERMANY

Big Data & Stream Processing with Apache Spark (Dusseldorf) - Tuesday, June 20
https://www.meetup.com/Scala-User-Group-Dusseldorf/events/238984527/

SWITZERLAND

20th Swiss Big Data User Group Meeting (Zurich) - Monday, June 19
https://www.meetup.com/swiss-big-data/events/240355263/

ISRAEL

Data Science Workbench with Cloudera Experts (Herzliya) - Monday, June 19
https://www.meetup.com/Think-Big-Data-Tel-aviv/events/240176069/

SOUTH AFRICA

First Johannesburg Meetup (Sandton) - Thursday, June 22
https://www.meetup.com/ZA-Hadoop-User-Group/events/240547723/

If you didn't receive this email directly, and you'd like to subscribe to weekly emails please visit https://hadoopweekly.com