Dian Fu created FLINK-35208:
---
Summary: Respect pipeline.cached-files during processing Python
dependencies
Key: FLINK-35208
URL: https://issues.apache.org/jira/browse/FLINK-35208
Project: Flink
Dian Fu created FLINK-34985:
---
Summary: It doesn't support to access fields by name for map
function in thread mode
Key: FLINK-34985
URL: https://issues.apache.org/jira/browse/FLINK-34985
Project: Flink
Dian Fu created FLINK-32989:
---
Summary: PyFlink wheel package build failed
Key: FLINK-32989
URL: https://issues.apache.org/jira/browse/FLINK-32989
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-32724:
---
Summary: Mark CEP API classes as Public / PublicEvolving
Key: FLINK-32724
URL: https://issues.apache.org/jira/browse/FLINK-32724
Project: Flink
Issue Type:
Dian Fu created FLINK-32131:
---
Summary: Support specifying hadoop config dir for Python
HiveCatalog
Key: FLINK-32131
URL: https://issues.apache.org/jira/browse/FLINK-32131
Project: Flink
Issue
Dian Fu created FLINK-31949:
---
Summary: The state of CountTumblingWindowAssigner of Python
DataStream API were never purged
Key: FLINK-31949
URL: https://issues.apache.org/jira/browse/FLINK-31949
Project:
Dian Fu created FLINK-31905:
---
Summary: Exception thrown when accessing nested field of the
result of Python UDF with complex type
Key: FLINK-31905
URL: https://issues.apache.org/jira/browse/FLINK-31905
Dian Fu created FLINK-31861:
---
Summary: Introduce ByteArraySchema which serialize/deserialize
data of type byte array
Key: FLINK-31861
URL: https://issues.apache.org/jira/browse/FLINK-31861
Project: Flink
Dian Fu created FLINK-31707:
---
Summary: Constant string cannot be used as input arguments of
Pandas UDAF
Key: FLINK-31707
URL: https://issues.apache.org/jira/browse/FLINK-31707
Project: Flink
Dian Fu created FLINK-31690:
---
Summary: The current key is not set for KeyedCoProcessOperator
Key: FLINK-31690
URL: https://issues.apache.org/jira/browse/FLINK-31690
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-31532:
---
Summary: Support StreamExecutionEnvironment.socketTextStream in
Python DataStream API
Key: FLINK-31532
URL: https://issues.apache.org/jira/browse/FLINK-31532
Project: Flink
Dian Fu created FLINK-31503:
---
Summary: "org.apache.beam.sdk.options.PipelineOptionsRegistrar:
Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a
subtype" is thrown when executing Python UDFs in SQL Client
Key:
Dian Fu created FLINK-31478:
---
Summary: TypeError: a bytes-like object is required, not
'JavaList' is thrown when ds.execute_and_collect() is called on a KeyedStream
Key: FLINK-31478
URL:
Dian Fu created FLINK-31286:
---
Summary: Python processes are still alive when shutting down a
session cluster directly without stopping the jobs
Key: FLINK-31286
URL: https://issues.apache.org/jira/browse/FLINK-31286
Dian Fu created FLINK-31272:
---
Summary: Duplicate operators appear in the StreamGraph for Python
DataStream API jobs
Key: FLINK-31272
URL: https://issues.apache.org/jira/browse/FLINK-31272
Project: Flink
Dian Fu created FLINK-31172:
---
Summary: Support coGroup in Python DataStream API
Key: FLINK-31172
URL: https://issues.apache.org/jira/browse/FLINK-31172
Project: Flink
Issue Type: New Feature
Dian Fu created FLINK-31171:
---
Summary: Support iterate in Python DataStream API
Key: FLINK-31171
URL: https://issues.apache.org/jira/browse/FLINK-31171
Project: Flink
Issue Type: New Feature
Dian Fu created FLINK-31043:
---
Summary: KeyError exception is thrown in CachedMapState
Key: FLINK-31043
URL: https://issues.apache.org/jira/browse/FLINK-31043
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-31031:
---
Summary: Disable the output buffer of Python process to make it
more convenient for interactive users
Key: FLINK-31031
URL: https://issues.apache.org/jira/browse/FLINK-31031
Dian Fu created FLINK-30364:
---
Summary: Job failed without exception stack
Key: FLINK-30364
URL: https://issues.apache.org/jira/browse/FLINK-30364
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-30308:
---
Summary: ClassCastException: class
java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is
showing in the logging when the job shutdown
Key: FLINK-30308
URL:
Dian Fu created FLINK-29192:
---
Summary: Add completeness test for built-in functions between Java
and Python Table API
Key: FLINK-29192
URL: https://issues.apache.org/jira/browse/FLINK-29192
Project: Flink
Dian Fu created FLINK-28886:
---
Summary: Support HybridSource in Python DataStream API
Key: FLINK-28886
URL: https://issues.apache.org/jira/browse/FLINK-28886
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-28253:
---
Summary: LocalDateTime is not supported in PyFlink
Key: FLINK-28253
URL: https://issues.apache.org/jira/browse/FLINK-28253
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-28140:
---
Summary: Improve the documentation by adding Python examples
Key: FLINK-28140
URL: https://issues.apache.org/jira/browse/FLINK-28140
Project: Flink
Issue Type:
Dian Fu created FLINK-28114:
---
Summary: The path of the Python client interpreter could not point
to an archive file in distributed file system
Key: FLINK-28114
URL: https://issues.apache.org/jira/browse/FLINK-28114
Dian Fu created FLINK-28071:
---
Summary: Support missing built-in functions in Table API
Key: FLINK-28071
URL: https://issues.apache.org/jira/browse/FLINK-28071
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-28015:
---
Summary: FROM_UNIXTIME could not be used in Table API
Key: FLINK-28015
URL: https://issues.apache.org/jira/browse/FLINK-28015
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-27760:
---
Summary: NPE is thrown when executing PyFlink jobs in batch mode
Key: FLINK-27760
URL: https://issues.apache.org/jira/browse/FLINK-27760
Project: Flink
Issue Type:
Dian Fu created FLINK-27729:
---
Summary: Support constructing StartCursor and StopCursor from
MessageId
Key: FLINK-27729
URL: https://issues.apache.org/jira/browse/FLINK-27729
Project: Flink
Issue
Dian Fu created FLINK-27598:
---
Summary: Improve the exception message when mixing use Python UDF
and Pandas UDF
Key: FLINK-27598
URL: https://issues.apache.org/jira/browse/FLINK-27598
Project: Flink
Dian Fu created FLINK-27584:
---
Summary: Support broadcast state in PyFlink DataStream API
Key: FLINK-27584
URL: https://issues.apache.org/jira/browse/FLINK-27584
Project: Flink
Issue Type: New
Dian Fu created FLINK-27564:
---
Summary: Split PyFlink DataStream connectors into separate files
Key: FLINK-27564
URL: https://issues.apache.org/jira/browse/FLINK-27564
Project: Flink
Issue Type:
Dian Fu created FLINK-27545:
---
Summary: Update examples in PyFlink shell
Key: FLINK-27545
URL: https://issues.apache.org/jira/browse/FLINK-27545
Project: Flink
Issue Type: Bug
Components:
Dian Fu created FLINK-27421:
---
Summary: Bundle test utility classes into the PyFlink package to
make users write test cases easily
Key: FLINK-27421
URL: https://issues.apache.org/jira/browse/FLINK-27421
Dian Fu created FLINK-27373:
---
Summary: Disable installing PyFlink using `python setup.py install`
Key: FLINK-27373
URL: https://issues.apache.org/jira/browse/FLINK-27373
Project: Flink
Issue Type:
Dian Fu created FLINK-27223:
---
Summary: State access doesn't work as expected when cache size is
set to 0
Key: FLINK-27223
URL: https://issues.apache.org/jira/browse/FLINK-27223
Project: Flink
Dian Fu created FLINK-27126:
---
Summary: Respect the state cache size configurations in Python
DataStream API operators
Key: FLINK-27126
URL: https://issues.apache.org/jira/browse/FLINK-27126
Project: Flink
Dian Fu created FLINK-27108:
---
Summary: State cache clean up doesn't work as expected
Key: FLINK-27108
URL: https://issues.apache.org/jira/browse/FLINK-27108
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-27067:
---
Summary: Prevent usage of deprecated APIs in PyFlink examples
Key: FLINK-27067
URL: https://issues.apache.org/jira/browse/FLINK-27067
Project: Flink
Issue Type:
Dian Fu created FLINK-26986:
---
Summary: Remove deprecated string expressions in Python Table API
Key: FLINK-26986
URL: https://issues.apache.org/jira/browse/FLINK-26986
Project: Flink
Issue Type:
Dian Fu created FLINK-26920:
---
Summary: It reported "The configured managed memory fraction for
Python worker process must be within (0, 1], was: %s."
Key: FLINK-26920
URL:
Dian Fu created FLINK-26919:
---
Summary: Table API program compiles field with "Cannot resolve
field [a], input field list:[EXPR$0]"
Key: FLINK-26919
URL: https://issues.apache.org/jira/browse/FLINK-26919
Dian Fu created FLINK-26855:
---
Summary: ImportError: cannot import name 'environmentfilter' from
'jinja2'
Key: FLINK-26855
URL: https://issues.apache.org/jira/browse/FLINK-26855
Project: Flink
Dian Fu created FLINK-26847:
---
Summary: Unify the logic for the command line option -py and -pym
Key: FLINK-26847
URL: https://issues.apache.org/jira/browse/FLINK-26847
Project: Flink
Issue Type:
Dian Fu created FLINK-26846:
---
Summary: Gauge metrics doesn't work in PyFlink
Key: FLINK-26846
URL: https://issues.apache.org/jira/browse/FLINK-26846
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-26506:
---
Summary: Support StreamExecutionEnvironment.registerCachedFile in
Python DataStream API
Key: FLINK-26506
URL: https://issues.apache.org/jira/browse/FLINK-26506
Project: Flink
Dian Fu created FLINK-26483:
---
Summary: Support WindowedStream.aggregate in Python DataStream API
Key: FLINK-26483
URL: https://issues.apache.org/jira/browse/FLINK-26483
Project: Flink
Issue Type:
Dian Fu created FLINK-26482:
---
Summary: Support WindowedStream.reduce in Python DataStream API
Key: FLINK-26482
URL: https://issues.apache.org/jira/browse/FLINK-26482
Project: Flink
Issue Type:
Dian Fu created FLINK-26481:
---
Summary: Support side output for windowing in Python DataStream API
Key: FLINK-26481
URL: https://issues.apache.org/jira/browse/FLINK-26481
Project: Flink
Issue Type:
Dian Fu created FLINK-26480:
---
Summary: Support window_all in Python DataStream API
Key: FLINK-26480
URL: https://issues.apache.org/jira/browse/FLINK-26480
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-26479:
---
Summary: Add time_window and count_window in KeyedStream in Python
DataStream API
Key: FLINK-26479
URL: https://issues.apache.org/jira/browse/FLINK-26479
Project: Flink
Dian Fu created FLINK-26478:
---
Summary: Support evictor in Python DataStream API
Key: FLINK-26478
URL: https://issues.apache.org/jira/browse/FLINK-26478
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-26477:
---
Summary: Finalize the window support in Python DataStream API
Key: FLINK-26477
URL: https://issues.apache.org/jira/browse/FLINK-26477
Project: Flink
Issue Type:
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
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/FLINK-25216
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:
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/jira/browse/FLINK-24662
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 Type:
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-24083
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: Flink
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-24003
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
Project:
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
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:
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-23584
Dian Fu created FLINK-23578:
---
Summary: Remove Python operators
PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator and use
PythonProcessOperator instead
Key: FLINK-23578
URL:
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:
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: Flink
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:
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
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: Flink
1 - 100 of 439 matches
Mail list logo
