(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 ... 564565566567568569570 ... 781

Topics (27306)

Replies

Last Post

Views

[jira] [Created] (FLINK-6348) Migrate from Java serialization for RollingSink's state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6346) Migrate from Java serialization for GenericWriteAheadSink's state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6345) Migrate from Java serialization for ContinuousFileReaderOperator's state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6344) Migrate from Java serialization for `BucketingSink`'s state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6342) Start ZooKeeperLeaderElectionService under lock to avoid race condition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6341) JobManager can go to definite message sending loop when TaskManager registered by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6340) Introduce a TerminationFuture for Execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6339) Remove useless and unused class ConnectorSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6338) SimpleStringUtils should be called StringValueUtils by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6336) Placement Constraints for Mesos by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6335) Support DISTINCT over grouped window in stream SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6334) Refactoring UDTF interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6333) Utilize Bloomfilters in RocksDb by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Read from and Write to Kafka through flink by Pradeep Anumala

by Pradeep Anumala

[jira] [Created] (FLINK-6332) Upgrade Scala version to 2.11.11 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6331) StreamingOperatorsITCase.testAsyncWaitOperator spuriously failing on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6330) Improve Docker documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6329) refactor name-addressable accessors in BlobService classes from returning a URL to a File or InputStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6328) Savepoints must not be counted as retained checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6327) Bug in CommonCalc's estimateRowCount() method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6326) add ProjectMergeRule at logical optimization stage by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6325) Refinement of slot reuse for task manager failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6324) Refine state access methods in OperatorStateStore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Rescaling state by Vishnu Viswanath

by Aljoscha Krettek-2

[jira] [Created] (FLINK-6323) Add new Sink interface with access to more meta data by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6322) Mesos task labels by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeydCEP. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6319) Add timeout when shutting SystemProcessingTimeService down by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6317) History server - wrong default directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 564565566567568569570 ... 781