(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 481482483484485486487 ... 783

Topics (27400)

Replies

Last Post

Views

[jira] [Created] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9017) FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Correct way to reference Hadoop dependencies in Flink 1.4.0 by lrao@lyft.com

by Deepak Jha

[jira] [Created] (FLINK-9016) Unregister jobs from JobMetricGroup after termination by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9015) Upgrade Calcite dependency to 1.17 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Yarn deployment takes long on some networks by Gyula Fóra

by Gyula Fóra

[jira] [Created] (FLINK-9014) Adapt BackPressureStatsTracker to work with credit-based flow control by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9012) Shaded Hadoop S3A end-to-end test failing with S3 bucket in Ireland by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9011) YarnResourceManager spamming log file at INFO level by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9010) NoResourceAvailableException with FLIP-6 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Flink 1.5 release testing effort by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-9009) Error| You are creating too many HashedWheelTimer instances. HashedWheelTimer is a shared resource that must be reused across the application, so that only a few instances are created. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9008) End-to-end test: Quickstarts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9007) Cluster test: Kinesis connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9006) Cluster test: Run general purpose job with failures with Yarn and per-job mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9005) Cluster test: Run general purpose job with failures with Mesos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9004) Cluster test: Run general purpose job with failures with Yarn session by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9003) Add operators with input type that goes through custom, stateful serialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9000) Add automated cluster framework tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8999) Ensure the job has an operator with operator state. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8997) Add sliding window aggregation to the job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8996) Include an operator with broadcast and union state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8992) Implement source and operator that validate exactly-once by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8991) End-to-end test: Ganglia metrics reporter by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8989) End-to-end test: ElasticSearch connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8988) End-to-end test: Cassandra connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-8987) End-to-end test: Avro state evolution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 481482483484485486487 ... 783