Huang Xingbo created FLINK-13137:
Summary: Remove the legacy flink python docs
Key: FLINK-13137
URL: https://issues.apache.org/jira/browse/FLINK-13137
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-15961:
Summary: Introduce Python Physical Correlate RelNodes which are
containers for Python Python TableFunction
Key: FLINK-15961
URL: https://issues.apache.org/jira/browse/FLINK-15961
Huang Xingbo created FLINK-15972:
Summary: Add Python building blocks to make sure the basic
functionality of Python TableFunction could work
Key: FLINK-15972
URL: https://issues.apache.org/jira/browse/FLINK-15972
Huang Xingbo created FLINK-16007:
Summary: Add rules to push down the Java Calls contained in Python
Correlate node
Key: FLINK-16007
URL: https://issues.apache.org/jira/browse/FLINK-16007
Project: Fli
Huang Xingbo created FLINK-16008:
Summary: Add rules to transpose the join condition of Python
Correlate node
Key: FLINK-16008
URL: https://issues.apache.org/jira/browse/FLINK-16008
Project: Flink
Huang Xingbo created FLINK-16040:
Summary: Change local import to global import
Key: FLINK-16040
URL: https://issues.apache.org/jira/browse/FLINK-16040
Project: Flink
Issue Type: Improvement
Huang Xingbo created FLINK-16071:
Summary: Optimize the cost of the get item of the Row in operation
and coder
Key: FLINK-16071
URL: https://issues.apache.org/jira/browse/FLINK-16071
Project: Flink
Huang Xingbo created FLINK-16072:
Summary: Optimize the performance of the write/read null mask in
RowCoder
Key: FLINK-16072
URL: https://issues.apache.org/jira/browse/FLINK-16072
Project: Flink
Huang Xingbo created FLINK-16251:
Summary: Optimize the cost of function call in
ScalarFunctionOpertation
Key: FLINK-16251
URL: https://issues.apache.org/jira/browse/FLINK-16251
Project: Flink
Huang Xingbo created FLINK-16252:
Summary: Optimize the progress of the process_outputs in Python UDF
Key: FLINK-16252
URL: https://issues.apache.org/jira/browse/FLINK-16252
Project: Flink
Is
Huang Xingbo created FLINK-16435:
Summary: Fix ide static check
Key: FLINK-16435
URL: https://issues.apache.org/jira/browse/FLINK-16435
Project: Flink
Issue Type: Improvement
Compo
Huang Xingbo created FLINK-16516:
Summary: Remove Python UDF Codegen Code
Key: FLINK-16516
URL: https://issues.apache.org/jira/browse/FLINK-16516
Project: Flink
Issue Type: Improvement
Huang Xingbo created FLINK-16522:
Summary: Take use of Python3 type hint to rebuild Python Function
signature
Key: FLINK-16522
URL: https://issues.apache.org/jira/browse/FLINK-16522
Project: Flink
Huang Xingbo created FLINK-16524:
Summary: Optimize the result of FlattenRowCoder to generator to
eliminate unnecessary function calls
Key: FLINK-16524
URL: https://issues.apache.org/jira/browse/FLINK-16524
Huang Xingbo created FLINK-16691:
Summary: Adjust Python UDF document to remind users to install
PyFlink on the cluster
Key: FLINK-16691
URL: https://issues.apache.org/jira/browse/FLINK-16691
Project:
Huang Xingbo created FLINK-16748:
Summary: Add Python UDTF doc
Key: FLINK-16748
URL: https://issues.apache.org/jira/browse/FLINK-16748
Project: Flink
Issue Type: Improvement
Compone
Huang Xingbo created FLINK-16796:
Summary: Fix The Bug of Python UDTF in SQL Query
Key: FLINK-16796
URL: https://issues.apache.org/jira/browse/FLINK-16796
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-16980:
Summary: PyFlink UDF execution module is not compatible with
protobuf 3.6.1
Key: FLINK-16980
URL: https://issues.apache.org/jira/browse/FLINK-16980
Project: Flink
Huang Xingbo created FLINK-17013:
Summary: Support Python UDTF in old planner under batch mode
Key: FLINK-17013
URL: https://issues.apache.org/jira/browse/FLINK-17013
Project: Flink
Issue Typ
Huang Xingbo created FLINK-17065:
Summary: Adds notes of Python versions supported by PyFlink in doc
Key: FLINK-17065
URL: https://issues.apache.org/jira/browse/FLINK-17065
Project: Flink
Iss
Huang Xingbo created FLINK-17066:
Summary: Limits the PyArrow version to 0.13
Key: FLINK-17066
URL: https://issues.apache.org/jira/browse/FLINK-17066
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-17115:
Summary: Support Cython Optimizing Python User Defined
Function(FLIP-121)
Key: FLINK-17115
URL: https://issues.apache.org/jira/browse/FLINK-17115
Project: Flink
Huang Xingbo created FLINK-17118:
Summary: Support Primitive DataTypes in Cython
Key: FLINK-17118
URL: https://issues.apache.org/jira/browse/FLINK-17118
Project: Flink
Issue Type: Sub-task
Huang Xingbo created FLINK-17119:
Summary: Support Composite DataTypes in Cython
Key: FLINK-17119
URL: https://issues.apache.org/jira/browse/FLINK-17119
Project: Flink
Issue Type: Sub-task
Huang Xingbo created FLINK-17120:
Summary: Support Cython Optimizing Python Operations
Key: FLINK-17120
URL: https://issues.apache.org/jira/browse/FLINK-17120
Project: Flink
Issue Type: Sub-t
Huang Xingbo created FLINK-17121:
Summary: Adds Pipeline of Building Wheel Packages in Azure CI
Key: FLINK-17121
URL: https://issues.apache.org/jira/browse/FLINK-17121
Project: Flink
Issue Ty
Huang Xingbo created FLINK-17124:
Summary: The PyFlink Job runs into infinite loop if the UDF file
imports job code.
Key: FLINK-17124
URL: https://issues.apache.org/jira/browse/FLINK-17124
Project: Fl
Huang Xingbo created FLINK-17125:
Summary: Add a Usage Notes Page to Answer Common Questions
Encountered by PyFlink Users
Key: FLINK-17125
URL: https://issues.apache.org/jira/browse/FLINK-17125
Projec
Huang Xingbo created FLINK-17212:
Summary: Disable the cython tests
Key: FLINK-17212
URL: https://issues.apache.org/jira/browse/FLINK-17212
Project: Flink
Issue Type: Improvement
Co
Huang Xingbo created FLINK-17311:
Summary: Add executable permissions to the script in the wheel
package
Key: FLINK-17311
URL: https://issues.apache.org/jira/browse/FLINK-17311
Project: Flink
Huang Xingbo created FLINK-17394:
Summary: Add RemoteEnvironment and RemoteStreamEnvironment in
Python
Key: FLINK-17394
URL: https://issues.apache.org/jira/browse/FLINK-17394
Project: Flink
Huang Xingbo created FLINK-17395:
Summary: Add the sign and sha logic for PyFlink wheel packages
Key: FLINK-17395
URL: https://issues.apache.org/jira/browse/FLINK-17395
Project: Flink
Issue T
Huang Xingbo created FLINK-17414:
Summary: Change the steps of building PyFlink in doc
Key: FLINK-17414
URL: https://issues.apache.org/jira/browse/FLINK-17414
Project: Flink
Issue Type: Sub-t
Huang Xingbo created FLINK-14547:
Summary: UDF cannot be in the join condition in blink planner
Key: FLINK-14547
URL: https://issues.apache.org/jira/browse/FLINK-14547
Project: Flink
Issue Ty
Huang Xingbo created FLINK-14573:
Summary: Support time data types in Python user-defined functions
Key: FLINK-14573
URL: https://issues.apache.org/jira/browse/FLINK-14573
Project: Flink
Issu
Huang Xingbo created FLINK-14584:
Summary: Support complex data types in Python user-defined
functions
Key: FLINK-14584
URL: https://issues.apache.org/jira/browse/FLINK-14584
Project: Flink
Huang Xingbo created FLINK-15168:
Summary: Exception is thrown when using kafka source connector
with flink planner
Key: FLINK-15168
URL: https://issues.apache.org/jira/browse/FLINK-15168
Project: Fli
Huang Xingbo created FLINK-15650:
Summary: Improve the udfs documentation of the Python API
Key: FLINK-15650
URL: https://issues.apache.org/jira/browse/FLINK-15650
Project: Flink
Issue Type:
Huang Xingbo created FLINK-15657:
Summary: Fix the python table api doc link
Key: FLINK-15657
URL: https://issues.apache.org/jira/browse/FLINK-15657
Project: Flink
Issue Type: Improvement
Huang Xingbo created FLINK-15700:
Summary: Improve Python API Tutorial doc
Key: FLINK-15700
URL: https://issues.apache.org/jira/browse/FLINK-15700
Project: Flink
Issue Type: Improvement
Huang Xingbo created FLINK-15861:
Summary: Change TableEnvironmentImpl to
StreamTableaEnvironmentImpl in python blink batch mode
Key: FLINK-15861
URL: https://issues.apache.org/jira/browse/FLINK-15861
Huang Xingbo created FLINK-15913:
Summary: Add Python Table Function Runner And Operator
Key: FLINK-15913
URL: https://issues.apache.org/jira/browse/FLINK-15913
Project: Flink
Issue Type: New
Huang Xingbo created FLINK-19138:
Summary: Python UDF supports directly specifying input_types as
DataTypes.ROW
Key: FLINK-19138
URL: https://issues.apache.org/jira/browse/FLINK-19138
Project: Flink
Huang Xingbo created FLINK-19163:
Summary: Add building py38 wheel package of PyFlink in Azure CI
Key: FLINK-19163
URL: https://issues.apache.org/jira/browse/FLINK-19163
Project: Flink
Issue
Huang Xingbo created FLINK-19169:
Summary: Support Pandas UDAF in PyFlink (FLIP-137)
Key: FLINK-19169
URL: https://issues.apache.org/jira/browse/FLINK-19169
Project: Flink
Issue Type: Improve
Huang Xingbo created FLINK-19173:
Summary: Add Pandas Batch Group Aggregation Function Operator
Key: FLINK-19173
URL: https://issues.apache.org/jira/browse/FLINK-19173
Project: Flink
Issue Ty
Huang Xingbo created FLINK-19184:
Summary: Add Batch Physical Pandas Group Aggregate Rule and RelNode
Key: FLINK-19184
URL: https://issues.apache.org/jira/browse/FLINK-19184
Project: Flink
Is
Huang Xingbo created FLINK-19186:
Summary: Add Python building blocks to make sure the basic
functionality of Pandas Batch Group Aggregation could work
Key: FLINK-19186
URL: https://issues.apache.org/jira/browse/F
Huang Xingbo created FLINK-19277:
Summary: Introduce
BatchArrowPythonGroupWindowAggregateFunctionOperator
Key: FLINK-19277
URL: https://issues.apache.org/jira/browse/FLINK-19277
Project: Flink
Huang Xingbo created FLINK-19333:
Summary: Introduce
BatchArrowPythonOverWindowAggregateFunctionOperator
Key: FLINK-19333
URL: https://issues.apache.org/jira/browse/FLINK-19333
Project: Flink
Huang Xingbo created FLINK-19364:
Summary: Add Batch Physical Pandas Group Window Aggregate Rule and
RelNode
Key: FLINK-19364
URL: https://issues.apache.org/jira/browse/FLINK-19364
Project: Flink
Huang Xingbo created FLINK-19372:
Summary: Support Pandas Batch Over Window Aggregation
Key: FLINK-19372
URL: https://issues.apache.org/jira/browse/FLINK-19372
Project: Flink
Issue Type: Sub-
Huang Xingbo created FLINK-19403:
Summary: Support Pandas Stream Group Window Aggregation
Key: FLINK-19403
URL: https://issues.apache.org/jira/browse/FLINK-19403
Project: Flink
Issue Type: Su
Huang Xingbo created FLINK-19404:
Summary: Support Pandas Stream Over Window Aggregation
Key: FLINK-19404
URL: https://issues.apache.org/jira/browse/FLINK-19404
Project: Flink
Issue Type: Sub
Huang Xingbo created FLINK-19412:
Summary: Re-layer Python Operation Make it Possible to Provide
only Python implementation
Key: FLINK-19412
URL: https://issues.apache.org/jira/browse/FLINK-19412
Proj
Huang Xingbo created FLINK-19416:
Summary: Support Python datetime object in from_collection of
Python DataStream
Key: FLINK-19416
URL: https://issues.apache.org/jira/browse/FLINK-19416
Project: Flink
Huang Xingbo created FLINK-19417:
Summary: Fix the bug of the method from_data_stream in
table_environement
Key: FLINK-19417
URL: https://issues.apache.org/jira/browse/FLINK-19417
Project: Flink
Huang Xingbo created FLINK-19450:
Summary: Optimize the Python CI Test
Key: FLINK-19450
URL: https://issues.apache.org/jira/browse/FLINK-19450
Project: Flink
Issue Type: Improvement
Huang Xingbo created FLINK-19643:
Summary: Add Pandas UDAF Doc
Key: FLINK-19643
URL: https://issues.apache.org/jira/browse/FLINK-19643
Project: Flink
Issue Type: Sub-task
Components
Huang Xingbo created FLINK-19733:
Summary: Make fast_operation and slow_operation produce functions
consistent
Key: FLINK-19733
URL: https://issues.apache.org/jira/browse/FLINK-19733
Project: Flink
Huang Xingbo created FLINK-19892:
Summary: Replace __metaclass__ field with metaclass keyword
Key: FLINK-19892
URL: https://issues.apache.org/jira/browse/FLINK-19892
Project: Flink
Issue Type
Huang Xingbo created FLINK-19894:
Summary: Use iloc for positional slicing instead of direct slicing
in from_pandas
Key: FLINK-19894
URL: https://issues.apache.org/jira/browse/FLINK-19894
Project: Fli
Huang Xingbo created FLINK-20177:
Summary: Liquid Exception: Could not find document
'dev/table/connectors/kinesis.md' in tag 'link'. Make sure the document exists
and the path is correct. in dev/table/connectors/index.zh.md
Key
Huang Xingbo created FLINK-20183:
Summary: Fix the default PYTHONPATH is overwritten in client side
Key: FLINK-20183
URL: https://issues.apache.org/jira/browse/FLINK-20183
Project: Flink
Issu
Huang Xingbo created FLINK-20198:
Summary: Liquid Exception: Could not find document
'dev/table/connectors/formats/index.md' in tag 'link'. Make sure the document
exists and the path is correct. in dev/table/connectors/upsert-kafka.zh.md
Huang Xingbo created FLINK-20199:
Summary: PyFlink unstable e2e DataStream test
Key: FLINK-20199
URL: https://issues.apache.org/jira/browse/FLINK-20199
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20202:
Summary: Add the Check of Unsupported Result Type in Pandas UDAF
Key: FLINK-20202
URL: https://issues.apache.org/jira/browse/FLINK-20202
Project: Flink
Issue
Huang Xingbo created FLINK-20218:
Summary: AttributeError: module 'urllib' has no attribute 'parse'
Key: FLINK-20218
URL: https://issues.apache.org/jira/browse/FLINK-20218
Project: Flink
Issu
Huang Xingbo created FLINK-20308:
Summary: Liquid Exception: Could not find document
'dev/table/streaming/time_attributes.md' in tag 'link'. Make sure the document
exists and the path is correct. in dev/table/sql/create.zh.md
Key
Huang Xingbo created FLINK-20362:
Summary: Broken Link in dev/table/sourceSinks.zh.md
Key: FLINK-20362
URL: https://issues.apache.org/jira/browse/FLINK-20362
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20384:
Summary: Broken Link in deployment/ha/kubernetes_ha.zh.md
Key: FLINK-20384
URL: https://issues.apache.org/jira/browse/FLINK-20384
Project: Flink
Issue Type:
Huang Xingbo created FLINK-20407:
Summary: Migrate test_pyflink.sh
Key: FLINK-20407
URL: https://issues.apache.org/jira/browse/FLINK-20407
Project: Flink
Issue Type: Sub-task
Compon
Huang Xingbo created FLINK-20408:
Summary: Migrate test_pyflink_yarn.sh
Key: FLINK-20408
URL: https://issues.apache.org/jira/browse/FLINK-20408
Project: Flink
Issue Type: Sub-task
C
Huang Xingbo created FLINK-20409:
Summary: Migrate test_kubernetes_pyflink_application.sh
Key: FLINK-20409
URL: https://issues.apache.org/jira/browse/FLINK-20409
Project: Flink
Issue Type: Su
Huang Xingbo created FLINK-20430:
Summary: Broken links in deployment/index.zh.md
Key: FLINK-20430
URL: https://issues.apache.org/jira/browse/FLINK-20430
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20431:
Summary:
KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134
expected:<10> but was:<1>
Key: FLINK-20431
URL: https
Huang Xingbo created FLINK-20461:
Summary:
YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication
Key: FLINK-20461
URL: https://issues.apache.org/jira/browse/FLINK-20461
Project: Flink
Huang Xingbo created FLINK-20462:
Summary: MailboxOperatorTest.testAvoidTaskStarvation
Key: FLINK-20462
URL: https://issues.apache.org/jira/browse/FLINK-20462
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20467:
Summary: Fix the Example in Python DataStream Doc
Key: FLINK-20467
URL: https://issues.apache.org/jira/browse/FLINK-20467
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20475:
Summary: Broken Link in gettingStarted.zh.md
Key: FLINK-20475
URL: https://issues.apache.org/jira/browse/FLINK-20475
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20476:
Summary: New File Sink end-to-end test Failed
Key: FLINK-20476
URL: https://issues.apache.org/jira/browse/FLINK-20476
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20477:
Summary: Maven: Could not find the selected project in the
reactor: flink-shaded-netty-tcnative-static
Key: FLINK-20477
URL: https://issues.apache.org/jira/browse/FLINK-20477
Huang Xingbo created FLINK-20479:
Summary: Support Row-based Operations in Python Table API
Key: FLINK-20479
URL: https://issues.apache.org/jira/browse/FLINK-20479
Project: Flink
Issue Type:
Huang Xingbo created FLINK-20482:
Summary: Support Map Operation in Python Table API
Key: FLINK-20482
URL: https://issues.apache.org/jira/browse/FLINK-20482
Project: Flink
Issue Type: Sub-tas
Huang Xingbo created FLINK-20483:
Summary: Support Pandas UDF for Map Operation in Python Table API
Key: FLINK-20483
URL: https://issues.apache.org/jira/browse/FLINK-20483
Project: Flink
Issu
Huang Xingbo created FLINK-20493:
Summary: SQLClientSchemaRegistryITCase test failed
Key: FLINK-20493
URL: https://issues.apache.org/jira/browse/FLINK-20493
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20494:
Summary: SQLClientHBaseITCase Task Timeout
Key: FLINK-20494
URL: https://issues.apache.org/jira/browse/FLINK-20494
Project: Flink
Issue Type: Bug
C
Huang Xingbo created FLINK-20495:
Summary: Elasticsearch6DynamicSinkITCase Hang
Key: FLINK-20495
URL: https://issues.apache.org/jira/browse/FLINK-20495
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-20497:
Summary: FlinkKafkaProducerITCase
testRestoreToCheckpointAfterExceedingProducersPool Timeout expired after
6milliseconds while awaiting InitProducerId
Key: FLINK-20497
URL: h
Huang Xingbo created FLINK-20498:
Summary: SQLClientSchemaRegistryITCase testReading test timed out
after 12 milliseconds
Key: FLINK-20498
URL: https://issues.apache.org/jira/browse/FLINK-20498
Pr
Huang Xingbo created FLINK-20499:
Summary: ES7 ElasticsearchSinkITCase hangs
Key: FLINK-20499
URL: https://issues.apache.org/jira/browse/FLINK-20499
Project: Flink
Issue Type: Bug
C
Huang Xingbo created FLINK-20500:
Summary: UpsertKafkaTableITCase.testTemporalJoin test failed
Key: FLINK-20500
URL: https://issues.apache.org/jira/browse/FLINK-20500
Project: Flink
Issue Typ
Huang Xingbo created FLINK-20501:
Summary:
FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with
"Delete test topic :
flink-kafka-producer-fail-and-recover-same-checkpoint-twice"
Key: FLINK-20501
Huang Xingbo created FLINK-20506:
Summary: Support FlatMap Operation in Python Table API
Key: FLINK-20506
URL: https://issues.apache.org/jira/browse/FLINK-20506
Project: Flink
Issue Type: Sub
Huang Xingbo created FLINK-20507:
Summary: Support Aggregate Operation in Python Table API
Key: FLINK-20507
URL: https://issues.apache.org/jira/browse/FLINK-20507
Project: Flink
Issue Type: S
Huang Xingbo created FLINK-20508:
Summary: Introduce PythonStreamGroupTableAggregateOperator
Key: FLINK-20508
URL: https://issues.apache.org/jira/browse/FLINK-20508
Project: Flink
Issue Type:
Huang Xingbo created FLINK-20514:
Summary: Introduce StreamExecPythonGroupTableAggregateRule and
StreamExecGroupTableAggregate
Key: FLINK-20514
URL: https://issues.apache.org/jira/browse/FLINK-20514
P
Huang Xingbo created FLINK-20523:
Summary: OffsetsInitializerTest test failed with
"java.net.BindException: Address already in use"
Key: FLINK-20523
URL: https://issues.apache.org/jira/browse/FLINK-20523
Huang Xingbo created FLINK-20525:
Summary: Fix
StreamArrowPythonGroupWindowAggregateFunctionOperator's incorrect handling of
rowtime and proctime fields
Key: FLINK-20525
URL: https://issues.apache.org/jira/browse
Huang Xingbo created FLINK-20528:
Summary: Add Python building blocks to make sure the basic
functionality of Stream Group Table Aggregation could work
Key: FLINK-20528
URL: https://issues.apache.org/jira/browse/
1 - 100 of 346 matches
Mail list logo
