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

Topics (27402)

Replies

Last Post

Views

[jira] [Created] (FLINK-10150) Inconsistent number of "Records received" / "Records sent" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10147) numBytesOut metric lagging behind by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10146) numBuffersOut not updated properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Weekly community update #33 by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-10145) Add replace supported in TableAPI and SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10143) date_format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10142) Reduce synchronization overhead for credit notifications by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10141) Reduce lock contention introduced with 1.5 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10140) Log files are not available via web UI in containerized environment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10139) Update migration tests for 1.6 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10138) Queryable state (rocksdb) end-to-end test failed on Travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10137) YARN: Log completed Containers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] Outer join support and timestamp assignment for IntervalJoin by Florian Schmidt

by Fabian Hueske-2

[jira] [Created] (FLINK-10136) Add REPEAT supported in Table API and SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10135) The JobManager doesn't report the cluster-level metrics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10134) UTF-16 support for TextInputFormat by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Discuss] FLIP-26 - SSL Mutual Authentication by Eron Wright-2

by Stephan Ewen

[jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10128) Timeout on transfering jars on travis-ci by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10127) Add TypeInformation and serializers for JDK7 Instant by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10126) There should be a Scala DataSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10124) Use ByteArrayDataInput/OutputView instead of stream + wrapper by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Request contribution permission by 邓林

by Timo Walther-2

[jira] [Created] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10121) Introduce methods to remove registered operator states by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10120) Support string representation for types like array by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 443444445446447448449 ... 783