Wei Zhong created FLINK-13809:
-
Summary: The log directory of Flink Python API is unwritable if
it is installed via "sudo"
Key: FLINK-13809
URL: https://issues.apache.org/jira/browse/FLINK-13809
Project:
Wei Zhong created FLINK-14140:
-
Summary: The Flink Logo Displayed in Flink Python Shell is Broken
Key: FLINK-14140
URL: https://issues.apache.org/jira/browse/FLINK-14140
Project: Flink
Issue Type
Wei Zhong created FLINK-14150:
-
Summary: Unnecessary __pycache__ directories appears in pyflink.zip
Key: FLINK-14150
URL: https://issues.apache.org/jira/browse/FLINK-14150
Project: Flink
Issue Ty
Wei Zhong created FLINK-14167:
-
Summary: Move python-related scripts in flink-dist to flink-python
Key: FLINK-14167
URL: https://issues.apache.org/jira/browse/FLINK-14167
Project: Flink
Issue Typ
Wei Zhong created FLINK-14198:
-
Summary: Add type options to all flink python API doc
Key: FLINK-14198
URL: https://issues.apache.org/jira/browse/FLINK-14198
Project: Flink
Issue Type: Improvemen
Wei Zhong created FLINK-14590:
-
Summary: Unify the working directory of Java process and Python
process when submitting python jobs via "flink run -py"
Key: FLINK-14590
URL: https://issues.apache.org/jira/browse/FLINK
Wei Zhong created FLINK-14591:
-
Summary: Execute PlannerBase#mergeParameters every time of
calling PlannerBase#translate method
Key: FLINK-14591
URL: https://issues.apache.org/jira/browse/FLINK-14591
Pro
Wei Zhong created FLINK-14604:
-
Summary: Bump commons-cli to 1.4
Key: FLINK-14604
URL: https://issues.apache.org/jira/browse/FLINK-14604
Project: Flink
Issue Type: Improvement
Component
Wei Zhong created FLINK-15194:
-
Summary: Directories in distributed caches are not extracted in
Yarn Per Job Cluster Mode
Key: FLINK-15194
URL: https://issues.apache.org/jira/browse/FLINK-15194
Project: F
Wei Zhong created FLINK-15244:
-
Summary: FileUtils#deleteDirectoryQuietly will delete files in the
symbolic link which point to a directory
Key: FLINK-15244
URL: https://issues.apache.org/jira/browse/FLINK-15244
Wei Zhong created FLINK-15248:
-
Summary: FileUtils#compressDirectory behaves buggy when processing
relative directory path
Key: FLINK-15248
URL: https://issues.apache.org/jira/browse/FLINK-15248
Project:
Wei Zhong created FLINK-12588:
-
Summary: Add TableSchema for Python Table API
Key: FLINK-12588
URL: https://issues.apache.org/jira/browse/FLINK-12588
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-13077:
-
Summary: CatalogPartitionAPICompletenessTests in pyflink failed
because of lacking "getComment" method
Key: FLINK-13077
URL: https://issues.apache.org/jira/browse/FLINK-13077
Wei Zhong created FLINK-13368:
-
Summary: Add Configuration for Python Table API to Align with Java
Key: FLINK-13368
URL: https://issues.apache.org/jira/browse/FLINK-13368
Project: Flink
Issue Typ
Wei Zhong created FLINK-13578:
-
Summary: Blink throws exception when using Types.INTERVAL_MILLIS
in TableSource
Key: FLINK-13578
URL: https://issues.apache.org/jira/browse/FLINK-13578
Project: Flink
Wei Zhong created FLINK-13594:
-
Summary: Improve the 'from_element' method of flink python api to
apply to blink planner
Key: FLINK-13594
URL: https://issues.apache.org/jira/browse/FLINK-13594
Project: F
Wei Zhong created FLINK-31184:
-
Summary: Failed to get python udf runner directory via running
GET_RUNNER_DIR_SCRIPT
Key: FLINK-31184
URL: https://issues.apache.org/jira/browse/FLINK-31184
Project: Flink
Wei Zhong created FLINK-27438:
-
Summary: SQL validation failed when constructing a map array
Key: FLINK-27438
URL: https://issues.apache.org/jira/browse/FLINK-27438
Project: Flink
Issue Type: Bug
Wei Zhong created FLINK-27563:
-
Summary: Resource Providers - Yarn doc page has minor display
error
Key: FLINK-27563
URL: https://issues.apache.org/jira/browse/FLINK-27563
Project: Flink
Issue
Wei Zhong created FLINK-28764:
-
Summary: Support more than 64 distinct aggregate function calls in
one aggregate SQL query
Key: FLINK-28764
URL: https://issues.apache.org/jira/browse/FLINK-28764
Project:
Wei Zhong created FLINK-30245:
-
Summary: NPE thrown when filtering decimal(18, 4) values after
calling DecimalDataUtils.subtract method
Key: FLINK-30245
URL: https://issues.apache.org/jira/browse/FLINK-30245
Wei Zhong created FLINK-15481:
-
Summary: The type hint of `TableEnvironment#from_elements` in
`table_environment.py` is incomplete
Key: FLINK-15481
URL: https://issues.apache.org/jira/browse/FLINK-15481
P
Wei Zhong created FLINK-15630:
-
Summary: Improve the environment requirement documentation of the
Python API
Key: FLINK-15630
URL: https://issues.apache.org/jira/browse/FLINK-15630
Project: Flink
Wei Zhong created FLINK-16031:
-
Summary: Improve the description in the README file of PyFlink
1.9.x
Key: FLINK-16031
URL: https://issues.apache.org/jira/browse/FLINK-16031
Project: Flink
Issue
Wei Zhong created FLINK-16304:
-
Summary: Remove python packages bundled in the flink-python jar
Key: FLINK-16304
URL: https://issues.apache.org/jira/browse/FLINK-16304
Project: Flink
Issue Type:
Wei Zhong created FLINK-16665:
-
Summary: Support Python UDF in SQL Function DDL (FLIP-106)
Key: FLINK-16665
URL: https://issues.apache.org/jira/browse/FLINK-16665
Project: Flink
Issue Type: New F
Wei Zhong created FLINK-1:
-
Summary: Support new Python dependency configuration options in
flink-java, flink-streaming-java and flink-table
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Wei Zhong created FLINK-16667:
-
Summary: Support new Python dependency configuration options in
flink-client
Key: FLINK-16667
URL: https://issues.apache.org/jira/browse/FLINK-16667
Project: Flink
Wei Zhong created FLINK-16668:
-
Summary: Support new Python dependency configuration options in
flink-python
Key: FLINK-16668
URL: https://issues.apache.org/jira/browse/FLINK-16668
Project: Flink
Wei Zhong created FLINK-16669:
-
Summary: Support Python UDF in SQL function DDL
Key: FLINK-16669
URL: https://issues.apache.org/jira/browse/FLINK-16669
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-16943:
-
Summary: Support adding jars in PyFlink
Key: FLINK-16943
URL: https://issues.apache.org/jira/browse/FLINK-16943
Project: Flink
Issue Type: Improvement
Co
Wei Zhong created FLINK-20962:
-
Summary: Rewrite the example in 'flink-python/pyflink/shell.py'
Key: FLINK-20962
URL: https://issues.apache.org/jira/browse/FLINK-20962
Project: Flink
Issue Type:
Wei Zhong created FLINK-20963:
-
Summary: Rewrite the example under
'flink-python/pyflink/table/examples'
Key: FLINK-20963
URL: https://issues.apache.org/jira/browse/FLINK-20963
Project: Flink
Is
Wei Zhong created FLINK-21114:
-
Summary: Support ReducingState in Python DataStream API
Key: FLINK-21114
URL: https://issues.apache.org/jira/browse/FLINK-21114
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-21115:
-
Summary: Add AggregatingState and corresponding StateDescriptor
for Python DataStream API
Key: FLINK-21115
URL: https://issues.apache.org/jira/browse/FLINK-21115
Project: F
Wei Zhong created FLINK-21179:
-
Summary: Split the base class of Python DataStream Function to
'Function' and 'RichFunction'
Key: FLINK-21179
URL: https://issues.apache.org/jira/browse/FLINK-21179
Project
Wei Zhong created FLINK-21180:
-
Summary: Move the state module from 'pyflink.common' to
'pyflink.datastream'
Key: FLINK-21180
URL: https://issues.apache.org/jira/browse/FLINK-21180
Project: Flink
Wei Zhong created FLINK-21242:
-
Summary: Support state access API for map operation
Key: FLINK-21242
URL: https://issues.apache.org/jira/browse/FLINK-21242
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-21294:
-
Summary: Support state access API for the map operation of Python
ConnectedStreams
Key: FLINK-21294
URL: https://issues.apache.org/jira/browse/FLINK-21294
Project: Flink
Wei Zhong created FLINK-21509:
-
Summary: "w.start" returns "1970-01-01" when used with Pandas UDAF
after grouping by slide window with processing time
Key: FLINK-21509
URL: https://issues.apache.org/jira/browse/FLINK-
Wei Zhong created FLINK-21679:
-
Summary: Set output type for transformations from SourceProvider
and DataStreamScanProvider in CommonExecTableSourceScan
Key: FLINK-21679
URL: https://issues.apache.org/jira/browse/FLIN
Wei Zhong created FLINK-21792:
-
Summary: Add a PythonFunctionRunnerDescriptor and unify the
creation of all the PythonFunctionRunner
Key: FLINK-21792
URL: https://issues.apache.org/jira/browse/FLINK-21792
Wei Zhong created FLINK-21842:
-
Summary: Support user defined WindowAssigner, Trigger and
ProcessWindowFunction on Python DataStream API
Key: FLINK-21842
URL: https://issues.apache.org/jira/browse/FLINK-21842
Wei Zhong created FLINK-21969:
-
Summary: PythonTimestampsAndWatermarksOperator emitted the
Long.MAX_VALUE watermark before emitting all the data
Key: FLINK-21969
URL: https://issues.apache.org/jira/browse/FLINK-21969
Wei Zhong created FLINK-18849:
-
Summary: Improve the code tabs of the Flink documents
Key: FLINK-18849
URL: https://issues.apache.org/jira/browse/FLINK-18849
Project: Flink
Issue Type: Improvemen
Wei Zhong created FLINK-18910:
-
Summary: Create the new document structure for Python
documentation according to FLIP-133
Key: FLINK-18910
URL: https://issues.apache.org/jira/browse/FLINK-18910
Project: F
Wei Zhong created FLINK-18911:
-
Summary: Move the "Installation" document from the old Python
Table API documentation to the new Python API documentation
Key: FLINK-18911
URL: https://issues.apache.org/jira/browse/FLI
Wei Zhong created FLINK-18912:
-
Summary: Add a Table API tutorial link under the "Python API" ->
"GettingStart" -> "Tutorial" section
Key: FLINK-18912
URL: https://issues.apache.org/jira/browse/FLINK-18912
Wei Zhong created FLINK-18913:
-
Summary: Add a "TableEnvironment" document under the "Python API"
-> "User Guide" section
Key: FLINK-18913
URL: https://issues.apache.org/jira/browse/FLINK-18913
Project:
Wei Zhong created FLINK-18914:
-
Summary: Move the "Python DataTypes" document from the old Python
Table API documentation to the "Python API" -> "GettingStart" section with a
new name "DataTypes"
Key: FLINK-18914
URL
Wei Zhong created FLINK-18916:
-
Summary: Add a "Operations" link(linked to dev/table/tableApi.md)
under the "Python API" -> "User Guide" section
Key: FLINK-18916
URL: https://issues.apache.org/jira/browse/FLINK-18916
Wei Zhong created FLINK-18917:
-
Summary: Add a "Built-in Functions" link (linked to
dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide"
section
Key: FLINK-18917
URL: https://issues.apache.o
Wei Zhong created FLINK-18918:
-
Summary: Add a "Connectors" document under the "Python API" ->
"User Guide" section
Key: FLINK-18918
URL: https://issues.apache.org/jira/browse/FLINK-18918
Project: Flink
Wei Zhong created FLINK-18919:
-
Summary: Move the "User Defined Functions" document and
"Vectorized User Defined Functions" document from the old Python Table API
documentation to the "Python API" -> "User Guide" section
Key: FLINK-1
Wei Zhong created FLINK-18920:
-
Summary: Move the "Dependency Management" document from the old
Python Table API documentation to the "Python API" -> "GettingStart" section
Key: FLINK-18920
URL: https://issues.apache.
Wei Zhong created FLINK-18921:
-
Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under
the "Python API" -> "User Guide" section
Key: FLINK-18921
URL: https://issues.apache.org/jira/browse/FLINK-18921
Wei Zhong created FLINK-18922:
-
Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md)
under the "Python API" -> "User Guide" section
Key: FLINK-18922
URL: https://issues.apache.org/jira/browse/FLINK-18922
Wei Zhong created FLINK-18923:
-
Summary: Add a "CEP" document under the "Python API" -> "User
Guide" section
Key: FLINK-18923
URL: https://issues.apache.org/jira/browse/FLINK-18923
Project: Flink
Wei Zhong created FLINK-18924:
-
Summary: Move the "Metrics" document from the old Python Table API
documentation to the "Python API" -> "User Guide" -> "Table API" section
Key: FLINK-18924
URL: https://issues.apache.o
Wei Zhong created FLINK-18925:
-
Summary: Move the "Configuration" document from the old Python
Table API documentation to the "Python API" -> "User Guide" -> "Table API"
section
Key: FLINK-18925
URL: https://issues.a
Wei Zhong created FLINK-18926:
-
Summary: Add a "Environment Variables" document under the "Python
API" -> "User Guide" -> "Table API" section
Key: FLINK-18926
URL: https://issues.apache.org/jira/browse/FLINK-18926
Wei Zhong created FLINK-18927:
-
Summary: Add a "Debugging" document under the "Python API" ->
"User Guide" -> "Table API" section
Key: FLINK-18927
URL: https://issues.apache.org/jira/browse/FLINK-18927
P
Wei Zhong created FLINK-18928:
-
Summary: Move the "Common Questions" document from the old Python
Table API documentation to the "Python API" section with a new name "FAQ"
Key: FLINK-18928
URL: https://issues.apache.o
Wei Zhong created FLINK-18929:
-
Summary: Add a "API Docs" link (linked to the generated sphinx
docs) under the "Python API" section
Key: FLINK-18929
URL: https://issues.apache.org/jira/browse/FLINK-18929
Wei Zhong created FLINK-18933:
-
Summary: Delete the old Python Table API document section
Key: FLINK-18933
URL: https://issues.apache.org/jira/browse/FLINK-18933
Project: Flink
Issue Type: Sub-ta
Wei Zhong created FLINK-18932:
-
Summary: Add a "Overview" document under the "Python API" section
Key: FLINK-18932
URL: https://issues.apache.org/jira/browse/FLINK-18932
Project: Flink
Issue Typ
Wei Zhong created FLINK-18937:
-
Summary: Add a "Environment Setup" section to the "Installation"
document
Key: FLINK-18937
URL: https://issues.apache.org/jira/browse/FLINK-18937
Project: Flink
I
Wei Zhong created FLINK-19110:
-
Summary: Flatten current PyFlink documentation structure
Key: FLINK-19110
URL: https://issues.apache.org/jira/browse/FLINK-19110
Project: Flink
Issue Type: Sub-tas
Wei Zhong created FLINK-19185:
-
Summary: Support General Python User-Defined Aggregate Function
Support on Table API (FLIP-139)
Key: FLINK-19185
URL: https://issues.apache.org/jira/browse/FLINK-19185
Proj
Wei Zhong created FLINK-19229:
-
Summary: Support ValueState and Python UDAF on blink stream planner
Key: FLINK-19229
URL: https://issues.apache.org/jira/browse/FLINK-19229
Project: Flink
Issue Ty
Wei Zhong created FLINK-19231:
-
Summary: Support ListState and ListView for Python UDAF
Key: FLINK-19231
URL: https://issues.apache.org/jira/browse/FLINK-19231
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-19232:
-
Summary: Support MapState and MapView for Python UDAF
Key: FLINK-19232
URL: https://issues.apache.org/jira/browse/FLINK-19232
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-19230:
-
Summary: Support Python UDAF on blink batch planner
Key: FLINK-19230
URL: https://issues.apache.org/jira/browse/FLINK-19230
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-19234:
-
Summary: Support FILTER KeyWord for Python UDAF
Key: FLINK-19234
URL: https://issues.apache.org/jira/browse/FLINK-19234
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-19235:
-
Summary: Support mixed use with built-in aggs for Python UDAF
Key: FLINK-19235
URL: https://issues.apache.org/jira/browse/FLINK-19235
Project: Flink
Issue Type: Su
Wei Zhong created FLINK-19233:
-
Summary: Support DISTINCT KeyWord for Python UDAF
Key: FLINK-19233
URL: https://issues.apache.org/jira/browse/FLINK-19233
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-19236:
-
Summary: Optimize the performance of Python UDAF
Key: FLINK-19236
URL: https://issues.apache.org/jira/browse/FLINK-19236
Project: Flink
Issue Type: Sub-task
Wei Zhong created FLINK-20207:
-
Summary: Improve the error message printed when submitting the
pyflink jobs via 'flink run'
Key: FLINK-20207
URL: https://issues.apache.org/jira/browse/FLINK-20207
Project:
Wei Zhong created FLINK-20333:
-
Summary: Flink standalone cluster throws metaspace OOM after
submitting multiple PyFlink UDF jobs.
Key: FLINK-20333
URL: https://issues.apache.org/jira/browse/FLINK-20333
P
Wei Zhong created FLINK-20756:
-
Summary: PythonCalcSplitConditionRule is not working as expected
Key: FLINK-20756
URL: https://issues.apache.org/jira/browse/FLINK-20756
Project: Flink
Issue Type:
Wei Zhong created FLINK-20834:
-
Summary: Add metrics for reporting the memory usage and CPU usage
of the Python UDF workers
Key: FLINK-20834
URL: https://issues.apache.org/jira/browse/FLINK-20834
Project:
Wei Zhong created FLINK-16971:
-
Summary: Support Python UDF in SQL Client (FLIP-114)
Key: FLINK-16971
URL: https://issues.apache.org/jira/browse/FLINK-16971
Project: Flink
Issue Type: Improvement
Wei Zhong created FLINK-17114:
-
Summary: When the pyflink job runs in local mode and the command
"python" points to Python 2.7, the startup of the Python UDF worker will fail.
Key: FLINK-17114
URL: https://issues.apac
Wei Zhong created FLINK-17206:
-
Summary: Refactor FunctionCatalog to support delayed UDF
initialization.
Key: FLINK-17206
URL: https://issues.apache.org/jira/browse/FLINK-17206
Project: Flink
Is
Wei Zhong created FLINK-17345:
-
Summary: Support registering and getting Python UDF in HiveCatalog
Key: FLINK-17345
URL: https://issues.apache.org/jira/browse/FLINK-17345
Project: Flink
Issue Typ
Wei Zhong created FLINK-17417:
-
Summary: The flink-avro-sql-jar is not really sql-jar
Key: FLINK-17417
URL: https://issues.apache.org/jira/browse/FLINK-17417
Project: Flink
Issue Type: Bug
Wei Zhong created FLINK-17436:
-
Summary: When submitting Python job via "flink run" a
IllegalAccessError will be raised due to the package's private access control
Key: FLINK-17436
URL: https://issues.apache.org/jira/
Wei Zhong created FLINK-17570:
-
Summary: BatchTableEnvironment#fromValues(Object... values) causes
StackOverflowError
Key: FLINK-17570
URL: https://issues.apache.org/jira/browse/FLINK-17570
Project: Flin
Wei Zhong created FLINK-17585:
-
Summary: "PythonProgramOptions" changes the entry point class when
user submit a Java sql job which contains Python UDF
Key: FLINK-17585
URL: https://issues.apache.org/jira/browse/FLIN
Wei Zhong created FLINK-17586:
-
Summary: Due to the new behavior of the table planner the Python
dependency management command line options does not work
Key: FLINK-17586
URL: https://issues.apache.org/jira/browse/FL
Wei Zhong created FLINK-17612:
-
Summary: The Python command line options are ignored by the
CliOptionsParser in SQL Client
Key: FLINK-17612
URL: https://issues.apache.org/jira/browse/FLINK-17612
Project:
Wei Zhong created FLINK-17628:
-
Summary: Remove the unnecessary py4j log information
Key: FLINK-17628
URL: https://issues.apache.org/jira/browse/FLINK-17628
Project: Flink
Issue Type: Improvement
Wei Zhong created FLINK-17646:
-
Summary: Reduce the python package size of PyFlink
Key: FLINK-17646
URL: https://issues.apache.org/jira/browse/FLINK-17646
Project: Flink
Issue Type: Improvement
Wei Zhong created FLINK-17866:
-
Summary: InvalidPathException was thrown when running the test
cases of PyFlink on Windows
Key: FLINK-17866
URL: https://issues.apache.org/jira/browse/FLINK-17866
Project:
Wei Zhong created FLINK-17876:
-
Summary: Add documents for the Python UDF SQL DDL.
Key: FLINK-17876
URL: https://issues.apache.org/jira/browse/FLINK-17876
Project: Flink
Issue Type: Improvement
Wei Zhong created FLINK-17881:
-
Summary: Add documentation for PyFlink's Windows support
Key: FLINK-17881
URL: https://issues.apache.org/jira/browse/FLINK-17881
Project: Flink
Issue Type: Improve
Wei Zhong created FLINK-18218:
-
Summary: Add yarn perjob, java dependency management e2e tests for
pyflink.
Key: FLINK-18218
URL: https://issues.apache.org/jira/browse/FLINK-18218
Project: Flink
Wei Zhong created FLINK-18460:
-
Summary: If the Python UDFs are called before calling the Python
Dependency Management API, the Python Dependency Management would not will not
take effect.
Key: FLINK-18460
URL: https
Wei Zhong created FLINK-18463:
-
Summary: Make the "input_types" parameter of the Python udf
decorator optional
Key: FLINK-18463
URL: https://issues.apache.org/jira/browse/FLINK-18463
Project: Flink
Wei Zhong created FLINK-18716:
-
Summary: Remove the deprecated "execute" and "insert_into" calls
in PyFlink Table API docs
Key: FLINK-18716
URL: https://issues.apache.org/jira/browse/FLINK-18716
Project:
1 - 100 of 102 matches
Mail list logo
