[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656
]
Dian Fu edited comment on FLINK-16026 at 2/14/20 2:52 AM:
--
[~chesnay] Thanks a
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656
]
Dian Fu edited comment on FLINK-16026 at 2/14/20 2:51 AM:
--
[~chesnay] Thanks a
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656
]
Dian Fu commented on FLINK-16026:
-
[~chesnay] Thanks a lot for your suggestions. Appreciated!
We have
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036656#comment-17036656
]
Dian Fu edited comment on FLINK-16026 at 2/14/20 2:53 AM:
--
[~chesnay] Thanks a
[
https://issues.apache.org/jira/browse/FLINK-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037508#comment-17037508
]
Dian Fu commented on FLINK-16010:
-
As [~dwysakowicz] mentioned in FLINK-9431, I also think that this is
Dian Fu created FLINK-16053:
---
Summary: Remove redundant metrics in PyFlink
Key: FLINK-16053
URL: https://issues.apache.org/jira/browse/FLINK-16053
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16026:
---
Assignee: Dian Fu
> Travis failed due to python setup
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16026:
---
Assignee: Huang Xingbo (was: Dian Fu)
> Travis failed due to python setup
>
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16026:
Fix Version/s: 1.10.1
> Travis failed due to python setup
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035921#comment-17035921
]
Dian Fu commented on FLINK-16026:
-
[~lzljs3620320] Thanks for reporting this issue.
[~hxbks2ks] Thanks
[
https://issues.apache.org/jira/browse/FLINK-15970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-15970.
---
Resolution: Resolved
Merged to master via 6278fa8cd034b510204dd8b4b849ae8ef381f288
> Optimize the Python
[
https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16026.
---
Resolution: Fixed
Merged to
master via c40b0b232f4b04102b8220ced99cc4ae638a65df
release-1.10 via
[
https://issues.apache.org/jira/browse/FLINK-16071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16071.
---
Resolution: Resolved
Merged to master via 9bc6f693294952cd1456701e60d63722514a8b9b
> Optimize the cost of
[
https://issues.apache.org/jira/browse/FLINK-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16053.
---
Resolution: Resolved
Merged to master via 881a3ca42ec48b0897fa11821473f4ffaf3cd3a3
> Remove redundant
[
https://issues.apache.org/jira/browse/FLINK-16053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16053:
Description: We have recorded the metrics about how many elements it has
processed in Python UDF. This
[
https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-14013.
---
Resolution: Fixed
> Support Flink Python User-Defined Stateless Function for Table
>
[
https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016738#comment-17016738
]
Dian Fu commented on FLINK-14013:
-
[~sunjincheng121] Thanks a lot for the remind. I will close it as all
[
https://issues.apache.org/jira/browse/FLINK-15675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019295#comment-17019295
]
Dian Fu commented on FLINK-15675:
-
Fixed in:
master: 360afd9fdf70484a246034b463251f36e8288130
1.10.0:
[
https://issues.apache.org/jira/browse/FLINK-15675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-15675.
---
Resolution: Resolved
> Add exception and documentation that Python UDF is not supported for Flink
>
[
https://issues.apache.org/jira/browse/FLINK-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-15636.
---
Fix Version/s: 1.11.0
Resolution: Resolved
Merged to master via
[
https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019853#comment-17019853
]
Dian Fu commented on FLINK-14557:
-
Resolved in 1.9.2 via c9f9c547ac3fd9e421e0140b27c08189708c2e46
>
[
https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019826#comment-17019826
]
Dian Fu commented on FLINK-14557:
-
Make sense to me as these redundant files are confusing for users.
[
https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14557:
Fix Version/s: 1.9.2
> Clean up the package of py4j
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15414:
Fix Version/s: 1.9.2
> KafkaITCase#prepare failed in travis
>
>
>
Dian Fu created FLINK-15412:
---
Summary: LocalExecutorITCase#testParameterizedTypes failed in
travis
Key: FLINK-15412
URL: https://issues.apache.org/jira/browse/FLINK-15412
Project: Flink
Issue
Dian Fu created FLINK-15413:
---
Summary: ScalarOperatorsTest failed in travis
Key: FLINK-15413
URL: https://issues.apache.org/jira/browse/FLINK-15413
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15413:
Description:
The travis of release-1.9 failed with the following error:
{code:java}
14:50:19.796 [ERROR]
[
https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15412:
Description:
The travis of release-1.9 failed with the following error:
{code:java}
14:43:17.916 [INFO]
[
https://issues.apache.org/jira/browse/FLINK-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15414:
Description:
The travis for release-1.9 failed with the following error:
{code:java}
15:43:24.454 [ERROR]
Dian Fu created FLINK-15414:
---
Summary: KafkaITCase#prepare failed in travis
Key: FLINK-15414
URL: https://issues.apache.org/jira/browse/FLINK-15414
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003088#comment-17003088
]
Dian Fu commented on FLINK-15382:
-
Hi [~xintongsong] [~karmagyz], thanks for reporting this issue. Could
[
https://issues.apache.org/jira/browse/FLINK-15382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003177#comment-17003177
]
Dian Fu commented on FLINK-15382:
-
Have investigated this problem with [~xintongsong] offline and found
[
https://issues.apache.org/jira/browse/FLINK-15382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003108#comment-17003108
]
Dian Fu commented on FLINK-15382:
-
The jar of flink-python should be available for the doc generation.
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15493:
Description:
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15493:
Description:
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009422#comment-17009422
]
Dian Fu commented on FLINK-15493:
-
I checked the code and there are no changes for the Kafka connector
Dian Fu created FLINK-15493:
---
Summary:
FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator
failed on travis
Key: FLINK-15493
URL:
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15493:
Fix Version/s: (was: 1.10.0)
1.11.0
>
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15493:
Affects Version/s: (was: 1.10.0)
>
[
https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009287#comment-17009287
]
Dian Fu commented on FLINK-15493:
-
cc [~becket_qin]
>
[
https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16524:
---
Assignee: Huang Xingbo
> Optimize the result of FlattenRowCoder to generator to eliminate
[
https://issues.apache.org/jira/browse/FLINK-16304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16304:
Affects Version/s: (was: 1.11.0)
> Remove python packages bundled in the flink-python jar
>
[
https://issues.apache.org/jira/browse/FLINK-16304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16304.
---
Resolution: Resolved
Merged to master via 42f49482a3217287abba5e8903cf50791acf287a
> Remove python
[
https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16516:
---
Assignee: Huang Xingbo
> Remove Python UDF Codegen Code
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16522:
Description: Type Hints was introduced in Python 3.5 and it would be great
if we can declare the
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16522:
Summary: Use type hints to declare the signature of the methods (was: Take
use of Python3 type hint to
[
https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16522:
---
Assignee: Huang Xingbo
> Take use of Python3 type hint to rebuild Python Function signature
>
[
https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16516.
---
Resolution: Resolved
> Avoid codegen user-defined function for Python UDF
>
[
https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057036#comment-17057036
]
Dian Fu commented on FLINK-16516:
-
Merged to master via b2c20e9cf5a58096d033bfe14cce277c938a53c6
>
[
https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16516:
Description: Currently we make use of codegen to generate
PythonScalarFunction and PythonTableFunction,
[
https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16516:
Summary: Avoid codegen user-defined function for Python UDF (was: Remove
Python UDF Codegen Code)
>
Dian Fu created FLINK-16538:
---
Summary: Restructure Python Table API documentation
Key: FLINK-16538
URL: https://issues.apache.org/jira/browse/FLINK-16538
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-16484:
---
Summary: Support all the data types in vectorized Python UDF
Key: FLINK-16484
URL: https://issues.apache.org/jira/browse/FLINK-16484
Project: Flink
Issue Type:
Dian Fu created FLINK-16485:
---
Summary: Support vectorized Python UDF in the batch mode of old
planner
Key: FLINK-16485
URL: https://issues.apache.org/jira/browse/FLINK-16485
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16483:
---
Assignee: Dian Fu
> Add Python building blocks to make sure the basic functionality of vectorized
Dian Fu created FLINK-16483:
---
Summary: Add Python building blocks to make sure the basic
functionality of vectorized Python UDF could work
Key: FLINK-16483
URL: https://issues.apache.org/jira/browse/FLINK-16483
[
https://issues.apache.org/jira/browse/FLINK-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16486:
Component/s: Documentation
> Add documentation for vectorized Python UDF
>
[
https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16273:
Parent: FLINK-16114
Issue Type: Sub-task (was: Bug)
> Solve "sun.misc.Unseafe or
Dian Fu created FLINK-16486:
---
Summary: Add documentation for vectorized Python UDF
Key: FLINK-16486
URL: https://issues.apache.org/jira/browse/FLINK-16486
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054774#comment-17054774
]
Dian Fu commented on FLINK-16485:
-
[~ykt836] [~hongfanxo] Thanks for sharing your thoughts about this
[
https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17054829#comment-17054829
]
Dian Fu commented on FLINK-16485:
-
[~ykt836] I get your concern now and it's transparent for the whole
[
https://issues.apache.org/jira/browse/FLINK-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16250.
---
Resolution: Resolved
Merged to master via 6f10a23e6bca741a9357a91457eb85a8879a40c2
> Add interfaces for
[
https://issues.apache.org/jira/browse/FLINK-16668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-16668.
---
Resolution: Resolved
Merged to master via c401da36dfb5ff05527ed769babe16cbfdfc80be
> Improve PythonDriver
[
https://issues.apache.org/jira/browse/FLINK-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078844#comment-17078844
]
Dian Fu commented on FLINK-15170:
-
Another instance from master:
[
https://issues.apache.org/jira/browse/FLINK-16668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16668:
Summary: Improve PythonDriver to parse python dependency info from
configuration (was: Refactor
Dian Fu created FLINK-17062:
---
Summary: Fix the conversion from Java row type to Python row type
Key: FLINK-17062
URL: https://issues.apache.org/jira/browse/FLINK-17062
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-1.
---
Resolution: Resolved
Merged to master via 6f235b0d961c1e08f778f25522bb7f605744a1d6
> Introduce Python
[
https://issues.apache.org/jira/browse/FLINK-17062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079084#comment-17079084
]
Dian Fu commented on FLINK-17062:
-
[~f.pompermaier] Thanks a lot for the suggestions!
The conversion
[
https://issues.apache.org/jira/browse/FLINK-17062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079084#comment-17079084
]
Dian Fu edited comment on FLINK-17062 at 4/9/20, 9:04 AM:
--
[~f.pompermaier]
[
https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079156#comment-17079156
]
Dian Fu commented on FLINK-17068:
-
[~rmetzger] Thanks for reporting this issue. Will take a look at
[
https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-17065:
---
Assignee: Huang Xingbo
> Adds notes of Python versions supported by PyFlink in doc
>
[
https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17065:
Fix Version/s: (was: 1.9.3)
> Adds notes of Python versions supported by PyFlink in doc
>
[
https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17065:
Summary: Add documentation about the Python versions supported for PyFlink
(was: Adds documentation
[
https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17065:
Summary: Adds documentation about the Python versions supported of PyFlink
(was: Adds notes of Python
[
https://issues.apache.org/jira/browse/FLINK-17123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082291#comment-17082291
]
Dian Fu commented on FLINK-17123:
-
[~longxibendi] Thanks for creating the ticket. Please use English in
[
https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083727#comment-17083727
]
Dian Fu commented on FLINK-16921:
-
Another instance :
[
https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084473#comment-17084473
]
Dian Fu commented on FLINK-17135:
-
[~dwysakowicz] Thanks a lot for this information. Very helpful. I
[
https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084473#comment-17084473
]
Dian Fu edited comment on FLINK-17135 at 4/16/20, 1:37 AM:
---
[~dwysakowicz]
Dian Fu created FLINK-17148:
---
Summary: Support converting pandas dataframe to flink table
Key: FLINK-17148
URL: https://issues.apache.org/jira/browse/FLINK-17148
Project: Flink
Issue Type:
Dian Fu created FLINK-17146:
---
Summary: Support conversion between PyFlink Table and Pandas
DataFrame
Key: FLINK-17146
URL: https://issues.apache.org/jira/browse/FLINK-17146
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-13811:
Parent: FLINK-17146
Issue Type: Sub-task (was: New Feature)
> Support converting flink table to
[
https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083816#comment-17083816
]
Dian Fu commented on FLINK-16572:
-
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-17212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-17212.
---
Resolution: Invalid
Mark it as invalid. Let's add the cython support after gcc is available in the
azure
[
https://issues.apache.org/jira/browse/FLINK-16280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16280:
Summary: Fix sample code errors in the documentation about elasticsearch
connector (was: Fix sample code
[
https://issues.apache.org/jira/browse/FLINK-17212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17212:
Parent: (was: FLINK-17115)
Issue Type: Bug (was: Sub-task)
> Disable the cython tests
>
[
https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11767:
Fix Version/s: 1.9.3
> Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest
>
[
https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-14316:
Summary: Stuck in "Job leader ... lost leadership" error (was: stuck in
"Job leader ... lost leadership"
[
https://issues.apache.org/jira/browse/FLINK-16242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16242:
Issue Type: Bug (was: Improvement)
> BinaryGeneric serialization error cause checkpoint failure
>
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11193:
Summary: Rocksdb timer service factory configuration option is not settable
per job (was: Rockdb timer
[
https://issues.apache.org/jira/browse/FLINK-16860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16860:
Summary: Failed to push filter into OrcTableSource when upgrading to 1.9.2
(was: TableException: Failed
[
https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16167:
Summary: Update documentation about python shell execution (was: update
python_shell document execution)
[
https://issues.apache.org/jira/browse/FLINK-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17119:
Summary: Add Cython support for composite types (was: Support Composite
DataTypes in Cython)
> Add
[
https://issues.apache.org/jira/browse/FLINK-17119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-17119.
---
Assignee: Huang Xingbo
Resolution: Resolved
Merged to master via
[
https://issues.apache.org/jira/browse/FLINK-16942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16942:
Summary: ES 5 sink should allow users to select netty transport client
(was: ES 5 sink should allows
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-1:
Summary: Introduce Python dependency config options (was: Support new
Python dependency configuration
[
https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17093:
Summary: Python UDF doesn't work when the input column is from composite
field (was: Python UDF doesn't
[
https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081602#comment-17081602
]
Dian Fu commented on FLINK-17092:
-
Thanks [~zjwang] for reporting this issue. Will take a look!
>
[
https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-17092:
---
Assignee: Wei Zhong
> Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests
>
[
https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081617#comment-17081617
]
Dian Fu commented on FLINK-17092:
-
cc [~zhongwei]
> Pyflink failure for BlinkStreamDependencyTests and
[
https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081616#comment-17081616
]
Dian Fu edited comment on FLINK-17092 at 4/12/20, 2:07 AM:
---
Update: there are
501 - 600 of 4090 matches
Mail list logo
