[jira] [Created] (FLINK-20141) Add documentation about the FileSink

Kostas Kloudas created FLINK-20141: -- Summary: Add documentation about the FileSink Key: FLINK-20141 URL: https://issues.apache.org/jira/browse/FLINK-20141 Project: Flink Issue Type:

[jira] [Created] (FLINK-20140) Add documentation of TableResult.collect for Python Table API

Dian Fu created FLINK-20140: --- Summary: Add documentation of TableResult.collect for Python Table API Key: FLINK-20140 URL: https://issues.apache.org/jira/browse/FLINK-20140 Project: Flink Issue

[DISCUSS] Proposal: New feature of flink window UDF

Hi all Currently, flink only supports limited window functions like TUMBLE, HOP, SESSION. They are very useful in many use cases but sometimes cannot meet business requirements which need a more complicated window logic. Here are some requirements which cannot be satisfied by the current window

[jira] [Created] (FLINK-20139) Enrich logs when MiniDispatcher shutting down

Zili Chen created FLINK-20139: - Summary: Enrich logs when MiniDispatcher shutting down Key: FLINK-20139 URL: https://issues.apache.org/jira/browse/FLINK-20139 Project: Flink Issue Type:

[jira] [Created] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

wgcn created FLINK-20138: Summary: Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted Key: FLINK-20138 URL: https://issues.apache.org/jira/browse/FLINK-20138

unsubscribe mail

Hello, I want to unsubscribe email. | | Ge Ge Software Engineer | | gg13871077...@163.com | 签名由网易邮箱大师定制

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

Shuiqiang Chen created FLINK-20137: -- Summary: User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API Key: FLINK-20137 URL:

[jira] [Created] (FLINK-20136) Test all other aspects of new features added in PyFlink

Dian Fu created FLINK-20136: --- Summary: Test all other aspects of new features added in PyFlink Key: FLINK-20136 URL: https://issues.apache.org/jira/browse/FLINK-20136 Project: Flink Issue Type:

[jira] [Created] (FLINK-20135) Test Python DataStream API

Dian Fu created FLINK-20135: --- Summary: Test Python DataStream API Key: FLINK-20135 URL: https://issues.apache.org/jira/browse/FLINK-20135 Project: Flink Issue Type: Task Components: API

[jira] [Created] (FLINK-20134) Test non-vectorized Python UDAF

Dian Fu created FLINK-20134: --- Summary: Test non-vectorized Python UDAF Key: FLINK-20134 URL: https://issues.apache.org/jira/browse/FLINK-20134 Project: Flink Issue Type: Task Components:

[jira] [Created] (FLINK-20133) Test Pandas UDAF

Dian Fu created FLINK-20133: --- Summary: Test Pandas UDAF Key: FLINK-20133 URL: https://issues.apache.org/jira/browse/FLINK-20133 Project: Flink Issue Type: Task Components: API / Python

[jira] [Created] (FLINK-20132) Test PyFlink new features

Dian Fu created FLINK-20132: --- Summary: Test PyFlink new features Key: FLINK-20132 URL: https://issues.apache.org/jira/browse/FLINK-20132 Project: Flink Issue Type: Sub-task Components:

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

Thilo Schneider created FLINK-20131: --- Summary: Error when using LAST_VALUE on two different datatypes in same query with over window Key: FLINK-20131 URL: https://issues.apache.org/jira/browse/FLINK-20131

[jira] [Created] (FLINK-20130) Add ZStandard format to inputs

João Boto created FLINK-20130: - Summary: Add ZStandard format to inputs Key: FLINK-20130 URL: https://issues.apache.org/jira/browse/FLINK-20130 Project: Flink Issue Type: Improvement

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

Dawid Wysakowicz created FLINK-20129: Summary: Create a zh download page for all optional sql client components Key: FLINK-20129 URL: https://issues.apache.org/jira/browse/FLINK-20129 Project:

[jira] [Created] (FLINK-20128) Data loss for over windows with rows unbounded preceding

Thilo Schneider created FLINK-20128: --- Summary: Data loss for over windows with rows unbounded preceding Key: FLINK-20128 URL: https://issues.apache.org/jira/browse/FLINK-20128 Project: Flink

[jira] [Created] (FLINK-20127) Benchmark unaligned checkpointing times under backpressure

Arvid Heise created FLINK-20127: --- Summary: Benchmark unaligned checkpointing times under backpressure Key: FLINK-20127 URL: https://issues.apache.org/jira/browse/FLINK-20127 Project: Flink

[jira] [Created] (FLINK-20123) Test native support of PyFlink on Kubernetes

Robert Metzger created FLINK-20123: -- Summary: Test native support of PyFlink on Kubernetes Key: FLINK-20123 URL: https://issues.apache.org/jira/browse/FLINK-20123 Project: Flink Issue Type:

[jira] [Created] (FLINK-20125) Test memory configuration display in the web ui

Robert Metzger created FLINK-20125: -- Summary: Test memory configuration display in the web ui Key: FLINK-20125 URL: https://issues.apache.org/jira/browse/FLINK-20125 Project: Flink Issue

[jira] [Created] (FLINK-20126) Test non-blocking job submission

Robert Metzger created FLINK-20126: -- Summary: Test non-blocking job submission Key: FLINK-20126 URL: https://issues.apache.org/jira/browse/FLINK-20126 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20124) Test pipelined region scheduler

