[jira] [Created] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

Juntao Hu created FLINK-35302: - Summary: Flink REST server throws exception on unknown fields in RequestBody Key: FLINK-35302 URL: https://issues.apache.org/jira/browse/FLINK-35302 Project: Flink

[jira] [Created] (FLINK-31328) Greedy option on the looping pattern at the end not working

Juntao Hu created FLINK-31328: - Summary: Greedy option on the looping pattern at the end not working Key: FLINK-31328 URL: https://issues.apache.org/jira/browse/FLINK-31328 Project: Flink Issue

[jira] [Created] (FLINK-31185) Python BroadcastProcessFunction not support side output

Juntao Hu created FLINK-31185: - Summary: Python BroadcastProcessFunction not support side output Key: FLINK-31185 URL: https://issues.apache.org/jira/browse/FLINK-31185 Project: Flink Issue

[jira] [Created] (FLINK-31083) Python ProcessFunction with OutputTag cannot be reused

Juntao Hu created FLINK-31083: - Summary: Python ProcessFunction with OutputTag cannot be reused Key: FLINK-31083 URL: https://issues.apache.org/jira/browse/FLINK-31083 Project: Flink Issue Type:

[jira] [Created] (FLINK-31044) Unexpected behavior using greedy on looping pattern with notFollowedBy at end

Juntao Hu created FLINK-31044: - Summary: Unexpected behavior using greedy on looping pattern with notFollowedBy at end Key: FLINK-31044 URL: https://issues.apache.org/jira/browse/FLINK-31044 Project:

[jira] [Created] (FLINK-31042) AfterMatchSkipStrategy not working on notFollowedBy ended pattern

Juntao Hu created FLINK-31042: - Summary: AfterMatchSkipStrategy not working on notFollowedBy ended pattern Key: FLINK-31042 URL: https://issues.apache.org/jira/browse/FLINK-31042 Project: Flink

[jira] [Created] (FLINK-31040) Looping pattern notFollowedBy at end missing an element

Juntao Hu created FLINK-31040: - Summary: Looping pattern notFollowedBy at end missing an element Key: FLINK-31040 URL: https://issues.apache.org/jira/browse/FLINK-31040 Project: Flink Issue

[jira] [Created] (FLINK-31017) Early-started partial match timeout not yield completed matches

Juntao Hu created FLINK-31017: - Summary: Early-started partial match timeout not yield completed matches Key: FLINK-31017 URL: https://issues.apache.org/jira/browse/FLINK-31017 Project: Flink

[jira] [Created] (FLINK-30981) explain_sql throws java method not exist

Juntao Hu created FLINK-30981: - Summary: explain_sql throws java method not exist Key: FLINK-30981 URL: https://issues.apache.org/jira/browse/FLINK-30981 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30969) Pyflink table example throws "module 'pandas' has no attribute 'Int8Dtype'"

Juntao Hu created FLINK-30969: - Summary: Pyflink table example throws "module 'pandas' has no attribute 'Int8Dtype'" Key: FLINK-30969 URL: https://issues.apache.org/jira/browse/FLINK-30969 Project: Flink

[jira] [Created] (FLINK-30962) Improve error messaging when launching py4j gateway server

Juntao Hu created FLINK-30962: - Summary: Improve error messaging when launching py4j gateway server Key: FLINK-30962 URL: https://issues.apache.org/jira/browse/FLINK-30962 Project: Flink Issue

[jira] [Created] (FLINK-30961) Remove deprecated tests_require in setup.py

Juntao Hu created FLINK-30961: - Summary: Remove deprecated tests_require in setup.py Key: FLINK-30961 URL: https://issues.apache.org/jira/browse/FLINK-30961 Project: Flink Issue Type:

[jira] [Created] (FLINK-30885) Optional group pattern starts with non-optional looping pattern get wrong result on followed-by

Juntao Hu created FLINK-30885: - Summary: Optional group pattern starts with non-optional looping pattern get wrong result on followed-by Key: FLINK-30885 URL: https://issues.apache.org/jira/browse/FLINK-30885

