(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 ... 607608609610611612613 ... 780

Topics (27278)

Replies

Last Post

Views

[jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5023) Add get() method in State interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FLIP-6 and running many "small" jobs by Maciek Próchniak

by Maciek Próchniak

Hadoop Summit EU 2017 by Alan Gates-2

by Alan Gates-2

[jira] [Created] (FLINK-5022) Suppress RejectedExecutionException when the Executor is shut down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

"Cannot resolve map" by Thomas FOURNIER

by Till Rohrmann

[jira] [Created] (FLINK-5019) Proper isRestored result for tasks that did not write state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5018) User configurable source idle timeout to work with WatermarkStatus emitting by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

RideCleansingToKafka Filter Parameter Type by daviD

by daviD

WindowRunner? by Radu Tudoran

by Radu Tudoran

[jira] [Created] (FLINK-5016) EventTimeWindowCheckpointingITCase testTumblingTimeWindowWithKVStateMaxMaxParallelism with RocksDB hangs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5014) RocksDBStateBackend misses good toString by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5012) Provide Timestamp in TimelyFlatMapFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Disabling Jenkins for PRs by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5010) Decouple the death watch parameters from the Akka ask timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5009) FS checkpoints leave empty directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5008) Update IDE setup documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5007) Retain externalized checkpoint on suspension by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5006) SystemProcessingTimeServiceTest.testTimerSorting fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5005) Publish Scala 2.12 artifacts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5004) Add task manager option to disable queryable state server by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5003) Provide Access to State Stores in Operator Snapshot Context by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] FLIP-2 Extending Window Function Metadata by Aljoscha Krettek-2

by Manu Zhang

[jira] [Created] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5000) Rename Methods in ManagedInitializationContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4999) Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-4997) Extending Window Function Metadata by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 607608609610611612613 ... 780