What are the responsibilities and job description for the Senior Java Developer with Apache Flink position at Byteware Inc.?
Job Details
Senior Java Developer with Apache Flink***
St. Louis - O'Fallon, MO (Hybrid)
12 Months
Core Skills: Cloud Native, event-driven, distributed systems Java / Spring Boot Reactive Architecture [NOT React.JS]. e.g. Project Reactor, Spring WebFlux, Vert.x, etc. Real-time streaming data - Kafka/Confluent OR AWS Kinesis OR similar Apache Flink - both from a development and infra perspective.
For example:
*Core Concepts*
*Stream vs. Batch Processing* (Flink treats batch as a special case of streaming)
*Dataflow Architecture* (Operators, tasks, job graphs, execution graphs)
*Time Semantics* - Event Time, Processing Time, Ingestion Time - Watermarks and their generation
*Flink Development (Programming Model)*
*DataStream API* (core API for stream processing)
*DataSet API* (deprecated but still in legacy projects)
*Table & SQL API* (important for declarative querying)
*State Management* - Keyed state vs. operator state - State backends (RocksDB, heap, etc.)
*Timers & Process Functions* - ProcessFunction, KeyedProcessFunction, BroadcastProcessFunction
*Windowing* - Tumbling, sliding, session windows - Triggers, evictors, allowed lateness
*Connectors* - Kafka, JDBC, Elasticsearch, Kinesis, etc
. *Serialization & Type Information* - POJOs, Avro, Protobuf, custom serializers
*Fault Tolerance & Checkpointing* - Exactly-once vs. at-least-once - Checkpoint barriers, savepoints ---
*Flink Infrastructure / Operations*
*Cluster Architecture* - Job Manager, Task Managers, Resource Manager
*Deployment Modes* - Standalone, YARN, Kubernetes, Mesos
*State Backends & Savepoints* - Rocks DB tuning, heap state, incremental checkpoints
*High Availability (HA) Setup* - ZooKeeper-based or Kubernetes-native
*Monitoring & Metrics* - Prometheus integration, Flink UI, logs
*Resource Management* - Task slots, parallelism, operator chaining, CPU/memory tuning
*Scaling & Resilience* - Horizontal scaling strategies - Savepoint-based upgrades
*Security* - TLS, Kerberos, Flink ACLs
*Advanced Topics*
*Async I/O* (e.g. database access in stream pipelines)
*Broadcast State & Dynamic Config Updates*
*Backpressure Handling*
*Latency vs. Throughput Trade-offs*
*Flink SQL Optimizer (Calcite-based)*
*Integration with Data Lakes and Catalogs* (Hive, Iceberg, etc.)
*Testing & Debugging*
Unit and integration tests with mini-cluster
State snapshot testing
Debugging complex pipelines with Flink UI & logs
Helpful Ecosystem Tools*
*Flink SQL Client / CLI*
*Apache Beam (if working with unified model)*
*Apache Kafka (for streaming pipelines)*
*MinIO / S3 (for state & checkpoint storage)
Employers have access to artificial intelligence language tools (“AI”) that help generate and enhance job descriptions and AI may have been used to create this description. The position description has been reviewed for accuracy and Dice believes it to correctly reflect the job opportunity.
