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

Topics (27681)

Replies

Last Post

Views

[jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Kafka Sink stuck in cancelling by Gyula Fóra-2

by Gyula Fóra

[DISCUSS] Merge batch and stream connector modules by Fabian Hueske-2

by mxm

[VOTE] Release Apache Flink 1.1.4 (RC1) by Ufuk Celebi-2

by Ufuk Celebi-2

[jira] [Created] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5121) Integrate YARN application ID with web interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5120) Show TM PID in web frontend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5118) Inconsistent records sent/received metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5117) Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5116) Missing RocksDB state backend factory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5115) Minimum time between checkpoints computed from trigger timestamp by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5114) PartitionState update with finished execution fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5113) Make all the testing Functions implement the CheckpointedFucntion interface. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5112) Remove unused accumulator code from ArchivedExecutionJobVertex by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5109) Invalid Content-Encoding Header in REST API responses by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5108) Remove ClientShutdownHook during job execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5106) improving IncrementalAggregateReduceFunction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5104) Implement BipartiteGraph validator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] State Backend use external HBase storage by shijinkui

by chenqin

[jira] [Created] (FLINK-5103) Process virtual memory and physical memory used size gauge by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5102) Connection establishment does not react to interrupt by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5101) Test CassandraConnectorITCase instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5100) Test testZooKeeperReelection is instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5099) Test testCancelPartitionRequest is instable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5098) Detect network problems to eagerly time out ask operations by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5096) Make the RollingSink rescalable. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 615616617618619620621 ... 791