Dian Fu created FLINK-17923:
---
Summary: It will throw MemoryAllocationException if rocksdb
statebackend and Python UDF are used in the same slot
Key: FLINK-17923
URL: https://issues.apache.org/jira/browse/FLINK-17923
Dian Fu created FLINK-17902:
---
Summary: Support the new interfaces about temporary functions in
PyFlink
Key: FLINK-17902
URL: https://issues.apache.org/jira/browse/FLINK-17902
Project: Flink
Issue
Dian Fu created FLINK-17901:
---
Summary: Add module interface in PyFlink
Key: FLINK-17901
URL: https://issues.apache.org/jira/browse/FLINK-17901
Project: Flink
Issue Type: Task
Components:
Dian Fu created FLINK-17822:
---
Summary: Flink CLI end-to-end test failed with
"JavaGcCleanerWrapper$PendingCleanersRunner cannot access class
jdk.internal.misc.SharedSecrets" in JDK 11
Key: FLINK-17822
URL: https://iss
Dian Fu created FLINK-17768:
---
Summary:
UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel
is instable
Key: FLINK-17768
URL: https://issues.apache.org/jira/browse/FLINK-17768
Dian Fu created FLINK-17597:
---
Summary: JavaSqlTests#test_java_sql_ddl is instable
Key: FLINK-17597
URL: https://issues.apache.org/jira/browse/FLINK-17597
Project: Flink
Issue Type: Bug
Co
Dian Fu created FLINK-17576:
---
Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are
instable
Key: FLINK-17576
URL: https://issues.apache.org/jira/browse/FLINK-17576
Project: Flink
Issue Typ
Dian Fu created FLINK-17220:
---
Summary: It reports "No space left on device" on azure pipeline
Key: FLINK-17220
URL: https://issues.apache.org/jira/browse/FLINK-17220
Project: Flink
Issue Type: Bug
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: Sub-task
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 Ty
Dian Fu created FLINK-17135:
---
Summary:
PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed
on master
Key: FLINK-17135
URL: https://issues.apache.org/jira/browse/FLINK-17135
Proj
Dian Fu created FLINK-17093:
---
Summary: Python UDF doesn't work when the input column is of
composite type
Key: FLINK-17093
URL: https://issues.apache.org/jira/browse/FLINK-17093
Project: Flink
Iss
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: Bu
Dian Fu created FLINK-16983:
---
Summary: Support RowType in vectorized Python UDF
Key: FLINK-16983
URL: https://issues.apache.org/jira/browse/FLINK-16983
Project: Flink
Issue Type: Task
Com
Dian Fu created FLINK-16932:
---
Summary: Remove unnecessary entries in the distribution jar NOTICE
Key: FLINK-16932
URL: https://issues.apache.org/jira/browse/FLINK-16932
Project: Flink
Issue Type: B
Dian Fu created FLINK-16914:
---
Summary: Support ArrayType in vectorized Python UDF
Key: FLINK-16914
URL: https://issues.apache.org/jira/browse/FLINK-16914
Project: Flink
Issue Type: Task
C
Dian Fu created FLINK-16847:
---
Summary: Support timestamp types in vectorized Python UDF
Key: FLINK-16847
URL: https://issues.apache.org/jira/browse/FLINK-16847
Project: Flink
Issue Type: Task
Dian Fu created FLINK-16759:
---
Summary: HiveModuleTest failed to compile on release-1.10
Key: FLINK-16759
URL: https://issues.apache.org/jira/browse/FLINK-16759
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-16747:
---
Summary: Performance improvements for Python UDF
Key: FLINK-16747
URL: https://issues.apache.org/jira/browse/FLINK-16747
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-16650:
---
Summary: Support LocalZonedTimestampType for Python UDF of blink
planner
Key: FLINK-16650
URL: https://issues.apache.org/jira/browse/FLINK-16650
Project: Flink
Issue
Dian Fu created FLINK-16608:
---
Summary: Support primitive data types for vectorized Python UDF
Key: FLINK-16608
URL: https://issues.apache.org/jira/browse/FLINK-16608
Project: Flink
Issue Type: Impr
Dian Fu created FLINK-16607:
---
Summary: Update flink-fn-execution.proto adding more schema
information
Key: FLINK-16607
URL: https://issues.apache.org/jira/browse/FLINK-16607
Project: Flink
Issue T
Dian Fu created FLINK-16606:
---
Summary: Throw exceptions for the data types which are not
currently supported
Key: FLINK-16606
URL: https://issues.apache.org/jira/browse/FLINK-16606
Project: Flink
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-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
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 T
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: Sub-tas
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
Dian Fu created FLINK-16337:
---
Summary: Add RelNodes and Rules for vectorized Python UDF execution
Key: FLINK-16337
URL: https://issues.apache.org/jira/browse/FLINK-16337
Project: Flink
Issue Type:
Dian Fu created FLINK-16271:
---
Summary: Introduce ArrowScalarFunctionOperator for vectorized
Python UDF execution
Key: FLINK-16271
URL: https://issues.apache.org/jira/browse/FLINK-16271
Project: Flink
Dian Fu created FLINK-16121:
---
Summary: Introduce ArrowReader and ArrowWriter for Arrow format
data read and write
Key: FLINK-16121
URL: https://issues.apache.org/jira/browse/FLINK-16121
Project: Flink
Dian Fu created FLINK-16114:
---
Summary: Support Scalar Vectorized Python UDF in PyFlink
Key: FLINK-16114
URL: https://issues.apache.org/jira/browse/FLINK-16114
Project: Flink
Issue Type: New Feature
Dian Fu created FLINK-16109:
---
Summary: Move the Python scalar operators and table operators to
separate package
Key: FLINK-16109
URL: https://issues.apache.org/jira/browse/FLINK-16109
Project: Flink
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
C
Dian Fu created FLINK-15974:
---
Summary: Support to use the Python UDF directly in the Python
Table API
Key: FLINK-15974
URL: https://issues.apache.org/jira/browse/FLINK-15974
Project: Flink
Issue T
Dian Fu created FLINK-15973:
---
Summary: Optimize the execution plan where it refers the Python
UDF result field in the where clause
Key: FLINK-15973
URL: https://issues.apache.org/jira/browse/FLINK-15973
Pro
Dian Fu created FLINK-15971:
---
Summary: Adjust the default value of bundle size and bundle time
Key: FLINK-15971
URL: https://issues.apache.org/jira/browse/FLINK-15971
Project: Flink
Issue Type: Imp
Dian Fu created FLINK-15970:
---
Summary: Optimize the Python UDF execution to only serialize the
value
Key: FLINK-15970
URL: https://issues.apache.org/jira/browse/FLINK-15970
Project: Flink
Issue Ty
Dian Fu created FLINK-15929:
---
Summary: test_dependency failed on travis
Key: FLINK-15929
URL: https://issues.apache.org/jira/browse/FLINK-15929
Project: Flink
Issue Type: Test
Components:
Dian Fu created FLINK-15902:
---
Summary: Improve the Python API doc of the version they are added
Key: FLINK-15902
URL: https://issues.apache.org/jira/browse/FLINK-15902
Project: Flink
Issue Type: Im
Dian Fu created FLINK-15897:
---
Summary: Deserialize the Python UDF execution results when sending
them out
Key: FLINK-15897
URL: https://issues.apache.org/jira/browse/FLINK-15897
Project: Flink
Iss
Dian Fu created FLINK-15875:
---
Summary: Bump Beam to 2.19.0
Key: FLINK-15875
URL: https://issues.apache.org/jira/browse/FLINK-15875
Project: Flink
Issue Type: Improvement
Components: API /
Dian Fu created FLINK-15493:
---
Summary:
FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator
failed on travis
Key: FLINK-15493
URL: https://issues.apache.org/jira/browse/FLINK-1
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
Componen
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
Componen
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 Type
Dian Fu created FLINK-15271:
---
Summary: Add documentation about the Python environment
requirements
Key: FLINK-15271
URL: https://issues.apache.org/jira/browse/FLINK-15271
Project: Flink
Issue Type
Dian Fu created FLINK-15270:
---
Summary: Add documentation about how to specify third-party
dependencies via API for Python UDFs
Key: FLINK-15270
URL: https://issues.apache.org/jira/browse/FLINK-15270
Project
Dian Fu created FLINK-15046:
---
Summary: Add guideline on how to report security issues
Key: FLINK-15046
URL: https://issues.apache.org/jira/browse/FLINK-15046
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-15025:
---
Summary: The license and notice is not correct for the
flink-python module
Key: FLINK-15025
URL: https://issues.apache.org/jira/browse/FLINK-15025
Project: Flink
Issu
Dian Fu created FLINK-14944:
---
Summary: Unstable test
FlinkFnExecutionSyncTests.test_flink_fn_execution_pb2_synced
Key: FLINK-14944
URL: https://issues.apache.org/jira/browse/FLINK-14944
Project: Flink
Dian Fu created FLINK-14891:
---
Summary: PythonScalarFunctionOperator should be chained with
upstream operators by default
Key: FLINK-14891
URL: https://issues.apache.org/jira/browse/FLINK-14891
Project: Flin
Dian Fu created FLINK-14888:
---
Summary: Move the Python SqlDialect to module table
Key: FLINK-14888
URL: https://issues.apache.org/jira/browse/FLINK-14888
Project: Flink
Issue Type: Task
C
Dian Fu created FLINK-14866:
---
Summary: A few documentation links are broken
Key: FLINK-14866
URL: https://issues.apache.org/jira/browse/FLINK-14866
Project: Flink
Issue Type: Bug
Componen
Dian Fu created FLINK-14865:
---
Summary:
PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 failed
in travis
Key: FLINK-14865
URL: https://issues.apache.org/jira/browse/FLINK-14865
Proje
Dian Fu created FLINK-14760:
---
Summary: Documentation links check failed on travis
Key: FLINK-14760
URL: https://issues.apache.org/jira/browse/FLINK-14760
Project: Flink
Issue Type: Bug
Co
Dian Fu created FLINK-14581:
---
Summary: Support to run Python UDF jobs in a YARN cluster
Key: FLINK-14581
URL: https://issues.apache.org/jira/browse/FLINK-14581
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14509:
---
Summary: Improve the README.md in pyflink to prepare for PyPI
release
Key: FLINK-14509
URL: https://issues.apache.org/jira/browse/FLINK-14509
Project: Flink
Issue Typ
Dian Fu created FLINK-14506:
---
Summary: Improve the release script for Python API release package
Key: FLINK-14506
URL: https://issues.apache.org/jira/browse/FLINK-14506
Project: Flink
Issue Type: S
Dian Fu created FLINK-14500:
---
Summary: Support Flink Python User-Defined Stateless Function for
Table(Phase 2)
Key: FLINK-14500
URL: https://issues.apache.org/jira/browse/FLINK-14500
Project: Flink
Dian Fu created FLINK-14469:
---
Summary: Drop Python 2 support
Key: FLINK-14469
URL: https://issues.apache.org/jira/browse/FLINK-14469
Project: Flink
Issue Type: Task
Components: API / Pyth
Dian Fu created FLINK-14388:
---
Summary: Support all the data types in Python user-defined
functions
Key: FLINK-14388
URL: https://issues.apache.org/jira/browse/FLINK-14388
Project: Flink
Issue Type
Dian Fu created FLINK-14342:
---
Summary: Remove method FunctionDefinition#getLanguage
Key: FLINK-14342
URL: https://issues.apache.org/jira/browse/FLINK-14342
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14272:
---
Summary: Support Blink planner for Python UDF
Key: FLINK-14272
URL: https://issues.apache.org/jira/browse/FLINK-14272
Project: Flink
Issue Type: Sub-task
Com
Dian Fu created FLINK-14269:
---
Summary: The close method does not work for UserDefinedFunction
Key: FLINK-14269
URL: https://issues.apache.org/jira/browse/FLINK-14269
Project: Flink
Issue Type: Sub-
Dian Fu created FLINK-14240:
---
Summary: The configuration added via TableConfig#configuration
should be added to GlobalJobParameters for the legacy planner
Key: FLINK-14240
URL: https://issues.apache.org/jira/browse/FLIN
Dian Fu created FLINK-14222:
---
Summary: Optimize for Python UDFs with all parameters are constant
values
Key: FLINK-14222
URL: https://issues.apache.org/jira/browse/FLINK-14222
Project: Flink
Issue
Dian Fu created FLINK-14212:
---
Summary: Support Python UDFs without arguments
Key: FLINK-14212
URL: https://issues.apache.org/jira/browse/FLINK-14212
Project: Flink
Issue Type: Sub-task
Co
Dian Fu created FLINK-14208:
---
Summary: Support Python UDF with parameters of constant values
Key: FLINK-14208
URL: https://issues.apache.org/jira/browse/FLINK-14208
Project: Flink
Issue Type: Sub-t
Dian Fu created FLINK-14202:
---
Summary: Optimize the execution plan for Python Calc when there is
a condition
Key: FLINK-14202
URL: https://issues.apache.org/jira/browse/FLINK-14202
Project: Flink
Dian Fu created FLINK-14028:
---
Summary: Support logging aggregation in Python user-defined
functions
Key: FLINK-14028
URL: https://issues.apache.org/jira/browse/FLINK-14028
Project: Flink
Issue Typ
Dian Fu created FLINK-14027:
---
Summary: Add documentation for Python user-defined functions
Key: FLINK-14027
URL: https://issues.apache.org/jira/browse/FLINK-14027
Project: Flink
Issue Type: Sub-tas
Dian Fu created FLINK-14026:
---
Summary: Manage the resource of Python worker properly
Key: FLINK-14026
URL: https://issues.apache.org/jira/browse/FLINK-14026
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14025:
---
Summary: Support to run the Python worker in docker mode
Key: FLINK-14025
URL: https://issues.apache.org/jira/browse/FLINK-14025
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14024:
---
Summary: Support use-defined metrics in Python user-defined
functions
Key: FLINK-14024
URL: https://issues.apache.org/jira/browse/FLINK-14024
Project: Flink
Issue Typ
Dian Fu created FLINK-14023:
---
Summary: Support accessing job parameters in Python user-defined
functions
Key: FLINK-14023
URL: https://issues.apache.org/jira/browse/FLINK-14023
Project: Flink
Issu
Dian Fu created FLINK-14022:
---
Summary: Add validation check for places where Python
ScalarFunction cannot be used
Key: FLINK-14022
URL: https://issues.apache.org/jira/browse/FLINK-14022
Project: Flink
Dian Fu created FLINK-14021:
---
Summary: Add rules to push down the Python ScalarFunctions
contained in the join condition of Correlate node
Key: FLINK-14021
URL: https://issues.apache.org/jira/browse/FLINK-14021
Dian Fu created FLINK-14020:
---
Summary: User Apache Arrow as the serializer for data transmission
between Java operator and Python harness
Key: FLINK-14020
URL: https://issues.apache.org/jira/browse/FLINK-14020
Dian Fu created FLINK-14019:
---
Summary: Python environment and dependency management
Key: FLINK-14019
URL: https://issues.apache.org/jira/browse/FLINK-14019
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14018:
---
Summary: Add Python building blocks to make sure the basic
functionality of Python ScalarFunction could work
Key: FLINK-14018
URL: https://issues.apache.org/jira/browse/FLINK-14018
Dian Fu created FLINK-14017:
---
Summary: Support to start up Python worker in process mode
Key: FLINK-14017
URL: https://issues.apache.org/jira/browse/FLINK-14017
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14016:
---
Summary: Introduce RelNodes FlinkLogicalPythonScalarFunctionExec
and DataStreamPythonScalarFunctionExec which are containers for Python
PythonScalarFunctions
Key: FLINK-14016
URL: https://
Dian Fu created FLINK-14015:
---
Summary: Introduce PythonScalarFunctionOperator as a standalone
StreamOperator for Python ScalarFunction execution
Key: FLINK-14015
URL: https://issues.apache.org/jira/browse/FLINK-14015
Dian Fu created FLINK-14014:
---
Summary: Introduce PythonScalarFunctionRunner to handle the
communication with Python worker for Python ScalarFunction execution
Key: FLINK-14014
URL: https://issues.apache.org/jira/browse/
Dian Fu created FLINK-14013:
---
Summary: Support Flink Python User-Defined Stateless Function for
Table
Key: FLINK-14013
URL: https://issues.apache.org/jira/browse/FLINK-14013
Project: Flink
Issue T
Dian Fu created FLINK-13999:
---
Summary: Correct the documentation of MATCH_RECOGNIZE
Key: FLINK-13999
URL: https://issues.apache.org/jira/browse/FLINK-13999
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-13743:
---
Summary: Port PythonTableUtils to flink-python module
Key: FLINK-13743
URL: https://issues.apache.org/jira/browse/FLINK-13743
Project: Flink
Issue Type: Task
Dian Fu created FLINK-12991:
---
Summary: Correct the implementation of Catalog.get_table_factory
Key: FLINK-12991
URL: https://issues.apache.org/jira/browse/FLINK-12991
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-12990:
---
Summary: Date type doesn't consider the local TimeZone
Key: FLINK-12990
URL: https://issues.apache.org/jira/browse/FLINK-12990
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-12962:
---
Summary: Allows pyflink to be pip installed
Key: FLINK-12962
URL: https://issues.apache.org/jira/browse/FLINK-12962
Project: Flink
Issue Type: Sub-task
Compo
Dian Fu created FLINK-12920:
---
Summary: Drop support for register_table_sink with field_names and
field_types parameters
Key: FLINK-12920
URL: https://issues.apache.org/jira/browse/FLINK-12920
Project: Flink
Dian Fu created FLINK-12910:
---
Summary: Fix the Python catalog test issue
Key: FLINK-12910
URL: https://issues.apache.org/jira/browse/FLINK-12910
Project: Flink
Issue Type: Bug
Components:
Dian Fu created FLINK-12897:
---
Summary: Improve the Python Table API docs by adding more examples
Key: FLINK-12897
URL: https://issues.apache.org/jira/browse/FLINK-12897
Project: Flink
Issue Type: S
Dian Fu created FLINK-12864:
---
Summary: Improves the performance of Python Table API test cases
Key: FLINK-12864
URL: https://issues.apache.org/jira/browse/FLINK-12864
Project: Flink
Issue Type: Sub
Dian Fu created FLINK-12821:
---
Summary: Fix the bug that fix time quantifier can not be the last
element of a pattern
Key: FLINK-12821
URL: https://issues.apache.org/jira/browse/FLINK-12821
Project: Flink
Dian Fu created FLINK-12788:
---
Summary: Add support to run a Python job-specific cluster on
Kubernetes
Key: FLINK-12788
URL: https://issues.apache.org/jira/browse/FLINK-12788
Project: Flink
Issue T
Dian Fu created FLINK-12787:
---
Summary: Allow to specify directory in option -pyfs
Key: FLINK-12787
URL: https://issues.apache.org/jira/browse/FLINK-12787
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12767:
---
Summary: Support user defined connectors/format
Key: FLINK-12767
URL: https://issues.apache.org/jira/browse/FLINK-12767
Project: Flink
Issue Type: Sub-task
C
Dian Fu created FLINK-12757:
---
Summary: Improves the Python word_count example to use the
descriptor API
Key: FLINK-12757
URL: https://issues.apache.org/jira/browse/FLINK-12757
Project: Flink
Issue
301 - 400 of 448 matches
Mail list logo
