{"id":4488,"date":"2025-08-09T16:55:31","date_gmt":"2025-08-09T16:55:31","guid":{"rendered":"https:\/\/uplatz.com\/blog\/?p=4488"},"modified":"2025-08-28T13:09:59","modified_gmt":"2025-08-28T13:09:59","slug":"apache-flink-pocket-book","status":"publish","type":"post","link":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/","title":{"rendered":"Apache Flink Pocket Book"},"content":{"rendered":"<p><!-- Apache Flink Pocket Book (Wide Layout, Readable Code, Scoped Styles) --><\/p>\n<div style=\"margin: 16px 0;\"><img loading=\"lazy\" decoding=\"async\" class=\"alignnone size-large wp-image-4948\" src=\"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-1024x576.jpg\" alt=\"\" width=\"840\" height=\"473\" srcset=\"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-1024x576.jpg 1024w, https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-300x169.jpg 300w, https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-768x432.jpg 768w, https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink.jpg 1280w\" sizes=\"auto, (max-width: 840px) 100vw, 840px\" \/><\/p>\n<style>\n    .wp-flink-pb { font-family: Arial, sans-serif; max-width: 1320px; margin:0 auto; }<br \/>\n    .wp-flink-pb .heading{<br \/>\n      background: linear-gradient(135deg, #e0f2fe, #ccfbf1);<br \/>\n      color:#0f172a; padding:22px 24px; border-radius:14px;<br \/>\n      text-align:center; margin-bottom:18px; box-shadow:0 8px 20px rgba(0,0,0,.08);<br \/>\n      border:1px solid #cbd5e1;<br \/>\n    }<br \/>\n    .wp-flink-pb .heading h2{ margin:0; font-size:2.1rem; letter-spacing:.2px; }<br \/>\n    .wp-flink-pb .heading p{ margin:6px 0 0; font-size:1.02rem; opacity:.9; }<\/p>\n<p>    .wp-flink-pb .grid{<br \/>\n      display:grid; gap:14px;<br \/>\n      grid-template-columns: repeat(auto-fill, minmax(400px, 1fr));<br \/>\n    }<br \/>\n    @media (min-width:1200px){<br \/>\n      .wp-flink-pb .grid{ grid-template-columns: repeat(3, 1fr); }<br \/>\n    }<\/p>\n<p>    .wp-flink-pb .section-title{<br \/>\n      grid-column:1\/-1; background:#f8fafc; border-left:8px solid #0ea5e9;<br \/>\n      padding:12px 16px; border-radius:10px; font-weight:700; color:#0f172a; font-size:1.08rem;<br \/>\n      box-shadow:0 2px 8px rgba(0,0,0,.05); border:1px solid #e2e8f0;<br \/>\n    }<br \/>\n    .wp-flink-pb .card{<br \/>\n      background:#ffffff; border-left:6px solid #0ea5e9;<br \/>\n      padding:18px; border-radius:12px;<br \/>\n      box-shadow:0 6px 14px rgba(0,0,0,.06);<br \/>\n      transition:transform .12s ease, box-shadow .12s ease;<br \/>\n      border:1px solid #e5e7eb;<br \/>\n    }<br \/>\n    .wp-flink-pb .card:hover{ transform: translateY(-3px); box-shadow:0 10px 22px rgba(0,0,0,.08); }<br \/>\n    .wp-flink-pb .card h3{ margin:0 0 10px; font-size:1.12rem; color:#0f172a; }<br \/>\n    .wp-flink-pb .card p{ margin:0; font-size:.96rem; color:#334155; line-height:1.62; }<\/p>\n<p>    \/* Color helpers *\/<br \/>\n    .bg-blue { border-left-color:#0ea5e9 !important; background:#f0f9ff !important; }<br \/>\n    .bg-green{ border-left-color:#10b981 !important; background:#f0fdf4 !important; }<br \/>\n    .bg-amber{ border-left-color:#f59e0b !important; background:#fffbeb !important; }<br \/>\n    .bg-violet{ border-left-color:#8b5cf6 !important; background:#f5f3ff !important; }<br \/>\n    .bg-rose{ border-left-color:#ef4444 !important; background:#fff1f2 !important; }<br \/>\n    .bg-cyan{ border-left-color:#06b6d4 !important; background:#ecfeff !important; }<br \/>\n    .bg-indigo{ border-left-color:#6366f1 !important; background:#eef2ff !important; }<br \/>\n    .bg-slate{ border-left-color:#334155 !important; background:#f8fafc !important; }<\/p>\n<p>    \/* Utilities *\/<br \/>\n    .tight ul{ margin:0; padding-left:18px; }<br \/>\n    .tight li{ margin:4px 0; }<br \/>\n    .mono{ font-family: ui-monospace, SFMono-Regular, Menlo, Monaco, Consolas, monospace; }<br \/>\n    .muted{ color:#64748b; }<br \/>\n    .wp-flink-pb code{ background:#f1f5f9; padding:0 4px; border-radius:4px; border:1px solid #e2e8f0; }<br \/>\n    .wp-flink-pb pre{<br \/>\n      background:#f5f5f5; color:#111827; border:1px solid #e5e7eb;<br \/>\n      padding:12px; border-radius:8px; overflow:auto; font-size:.92rem; line-height:1.55;<br \/>\n    }<br \/>\n    .q{font-weight:700;}<br \/>\n    .qa p{ margin:8px 0; }<br \/>\n    .qa b{ color:#0f172a; }<br \/>\n  <\/style>\n<div class=\"wp-flink-pb\">\n<div class=\"heading\">\n<h2>Apache Flink Pocket Book<\/h2>\n<p>Low-latency streaming \u2022 Stateful processing \u2022 Time &amp; windows \u2022 Checkpoints &amp; savepoints \u2022 CEP \u2022 Connectors \u2022 Deploy &amp; tune<\/p>\n<\/div>\n<div class=\"grid\"><!-- ===================== SECTION 1 ===================== --><\/p>\n<div class=\"section-title\">Section 1 \u2014 Fundamentals<\/div>\n<div class=\"card bg-blue\">\n<h3>1) What is Apache Flink?<\/h3>\n<p>Apache Flink is a distributed engine for <b>stateful<\/b> stream and batch processing with <b>event-time<\/b> semantics, exactly-once state consistency, and sub-second latency. It powers real-time analytics, fraud detection, anomaly alerts, and ETL.<\/p>\n<pre><code class=\"mono\"># Quick start (local binary)\r\n# download from flink.apache.org, then:\r\nbin\/start-cluster.sh\r\n# UI on http:\/\/localhost:8081<\/code><\/pre>\n<\/div>\n<div class=\"card bg-green\">\n<h3>2) Core Concepts<\/h3>\n<ul class=\"tight\">\n<li><b>DataStream API<\/b> (streaming), <b>Table\/SQL API<\/b> (relational), <b>DataSet<\/b> (legacy batch).<\/li>\n<li><b>Event time<\/b>, <b>processing time<\/b>, <b>ingestion time<\/b>.<\/li>\n<li><b>State<\/b> (keyed\/operator), <b>checkpoints<\/b>, <b>savepoints<\/b>.<\/li>\n<li><b>Parallelism<\/b>, <b>slots<\/b>, <b>task managers<\/b>.<\/li>\n<\/ul>\n<\/div>\n<div class=\"card bg-amber\">\n<h3>3) Minimal Streaming Job (Java)<\/h3>\n<pre><code class=\"mono\">StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();\r\nenv.fromElements(\"a\",\"b\",\"a\")\r\n   .keyBy(v -&gt; v)\r\n   .map(v -&gt; Tuple2.of(v, 1))\r\n   .keyBy(t -&gt; t.f0)\r\n   .sum(1)\r\n   .print();\r\nenv.execute(\"WordCount\");<\/code><\/pre>\n<\/div>\n<div class=\"card bg-violet\">\n<h3>4) Minimal Table SQL<\/h3>\n<pre><code class=\"mono\">TableEnvironment tEnv = TableEnvironment.create(...);\r\ntEnv.executeSql(\"CREATE TEMPORARY TABLE clicks (user STRING, ts TIMESTAMP(3), WATERMARK FOR ts AS ts - INTERVAL '5' SECOND) WITH (...)\");\r\ntEnv.executeSql(\"SELECT user, TUMBLE_START(ts, INTERVAL '1' MINUTE), COUNT(*) FROM clicks GROUP BY user, TUMBLE(ts, INTERVAL '1' MINUTE)\");<\/code><\/pre>\n<\/div>\n<div class=\"card bg-rose\">\n<h3>5) Connectors<\/h3>\n<p>Common sources\/sinks: Kafka, Kinesis, Pulsar, Filesystem, JDBC, Elasticsearch, Iceberg, Hive. Use the corresponding connector JARs and matching versions.<\/p>\n<\/div>\n<p><!-- ===================== SECTION 2 ===================== --><\/p>\n<div class=\"section-title\">Section 2 \u2014 Time, Windows &amp; State<\/div>\n<div class=\"card bg-blue\">\n<h3>6) Event-time with Watermarks<\/h3>\n<pre><code class=\"mono\">env.getConfig().setAutoWatermarkInterval(1000);\r\nWatermarkStrategy&lt;MyEvent&gt; wm = WatermarkStrategy\r\n  .&lt;MyEvent&gt;forBoundedOutOfOrderness(Duration.ofSeconds(10))\r\n  .withTimestampAssigner((e, ts) -&gt; e.getTsMillis());<\/code><\/pre>\n<p class=\"muted\">Pick out-of-orderness budget carefully; larger = more latency but fewer late events.<\/p>\n<\/div>\n<div class=\"card bg-green\">\n<h3>7) Windows<\/h3>\n<pre><code class=\"mono\">stream.keyBy(e -&gt; e.user)\r\n  .window(TumblingEventTimeWindows.of(Time.minutes(1)))\r\n  .reduce(new MyReducer());<\/code><\/pre>\n<p>Also: sliding, session, global windows. Use triggers &amp; evictors for custom emission.<\/p>\n<\/div>\n<div class=\"card bg-amber\">\n<h3>8) Keyed State<\/h3>\n<pre><code class=\"mono\">class Dedup extends KeyedProcessFunction&lt;String, Event, Event&gt; {\r\n  private transient ValueState&lt;Long&gt; lastSeen;\r\n  public void open(OpenContext ctx){ lastSeen = getRuntimeContext()\r\n    .getState(new ValueStateDescriptor&lt;&gt;(\"last\", Long.class)); }\r\n  public void processElement(Event e, Context ctx, Collector&lt;Event&gt; out) throws Exception {\r\n    Long prev = lastSeen.value();\r\n    if (prev == null || e.ts &gt; prev) { lastSeen.update(e.ts); out.collect(e); }\r\n  }\r\n}<\/code><\/pre>\n<\/div>\n<div class=\"card bg-violet\">\n<h3>9) Timers<\/h3>\n<p>Register event-time or processing-time timers for delayed actions (e.g., session close, reminders).<\/p>\n<pre><code class=\"mono\">ctx.timerService().registerEventTimeTimer(e.ts + 60000);<\/code><\/pre>\n<\/div>\n<div class=\"card bg-rose\">\n<h3>10) Exactly-once with Checkpoints<\/h3>\n<pre><code class=\"mono\">env.enableCheckpointing(60000, CheckpointingMode.EXACTLY_ONCE);\r\nenv.getCheckpointConfig().setMinPauseBetweenCheckpoints(30000);\r\nenv.getCheckpointConfig().setCheckpointTimeout(120000);<\/code><\/pre>\n<p>Use a persistent state backend (RocksDB) for large state.<\/p>\n<\/div>\n<p><!-- ===================== SECTION 3 ===================== --><\/p>\n<div class=\"section-title\">Section 3 \u2014 Table\/SQL &amp; CDC<\/div>\n<div class=\"card bg-blue\">\n<h3>11) Table API Joins &amp; Windows<\/h3>\n<pre><code class=\"mono\">Table result = tEnv.sqlQuery(\"\r\n SELECT user, COUNT(*) cnt\r\n FROM clicks\r\n WINDOW T AS (TUMBLE(ts, INTERVAL '1' MINUTE))\r\n GROUP BY user, TUMBLE_START(ts, INTERVAL '1' MINUTE)\");<\/code><\/pre>\n<\/div>\n<div class=\"card bg-green\">\n<h3>12) CDC with Debezium<\/h3>\n<p>Ingest change streams from MySQL\/Postgres via Debezium + Kafka into Flink SQL for materialized views and real-time ETL.<\/p>\n<\/div>\n<div class=\"card bg-amber\">\n<h3>13) Upserts &amp; Exactly-once Sinks<\/h3>\n<p>Use upsert-kafka, JDBC upserts, or file sinks with atomic commit. Ensure primary keys for correct changelog semantics.<\/p>\n<\/div>\n<div class=\"card bg-violet\">\n<h3>14) Flink SQL Catalogs<\/h3>\n<p>Integrate with Hive\/Iceberg catalogs for schema and table management; enables time travel and ACID in lakes.<\/p>\n<\/div>\n<p><!-- ===================== SECTION 4 ===================== --><\/p>\n<div class=\"section-title\">Section 4 \u2014 CEP, Patterns &amp; ML<\/div>\n<div class=\"card bg-blue\">\n<h3>15) Complex Event Processing (CEP)<\/h3>\n<pre><code class=\"mono\">Pattern&lt;Event, ?&gt; p = Pattern.&lt;Event&gt;begin(\"a\")\r\n  .where(e -&gt; e.type.equals(\"login\"))\r\n  .next(\"b\").where(e -&gt; e.type.equals(\"transfer\"))\r\n  .within(Time.minutes(10));<\/code><\/pre>\n<p>Apply to a keyed stream and select matches for fraud\/anomaly scenarios.<\/p>\n<\/div>\n<div class=\"card bg-green\">\n<h3>16) Side Outputs<\/h3>\n<p>Split streams for errors\/late data using <code>OutputTag&lt;T&gt;<\/code> and <code>ProcessFunction<\/code>.<\/p>\n<\/div>\n<div class=\"card bg-amber\">\n<h3>17) ML &amp; Feature Pipelines<\/h3>\n<p>Use Flink for real-time feature computation\/aggregation and serve to online stores; model scoring can run via custom operators or external services.<\/p>\n<\/div>\n<p><!-- ===================== SECTION 5 ===================== --><\/p>\n<div class=\"section-title\">Section 5 \u2014 Deploy, Operate &amp; Tune<\/div>\n<div class=\"card bg-blue\">\n<h3>18) Deployment Modes<\/h3>\n<ul class=\"tight\">\n<li><b>Standalone<\/b>: simple clusters.<\/li>\n<li><b>YARN<\/b>\/<b>Kubernetes<\/b>: session or per-job clusters.<\/li>\n<li><b>Native K8s<\/b>: Helm charts, operator-based management.<\/li>\n<\/ul>\n<\/div>\n<div class=\"card bg-green\">\n<h3>19) Savepoints &amp; Upgrades<\/h3>\n<p>Create <b>savepoints<\/b> for planned upgrades and schema changes. Keep state compatibility (serializers, schema evolution) stable across versions.<\/p>\n<pre><code class=\"mono\">bin\/flink savepoint :jobId s3:\/\/state\/savepoints\/ -yid :yarnAppId<\/code><\/pre>\n<\/div>\n<div class=\"card bg-amber\">\n<h3>20) Observability &amp; Tuning<\/h3>\n<ul class=\"tight\">\n<li>Monitor backpressure, checkpoint duration, busy time, GC.<\/li>\n<li>Right-size <b>parallelism<\/b> and <b>task slots<\/b>; avoid hot keys.<\/li>\n<li>Use RocksDB state backend for large state; tune memory\/IO.<\/li>\n<\/ul>\n<pre><code class=\"mono\"># Submit a job (fat JAR)\r\nbin\/flink run -d -p 8 -c com.acme.Job target\/app-1.0.jar<\/code><\/pre>\n<\/div>\n<div class=\"card bg-indigo qa\">\n<h3>21) Interview Q&amp;A \u2014 8 Quick Ones<\/h3>\n<p><b>1)<\/b> <i>Why Flink over Spark Structured Streaming?<\/i> Lower latency, fine-grained event-time control, rich state\/timers, CEP.<\/p>\n<p><b>2)<\/b> <i>Exactly-once semantics?<\/i> Checkpointed state + transactional sinks or idempotent upserts.<\/p>\n<p><b>3)<\/b> <i>Backpressure?<\/i> Propagates upstream; monitor and scale\/slow sources, increase resources, or optimize operators.<\/p>\n<p><b>4)<\/b> <i>Late data handling?<\/i> Watermarks + allowed lateness + side outputs; or retractions in Table API.<\/p>\n<p><b>5)<\/b> <i>State explosion?<\/i> TTL on state, compaction, partitioning strategy, RocksDB.<\/p>\n<p><b>6)<\/b> <i>Per-job vs session cluster?<\/i> Per-job isolates dependencies; session improves utilization.<\/p>\n<p><b>7)<\/b> <i>Scaling?<\/i> Rescale with savepoint; adjust parallelism and repartition keys.<\/p>\n<p><b>8)<\/b> <i>Schema evolution?<\/i> Use formats with evolution (Avro\/Protobuf), manage serializers carefully.<\/p>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"<p>Apache Flink Pocket Book Low-latency streaming \u2022 Stateful processing \u2022 Time &amp; windows \u2022 Checkpoints &amp; savepoints \u2022 CEP \u2022 Connectors \u2022 Deploy &amp; tune Section 1 \u2014 Fundamentals 1) <span class=\"readmore\"><a href=\"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/\">Read More &#8230;<\/a><\/span><\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2481,2462],"tags":[],"class_list":["post-4488","post","type-post","status-publish","format-standard","hentry","category-apache-flink","category-pocket-book"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v27.3 - https:\/\/yoast.com\/product\/yoast-seo-wordpress\/ -->\n<title>Apache Flink Pocket Book | Uplatz Blog<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/\" \/>\n<meta property=\"og:locale\" content=\"en_US\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Apache Flink Pocket Book | Uplatz Blog\" \/>\n<meta property=\"og:description\" content=\"Apache Flink Pocket Book Low-latency streaming \u2022 Stateful processing \u2022 Time &amp; windows \u2022 Checkpoints &amp; savepoints \u2022 CEP \u2022 Connectors \u2022 Deploy &amp; tune Section 1 \u2014 Fundamentals 1) Read More ...\" \/>\n<meta property=\"og:url\" content=\"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/\" \/>\n<meta property=\"og:site_name\" content=\"Uplatz Blog\" \/>\n<meta property=\"article:publisher\" content=\"https:\/\/www.facebook.com\/Uplatz-1077816825610769\/\" \/>\n<meta property=\"article:published_time\" content=\"2025-08-09T16:55:31+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2025-08-28T13:09:59+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"1280\" \/>\n\t<meta property=\"og:image:height\" content=\"720\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"uplatzblog\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:creator\" content=\"@uplatz_global\" \/>\n<meta name=\"twitter:site\" content=\"@uplatz_global\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"uplatzblog\" \/>\n\t<meta name=\"twitter:label2\" content=\"Est. reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"3 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\\\/\\\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#article\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/\"},\"author\":{\"name\":\"uplatzblog\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#\\\/schema\\\/person\\\/8ecae69a21d0757bdb2f776e67d2645e\"},\"headline\":\"Apache Flink Pocket Book\",\"datePublished\":\"2025-08-09T16:55:31+00:00\",\"dateModified\":\"2025-08-28T13:09:59+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/\"},\"wordCount\":469,\"publisher\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#organization\"},\"image\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2025\\\/08\\\/Apache-Flink-1024x576.jpg\",\"articleSection\":[\"Apache Flink\",\"Pocket Book\"],\"inLanguage\":\"en-US\"},{\"@type\":\"WebPage\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/\",\"url\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/\",\"name\":\"Apache Flink Pocket Book | Uplatz Blog\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#website\"},\"primaryImageOfPage\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#primaryimage\"},\"image\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2025\\\/08\\\/Apache-Flink-1024x576.jpg\",\"datePublished\":\"2025-08-09T16:55:31+00:00\",\"dateModified\":\"2025-08-28T13:09:59+00:00\",\"breadcrumb\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#breadcrumb\"},\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/\"]}]},{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#primaryimage\",\"url\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2025\\\/08\\\/Apache-Flink.jpg\",\"contentUrl\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2025\\\/08\\\/Apache-Flink.jpg\",\"width\":1280,\"height\":720},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/apache-flink-pocket-book\\\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Apache Flink Pocket Book\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#website\",\"url\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/\",\"name\":\"Uplatz Blog\",\"description\":\"Uplatz is a global IT Training &amp; Consulting company\",\"publisher\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#organization\"},\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"en-US\"},{\"@type\":\"Organization\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#organization\",\"name\":\"uplatz.com\",\"url\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/\",\"logo\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#\\\/schema\\\/logo\\\/image\\\/\",\"url\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2016\\\/11\\\/Uplatz-Logo-Copy-2.png\",\"contentUrl\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/wp-content\\\/uploads\\\/2016\\\/11\\\/Uplatz-Logo-Copy-2.png\",\"width\":1280,\"height\":800,\"caption\":\"uplatz.com\"},\"image\":{\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#\\\/schema\\\/logo\\\/image\\\/\"},\"sameAs\":[\"https:\\\/\\\/www.facebook.com\\\/Uplatz-1077816825610769\\\/\",\"https:\\\/\\\/x.com\\\/uplatz_global\",\"https:\\\/\\\/www.instagram.com\\\/\",\"https:\\\/\\\/www.linkedin.com\\\/company\\\/7956715?trk=tyah&amp;amp;amp;amp;trkInfo=clickedVertical:company,clickedEntityId:7956715,idx:1-1-1,tarId:1464353969447,tas:uplatz\"]},{\"@type\":\"Person\",\"@id\":\"https:\\\/\\\/uplatz.com\\\/blog\\\/#\\\/schema\\\/person\\\/8ecae69a21d0757bdb2f776e67d2645e\",\"name\":\"uplatzblog\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g\",\"url\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g\",\"contentUrl\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g\",\"caption\":\"uplatzblog\"}}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Apache Flink Pocket Book | Uplatz Blog","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/","og_locale":"en_US","og_type":"article","og_title":"Apache Flink Pocket Book | Uplatz Blog","og_description":"Apache Flink Pocket Book Low-latency streaming \u2022 Stateful processing \u2022 Time &amp; windows \u2022 Checkpoints &amp; savepoints \u2022 CEP \u2022 Connectors \u2022 Deploy &amp; tune Section 1 \u2014 Fundamentals 1) Read More ...","og_url":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/","og_site_name":"Uplatz Blog","article_publisher":"https:\/\/www.facebook.com\/Uplatz-1077816825610769\/","article_published_time":"2025-08-09T16:55:31+00:00","article_modified_time":"2025-08-28T13:09:59+00:00","og_image":[{"width":1280,"height":720,"url":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink.jpg","type":"image\/jpeg"}],"author":"uplatzblog","twitter_card":"summary_large_image","twitter_creator":"@uplatz_global","twitter_site":"@uplatz_global","twitter_misc":{"Written by":"uplatzblog","Est. reading time":"3 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#article","isPartOf":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/"},"author":{"name":"uplatzblog","@id":"https:\/\/uplatz.com\/blog\/#\/schema\/person\/8ecae69a21d0757bdb2f776e67d2645e"},"headline":"Apache Flink Pocket Book","datePublished":"2025-08-09T16:55:31+00:00","dateModified":"2025-08-28T13:09:59+00:00","mainEntityOfPage":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/"},"wordCount":469,"publisher":{"@id":"https:\/\/uplatz.com\/blog\/#organization"},"image":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#primaryimage"},"thumbnailUrl":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-1024x576.jpg","articleSection":["Apache Flink","Pocket Book"],"inLanguage":"en-US"},{"@type":"WebPage","@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/","url":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/","name":"Apache Flink Pocket Book | Uplatz Blog","isPartOf":{"@id":"https:\/\/uplatz.com\/blog\/#website"},"primaryImageOfPage":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#primaryimage"},"image":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#primaryimage"},"thumbnailUrl":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink-1024x576.jpg","datePublished":"2025-08-09T16:55:31+00:00","dateModified":"2025-08-28T13:09:59+00:00","breadcrumb":{"@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#breadcrumb"},"inLanguage":"en-US","potentialAction":[{"@type":"ReadAction","target":["https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/"]}]},{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#primaryimage","url":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink.jpg","contentUrl":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2025\/08\/Apache-Flink.jpg","width":1280,"height":720},{"@type":"BreadcrumbList","@id":"https:\/\/uplatz.com\/blog\/apache-flink-pocket-book\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/uplatz.com\/blog\/"},{"@type":"ListItem","position":2,"name":"Apache Flink Pocket Book"}]},{"@type":"WebSite","@id":"https:\/\/uplatz.com\/blog\/#website","url":"https:\/\/uplatz.com\/blog\/","name":"Uplatz Blog","description":"Uplatz is a global IT Training &amp; Consulting company","publisher":{"@id":"https:\/\/uplatz.com\/blog\/#organization"},"potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/uplatz.com\/blog\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"en-US"},{"@type":"Organization","@id":"https:\/\/uplatz.com\/blog\/#organization","name":"uplatz.com","url":"https:\/\/uplatz.com\/blog\/","logo":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/uplatz.com\/blog\/#\/schema\/logo\/image\/","url":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2016\/11\/Uplatz-Logo-Copy-2.png","contentUrl":"https:\/\/uplatz.com\/blog\/wp-content\/uploads\/2016\/11\/Uplatz-Logo-Copy-2.png","width":1280,"height":800,"caption":"uplatz.com"},"image":{"@id":"https:\/\/uplatz.com\/blog\/#\/schema\/logo\/image\/"},"sameAs":["https:\/\/www.facebook.com\/Uplatz-1077816825610769\/","https:\/\/x.com\/uplatz_global","https:\/\/www.instagram.com\/","https:\/\/www.linkedin.com\/company\/7956715?trk=tyah&amp;amp;amp;amp;trkInfo=clickedVertical:company,clickedEntityId:7956715,idx:1-1-1,tarId:1464353969447,tas:uplatz"]},{"@type":"Person","@id":"https:\/\/uplatz.com\/blog\/#\/schema\/person\/8ecae69a21d0757bdb2f776e67d2645e","name":"uplatzblog","image":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/secure.gravatar.com\/avatar\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g","url":"https:\/\/secure.gravatar.com\/avatar\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/7f814c72279199f59ded4418a8653ad15f5f8904ac75e025a4e2abe24d58fa5d?s=96&d=mm&r=g","caption":"uplatzblog"}}]}},"_links":{"self":[{"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/posts\/4488","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/comments?post=4488"}],"version-history":[{"count":2,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/posts\/4488\/revisions"}],"predecessor-version":[{"id":4949,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/posts\/4488\/revisions\/4949"}],"wp:attachment":[{"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/media?parent=4488"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/categories?post=4488"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/uplatz.com\/blog\/wp-json\/wp\/v2\/tags?post=4488"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}