[jira] [Created] (FLINK-30864) Optional pattern at the start of a group pattern not working

Juntao Hu created FLINK-30864: - Summary: Optional pattern at the start of a group pattern not working Key: FLINK-30864 URL: https://issues.apache.org/jira/browse/FLINK-30864 Project: Flink

[jira] [Created] (FLINK-30839) Relaxed looping group pattern make the following strict contiguity relaxed too

Juntao Hu created FLINK-30839: - Summary: Relaxed looping group pattern make the following strict contiguity relaxed too Key: FLINK-30839 URL: https://issues.apache.org/jira/browse/FLINK-30839 Project:

[jira] [Created] (FLINK-30069) Expected prune behavior for matches with same priority

Juntao Hu created FLINK-30069: - Summary: Expected prune behavior for matches with same priority Key: FLINK-30069 URL: https://issues.apache.org/jira/browse/FLINK-30069 Project: Flink Issue Type:

[jira] [Created] (FLINK-29681) Python side-output operator not generated in some cases

Juntao Hu created FLINK-29681: - Summary: Python side-output operator not generated in some cases Key: FLINK-29681 URL: https://issues.apache.org/jira/browse/FLINK-29681 Project: Flink Issue

[jira] [Created] (FLINK-29658) LocalTimeTypeInfo support in DataStream API in PyFlink

Juntao Hu created FLINK-29658: - Summary: LocalTimeTypeInfo support in DataStream API in PyFlink Key: FLINK-29658 URL: https://issues.apache.org/jira/browse/FLINK-29658 Project: Flink Issue Type:

[jira] [Created] (FLINK-29648) "LocalDateTime not supported" error when retrieving Java TypeInformation from PyFlink

Juntao Hu created FLINK-29648: - Summary: "LocalDateTime not supported" error when retrieving Java TypeInformation from PyFlink Key: FLINK-29648 URL: https://issues.apache.org/jira/browse/FLINK-29648

[jira] [Created] (FLINK-29477) ClassCastException when collect primitive array to Python

Juntao Hu created FLINK-29477: - Summary: ClassCastException when collect primitive array to Python Key: FLINK-29477 URL: https://issues.apache.org/jira/browse/FLINK-29477 Project: Flink Issue

[jira] [Created] (FLINK-28908) Coder for LIST type is incorrectly chosen is PyFlink

Juntao Hu created FLINK-28908: - Summary: Coder for LIST type is incorrectly chosen is PyFlink Key: FLINK-28908 URL: https://issues.apache.org/jira/browse/FLINK-28908 Project: Flink Issue Type:

[jira] [Created] (FLINK-28904) Add missing connector/format doc for PyFlink

Juntao Hu created FLINK-28904: - Summary: Add missing connector/format doc for PyFlink Key: FLINK-28904 URL: https://issues.apache.org/jira/browse/FLINK-28904 Project: Flink Issue Type:

[jira] [Created] (FLINK-28895) Eliminate the map to convert RowData to Row before RowData FileSink

Juntao Hu created FLINK-28895: - Summary: Eliminate the map to convert RowData to Row before RowData FileSink Key: FLINK-28895 URL: https://issues.apache.org/jira/browse/FLINK-28895 Project: Flink

[jira] [Created] (FLINK-28880) Fix CEP doc with wrong result of strict contiguity of looping patterns

Juntao Hu created FLINK-28880: - Summary: Fix CEP doc with wrong result of strict contiguity of looping patterns Key: FLINK-28880 URL: https://issues.apache.org/jira/browse/FLINK-28880 Project: Flink

[jira] [Created] (FLINK-28876) Support writing RowData to Orc files in PyFlink

Juntao Hu created FLINK-28876: - Summary: Support writing RowData to Orc files in PyFlink Key: FLINK-28876 URL: https://issues.apache.org/jira/browse/FLINK-28876 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28862) Support writing RowData to Parquet files in PyFlink

