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

Topics (27402)

Replies

Last Post

Views

[jira] [Created] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10204) Job is marked as FAILED after serialization exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Support Hadoop 2.6 for StreamingFileSink by Artsem Semianenka

by Artsem Semianenka

[jira] [Created] (FLINK-10203) HadoopRecoverableWriter does not support Hadoop by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Allowed lateness for coGroup/join operators by Евгений Юшин

by Евгений Юшин

[jira] [Created] (FLINK-10202) Enable configuration for state.checkpoint.dir with environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Proposal] Utilities for reading, transforming and creating Streaming savepoints by Gyula Fóra

by Hequn Cheng

[jira] [Created] (FLINK-10200) Consolidate FileBasedStateOutputStream and FsCheckpointStateOutputStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10199) StandaloneSessionClusterEntrypoint does not respect host/ui-port given from jobmanager.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Side effect of DataStreamRel#translateToPlan by wangsan

by Hequn Cheng

[jira] [Created] (FLINK-10198) Set Env object in DBOptions for RocksDB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10197) flink CEP error when use sql by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10196) API to test streaming pipelines with windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly community update #34 by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10194) Serialization issue with Scala's AggregateDataSet[Row] by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10192) SQL Client table visualization mode does not update correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10191) WindowCheckpointingITCase.testAggregatingSlidingProcessingTimeWindow by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Flink 1.5.3 released by Chesnay Schepler-3

by Till Rohrmann

[jira] [Created] (FLINK-10190) Unable to use custom endpoint in Kinesis producer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Release 1.5.3, release candidate #1 by Chesnay Schepler-3

by Chesnay Schepler-3

[Discussion] Move cluster creation functions from flink-cli.sh to other scripts by Renjie Liu

by Till Rohrmann

[jira] [Created] (FLINK-10189) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Change the Keyed partitioning behavior of the Kafka Producer API by Niels Basjes

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-10188) Solve nondeterministic functions problem for retraction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10186) FindBugs warnings: Random object created and used only once by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10185) Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Flink checkpointing to Google Cloud Storage by Oleksandr Serdiukov

by Oleksandr Serdiukov

[jira] [Created] (FLINK-10182) AsynchronousBufferFileWriterTest deadlocks on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10181) Add anchor link to individual rest requests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 441442443444445446447 ... 783