Robert Metzger created FLINK-20124: -- Summary: Test pipelined region scheduler Key: FLINK-20124 URL: https://issues.apache.org/jira/browse/FLINK-20124 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20122) Test Small file compaction

Robert Metzger created FLINK-20122: -- Summary: Test Small file compaction Key: FLINK-20122 URL: https://issues.apache.org/jira/browse/FLINK-20122 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20121) Test the upsert-kafka Connector

Robert Metzger created FLINK-20121: -- Summary: Test the upsert-kafka Connector Key: FLINK-20121 URL: https://issues.apache.org/jira/browse/FLINK-20121 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join

Robert Metzger created FLINK-20119: -- Summary: Test Temporal Table DDL and Temporal Table Join Key: FLINK-20119 URL: https://issues.apache.org/jira/browse/FLINK-20119 Project: Flink Issue

[jira] [Created] (FLINK-20120) Test Handling of metadata in SQL connectors

Robert Metzger created FLINK-20120: -- Summary: Test Handling of metadata in SQL connectors Key: FLINK-20120 URL: https://issues.apache.org/jira/browse/FLINK-20120 Project: Flink Issue Type:

[jira] [Created] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

Robert Metzger created FLINK-20118: -- Summary: Test New File Source API - Continuous Streaming Execution Key: FLINK-20118 URL: https://issues.apache.org/jira/browse/FLINK-20118 Project: Flink

[jira] [Created] (FLINK-20116) Test Intra-Slot Managed Memory Sharing

Robert Metzger created FLINK-20116: -- Summary: Test Intra-Slot Managed Memory Sharing Key: FLINK-20116 URL: https://issues.apache.org/jira/browse/FLINK-20116 Project: Flink Issue Type:

[jira] [Created] (FLINK-20117) Flink on Mesos Deployment

Robert Metzger created FLINK-20117: -- Summary: Flink on Mesos Deployment Key: FLINK-20117 URL: https://issues.apache.org/jira/browse/FLINK-20117 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20114) Test Kafka Source based on the new Source API 

Robert Metzger created FLINK-20114: -- Summary: Test Kafka Source based on the new Source API  Key: FLINK-20114 URL: https://issues.apache.org/jira/browse/FLINK-20114 Project: Flink Issue

[jira] [Created] (FLINK-20115) Test Batch execution for the DataStream API 

Robert Metzger created FLINK-20115: -- Summary: Test Batch execution for the DataStream API  Key: FLINK-20115 URL: https://issues.apache.org/jira/browse/FLINK-20115 Project: Flink Issue Type:

[jira] [Created] (FLINK-20113) Test K8s High Availability Service

Robert Metzger created FLINK-20113: -- Summary: Test K8s High Availability Service Key: FLINK-20113 URL: https://issues.apache.org/jira/browse/FLINK-20113 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20112) Test Flink 1.12 release

Robert Metzger created FLINK-20112: -- Summary: Test Flink 1.12 release Key: FLINK-20112 URL: https://issues.apache.org/jira/browse/FLINK-20112 Project: Flink Issue Type: Task Affects

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

hailong wang created FLINK-20111: Summary: Update the description of UDAF `merge` method in User-defined function document Key: FLINK-20111 URL: https://issues.apache.org/jira/browse/FLINK-20111

[jira] [Created] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

hailong wang created FLINK-20110: Summary: Support 'merge' method for first_value and last_value UDAF Key: FLINK-20110 URL: https://issues.apache.org/jira/browse/FLINK-20110 Project: Flink

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

xuhaoran created FLINK-20109: Summary: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer Key: FLINK-20109 URL: https://issues.apache.org/jira/browse/FLINK-20109

[jira] [Created] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

Jiangjie Qin created FLINK-20108: Summary: SingleThreadFetcherManager may add splits to a shutting down SplitFetcher Key: FLINK-20108 URL: https://issues.apache.org/jira/browse/FLINK-20108 Project:

[jira] [Created] (FLINK-20107) Issues with setting InputChannel.statePersister

Roman Khachatryan created FLINK-20107: - Summary: Issues with setting InputChannel.statePersister Key: FLINK-20107 URL: https://issues.apache.org/jira/browse/FLINK-20107 Project: Flink

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

赵富午 created FLINK-20106: --- Summary: flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了 Key: FLINK-20106 URL:

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

Benoît Paris created FLINK-20105: Summary: Temporary Table does not work when Kafka is used as the versioned side (planner PK problem) Key: FLINK-20105 URL: https://issues.apache.org/jira/browse/FLINK-20105

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

Nico Kruber created FLINK-20104: --- Summary: Web UI checkpoint stats "refresh" button has to be clicked twice Key: FLINK-20104 URL: https://issues.apache.org/jira/browse/FLINK-20104 Project: Flink

[jira] [Created] (FLINK-20103) Improve test coverage for network stack

Roman Khachatryan created FLINK-20103: - Summary: Improve test coverage for network stack Key: FLINK-20103 URL: https://issues.apache.org/jira/browse/FLINK-20103 Project: Flink Issue

[jira] [Created] (FLINK-20102) Update HBase connector documentation for HBase 2.x supporting

Jark Wu created FLINK-20102: --- Summary: Update HBase connector documentation for HBase 2.x supporting Key: FLINK-20102 URL: https://issues.apache.org/jira/browse/FLINK-20102 Project: Flink Issue