Juntao Hu created FLINK-28862: - Summary: Support writing RowData to Parquet files in PyFlink Key: FLINK-28862 URL: https://issues.apache.org/jira/browse/FLINK-28862 Project: Flink Issue Type:

[jira] [Created] (FLINK-28827) Complete DataType support in DataStream API for PyFlink

Juntao Hu created FLINK-28827: - Summary: Complete DataType support in DataStream API for PyFlink Key: FLINK-28827 URL: https://issues.apache.org/jira/browse/FLINK-28827 Project: Flink Issue

[jira] [Created] (FLINK-28782) Support FileSink compaction in PyFlink

Juntao Hu created FLINK-28782: - Summary: Support FileSink compaction in PyFlink Key: FLINK-28782 URL: https://issues.apache.org/jira/browse/FLINK-28782 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28762) Support AvroParquetWriters in PyFlink

Juntao Hu created FLINK-28762: - Summary: Support AvroParquetWriters in PyFlink Key: FLINK-28762 URL: https://issues.apache.org/jira/browse/FLINK-28762 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28740) Support CsvBulkWriter in PyFlink

Juntao Hu created FLINK-28740: - Summary: Support CsvBulkWriter in PyFlink Key: FLINK-28740 URL: https://issues.apache.org/jira/browse/FLINK-28740 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28664) Support AvroWriters in PyFlink

Juntao Hu created FLINK-28664: - Summary: Support AvroWriters in PyFlink Key: FLINK-28664 URL: https://issues.apache.org/jira/browse/FLINK-28664 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28510) Support using new KafkaSink in PyFlink

Juntao Hu created FLINK-28510: - Summary: Support using new KafkaSink in PyFlink Key: FLINK-28510 URL: https://issues.apache.org/jira/browse/FLINK-28510 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28464) Support CsvReaderFormat in PyFlink

Juntao Hu created FLINK-28464: - Summary: Support CsvReaderFormat in PyFlink Key: FLINK-28464 URL: https://issues.apache.org/jira/browse/FLINK-28464 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28413) Support ParquetColumnarRowInputFormat in PyFlink

Juntao Hu created FLINK-28413: - Summary: Support ParquetColumnarRowInputFormat in PyFlink Key: FLINK-28413 URL: https://issues.apache.org/jira/browse/FLINK-28413 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28393) Support AvroInputFormat in PyFlink

Juntao Hu created FLINK-28393: - Summary: Support AvroInputFormat in PyFlink Key: FLINK-28393 URL: https://issues.apache.org/jira/browse/FLINK-28393 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28340) Support using system conda env for PyFlink tests

Juntao Hu created FLINK-28340: - Summary: Support using system conda env for PyFlink tests Key: FLINK-28340 URL: https://issues.apache.org/jira/browse/FLINK-28340 Project: Flink Issue Type:

[jira] [Created] (FLINK-28336) Support parquet-avro format in PyFlink DataStream

Juntao Hu created FLINK-28336: - Summary: Support parquet-avro format in PyFlink DataStream Key: FLINK-28336 URL: https://issues.apache.org/jira/browse/FLINK-28336 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28323) Support using new KafkaSource in PyFlink

Juntao Hu created FLINK-28323: - Summary: Support using new KafkaSource in PyFlink Key: FLINK-28323 URL: https://issues.apache.org/jira/browse/FLINK-28323 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28182) Support Avro generic record decoder in PyFlink

Juntao Hu created FLINK-28182: - Summary: Support Avro generic record decoder in PyFlink Key: FLINK-28182 URL: https://issues.apache.org/jira/browse/FLINK-28182 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28043) "Invalid lambda deserialization" in AvroParquetReaders

Juntao Hu created FLINK-28043: - Summary: "Invalid lambda deserialization" in AvroParquetReaders Key: FLINK-28043 URL: https://issues.apache.org/jira/browse/FLINK-28043 Project: Flink Issue Type:

