• Home
  • About Us
  • Contact Us
  • Privacy Policy
  • Special Offers
Business Intelligence Info
  • Business Intelligence
    • BI News and Info
    • Big Data
    • Mobile and Cloud
    • Self-Service BI
  • CRM
    • CRM News and Info
    • InfusionSoft
    • Microsoft Dynamics CRM
    • NetSuite
    • OnContact
    • Salesforce
    • Workbooks
  • Data Mining
    • Pentaho
    • Sisense
    • Tableau
    • TIBCO Spotfire
  • Data Warehousing
    • DWH News and Info
    • IBM DB2
    • Microsoft SQL Server
    • Oracle
    • Teradata
  • Predictive Analytics
    • FICO
    • KNIME
    • Mathematica
    • Matlab
    • Minitab
    • RapidMiner
    • Revolution
    • SAP
    • SAS/SPSS
  • Humor

Expert Interview (Part 3): Jeff Bean and Apache Flink’s Take on Streaming and Batch Processing

December 2, 2018   Big Data
Expert Interview Part 3 Jeff Bean and Apache Flinks Take on Streaming and Batch Processing Expert Interview (Part 3): Jeff Bean and Apache Flink’s Take on Streaming and Batch Processing
 Expert Interview (Part 3): Jeff Bean and Apache Flink’s Take on Streaming and Batch Processing

Paige Roberts

November 29, 2018

At the recent Strata Data conference in NYC, Paige Roberts of Syncsort sat down for a conversation with Jeff Bean, the Technical Evangelist at data Artisans.

In the first of the three part blog, Roberts and Bean discussed data Artisans, Apache Flink, and how Flink handles state in streaming processing. Part two focuses on the adoption of Flink, why people tend to choose Flink, and available training and learning resources.

In the final installment, Roberts and Bean speak about Flink’s unique take on streaming and batch processing, and how Flink compares to other stream processing frameworks.

Roberts: So, aside from the ability to describe state, what else about Flink makes it especially cool?

Bean: It’s the real-time stream processing. A lot of vendors will say that they offer real time stream processing. When you look at what they actually offer, it’s some derivative side project, maybe a set of libraries that does stream processing, or a couple of extra functions that you can call. Flink is designed from the ground up for stream processing, and it treats batch processing as a special case rather than the other way around. I think that is more interesting for applications that want to handle both analytic data, and real-time data with streams. You don’t need to have two different sets of applications for that since Flink treats them both as the same. It sees batch as a special case of streaming rather than the other way around.

I can picture how if you have a batch process that you sort of chop it into tinier and tinier batches until you’re down to one event, and now you have streaming, but if I’m starting from a streaming point of view, how do I get to batch? What kind of a special case is batch?

Batch is basically streaming with bounds. You point your processor at a fixed data set, and it will process it one record at a time as if it were a stream. Off it goes and it’s done. With Flink, it’s really designed for streams as input. You can point it at a file or a table and say, “That’s a stream.”” I found that when you consider batch processing as a special case of streaming, rather than the other way around, it all comes together more easily.

And if you’ve pointed it at a table, after it pulls all the data off, then new transactions coming in actually become a stream?

Yep, exactly. We’re trained to think about data as if it were static, fixed objects like tables and files, but in fact all data is generated as a stream.

You didn’t get a million records all at once. You got them one at a time. 

The New Rules for Your Data Landscape Expert Interview (Part 3): Jeff Bean and Apache Flink’s Take on Streaming and Batch Processing

So, I remember one time asking one of the Spark experts about true streaming handling in Spark Streaming, and they said, “Well, yeah, it does true streaming.” And I said “I thought it did microbatch.” They said, “Well, everybody does microbatch. It’s just that our microbatches have gone down to one message at a time.” What’s your opinion on that?

When you’re working with Spark Streaming, in order to get optimal performance, you have to tune your microbatch size, or your microbatch interval. In Flink you choose the time characteristic instead, and in the event time characteristic, events are microbatched until the watermark advances. It’s a similar issue but it’s closer to the business problem. There is microbatching, but it happens at the framework level, and the OS level, at the level of the network buffer. Which is where it should be, really.

Okay. That makes sense. 

It’s more intuitive, it’s more expressive. As a developer, I find it much easier to learn.

Are there any non-programming interfaces? I know there’s a lot of ways you can write Spark jobs that have nothing to do with Java or Scala or Python. You can build a KNIME workflow and execute in Spark. Syncsort DMX-h can build a data integration job and execute it on Spark. There are notebooks and such. Is there anything like that for Flink?

Not so much, at least on the commercial side. Zeppelin supports Flink, though. I would love to see more of that, and I kind of see that as part of my charter to help build.

So, before we wrap up, is there anything you’d like to let the readers know about before we end?

I mentioned it a little earlier but make sure to check out training.data-artisans.com for some great courses.

Alright. Thanks for taking the time do this. Good talking to you. Good luck with the new job!

Thank you.

Let’s block ads! (Why?)

Syncsort Blog

Apache, Batch, bean, Expert, Flink’s, Interview, Jeff, Part, processing, Streaming, take
  • Recent Posts

    • We were upgraded to the Unified Interface for Dynamics 365. Now What?
    • Recreating Art – the unexpected way
    • Upcoming Webinar: Using Dynamics 365 to Empower your Marketing and Sales Teams with Digital Automation
    • Center for Applied Data Ethics suggests treating AI like a bureaucracy
    • Improving Dynamics 365 Data Integrations with Alternate Keys
  • Categories

  • Archives

    • January 2021
    • December 2020
    • November 2020
    • October 2020
    • September 2020
    • August 2020
    • July 2020
    • June 2020
    • May 2020
    • April 2020
    • March 2020
    • February 2020
    • January 2020
    • December 2019
    • November 2019
    • October 2019
    • September 2019
    • August 2019
    • July 2019
    • June 2019
    • May 2019
    • April 2019
    • March 2019
    • February 2019
    • January 2019
    • December 2018
    • November 2018
    • October 2018
    • September 2018
    • August 2018
    • July 2018
    • June 2018
    • May 2018
    • April 2018
    • March 2018
    • February 2018
    • January 2018
    • December 2017
    • November 2017
    • October 2017
    • September 2017
    • August 2017
    • July 2017
    • June 2017
    • May 2017
    • April 2017
    • March 2017
    • February 2017
    • January 2017
    • December 2016
    • November 2016
    • October 2016
    • September 2016
    • August 2016
    • July 2016
    • June 2016
    • May 2016
    • April 2016
    • March 2016
    • February 2016
    • January 2016
    • December 2015
    • November 2015
    • October 2015
    • September 2015
    • August 2015
    • July 2015
    • June 2015
    • May 2015
    • April 2015
    • March 2015
    • February 2015
    • January 2015
    • December 2014
    • November 2014
© 2021 Business Intelligence Info
Power BI Training | G Com Solutions Limited