[
https://issues.apache.org/jira/browse/FLINK-26070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550329#comment-17550329
]
LuNng Wang commented on FLINK-26070:
[~dianfu] [~martijnvisser] Could we close this
[
https://issues.apache.org/jira/browse/FLINK-26070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550329#comment-17550329
]
LuNng Wang edited comment on FLINK-26070 at 6/6/22 7:14 AM:
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550330#comment-17550330
]
LuNng Wang commented on FLINK-24999:
We need to bump Arrow to 8.0.0
https://arrow.a
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550330#comment-17550330
]
LuNng Wang edited comment on FLINK-24999 at 6/6/22 7:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550330#comment-17550330
]
LuNng Wang edited comment on FLINK-24999 at 6/6/22 7:20 AM:
LuNng Wang created FLINK-27924:
--
Summary: Add pulsar comments in the datastream package
Key: FLINK-27924
URL: https://issues.apache.org/jira/browse/FLINK-27924
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-27924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27924:
---
Component/s: Documentation
> Add pulsar comments in the datastream package
> ---
LuNng Wang created FLINK-27929:
--
Summary: Drop support for python 3.6
Key: FLINK-27929
URL: https://issues.apache.org/jira/browse/FLINK-27929
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-27929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27929:
---
Description:
Python 3.6 lifecycle is ended on 23 Dec 2021. We can drop this support in the
1.17 rel
[
https://issues.apache.org/jira/browse/FLINK-27770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551438#comment-17551438
]
LuNng Wang commented on FLINK-27770:
I would like to take this.
> Introduce the scr
LuNng Wang created FLINK-27966:
--
Summary: All the classes move to the connector specific files
Key: FLINK-27966
URL: https://issues.apache.org/jira/browse/FLINK-27966
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17551949#comment-17551949
]
LuNng Wang commented on FLINK-27966:
I would like to take this.
> All the classes m
[
https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27713:
---
Fix Version/s: 1.17.0
> Bump Apache Beam to 2.40.0
> --
>
>
LuNng Wang created FLINK-27968:
--
Summary: end-to-end-tests-sql CI test failed
Key: FLINK-27968
URL: https://issues.apache.org/jira/browse/FLINK-27968
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-27968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27968:
---
Description:
{code:java}
Jun 09 03:15:01 at
org.apache.maven.surefire.booter.ForkedBooter
[
https://issues.apache.org/jira/browse/FLINK-27968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27968:
---
Priority: Critical (was: Blocker)
> end-to-end-tests-sql CI test failed
> -
[
https://issues.apache.org/jira/browse/FLINK-27968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27968:
---
Priority: Major (was: Critical)
> end-to-end-tests-sql CI test failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-27968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27968:
---
Affects Version/s: 1.16.0
> end-to-end-tests-sql CI test failed
> --
[
https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27713:
---
Fix Version/s: 1.17.0
> Bump Apache Beam to 2.40.0
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552522#comment-17552522
]
LuNng Wang commented on FLINK-27197:
We need to replace env#fromTableSource.
> Port
[
https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552522#comment-17552522
]
LuNng Wang edited comment on FLINK-27197 at 6/10/22 6:06 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532582#comment-17532582
]
LuNng Wang commented on FLINK-25795:
[~syhily] Yes , It will take about a week to co
[
https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532582#comment-17532582
]
LuNng Wang edited comment on FLINK-25795 at 5/6/22 6:43 AM:
[
https://issues.apache.org/jira/browse/FLINK-27297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534070#comment-17534070
]
LuNng Wang commented on FLINK-27297:
[~dianfu] [~hxbks2ks] I would like to try this.
[
https://issues.apache.org/jira/browse/FLINK-27421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534299#comment-17534299
]
LuNng Wang commented on FLINK-27421:
I would like to take this. [~dianfu]
> Bundle
[
https://issues.apache.org/jira/browse/FLINK-27575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534857#comment-17534857
]
LuNng Wang commented on FLINK-27575:
[~hxbks2ks] I would like to take this.
> Suppo
[
https://issues.apache.org/jira/browse/FLINK-27340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17535913#comment-17535913
]
LuNng Wang commented on FLINK-27340:
[~dianfu] I would like to take this.
> [JUnit5
[
https://issues.apache.org/jira/browse/FLINK-27564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17536013#comment-17536013
]
LuNng Wang commented on FLINK-27564:
I would like to take this. [~dianfu]
> Split
[
https://issues.apache.org/jira/browse/FLINK-27588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537299#comment-17537299
]
LuNng Wang commented on FLINK-27588:
[~dianfu] I would like to take this.
> Update
LuNng Wang created FLINK-27689:
--
Summary: Pulsar Connector support PulsarSchema
Key: FLINK-27689
URL: https://issues.apache.org/jira/browse/FLINK-27689
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27689:
---
Description:
Currently, Python Pulsar Connector only supports Flink Schema, we also need to
support
[
https://issues.apache.org/jira/browse/FLINK-27689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27689:
---
Description:
Currently, Python Pulsar Connector only supports Flink Schema, we also need to
support
[
https://issues.apache.org/jira/browse/FLINK-27690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539193#comment-17539193
]
LuNng Wang commented on FLINK-27690:
I would like to take this. [~dianfu]
> Add Pu
LuNng Wang created FLINK-27690:
--
Summary: Add Pulsar Source connector document
Key: FLINK-27690
URL: https://issues.apache.org/jira/browse/FLINK-27690
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27690:
---
Summary: Add Pulsar Source connector document and examples (was: Add
Pulsar Source connector docume
LuNng Wang created FLINK-27694:
--
Summary: Move lint-python log location
Key: FLINK-27694
URL: https://issues.apache.org/jira/browse/FLINK-27694
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-27694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27694:
---
Description:
Some logs are in the wrong location, we need to move them to the inside of the
'if' st
[
https://issues.apache.org/jira/browse/FLINK-27694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27694:
---
Description:
Some logs are in the wrong location, we need to move them to the inside of the
'if' st
LuNng Wang created FLINK-27699:
--
Summary: Align Pulsar source atPublishTime method
Key: FLINK-27699
URL: https://issues.apache.org/jira/browse/FLINK-27699
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27699:
---
Summary: Align Pulsar source atPublishTime method (was: Align Pulsar
source atPublishTime method)
[
https://issues.apache.org/jira/browse/FLINK-27699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27699:
---
Summary: Align atPublishTime method of for Pulsar connector (was: Align
Pulsar source atPublishTim
[
https://issues.apache.org/jira/browse/FLINK-27699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27699:
---
Summary: Align atPublishTime method of StopCursor class for Pulsar
connector (was: Align atPublishT
LuNng Wang created FLINK-27711:
--
Summary: Align setTopicPattern for Pulsar Connector
Key: FLINK-27711
URL: https://issues.apache.org/jira/browse/FLINK-27711
Project: Flink
Issue Type: Improvemen
LuNng Wang created FLINK-27713:
--
Summary: Bump Apache Beam to 2.40.0
Key: FLINK-27713
URL: https://issues.apache.org/jira/browse/FLINK-27713
Project: Flink
Issue Type: Improvement
Comp
[
https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27713:
---
Description:
Directly depending on Beam 2.36 will throw an error.
{code:java}
AttributeError: modul
[
https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27713:
---
Description:
Directly depending on Beam 2.38 will throw an error.
{code:java}
AttributeError: modul
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27736:
---
Issue Type: Bug (was: Improvement)
> Pulsar sink catch watermark error
> --
LuNng Wang created FLINK-27736:
--
Summary: Pulsar sink catch watermark error
Key: FLINK-27736
URL: https://issues.apache.org/jira/browse/FLINK-27736
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-27736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27736:
---
Description:
The following is my demo code.
{code:java}
public class WatermarkDemo {
private fi
[
https://issues.apache.org/jira/browse/FLINK-27058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541279#comment-17541279
]
LuNng Wang commented on FLINK-27058:
Need to bump fastavro
> Add support for Python
[
https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27713:
---
Fix Version/s: 1.17.0
> Bump Apache Beam to 2.40.0
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516260#comment-17516260
]
LuNng Wang commented on FLINK-27010:
[~ZhangChaoming] There is two scenarios:
1) Us
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516260#comment-17516260
]
LuNng Wang edited comment on FLINK-27010 at 4/2/22 9:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517504#comment-17517504
]
LuNng Wang commented on FLINK-27010:
[~martijnvisser] the SQL client already relyin
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27010:
---
Description:
'-i' '-j' and '-l' only be set in startup options.
I want to add the following option
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNng Wang updated FLINK-27010:
---
Description:
'-i' '-j' and '-l' only be set in startup options.
I want to add the following option
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517773#comment-17517773
]
LuNng Wang commented on FLINK-27010:
[~martijnvisser] [~fsk119] When we use SQL Clie
[
https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17517773#comment-17517773
]
LuNng Wang edited comment on FLINK-27010 at 4/6/22 2:25 AM:
58 matches
Mail list logo
