(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 ... 99100101102103104105 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20136) Test all other aspects of new features added in PyFlink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20135) Test Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20134) Test non-vectorized Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20133) Test Pandas UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20132) Test PyFlink new features by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20131) Error when using LAST_VALUE on two different datatypes in same query with over window by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20130) Add ZStandard format to inputs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20129) Create a zh download page for all optional sql client components by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20128) Data loss for over windows with rows unbounded preceding by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20127) Benchmark unaligned checkpointing times under backpressure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20125) Test memory configuration display in the web ui by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20126) Test non-blocking job submission by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20123) Test native support of PyFlink on Kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20124) Test pipelined region scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20122) Test Small file compaction by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20121) Test the upsert-kafka Connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20120) Test Handling of metadata in SQL connectors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20118) Test New File Source API - Continuous Streaming Execution by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20116) Test Intra-Slot Managed Memory Sharing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20117) Flink on Mesos Deployment by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20115) Test Batch execution for the DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20114) Test Kafka Source based on the new Source API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20113) Test K8s High Availability Service by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20112) Test Flink 1.12 release by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20111) Update the description of UDAF `merge` method in User-defined function document by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20107) Issues with setting InputChannel.statePersister by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20106) flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20104) Web UI checkpoint stats "refresh" button has to be clicked twice by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20103) Improve test coverage for network stack by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 99100101102103104105 ... 778