(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 ... 614615616617618619620 ... 791

Topics (27681)

Replies

Last Post

Views

[jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5153) Allow setting custom application tags for Flink on YARN by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5152) accepting NullValue for EV in Gelly examples by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

FOSDEM 2017 HPC, Bigdata and Data Science DevRoom CFP is closing soon by Roman Shaposhnik-2

by Roman Shaposhnik-2

[DISCUSS] Hold copies in HeapStateBackend by Fabian Hueske-2

by Fabian Hueske-2

[jira] [Created] (FLINK-5151) Add discussion about object mutations to heap-based state backend docs. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5150) WebUI metric-related resource leak by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Very wide csv files by Anton Solovev

by Flavio Pompermaier

[jira] [Created] (FLINK-5149) ContinuousEventTimeTrigger doesn't fire at the end of the window by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5148) LocalFileSystem#delete can fail with NullpointerException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5145) WebInterface to aggressive in pulling metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5143) Add EXISTS to list of supported operators by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5142) Resource leak in CheckpointCoordinator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5141) Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5139) consum kafka can set offset by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5138) The StateBackend provides the method to estimate memory usage based on hint of state size in ResourceSpec by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5137) Config JVM options and set onto the TaskManager container by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5136) ResourceManager should consider both slot resource profile and framework memory for requesting resource from cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5135) ResourceProfile should be expanded to correspond with ResourceSpec by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5134) Aggregate ResourceSpe for chained operators when generating stream graph by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5133) Add new setResource API for DataStream and DataSet by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5132) Introduce the ResourceSpec for grouping different resource factors in API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5131) Fine-grained Resource Configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5130) Remove Deprecated Methods from WindowedStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5129) make the BlobServer use a distributed file system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5128) Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5126) Remove Checked Exceptions from State Interfaces by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5124) Support more temporal arithmetic by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 614615616617618619620 ... 791