Shuiqiang Chen created FLINK-30817:
--
Summary: ClassCastException in
TestValuesTableFactory.TestValuesScanTableSourceWithoutProjectionPushDown
Key: FLINK-30817
URL: https://issues.apache.org/jira/browse/FLINK
Congratulations, Lincoln!
Best,
Shuiqiang
Benchao Li 于2023年1月10日 周二13:48写道：
> Congratulations, Lincoln!
>
> Hangxiang Yu 于2023年1月10日周二 13:46写道：
>
> > Congratulations, Lincoln!
> >
> > On Tue, Jan 10, 2023 at 1:34 PM Dian Fu wrote:
> >
> > > Congratulations, Lincoln!
> > >
> > > Regards,
> > >
Congratulations, Godfrey and Xingbo!
Best,
Shuiqiang
Runker Hanna 于2022年11月23日周三 15:28写道：
> Congrats, Godfrey and Xingbo!
>
> Best,
> Runkang He
>
> Lincoln Lee 于2022年11月23日周三 15:21写道：
>
> > Congrats, Godfrey and Xingbo!
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Benchao Li 于2022年11月23日周三 14:1
Shuiqiang Chen created FLINK-29146:
--
Summary: User set job configuration can not be retirieved from
JobGraph and ExecutionGraph
Key: FLINK-29146
URL: https://issues.apache.org/jira/browse/FLINK-29146
Shuiqiang Chen created FLINK-28119:
--
Summary: Update the document for Contribute Documentation
Key: FLINK-28119
URL: https://issues.apache.org/jira/browse/FLINK-28119
Project: Flink
Issue
+1(non-binding)
- Verified the source code tag with release-1.14.5-rc1
- Verified the checksum and signature
- Go through the artifacts to be deployed to maven central repository
- Reviewed the website PR
Thanks for driving this.
Best,
Shuiqiang
Dian Fu 于2022年6月16日周四 20:41写道：
> +1 (binding)
Shuiqiang Chen created FLINK-27881:
--
Summary: The key(String) in PulsarMessageBuilder returns null
Key: FLINK-27881
URL: https://issues.apache.org/jira/browse/FLINK-27881
Project: Flink
+1 (non-binding)
It will make job management more convenient in session mode.
Best,
shuiqiang
Xintong Song 于2022年3月21日周一 09:57写道：
> Thanks Aitozi, the FLIP LGTM.
>
> +1 (binding)
>
> Thank you~
>
> Xintong Song
>
>
>
> On Fri, Mar 18, 2022 at 10:36 PM Őrhidi Mátyás
> wrote:
>
> > +1 (non-bindi
Shuiqiang Chen created FLINK-21966:
--
Summary: Support Kinesis connector in Python DataStream API.
Key: FLINK-21966
URL: https://issues.apache.org/jira/browse/FLINK-21966
Project: Flink
Hi Partha,
PyFlink DataStream API is a newly introduced feature in Flink 1.12.
Currently, some basic operations (map/flat_map/filter/key_by/process, etc),
timer and state access operations are supported. We are also continuously
improving and enriching these APIs. Looking forward to your feedback!
Shuiqiang Chen created FLINK-21113:
--
Summary: Add State access API for KeyedStream RuntimeContext.
Key: FLINK-21113
URL: https://issues.apache.org/jira/browse/FLINK-21113
Project: Flink
Shuiqiang Chen created FLINK-21112:
--
Summary: Add ValueState/ListState/MapState and corresponding
StateDescriptors for Python DataStream API
Key: FLINK-21112
URL: https://issues.apache.org/jira/browse/FLINK
Shuiqiang Chen created FLINK-2:
--
Summary: Support State access in Python DataStream API
Key: FLINK-2
URL: https://issues.apache.org/jira/browse/FLINK-2
Project: Flink
Issue Type
Python DataStream
> > API
> > >
> > > +1 (non-binding)
> > >
> > > Best,
> > > Wei
> > >
> > > > 在 2021年1月6日，14:05，Xingbo Huang 写道：
> > > >
> > > > +1 (non-binding)
> > > >
> > > >
Hi devs,
The discussion of the FLIP-153 [1] seems has reached a consensus through
the mailing thread [2]. I would like to start a vote for it.
The vote will be opened until 11th January (72h), unless there is an
objection or no enough votes.
Best,
Shuiqiang
[1]:
https://cwiki.apache.org/conflue
ne comments in the FLIP, please
> take a look.
>
> Thanks.
>
> Best Regards,
> Yu
>
>
> On Fri, 18 Dec 2020 at 15:10, Shuiqiang Chen wrote:
>
> > Hi wei,
> >
> > Big thanks for pointing out the mistakes! I have updated the FLIP
> > acco
Shuiqiang Chen created FLINK-20720:
--
Summary: Add documentation for ProcessFunction in Python
DataStream API
Key: FLINK-20720
URL: https://issues.apache.org/jira/browse/FLINK-20720
Project: Flink
update(self, values: List[T]) -> None:
> pass
>
> @abstractmethod
> def add_all(self, values: List[T]) -> None:
> pass
>
> def __iter__(self) -> Iterator[T]:
> return iter(self.get())
>
> Best,
> Wei
>
>> 在 2020年12月17日，21:
eam/state/schema_evolution.html#evolving-state-schema
> [5]
> https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/state/custom_serialization.html#off-heap-state-backends-eg-rocksdbstatebackend
> [6]
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/st
Shuiqiang Chen created FLINK-20647:
--
Summary: Use yield to generate output datas in ProcessFunction for
Python DataStream
Key: FLINK-20647
URL: https://issues.apache.org/jira/browse/FLINK-20647
State` and `AppendingState`
> interfaces, and then extract the `get` and `add` methods from `ListState`,
> `AggregatingState`, and `ReducingState` into `AppendingState`. Then let
> `ListState`, `AggregatingState` and `ReducingState` inherit `MergingState`.
>
> Best,
> Xingbo
>
&
Shuiqiang Chen created FLINK-20621:
--
Summary: Refactor the TypeInformation implementation in Python
DataStream API
Key: FLINK-20621
URL: https://issues.apache.org/jira/browse/FLINK-20621
Project
Hi devs,
In FLIP-130, we have already supported Python DataStream stateless APIs so
that users are able to perform some basic data transformations. To
implement more complex data processing, we need to provide state access
support. So I would propose to add state access APIs in Python DataStream
A
Shuiqiang Chen created FLINK-20365:
--
Summary: The native k8s cluster could not be unregistered when
executing Python DataStream application attachedly.
Key: FLINK-20365
URL: https://issues.apache.org/jira/browse
Shuiqiang Chen created FLINK-20275:
--
Summary: The path delimiter for add_jars and add_classpaths in
Python StreamExecutionEnvironment should be ;
Key: FLINK-20275
URL: https://issues.apache.org/jira/browse
Shuiqiang Chen created FLINK-20164:
--
Summary: Add docs for ProcessFunction and Timer for Python
DataStream API.
Key: FLINK-20164
URL: https://issues.apache.org/jira/browse/FLINK-20164
Project: Flink
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: https://issues.apache.org/jira
Shuiqiang Chen created FLINK-20016:
--
Summary: Support TimestampAssigner and WatermarkGenerator for
Python DataStream API.
Key: FLINK-20016
URL: https://issues.apache.org/jira/browse/FLINK-20016
Shuiqiang Chen created FLINK-19821:
--
Summary: Add ProcessFunction and timer access for Python
DataStream API.
Key: FLINK-19821
URL: https://issues.apache.org/jira/browse/FLINK-19821
Project: Flink
Hi blackjact,
We are already working on the design of stateful part, however, it will not be
supported in 1.12. We hope to support it in the later releases, e.g. 1.13.
Thank you for your attention.
Regards,
Shuiqiang
> 在 2020年10月20日，下午7:34，blackjjcat 写道：
>
> May I ask the plan of stateful p
+1 (non-binding)
> 在 2020年9月7日，下午2:38，Wei Zhong 写道：
>
> +1 (non-binding)
>
>> 在 2020年9月7日，10:00，Dian Fu 写道：
>>
>> +1
>>
>>> 在 2020年9月4日，上午11:12，Xingbo Huang 写道：
>>>
>>> Hi all,
>>> I would like to start the vote for FLIP-137[1], which is discussed and
>>> reached a consensus in the discuss
Shuiqiang Chen created FLINK-19145:
--
Summary: Add PyFlink-walkthrough in Flink playground.
Key: FLINK-19145
URL: https://issues.apache.org/jira/browse/FLINK-19145
Project: Flink
Issue Type
Shuiqiang Chen created FLINK-19134:
--
Summary: Fix the converter of array coder for Python DataStream
API.
Key: FLINK-19134
URL: https://issues.apache.org/jira/browse/FLINK-19134
Project: Flink
Shuiqiang Chen created FLINK-19097:
--
Summary: Support add_jar() for Python DataStream API
Key: FLINK-19097
URL: https://issues.apache.org/jira/browse/FLINK-19097
Project: Flink
Issue Type
Shuiqiang Chen created FLINK-19041:
--
Summary: Add dependency management for ConnectedStream in Python
DataStream API.
Key: FLINK-19041
URL: https://issues.apache.org/jira/browse/FLINK-19041
Project
Shuiqiang Chen created FLINK-18950:
--
Summary: Add documentation for Operations in Python DataStream
API.
Key: FLINK-18950
URL: https://issues.apache.org/jira/browse/FLINK-18950
Project: Flink
Shuiqiang Chen created FLINK-18951:
--
Summary: Add documentation for Configurations in Python DataStream
API.
Key: FLINK-18951
URL: https://issues.apache.org/jira/browse/FLINK-18951
Project: Flink
Shuiqiang Chen created FLINK-18946:
--
Summary: Support Cassandra connector for Python DataStream API
Key: FLINK-18946
URL: https://issues.apache.org/jira/browse/FLINK-18946
Project: Flink
Shuiqiang Chen created FLINK-18944:
--
Summary: Support JDBC connector for Python DataStream API
Key: FLINK-18944
URL: https://issues.apache.org/jira/browse/FLINK-18944
Project: Flink
Issue
+1 (non-binding)
Best,
Shuiqiang
Dian Fu 于2020年8月12日周三 上午10:10写道：
> +1 (binding)
>
> Thanks,
> Dian
>
> > 在 2020年8月11日，下午10:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the discussion
Shuiqiang Chen created FLINK-1:
--
Summary: Add ElasticSearch connector for Python DataStream API
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Project: Flink
Shuiqiang Chen created FLINK-18887:
--
Summary: Add ElasticSearch connector for Python DataStream API
Key: FLINK-18887
URL: https://issues.apache.org/jira/browse/FLINK-18887
Project: Flink
Shuiqiang Chen created FLINK-18886:
--
Summary: Support Kafka connectors for Python DataStream API
Key: FLINK-18886
URL: https://issues.apache.org/jira/browse/FLINK-18886
Project: Flink
Issue
Shuiqiang Chen created FLINK-18885:
--
Summary: Add partitioning interfaces for Python DataStream.
Key: FLINK-18885
URL: https://issues.apache.org/jira/browse/FLINK-18885
Project: Flink
Issue
Shuiqiang Chen created FLINK-18884:
--
Summary: Add chaining strategy and slot sharing group interfaces
for DataStream
Key: FLINK-18884
URL: https://issues.apache.org/jira/browse/FLINK-18884
Project
Shuiqiang Chen created FLINK-18879:
--
Summary: Support Row Serialization and Deserialization schemas for
DataStream source/sink
Key: FLINK-18879
URL: https://issues.apache.org/jira/browse/FLINK-18879
Shuiqiang Chen created FLINK-18878:
--
Summary: Support dependency management for Python
StreamExecutionEnvironment.
Key: FLINK-18878
URL: https://issues.apache.org/jira/browse/FLINK-18878
Project
Shuiqiang Chen created FLINK-18874:
--
Summary: Support conversion between Table and DataStream
Key: FLINK-18874
URL: https://issues.apache.org/jira/browse/FLINK-18874
Project: Flink
Issue
Shuiqiang Chen created FLINK-18866:
--
Summary: Support filter() interface for Python DataStream API.
Key: FLINK-18866
URL: https://issues.apache.org/jira/browse/FLINK-18866
Project: Flink
Shuiqiang Chen created FLINK-18864:
--
Summary: Support key_by() operation for Python DataStream API
Key: FLINK-18864
URL: https://issues.apache.org/jira/browse/FLINK-18864
Project: Flink
Shuiqiang Chen created FLINK-18863:
--
Summary: Support print() and write_as_text() interface for Python
DataStream API.
Key: FLINK-18863
URL: https://issues.apache.org/jira/browse/FLINK-18863
Project
Shuiqiang Chen created FLINK-18861:
--
Summary: Support add_source() to get a DataStream for Python
StreamExecutionEnvironment
Key: FLINK-18861
URL: https://issues.apache.org/jira/browse/FLINK-18861
Hi jincheng,
Thanks for the discussion. +1 for the FLIP.
A well-organized documentation will greatly improve the efficiency and
experience for developers.
Best,
Shuiqiang
Hequn Cheng 于2020年8月1日周六 上午8:42写道：
> Hi Jincheng,
>
> Thanks a lot for raising the discussion. +1 for the FLIP.
>
> I thin
gt; >
> > Aljoscha
> >
> > On 28.07.20 04:12, Dian Fu wrote:
> > > Thanks for driving this Shuiqiang.
> > >
> > > +1
> > >
> > > Regards,
> > > Dian
> > >
> > >> 在 2020年7月27日，下午3:33，jincheng sun 写道：
is being used for
> enrichment.
>
> For an example, consider
> https://github.com/knaufk/enrichments-with-flink/blob/master/src/main/java/com/github/knaufk/enrichments/CustomPartitionEnrichmenttJob.java
> .
>
> Regards,
> David
>
> On Fri, Jul 24, 2020 at 12:18 PM Shuiq
Hi everyone,
I would like to start the vote for FLIP-130[1], which is discussed and
reached a consensus through the discussion thread[2].
The vote will be open until 29th July (72h), unless there is an objection
or not enough votes.
Best,
Shuiqiang
[1]:
https://cwiki.apache.org/confluence/page
gt; > > cases for playing with Flink.
> > >
> > > What do you think?
> > >
> > > Best,
> > > Hequn
> > >
> > > [1]
> > >
> >
> https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/ma
ing this. Big +1 for supporting DataStream API in
> PyFlink!
> > > >
> > > > Best,
> > > > Wei
> > > >
> > > >
> > > > > 在 2020年7月9日，10:29，Hequn Cheng 写道：
> > > > >
> > > > > +1
Sorry, the 3rd link is broken, please refer to this one: Support Python
DataStream API
<https://docs.google.com/document/d/1H3hz8wuk22-8cDBhQmQKNw3m1q5gDAMkwTDEwnj3FBI/edit>
Shuiqiang Chen 于2020年7月8日周三 上午11:13写道：
> Hi everyone,
>
> As we all know, Flink provides three la
Hi everyone,
As we all know, Flink provides three layered APIs: the ProcessFunctions,
the DataStream API and the SQL & Table API. Each API offers a different
trade-off between conciseness and expressiveness and targets different use
cases[1].
Currently, the SQL & Table API has already been suppor
Hi Robert,
Thank you for your reminding! I have added the wiki page[1] for this FLIP.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-39+Flink+ML+pipeline+and+ML+libs
Robert Metzger 于2019年8月14日周三 下午5:56写道：
> It seems that this FLIP doesn't have a Wiki page yet [1], even though it is
https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals
My ID is : Shuiqiang Chen
Best,
Shuiqiang
? Apart from that, I left some minor comments in the
> design document.
>
> Cheers,
> Till
>
> On Tue, Apr 23, 2019 at 10:04 AM Shuiqiang Chen
> wrote:
>
> > Hi All,
> >
> > We would like to start a discussion thread about a new feature called
>
Hi All,
We would like to start a discussion thread about a new feature called Flink
Driver. A brief summary is following.
As mentioned in the discussion of Interactive Programming, user
applications might consist of multiple jobs and take long to finish.
Currently, when Flink runs applications wi
Hi guys:
Could somebody give me contributor permissions? my jira username is :
csq.
Thanks.
65 matches
Mail list logo
