(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 ... 436437438439440441442 ... 783

Topics (27402)

Replies

Last Post

Views

[jira] [Created] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly community update #38 by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10355) The order of the column should start from 1. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10354) Savepoints should be counted as retained checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10352) Bind Task's URLClassLoader to TaskExecutor's slot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

spring boot application load to flink 1.5.1 by flink-stgo-qba

by Till Rohrmann

[jira] [Created] (FLINK-10351) Ignore specific operator's state when restore from savepoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10350) Add assignTimestampsAndWatermarks in KeyedStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10349) Unify stopActor* utils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10348) Solve data skew when consuming data from kafka by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10347) Kafka09SecuredRunITCase failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kinesis connector shard discovery mechanism by Евгений Юшин

by Ying Xu-2

[jira] [Created] (FLINK-10344) Rethink SubmittedJobGraphListener by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10345) Rethink SubmittedJobGraphListener by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10343) Expose setCurrentKey method to streamRuntimeContext by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10342) Kafka duplicate topic consumption when topic name is changed by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10341) Add option to print flink command when running bin/flink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10340) Implement Cosh udf by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10338) Use ZooKeeperStateStore in ZooKeeperMesosWorkerStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10337) Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10336) Use ZooKeeperStateStore in ZooKeeperSubmittedJobGraphStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10335) Create common ZooKeeperStateStore based on ZooKeeperStateHandleStore and RetrievableStateStorageHelper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10334) Move RetrievableStateStorageHelper out of ZooKeeperStateHandleStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10332) Move data available notification in PipelinedSubpartition out of the synchronized block by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10331) Fix unnecessary flush requests to the network stack by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10330) Code Compilation failed in local mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10329) Fail with exception if job cannot be removed by ZooKeeperSubmittedJobGraphStore#removeJobGraph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10328) Stopping the ZooKeeperSubmittedJobGraphStore should release all currently held locks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10326) Simplify ZooKeeperSubmittedJobGraphStore constructor by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 436437438439440441442 ... 783