Dian Fu created FLINK-25676:
---
Summary: Add set_description in Python API
Key: FLINK-25676
URL: https://issues.apache.org/jira/browse/FLINK-25676
Project: Flink
Issue Type: Improvement
+1 (binding)
Regards,
Dian
On Thu, Jan 13, 2022 at 6:50 AM Thomas Weise wrote:
> +1 (binding)
>
> On Wed, Jan 12, 2022 at 4:58 AM Till Rohrmann
> wrote:
> >
> > +1 (binding)
> >
> > Cheers,
> > Till
> >
> > On Wed, Jan 12, 2022 at 11:07 AM Wei Zhong
> wrote:
> >
> > > +1(binding)
> > >
> > >
+1 (binding)
- Verified the checksum and signature
- Build the Java code and also run the tests using `mvn clean verify`
- Checked the NOTICE file
- Pip installed the python package in MacOS under Python 3.7
- Reviewed the flink-web PR
Regards,
Dian
On Tue, Jan 4, 2022 at 12:25 AM Dong Lin wrot
Thanks Yunfeng for bringing up this discussion. I have seen that there were
many users asking for this feature in the past. So big +1 for this proposal.
Regarding this FLIP, I have the following question:
- Does it make sense to rename the method `getLatestRules` into
`getRuleChanges`? I assume we
+1 for the proposal and creating a quick release.
Regards,
Dian
On Mon, Dec 13, 2021 at 11:15 AM Kyle Bendickson wrote:
> +1 to doing a release for this widely publicized vulnerability.
>
> In my experience, users will often update to the latest minor patch version
> without much fuss. Plus, u
Congratulations!
On Fri, Dec 10, 2021 at 7:58 PM Zhilong Hong wrote:
> Congratulations, Ingo!
>
> Best,
> Zhilong
>
> On Wed, Dec 8, 2021 at 10:18 PM godfrey he wrote:
>
> > Congratulations, Ingo!
> >
> > Best,
> > Godfrey
> >
> > Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
> > >
> > > Congratul
Congratulations!
On Fri, Dec 10, 2021 at 8:00 PM Zhilong Hong wrote:
> Congratulations, Matthias!
>
> Best,
> Zhilong
>
> On Wed, Dec 8, 2021 at 10:18 PM godfrey he wrote:
>
> > Congratulations, Matthias!
> >
> > Best,
> > Godfrey
> >
> > Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
> > >
> > > C
Dian Fu created FLINK-25231:
---
Summary: Update PyFlink to use the new type system
Key: FLINK-25231
URL: https://issues.apache.org/jira/browse/FLINK-25231
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-25216:
---
Summary: test_sliding_group_window_over_proctime failed with
"IndexError: list index out of range"
Key: FLINK-25216
URL: https://issues.apache.org/jira/browse/F
+1
Regards,
Dian
On Tue, Nov 30, 2021 at 12:08 PM Yun Gao
wrote:
> +1 for the new GraphBuilder API supports more complex
> estimator / model structure and helps to reduce the repeat
> code. Thanks Dong for the proposal.
>
> Best,
> Yun
>
>
> -
Dian Fu created FLINK-24962:
---
Summary: The root cause of a failed job was hidden in certain cases
Key: FLINK-24962
URL: https://issues.apache.org/jira/browse/FLINK-24962
Project: Flink
Issue Type
Congratulations!
Regards,
Dian
On Wed, Nov 17, 2021 at 5:14 PM Yang Wang wrote:
> Congratulations, Yiingjie!
>
> Best,
> Yang
>
> Zakelly Lan 于2021年11月17日周三 下午4:26写道：
>
> > Congratulations, Yiingjie :)
> >
> > Best,
> > Zakelly
> >
> > On Wed, Nov 17, 2021 at 2:58 PM Lincoln Lee
> > wrote:
>
Congratulations!
Regards,
Dian
On Tue, Nov 16, 2021 at 9:47 AM Qingsheng Ren wrote:
> Congratulations Fabian!
>
> --
> Best Regards,
>
> Qingsheng Ren
> Email: renqs...@gmail.com
> On Nov 15, 2021, 9:17 PM +0800, Arvid Heise , wrote:
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy
Congratulations!
Regards,
Dian
On Tue, Nov 16, 2021 at 9:48 AM godfrey he wrote:
> Congrats & well deserved, Jing!
>
> Best,
> Godfrey
>
> Leonard Xu 于2021年11月16日周二 上午12:11写道：
> >
> > Congratulations Jing! Well Deserved.
> >
> >
> > > 在 2021年11月15日，22:30，Dawid Wysakowicz 写道：
> > >
> > > Congr
Congratulations!
Regards,
Dian
On Fri, Nov 12, 2021 at 4:34 PM Till Rohrmann wrote:
> Congratulations!
>
> Cheers,
> Till
>
> On Fri, Nov 12, 2021 at 9:19 AM Martijn Visser
> wrote:
>
> > Congratulations!
> >
> > Best regards,
> >
> > Martijn
> >
> > On Fri, 12 Nov 2021 at 07:49, Jark Wu wrot
Congratulations, Leonard!
Regards,
Dian
On Fri, Nov 12, 2021 at 4:19 PM Martijn Visser
wrote:
> Well deserved, congratulations Leonard!
>
> Best regards,
>
> Martijn
>
> On Fri, 12 Nov 2021 at 08:44, Caizhi Weng wrote:
>
> > Congrats, Leonard!
> >
> > Shuo Cheng 于2021年11月12日周五 下午3:12写道：
> >
>
+1
On Fri, Nov 5, 2021 at 10:09 PM Yun Gao
wrote:
> +1.
>
> Very thanks for drafting the FLIP!
>
>
> Best,
> Yun
>
>
> --
> Sender:Becket Qin
> Date:2021/11/05 18:15:11
> Recipient:dev
> Theme:Re: [VOTE] FLIP-174: Improve the WithPa
Dian Fu created FLINK-24662:
---
Summary: PyFlink sphinx check failed with "node class 'meta' is
already registered, its visitors will be overridden"
Key: FLINK-24662
URL: https://issues.apache.org/jir
+1 (binding)
- verified the checksum and signature
- checked the dependency changes since 1.13.2. There is only one dependency
change (commons-compress: 1.20 -> 1.21) and it is well documented in the
NOTICE file
- installed the PyFlink packages in MacOS and runs a few examples
successfully
- the w
Hi Jeff,
It has split the jars into a separate package since 1.13 and so there are two
packages now.
You need install `apache-flink-libraries` firstly:
pip install apache-flink-libraries-1.14.0.tar.gz
Note that this is only necessary when installing from source. Could also refer
to [1] for mo
Dian Fu created FLINK-24287:
---
Summary: Bump virtualenv to the latest version
Key: FLINK-24287
URL: https://issues.apache.org/jira/browse/FLINK-24287
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-24244:
---
Summary: Add logging about whether it's executed in loopback mode
Key: FLINK-24244
URL: https://issues.apache.org/jira/browse/FLINK-24244
Project: Flink
Issue
Dian Fu created FLINK-24243:
---
Summary: Clean up the code and avoid warning messages introduced
by deprecated API
Key: FLINK-24243
URL: https://issues.apache.org/jira/browse/FLINK-24243
Project: Flink
Dian Fu created FLINK-24101:
---
Summary: Support to generate PyDocs without Flink distribution
Key: FLINK-24101
URL: https://issues.apache.org/jira/browse/FLINK-24101
Project: Flink
Issue Type
Dian Fu created FLINK-24097:
---
Summary: Remove the streaming check in StreamTableEnvironment in
PyFlink
Key: FLINK-24097
URL: https://issues.apache.org/jira/browse/FLINK-24097
Project: Flink
Issue
Dian Fu created FLINK-24083:
---
Summary: The result isn't as expected when the result type is
generator of string for Python UDTF
Key: FLINK-24083
URL: https://issues.apache.org/jira/browse/FLINK-
Dian Fu created FLINK-24082:
---
Summary: Python UDTF throws exception when the result type is
generator of Row
Key: FLINK-24082
URL: https://issues.apache.org/jira/browse/FLINK-24082
Project: Flink
Dian Fu created FLINK-24062:
---
Summary: Exception encountered during timer serialization in
Python DataStream API
Key: FLINK-24062
URL: https://issues.apache.org/jira/browse/FLINK-24062
Project: Flink
Dian Fu created FLINK-24049:
---
Summary: TupleTypeInfo doesn't handle correctly for data types
need conversion
Key: FLINK-24049
URL: https://issues.apache.org/jira/browse/FLINK-24049
Project:
Dian Fu created FLINK-24003:
---
Summary: Lookback mode doesn't work when mixing use of Python
Table API and Python DataStream API
Key: FLINK-24003
URL: https://issues.apache.org/jira/browse/FLINK-
Dian Fu created FLINK-23994:
---
Summary: ArrayDataSerializer and MapDataSerializer doesn't handle
correctly for Null values
Key: FLINK-23994
URL: https://issues.apache.org/jira/browse/FLINK-23994
Pr
Dian Fu created FLINK-23944:
---
Summary: PulsarSourceITCase.testTaskManagerFailure is instable
Key: FLINK-23944
URL: https://issues.apache.org/jira/browse/FLINK-23944
Project: Flink
Issue Type
Dian Fu created FLINK-23940:
---
Summary: Improve the documentation about how to use logging in
PyFlink jobs
Key: FLINK-23940
URL: https://issues.apache.org/jira/browse/FLINK-23940
Project: Flink
Dian Fu created FLINK-23936:
---
Summary: Python UDFs instances are released and reinitialized if
there is no input for more than 1 minute
Key: FLINK-23936
URL: https://issues.apache.org/jira/browse/FLINK-23936
Dian Fu created FLINK-23931:
---
Summary: Format the exception message shown in PythonDriver
Key: FLINK-23931
URL: https://issues.apache.org/jira/browse/FLINK-23931
Project: Flink
Issue Type
Dian Fu created FLINK-23929:
---
Summary: Chaining optimization doesn't handle properly for
transformations with multiple inputs
Key: FLINK-23929
URL: https://issues.apache.org/jira/browse/FLINK-23929
Pr
gt; Thank you~
>
> Xintong Song
>
>
>
> On Wed, Aug 18, 2021 at 10:27 PM Dian Fu wrote:
>
>> The risk should be very limited and it should not affect other parts of the
>> functionality. So I'm also in favour of merging it.
>>
>> Regards,
>
The risk should be very limited and it should not affect other parts of the
functionality. So I'm also in favour of merging it.
Regards,
Dian
On Wed, Aug 18, 2021 at 8:07 PM Till Rohrmann wrote:
> @Dian Fu could you assess how involved this
> change is? If the change is not very i
for one module I'm trying to get
> the whole Flink project to work as one in IntelliJ. Do PyFlink developers
> generally work solely on PyFlink and nothing else / do you switch IDEs for
> everything?
>
>
> Best
> Ingo
>
> On Wed, Aug 18, 2021 at 1:20 PM Dian Fu w
Hi Ingo,
Thanks a lot for starting up this discussion. I have not tried IntelliJ and
I’m using PyCharm for PyFlink development. Have you tried this guideline?
[1]
It’s written in 1.9 and I think it should still work.
Regards,
Dian
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/
Dian Fu created FLINK-23819:
---
Summary: Testing tgz file for python archives
Key: FLINK-23819
URL: https://issues.apache.org/jira/browse/FLINK-23819
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-23818:
---
Summary: Add documentation about tgz files support for python
archives
Key: FLINK-23818
URL: https://issues.apache.org/jira/browse/FLINK-23818
Project: Flink
Issue
Dian Fu created FLINK-23787:
---
Summary: Providing utility class for initializing various process
function test harnesses
Key: FLINK-23787
URL: https://issues.apache.org/jira/browse/FLINK-23787
Project
Dian Fu created FLINK-23754:
---
Summary: Testing Python DataStream API chaining functionality
Key: FLINK-23754
URL: https://issues.apache.org/jira/browse/FLINK-23754
Project: Flink
Issue Type: Sub
Dian Fu created FLINK-23753:
---
Summary: Add documentation about Python DataStream API chaining
optimization
Key: FLINK-23753
URL: https://issues.apache.org/jira/browse/FLINK-23753
Project: Flink
Dian Fu created FLINK-23619:
---
Summary: Remove PythonTimestampsAndWatermarksOperator
Key: FLINK-23619
URL: https://issues.apache.org/jira/browse/FLINK-23619
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-23616:
---
Summary: Support to chain for the Python operators as much as
possible
Key: FLINK-23616
URL: https://issues.apache.org/jira/browse/FLINK-23616
Project: Flink
Issue
Dian Fu created FLINK-23584:
---
Summary: Introduce PythonCoProcessOperator and remove
PythonCoFlatMapOperator & PythonCoMapOperator
Key: FLINK-23584
URL: https://issues.apache.org/jira/browse/FLINK-2
Dian Fu created FLINK-23578:
---
Summary: Remove Python operators
PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator and use
PythonProcessOperator instead
Key: FLINK-23578
URL: https
+1 (binding)
- checked the website PR
- verified the signatures and checksum
- installed the Python wheel package of Python 3.7 on MacOS and runs the word
count example
Regards,
Dian
> 2021年8月1日 下午4:17，Leonard Xu 写道：
>
> +1 (non-binding)
>
> - verified signatures and hashsums
> - built fr
+1 (binding)
- reviewed the website PR and have left a minor comment
- verified the signatures and checksum
- installed the Python wheel package of Python 3.8 on MacOS and runs some
simple examples
Regards,
Dian
> 2021年8月1日 下午3:10，Leonard Xu 写道：
>
>
> +1 (non-binding)
>
> - verified sign
+1 (binding)
- checked the website PR
- verified the signatures and checksum
- Installed the Python wheel package of Python 3.8 on MacOS and runs some
simple examples
Regards,
Dian
> 2021年8月1日 下午3:32，Leonard Xu 写道：
>
> +1 (non-binding)
>
> - verified signatures and hashsums
> - checked al
Dian Fu created FLINK-23445:
---
Summary: Separate data and timer connection into different
channels for Python Table API operators
Key: FLINK-23445
URL: https://issues.apache.org/jira/browse/FLINK-23445
Dian Fu created FLINK-23421:
---
Summary: Unify the space handling in RowData CSV parser
Key: FLINK-23421
URL: https://issues.apache.org/jira/browse/FLINK-23421
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-23401:
---
Summary: Separate data and timer connection into different channel
Key: FLINK-23401
URL: https://issues.apache.org/jira/browse/FLINK-23401
Project: Flink
Issue Type
Dian Fu created FLINK-23400:
---
Summary: Support to decode a single record for the Python coder
Key: FLINK-23400
URL: https://issues.apache.org/jira/browse/FLINK-23400
Project: Flink
Issue Type: Sub
Congratulations, Yang,
Regards,
Dian
> 2021年7月7日 上午10:46，Jary Zhen 写道：
>
> Congratulations, Yang Wang.
>
> Best
> Jary
>
> Yun Gao 于2021年7月7日周三 上午10:38写道：
>
>> Congratulations Yang!
>>
>> Best,
>> Yun
>>
>>
>> --
>> Sender:J
Congratulations, Guowei!
Regards,
Dian
> 2021年7月7日 上午10:37，Yun Gao 写道：
>
> Congratulations Guowei!
>
>
> Best,
> Yun
>
>
> --
> Sender:JING ZHANG
> Date:2021/07/07 10:33:51
> Recipient:dev
> Theme:Re: [ANNOUNCE] New PMC member:
Dian Fu created FLINK-23213:
---
Summary: Remove ProcessFunctionOperation
Key: FLINK-23213
URL: https://issues.apache.org/jira/browse/FLINK-23213
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-23166:
---
Summary: ZipUtils doesn't handle properly for softlinks inside the
zip file
Key: FLINK-23166
URL: https://issues.apache.org/jira/browse/FLINK-23166
Project:
Dian Fu created FLINK-23141:
---
Summary: Support KafkaSerializationSchema in Kafka connector for
Python DataStream API
Key: FLINK-23141
URL: https://issues.apache.org/jira/browse/FLINK-23141
Project: Flink
Dian Fu created FLINK-23138:
---
Summary: Raise an exception if types other than
PickledBytesTypeInfo are specified for state descriptor
Key: FLINK-23138
URL: https://issues.apache.org/jira/browse/FLINK-23138
Dian Fu created FLINK-23133:
---
Summary: The dependencies are not handled properly when mixing use
of Python Table API and Python DataStream API
Key: FLINK-23133
URL: https://issues.apache.org/jira/browse/FLINK-23133
Dian Fu created FLINK-23120:
---
Summary: ByteArrayWrapperSerializer.serialize should use writeInt
to serialize the length
Key: FLINK-23120
URL: https://issues.apache.org/jira/browse/FLINK-23120
Project
Thanks David for taking care of this. I will take a look at this issue.
Regards,
Dian
> 2021年6月22日 上午4:06，David Anderson 写道：
>
> I've been trying to upgrade the pyflink-walkthrough to Flink 1.13.1, but
> without any success.
>
> Unless I give it a lot of resources the data generator times out
Dian Fu created FLINK-23033:
---
Summary: Support object array in Python DataStream API
Key: FLINK-23033
URL: https://issues.apache.org/jira/browse/FLINK-23033
Project: Flink
Issue Type: Improvement
Congratulations, Xintong!
> 2021年6月16日 下午7:16，Benchao Li 写道：
>
> Congratulations, Xintong!
>
> Yang Wang 于2021年6月16日周三 下午6:48写道：
>
>> Congratulations Xintong!
>>
>> Best,
>> Yang
>>
>> Thomas Weise 于2021年6月16日周三 下午6:46写道：
>>
>>> Congratulations!
>>>
>>> On Wed, Jun 16, 2021 at 12:14 PM N
Congratulations, Arvid!
> 2021年6月16日 下午7:16，Benchao Li 写道：
>
> Congratulations, Arvid!
>
> Thomas Weise 于2021年6月16日周三 下午6:44写道：
>
>> Congratulations!
>>
>> On Wed, Jun 16, 2021 at 12:04 PM 刘建刚 wrote:
>>>
>>> Congratulations, Arvid!
>>>
>>> Best
>>>
>>> Xintong Song 于2021年6月16日周三 下午5:51写
Dian Fu created FLINK-22913:
---
Summary: Support Python UDF chaining in Python DataStream API
Key: FLINK-22913
URL: https://issues.apache.org/jira/browse/FLINK-22913
Project: Flink
Issue Type
Dian Fu created FLINK-22912:
---
Summary: Support state ttl in Python DataStream API
Key: FLINK-22912
URL: https://issues.apache.org/jira/browse/FLINK-22912
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-22911:
---
Summary: Align FLIP-136 (Improve interoperability between
DataStream and Table API) in PyFlink Table API
Key: FLINK-22911
URL: https://issues.apache.org/jira/browse/FLINK-22911
Dian Fu created FLINK-22733:
---
Summary: Type mismatch thrown in KeyedStream.union in Python
DataStream API
Key: FLINK-22733
URL: https://issues.apache.org/jira/browse/FLINK-22733
Project: Flink
Dian Fu created FLINK-22589:
---
Summary: There are quite a few Python classes doesn't appear in
the Python docs
Key: FLINK-22589
URL: https://issues.apache.org/jira/browse/FLINK-22589
Project:
Dian Fu created FLINK-22544:
---
Summary: Add the missing documentation about the command line
options for PyFlink
Key: FLINK-22544
URL: https://issues.apache.org/jira/browse/FLINK-22544
Project: Flink
Dian Fu created FLINK-22539:
---
Summary: Restructure the Python dependency management documentation
Key: FLINK-22539
URL: https://issues.apache.org/jira/browse/FLINK-22539
Project: Flink
Issue Type
+1 (binding)
- Verified the signature and checksum
- Installed PyFlink successfully using the source package
- Run a few PyFlink examples: Python UDF, Pandas UDF, Python DataStream API
with state access, Python DataStream API with batch execution mode
- Reviewed the website PR
Regards,
Dian
> 2
Dian Fu created FLINK-22470:
---
Summary: The root cause of the exception encountered during
compiling the job was not exposed to users in certain cases
Key: FLINK-22470
URL: https://issues.apache.org/jira/browse/FLINK
+1 (binding)
- Verified the checksum and signature
- Reviewed the website PR and have left a few comments
- Installed PyFlink with the source package on Mac OS and everything works well
- Ran a PyFlink example which uses both Python Table API and Python DataStream
API
Regards,
Dian
> 2021年4月24日
Dian Fu created FLINK-22418:
---
Summary: The currently activated tab in the same page isn't
consistent
Key: FLINK-22418
URL: https://issues.apache.org/jira/browse/FLINK-22418
Project: Flink
Dian Fu created FLINK-22327:
---
Summary: NPE exception happens if it throws exception in
finishBundle during job shutdown
Key: FLINK-22327
URL: https://issues.apache.org/jira/browse/FLINK-22327
Project
Dian Fu created FLINK-22297:
---
Summary: Perform early check to ensure that the length of the
result is the same as the input for Pandas UDF
Key: FLINK-22297
URL: https://issues.apache.org/jira/browse/FLINK-22297
Dian Fu created FLINK-22292:
---
Summary: Add documentation about state access in Python DataStream
API
Key: FLINK-22292
URL: https://issues.apache.org/jira/browse/FLINK-22292
Project: Flink
Issue
Dian Fu created FLINK-22125:
---
Summary: Revisit the return value of MapState.get when the key
doesn't exists
Key: FLINK-22125
URL: https://issues.apache.org/jira/browse/FLINK-22125
Project:
Dian Fu created FLINK-22124:
---
Summary: The job finished without any exception if error was
thrown during state access
Key: FLINK-22124
URL: https://issues.apache.org/jira/browse/FLINK-22124
Project: Flink
Dian Fu created FLINK-22123:
---
Summary: Test state access in Python DataStream API
Key: FLINK-22123
URL: https://issues.apache.org/jira/browse/FLINK-22123
Project: Flink
Issue Type: Test
Dian Fu created FLINK-22082:
---
Summary: Nested projection push down doesn't work for data:
row(array(row))
Key: FLINK-22082
URL: https://issues.apache.org/jira/browse/FLINK-22082
Project:
Dian Fu created FLINK-22070:
---
Summary: Support FileSink in PyFlink DataStream API
Key: FLINK-22070
URL: https://issues.apache.org/jira/browse/FLINK-22070
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-22061:
---
Summary: The DEFAULT_NON_SPLITTABLE_FILE_ENUMERATOR defined in
FileSource should points to NonSplittingRecursiveEnumerator
Key: FLINK-22061
URL: https://issues.apache.org/jira/browse/FLINK
Dian Fu created FLINK-22058:
---
Summary: Support FLIP-27 based NumberSequenceSource connector in
PyFlink DataStream API
Key: FLINK-22058
URL: https://issues.apache.org/jira/browse/FLINK-22058
Project: Flink
Dian Fu created FLINK-21994:
---
Summary: Support FLIP-27 based FileSource connector in PyFlink
DataStream API
Key: FLINK-21994
URL: https://issues.apache.org/jira/browse/FLINK-21994
Project: Flink
Dian Fu created FLINK-21971:
---
Summary: Support FLIP-27 based kafka source connector in PyFlink
DataStream API
Key: FLINK-21971
URL: https://issues.apache.org/jira/browse/FLINK-21971
Project: Flink
Dian Fu created FLINK-21953:
---
Summary: Add documentation on batch mode support of Python
DataStream API
Key: FLINK-21953
URL: https://issues.apache.org/jira/browse/FLINK-21953
Project: Flink
Dian Fu created FLINK-21944:
---
Summary: AbstractArrowPythonAggregateFunctionOperator.dispose
should consider whether arrowSerializer is null
Key: FLINK-21944
URL: https://issues.apache.org/jira/browse/FLINK-21944
Dian Fu created FLINK-21939:
---
Summary: Support batch mode in Python DataStream API for process
operation
Key: FLINK-21939
URL: https://issues.apache.org/jira/browse/FLINK-21939
Project: Flink
Dian Fu created FLINK-21938:
---
Summary: Add documentation about how to test Python UDFs
Key: FLINK-21938
URL: https://issues.apache.org/jira/browse/FLINK-21938
Project: Flink
Issue Type
Dian Fu created FLINK-21937:
---
Summary: Support batch mode in Python DataStream API for basic
operations
Key: FLINK-21937
URL: https://issues.apache.org/jira/browse/FLINK-21937
Project: Flink
Dian Fu created FLINK-21922:
---
Summary: The method partition_by in Over doesn't work
Key: FLINK-21922
URL: https://issues.apache.org/jira/browse/FLINK-21922
Project: Flink
Issue Type
Dian Fu created FLINK-21918:
---
Summary: Add execution.runtime-mode setter in
StreamExecutionEnvironment
Key: FLINK-21918
URL: https://issues.apache.org/jira/browse/FLINK-21918
Project: Flink
Issue
Dian Fu created FLINK-21916:
---
Summary: Allows multiple kinds of ManagedMemoryUseCase for the
same operator
Key: FLINK-21916
URL: https://issues.apache.org/jira/browse/FLINK-21916
Project: Flink
+1
Regards,
Dian
On Fri, Mar 19, 2021 at 6:39 PM Till Rohrmann wrote:
> +1
>
> Cheers,
> Till
>
> On Fri, Mar 19, 2021 at 9:02 AM Becket Qin wrote:
>
> > +1. Thanks for driving the effort, Dong.
> >
> > Jiangjie (Becket) Qin
> >
> > On Fri, Mar 19, 2021 at 10:07 AM Dong Lin wrote:
> >
> > > H
101 - 200 of 786 matches
Mail list logo
