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

Topics (27278)

Replies

Last Post

Views

[jira] [Created] (FLINK-6354) Add documentation for migration away from Checkpointed interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Planning Release 1.3 by Robert Metzger

by Kostas Kloudas

[jira] [Created] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 563564565566567568569 ... 780