[jira] [Created] (FLINK-27932) align noWatermarks and withWatemarkAlignment API in PyFlink

Juntao Hu created FLINK-27932: - Summary: align noWatermarks and withWatemarkAlignment API in PyFlink Key: FLINK-27932 URL: https://issues.apache.org/jira/browse/FLINK-27932 Project: Flink Issue

[jira] [Created] (FLINK-27901) support TableEnvironment.create(configuration) in PyFlink

Juntao Hu created FLINK-27901: - Summary: support TableEnvironment.create(configuration) in PyFlink Key: FLINK-27901 URL: https://issues.apache.org/jira/browse/FLINK-27901 Project: Flink Issue

[jira] [Created] (FLINK-27733) Rework on_timer output behind watermark bug fix

Juntao Hu created FLINK-27733: - Summary: Rework on_timer output behind watermark bug fix Key: FLINK-27733 URL: https://issues.apache.org/jira/browse/FLINK-27733 Project: Flink Issue Type:

[jira] [Created] (FLINK-27676) Output records from on_timer are behind the triggering watermark in PyFlink

Juntao Hu created FLINK-27676: - Summary: Output records from on_timer are behind the triggering watermark in PyFlink Key: FLINK-27676 URL: https://issues.apache.org/jira/browse/FLINK-27676 Project: Flink

[jira] [Created] (FLINK-27657) Implement remote operator state backend in PyFlink

Juntao Hu created FLINK-27657: - Summary: Implement remote operator state backend in PyFlink Key: FLINK-27657 URL: https://issues.apache.org/jira/browse/FLINK-27657 Project: Flink Issue Type:

[jira] [Created] (FLINK-27588) Update broadcast state related docs for PyFlink

Juntao Hu created FLINK-27588: - Summary: Update broadcast state related docs for PyFlink Key: FLINK-27588 URL: https://issues.apache.org/jira/browse/FLINK-27588 Project: Flink Issue Type:

[jira] [Created] (FLINK-27587) Support keyed co-broadcast processing

Juntao Hu created FLINK-27587: - Summary: Support keyed co-broadcast processing Key: FLINK-27587 URL: https://issues.apache.org/jira/browse/FLINK-27587 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27586) Support non-keyed co-broadcast processing

Juntao Hu created FLINK-27586: - Summary: Support non-keyed co-broadcast processing Key: FLINK-27586 URL: https://issues.apache.org/jira/browse/FLINK-27586 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27560) Refactor SimpleStateRequestHandler for PyFlink state

Juntao Hu created FLINK-27560: - Summary: Refactor SimpleStateRequestHandler for PyFlink state Key: FLINK-27560 URL: https://issues.apache.org/jira/browse/FLINK-27560 Project: Flink Issue Type:

[jira] [Created] (FLINK-27414) Support operator state in PyFlink DataStream API

Juntao Hu created FLINK-27414: - Summary: Support operator state in PyFlink DataStream API Key: FLINK-27414 URL: https://issues.apache.org/jira/browse/FLINK-27414 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26775) PyFlink WindowOperator#process_element register wrong cleanup timer

Juntao Hu created FLINK-26775: - Summary: PyFlink WindowOperator#process_element register wrong cleanup timer Key: FLINK-26775 URL: https://issues.apache.org/jira/browse/FLINK-26775 Project: Flink

[jira] [Created] (FLINK-26763) PyFlink support using system conda when running checks and tests

Juntao Hu created FLINK-26763: - Summary: PyFlink support using system conda when running checks and tests Key: FLINK-26763 URL: https://issues.apache.org/jira/browse/FLINK-26763 Project: Flink

[jira] [Created] (FLINK-26536) PyFlink RemoteKeyedStateBackend#merge_namespaces bug

Juntao Hu created FLINK-26536: - Summary: PyFlink RemoteKeyedStateBackend#merge_namespaces bug Key: FLINK-26536 URL: https://issues.apache.org/jira/browse/FLINK-26536 Project: Flink Issue Type: