[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844179#comment-17844179
]
Juntao Hu commented on FLINK-33268:
---
[~gaborgsomogyi] thanks for replying! I've creat
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844165#comment-17844165
]
Juntao Hu commented on FLINK-35302:
---
Hi [~gaborgsomogyi], do you have time to look at
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-35302:
--
Description:
As
[FLIP-401|https://cwiki.apache.org/confluence/display/FLINK/FLIP-401%3A+REST+API+JSON
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-35302:
--
Description:
As
[FLIP-401|https://cwiki.apache.org/confluence/display/FLINK/FLIP-401%3A+REST+API+JSON
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
[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841564#comment-17841564
]
Juntao Hu commented on FLINK-33268:
---
Sorry to comment on a closed issue, but I wonder
[
https://issues.apache.org/jira/browse/FLINK-31337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696950#comment-17696950
]
Juntao Hu commented on FLINK-31337:
---
[~mapohl], FLINK-31185 introduces a test case tha
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
[
https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696660#comment-17696660
]
Juntao Hu commented on FLINK-31040:
---
[~nicholasjiang], [~martijnvisser] I could take t
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
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 Type:
[
https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31040:
--
Description:
Pattern: begin("A",
SKIP_TO_NEXT).oneOrMore().consecutive().notFollowedBy("B").within(Ti
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Affects Version/s: 1.16.1
1.15.3
> Expected prune behavior for matches with sam
[
https://issues.apache.org/jira/browse/FLINK-29681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-29681:
--
Affects Version/s: (was: 1.17.0)
> Python side-output operator not generated in some cases
> -
[
https://issues.apache.org/jira/browse/FLINK-30864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30864:
--
Affects Version/s: 1.15.3
> Optional pattern at the start of a group pattern not working
> ---
[
https://issues.apache.org/jira/browse/FLINK-30839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30839:
--
Affects Version/s: 1.15.3
> Relaxed looping group pattern make the following strict contiguity relaxed
[
https://issues.apache.org/jira/browse/FLINK-30961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30961:
--
Fix Version/s: 1.17.0
(was: 1.18.0)
> Remove deprecated tests_require in setup.
[
https://issues.apache.org/jira/browse/FLINK-30885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30885:
--
Affects Version/s: 1.16.1
1.15.3
> Optional group pattern starts with non-optio
[
https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31017:
--
Affects Version/s: (was: 1.17.0)
> Early-started partial match timeout not yield completed matches
[
https://issues.apache.org/jira/browse/FLINK-31042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31042:
--
Fix Version/s: 1.17.0
1.15.4
1.16.2
Affects Versi
[
https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690204#comment-17690204
]
Juntao Hu commented on FLINK-31017:
---
[~martijnvisser] I've changed the tags, thx for r
[
https://issues.apache.org/jira/browse/FLINK-31017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31017:
--
Fix Version/s: 1.17.0
1.15.4
1.16.2
(was:
[
https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31040:
--
Fix Version/s: (was: 1.17.0)
(was: 1.15.4)
(was: 1.16
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:
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: Flin
[
https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-31040:
--
Description:
Pattern:
begin("A").oneOrMore().consecutive().notFollowedBy("B").within(Time.millisecond
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
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 Type:
[
https://issues.apache.org/jira/browse/FLINK-30969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30969:
--
Fix Version/s: (was: 1.15.4)
(was: 1.16.2)
Affects Version/s:
[
https://issues.apache.org/jira/browse/FLINK-30969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30969:
--
Fix Version/s: 1.15.4
1.16.2
Affects Version/s: 1.16.1
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
Is
[
https://issues.apache.org/jira/browse/FLINK-30981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30981:
--
Description:
Execute `t_env.explainSql("ANY VALID SQL")` will throw error:
{code:java}
Traceback (most
[
https://issues.apache.org/jira/browse/FLINK-30981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30981:
--
Description:
Execute `t_env.explainSql("ANY VALID SQL")` will throw error:
{code:java}
Traceback (most
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
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
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-30961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30961:
--
Description:
According to [https://github.com/pypa/setuptools/pull/1878] , `python setup.py
test` com
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: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685146#comment-17685146
]
Juntao Hu commented on FLINK-27456:
---
Hi [~danderson] , the example uses relaxed contig
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
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
Issue
[
https://issues.apache.org/jira/browse/FLINK-30839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30839:
--
Description:
If a group pattern loops with relaxed contiguity, the strict contiguity between
group pa
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: Fli
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
[
https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30069:
--
Description:
When a pattern produces several matches with same priority, is it the expected
behavior
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:
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 Type:
[
https://issues.apache.org/jira/browse/FLINK-29658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-29658:
--
Description: Support for Java LocalDate/Time/DateTime is needed when
calling `to_data_stream` on table
[
https://issues.apache.org/jira/browse/FLINK-29658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-29658:
--
Summary: LocalTime support when converting Table to DataStream in PyFlink
(was: LocalTimeTypeInfo sup
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:
[
https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-29648:
--
Priority: Critical (was: Blocker)
> "LocalDateTime not supported" error when retrieving Java TypeInfo
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
Proje
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 Typ
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: Bu
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: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-28895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-28895:
--
Summary: Eliminate RowRowConverter between RowData source and sink (was:
Eliminate the map to convert
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
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
[
https://issues.apache.org/jira/browse/FLINK-28876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-28876:
--
Fix Version/s: 1.16.0
> 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 Fea
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: New
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 Type:
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
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
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
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
Co
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
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
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 Fe
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
[
https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561836#comment-17561836
]
Juntao Hu edited comment on FLINK-27587 at 7/3/22 10:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561836#comment-17561836
]
Juntao Hu commented on FLINK-27587:
---
[~Zsigner] Oh I separate broadcast process implem
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: Improv
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 F
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
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 Feat
[
https://issues.apache.org/jira/browse/FLINK-28043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554062#comment-17554062
]
Juntao Hu commented on FLINK-28043:
---
[~jingge] could you take a look at this PR?
> "I
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:
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
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 Typ
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: Improve
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
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: Sub-
[
https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-27587:
--
Summary: Support keyed co-broadcast processing in PyFlink (was: Support
keyed co-broadcast processing
[
https://issues.apache.org/jira/browse/FLINK-27586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-27586:
--
Summary: Support non-keyed co-broadcast processing in PyFlink (was:
Support non-keyed co-broadcast pr
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: Sub-tas
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
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
[
https://issues.apache.org/jira/browse/FLINK-27560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-27560:
--
Parent: FLINK-27584
Issue Type: Sub-task (was: Improvement)
> Refactor SimpleStateRequestHand
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: Im
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 Fe
[
https://issues.apache.org/jira/browse/FLINK-22984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526176#comment-17526176
]
Juntao Hu commented on FLINK-22984:
---
It's a bug in optimizing sql plan, rather than a
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
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
I
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: Bu
[
https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499938#comment-17499938
]
Juntao Hu commented on FLINK-26444:
---
[~cun8cun8] are you working on this?
> Window al
99 matches
Mail list logo
