Public signup for this instance is disabled. Go to our Self serve sign up page to request an account. Report potential security issues privately

  1. Sub-task FLINK-10863
    Assign uids to all operators
  2. Sub-task FLINK-9322
    Add exception throwing map function that simulates failures to the general purpose DataStream job
  3. Sub-task FLINK-9003
    Add operators with input type that goes through custom, stateful serialization
  4. Sub-task FLINK-9002
    Add operators with input type that goes through Avro serialization (with schema/generic)
  5. Sub-task FLINK-9001
    Add operators with input type that goes through Kryo serialization (registered/generic/custom)
  6. Sub-task FLINK-8999
    Ensure the job has an operator with operator state.
  7. Sub-task FLINK-8998
    Add user-defined watermark assigner and timestamp extractor to the test job
  8. Sub-task FLINK-8997
    Add sliding window aggregation to the job
  9. Sub-task FLINK-8996
    Include an operator with broadcast and union state
  10. Sub-task FLINK-8995
    Add a test operator with keyed state that uses custom, stateful serializer
  11. Sub-task FLINK-8994
    Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)
  12. Sub-task FLINK-8993
    Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)
  13. Sub-task FLINK-8992
    Implement source and operator that validate exactly-once
Refresh results