sunjincheng created FLINK-19913:
---
Summary: The precision in document and code of `INTERVAL DAY(p1)
TO SECOND(p2)` are inconsistent
Key: FLINK-19913
URL: https://issues.apache.org/jira/browse/FLINK-19913
sunjincheng created FLINK-19337:
---
Summary: Make a little bit improvement for PyFlink package
structure and class name.
Key: FLINK-19337
URL: https://issues.apache.org/jira/browse/FLINK-19337
Project:
sunjincheng created FLINK-19131:
---
Summary: Add py38 support in PyFlink
Key: FLINK-19131
URL: https://issues.apache.org/jira/browse/FLINK-19131
Project: Flink
Issue Type: New Feature
sunjincheng created FLINK-18816:
---
Summary: Correct API usage in Pyflink Dependency Management page
Key: FLINK-18816
URL: https://issues.apache.org/jira/browse/FLINK-18816
Project: Flink
Issue
sunjincheng created FLINK-18775:
---
Summary: Rework PyFlink Documentation
Key: FLINK-18775
URL: https://issues.apache.org/jira/browse/FLINK-18775
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-18108:
---
Summary: Wheel package consistency checks
Key: FLINK-18108
URL: https://issues.apache.org/jira/browse/FLINK-18108
Project: Flink
Issue Type: Test
sunjincheng created FLINK-18107:
---
Summary: Performance tests for PyFlink UDFs
Key: FLINK-18107
URL: https://issues.apache.org/jira/browse/FLINK-18107
Project: Flink
Issue Type: Test
sunjincheng created FLINK-18106:
---
Summary: Tests Python UDTF support
Key: FLINK-18106
URL: https://issues.apache.org/jira/browse/FLINK-18106
Project: Flink
Issue Type: Test
sunjincheng created FLINK-18105:
---
Summary: Test submitting Java SQL job with Python UDF
Key: FLINK-18105
URL: https://issues.apache.org/jira/browse/FLINK-18105
Project: Flink
Issue Type: Test
sunjincheng created FLINK-18104:
---
Summary: Test pyflink on windows
Key: FLINK-18104
URL: https://issues.apache.org/jira/browse/FLINK-18104
Project: Flink
Issue Type: Test
Components:
sunjincheng created FLINK-18103:
---
Summary: Test Pandas DataFrame and Flink Table conversion
Key: FLINK-18103
URL: https://issues.apache.org/jira/browse/FLINK-18103
Project: Flink
Issue Type:
sunjincheng created FLINK-18102:
---
Summary: Test Pandas UDF support
Key: FLINK-18102
URL: https://issues.apache.org/jira/browse/FLINK-18102
Project: Flink
Issue Type: Test
Components:
sunjincheng created FLINK-18101:
---
Summary: Test Python Pipeline API including Transformer and
Estimator
Key: FLINK-18101
URL: https://issues.apache.org/jira/browse/FLINK-18101
Project: Flink
sunjincheng created FLINK-18100:
---
Summary: Test different user-defined metrics for Python UDF
Key: FLINK-18100
URL: https://issues.apache.org/jira/browse/FLINK-18100
Project: Flink
Issue Type:
sunjincheng created FLINK-18099:
---
Summary: Release guard for PyFlink
Key: FLINK-18099
URL: https://issues.apache.org/jira/browse/FLINK-18099
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-18041:
---
Summary: Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE
and DEFAULT_FLUSH_INTERVAL_MILLS of AbstractJdbcOutputFormat
Key: FLINK-18041
URL:
sunjincheng created FLINK-17856:
---
Summary: Adds the feature of monitoring directory changes for
FileSystem table source connector
Key: FLINK-17856
URL: https://issues.apache.org/jira/browse/FLINK-17856
sunjincheng created FLINK-17256:
---
Summary: Suppport keyword arguments in the PyFlink Descriptor API
Key: FLINK-17256
URL: https://issues.apache.org/jira/browse/FLINK-17256
Project: Flink
Issue
sunjincheng created FLINK-17255:
---
Summary: Add HBase connector descriptor support in PyFlink
Key: FLINK-17255
URL: https://issues.apache.org/jira/browse/FLINK-17255
Project: Flink
Issue Type:
sunjincheng created FLINK-17254:
---
Summary: Improve the PyFlink documentation and examples to use SQL
DDL for source/sink definition
Key: FLINK-17254
URL: https://issues.apache.org/jira/browse/FLINK-17254
sunjincheng created FLINK-16762:
---
Summary: Relocation Beam dependency of PyFlink
Key: FLINK-16762
URL: https://issues.apache.org/jira/browse/FLINK-16762
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-15937:
---
Summary: Correct the Development Status for PyFlink
Key: FLINK-15937
URL: https://issues.apache.org/jira/browse/FLINK-15937
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-15921:
---
Summary: PYTHON exited with EXIT CODE: 143 in travis-ci
Key: FLINK-15921
URL: https://issues.apache.org/jira/browse/FLINK-15921
Project: Flink
Issue Type:
sunjincheng created FLINK-15909:
---
Summary: Add PyPI release process into the subsequent release of
1.9.x
Key: FLINK-15909
URL: https://issues.apache.org/jira/browse/FLINK-15909
Project: Flink
sunjincheng created FLINK-15908:
---
Summary: Add Description of support 'pip install' to 1.9.x
documents
Key: FLINK-15908
URL: https://issues.apache.org/jira/browse/FLINK-15908
Project: Flink
sunjincheng created FLINK-15840:
---
Summary: ClassCastException is thrown when use ConnectorDescriptor
under Blink planner
Key: FLINK-15840
URL: https://issues.apache.org/jira/browse/FLINK-15840
Project:
sunjincheng created FLINK-15338:
---
Summary: TM Metaspace memory leak when submitting PyFlink UDF jobs
multiple times
Key: FLINK-15338
URL: https://issues.apache.org/jira/browse/FLINK-15338
Project:
sunjincheng created FLINK-15138:
---
Summary: Add e2e Test for PyFlink
Key: FLINK-15138
URL: https://issues.apache.org/jira/browse/FLINK-15138
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-15078:
---
Summary: Report Python version exceptions in time
Key: FLINK-15078
URL: https://issues.apache.org/jira/browse/FLINK-15078
Project: Flink
Issue Type:
sunjincheng created FLINK-14558:
---
Summary: Fix the ClassNotFoundException issue for run python job
in standalone mode
Key: FLINK-14558
URL: https://issues.apache.org/jira/browse/FLINK-14558
Project:
sunjincheng created FLINK-14557:
---
Summary: Clean up the package of py4j
Key: FLINK-14557
URL: https://issues.apache.org/jira/browse/FLINK-14557
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-14556:
---
Summary: Correct the package of cloud pickle
Key: FLINK-14556
URL: https://issues.apache.org/jira/browse/FLINK-14556
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-14479:
---
Summary: Strange exceptions found in log file after executing
`test_udf.py`
Key: FLINK-14479
URL: https://issues.apache.org/jira/browse/FLINK-14479
Project: Flink
sunjincheng created FLINK-14478:
---
Summary: The python test on travis consumes too much time
Key: FLINK-14478
URL: https://issues.apache.org/jira/browse/FLINK-14478
Project: Flink
Issue Type:
sunjincheng created FLINK-14288:
---
Summary: Add Py4j NOTICE for source release
Key: FLINK-14288
URL: https://issues.apache.org/jira/browse/FLINK-14288
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-14007:
---
Summary: Add doc for how to using Java user-defined source/sink in
Python API
Key: FLINK-14007
URL: https://issues.apache.org/jira/browse/FLINK-14007
Project: Flink
sunjincheng created FLINK-14006:
---
Summary: Add doc for how to using Java UDFs in Python API
Key: FLINK-14006
URL: https://issues.apache.org/jira/browse/FLINK-14006
Project: Flink
Issue Type:
sunjincheng created FLINK-13473:
---
Summary: Add GroupWindowed FlatAggregate support to stream Table
API(blink planner), i.e, align with flink planner
Key: FLINK-13473
URL:
sunjincheng created FLINK-13471:
---
Summary: Add FlatAggregate support to stream Table API(blink
planner)
Key: FLINK-13471
URL: https://issues.apache.org/jira/browse/FLINK-13471
Project: Flink
sunjincheng created FLINK-13470:
---
Summary: Enhancements to Flink Table API for blink planner
Key: FLINK-13470
URL: https://issues.apache.org/jira/browse/FLINK-13470
Project: Flink
Issue Type:
sunjincheng created FLINK-13011:
---
Summary: Release the PyFlink into PyPI
Key: FLINK-13011
URL: https://issues.apache.org/jira/browse/FLINK-13011
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12849:
---
Summary: Add support for build Python Docs in Buildbot
Key: FLINK-12849
URL: https://issues.apache.org/jira/browse/FLINK-12849
Project: Flink
Issue Type:
sunjincheng created FLINK-12803:
---
Summary: Correct the package name for python API
Key: FLINK-12803
URL: https://issues.apache.org/jira/browse/FLINK-12803
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12794:
---
Summary: Support ACC mode for non-window streaming FlatAggregate
on Table API
Key: FLINK-12794
URL: https://issues.apache.org/jira/browse/FLINK-12794
Project: Flink
sunjincheng created FLINK-12704:
---
Summary: Support blink planner
Key: FLINK-12704
URL: https://issues.apache.org/jira/browse/FLINK-12704
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12602:
---
Summary: Correct the flink pom `artifactId` config and scala-free
check logic
Key: FLINK-12602
URL: https://issues.apache.org/jira/browse/FLINK-12602
Project: Flink
sunjincheng created FLINK-12585:
---
Summary: Align Stream/BatchTableEnvironment with JAVA Table API
Key: FLINK-12585
URL: https://issues.apache.org/jira/browse/FLINK-12585
Project: Flink
Issue
sunjincheng created FLINK-12583:
---
Summary: Add all format support align with the Java Table API
Key: FLINK-12583
URL: https://issues.apache.org/jira/browse/FLINK-12583
Project: Flink
Issue
sunjincheng created FLINK-12541:
---
Summary: Add deploy a Python Flink job and session cluster on
Kubernetes support.
Key: FLINK-12541
URL: https://issues.apache.org/jira/browse/FLINK-12541
Project:
sunjincheng created FLINK-12534:
---
Summary: Reduce the test cost for Python API
Key: FLINK-12534
URL: https://issues.apache.org/jira/browse/FLINK-12534
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-12495:
---
Summary: Move PythonGatewayServer into flink-clients
Key: FLINK-12495
URL: https://issues.apache.org/jira/browse/FLINK-12495
Project: Flink
Issue Type:
sunjincheng created FLINK-12485:
---
Summary: Add a tool to check the user interface of Python Table
API aligns with Java Table API.
Key: FLINK-12485
URL: https://issues.apache.org/jira/browse/FLINK-12485
sunjincheng created FLINK-12454:
---
Summary: Add custom check options for lint-python.sh
Key: FLINK-12454
URL: https://issues.apache.org/jira/browse/FLINK-12454
Project: Flink
Issue Type:
sunjincheng created FLINK-12440:
---
Summary: Add all connector support align Java Table API
Key: FLINK-12440
URL: https://issues.apache.org/jira/browse/FLINK-12440
Project: Flink
Issue Type:
sunjincheng created FLINK-12439:
---
Summary: Add FileSystem Connector with CSV format support in
Python Table API
Key: FLINK-12439
URL: https://issues.apache.org/jira/browse/FLINK-12439
Project: Flink
sunjincheng created FLINK-12407:
---
Summary: Add all table operators align Java Table API
Key: FLINK-12407
URL: https://issues.apache.org/jira/browse/FLINK-12407
Project: Flink
Issue Type:
sunjincheng created FLINK-12370:
---
Summary: Integrated Travis for Python Table API
Key: FLINK-12370
URL: https://issues.apache.org/jira/browse/FLINK-12370
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12330:
---
Summary: Add integrated Tox for ensuring compatibility with the
python2/3 version
Key: FLINK-12330
URL: https://issues.apache.org/jira/browse/FLINK-12330
Project:
sunjincheng created FLINK-12327:
---
Summary: Add simplicity support for submitting Python Table API
job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple
test).
Key: FLINK-12327
URL:
sunjincheng created FLINK-12326:
---
Summary: Add a basic test framework, just like the existing Java
TableAPI, abstract some TestBase.
Key: FLINK-12326
URL: https://issues.apache.org/jira/browse/FLINK-12326
sunjincheng created FLINK-12311:
---
Summary: Add base python framework and Add Scan, Projection, and
Filter operator support
Key: FLINK-12311
URL: https://issues.apache.org/jira/browse/FLINK-12311
sunjincheng created FLINK-12308:
---
Summary: Support python language in Flink Table API
Key: FLINK-12308
URL: https://issues.apache.org/jira/browse/FLINK-12308
Project: Flink
Issue Type: New
sunjincheng created FLINK-12074:
---
Summary: Fix typo in `flinkDev/building.md`
Key: FLINK-12074
URL: https://issues.apache.org/jira/browse/FLINK-12074
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-12029:
---
Summary: Add Column selections
Key: FLINK-12029
URL: https://issues.apache.org/jira/browse/FLINK-12029
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12028:
---
Summary: Add Column Operators(add/rename/drop)
Key: FLINK-12028
URL: https://issues.apache.org/jira/browse/FLINK-12028
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-12026:
---
Summary: Remove the `xxxInternal` method from TableImpl
Key: FLINK-12026
URL: https://issues.apache.org/jira/browse/FLINK-12026
Project: Flink
Issue Type:
sunjincheng created FLINK-12001:
---
Summary: Test AvroExternalJarProgramITCase, get `JAR file does not
exist` Error.
Key: FLINK-12001
URL: https://issues.apache.org/jira/browse/FLINK-12001
Project:
sunjincheng created FLINK-11972:
---
Summary: Fix `Command: start_kubernetes_if_not_ruunning failed`
error
Key: FLINK-11972
URL: https://issues.apache.org/jira/browse/FLINK-11972
Project: Flink
sunjincheng created FLINK-11971:
---
Summary: The classpath is missing the
`flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.
Key: FLINK-11971
URL:
sunjincheng created FLINK-11967:
---
Summary: Add Column Operators/Operations
Key: FLINK-11967
URL: https://issues.apache.org/jira/browse/FLINK-11967
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-11950:
---
Summary: Add missing dependencies in NOTICE file of flink-dist.
Key: FLINK-11950
URL: https://issues.apache.org/jira/browse/FLINK-11950
Project: Flink
Issue
sunjincheng created FLINK-11918:
---
Summary: Deprecated Window and Rename it to GroupWindow
Key: FLINK-11918
URL: https://issues.apache.org/jira/browse/FLINK-11918
Project: Flink
Issue Type:
sunjincheng created FLINK-11891:
---
Summary: Fix some script or test case bug in 1.8 RC
Key: FLINK-11891
URL: https://issues.apache.org/jira/browse/FLINK-11891
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11290:
---
Summary: BatchTableEnvironment and StreamTableEnvironment should
transparent to users
Key: FLINK-11290
URL: https://issues.apache.org/jira/browse/FLINK-11290
Project:
sunjincheng created FLINK-11278:
---
Summary: Add documentation for TableAPI in scala-shell
Key: FLINK-11278
URL: https://issues.apache.org/jira/browse/FLINK-11278
Project: Flink
Issue Type:
sunjincheng created FLINK-11246:
---
Summary: Fix distinct AGG visibility issues
Key: FLINK-11246
URL: https://issues.apache.org/jira/browse/FLINK-11246
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11243:
---
Summary: GroupBy udf() can not be select in TableAPI
Key: FLINK-11243
URL: https://issues.apache.org/jira/browse/FLINK-11243
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11242:
---
Summary: The predicate `'o_c_id === Null(Types.STRING)` not work
in TableAPI
Key: FLINK-11242
URL: https://issues.apache.org/jira/browse/FLINK-11242
Project: Flink
sunjincheng created FLINK-11231:
---
Summary: Unified the definition of Java DataStream and Scala
DataStream interface for set parallelism
Key: FLINK-11231
URL: https://issues.apache.org/jira/browse/FLINK-11231
sunjincheng created FLINK-11223:
---
Summary: Time zone problem of row time field
Key: FLINK-11223
URL: https://issues.apache.org/jira/browse/FLINK-11223
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11220:
---
Summary: Can not Select row time field in JOIN query
Key: FLINK-11220
URL: https://issues.apache.org/jira/browse/FLINK-11220
Project: Flink
Issue Type: Bug
sunjincheng created FLINK-11182:
---
Summary: JobManagerHACheckpointRecoveryITCase need be improved
Key: FLINK-11182
URL: https://issues.apache.org/jira/browse/FLINK-11182
Project: Flink
Issue
sunjincheng created FLINK-11180:
---
Summary:
ProcessFailureCancelingITCase#testCancelingOnProcessFailure
Key: FLINK-11180
URL: https://issues.apache.org/jira/browse/FLINK-11180
Project: Flink
sunjincheng created FLINK-11181:
---
Summary: SimpleRecoveryITCaseBase test error
Key: FLINK-11181
URL: https://issues.apache.org/jira/browse/FLINK-11181
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-11179:
---
Summary:
JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test error
Key: FLINK-11179
URL: https://issues.apache.org/jira/browse/FLINK-11179
Project:
sunjincheng created FLINK-11178:
---
Summary: Check flink-test module for 1.7.1-rc2
Key: FLINK-11178
URL: https://issues.apache.org/jira/browse/FLINK-11178
Project: Flink
Issue Type: Test
sunjincheng created FLINK-11123:
---
Summary: Improve ml quick start doc
Key: FLINK-11123
URL: https://issues.apache.org/jira/browse/FLINK-11123
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-11091:
---
Summary: Clear the use of deprecated methods of KeyedStream in
table operators
Key: FLINK-11091
URL: https://issues.apache.org/jira/browse/FLINK-11091
Project: Flink
sunjincheng created FLINK-11052:
---
Summary: Add Bounded(Group Window) FlatAggregate operator to batch
Table API
Key: FLINK-11052
URL: https://issues.apache.org/jira/browse/FLINK-11052
Project: Flink
sunjincheng created FLINK-11051:
---
Summary: Add Bounded(Group Window) FlatAggregate operator to
streaming Table API
Key: FLINK-11051
URL: https://issues.apache.org/jira/browse/FLINK-11051
Project: Flink
sunjincheng created FLINK-10979:
---
Summary: Add support for group keys in Unbounded
Aggregate/FlatAggregate operator
Key: FLINK-10979
URL: https://issues.apache.org/jira/browse/FLINK-10979
Project:
sunjincheng created FLINK-10978:
---
Summary: Add UnBounded FlatAggregate operator to batch Table API
Key: FLINK-10978
URL: https://issues.apache.org/jira/browse/FLINK-10978
Project: Flink
Issue
sunjincheng created FLINK-10977:
---
Summary: Add UnBounded FlatAggregate operator to streaming Table
API
Key: FLINK-10977
URL: https://issues.apache.org/jira/browse/FLINK-10977
Project: Flink
sunjincheng created FLINK-10976:
---
Summary: Add Aggregate operator to Table API
Key: FLINK-10976
URL: https://issues.apache.org/jira/browse/FLINK-10976
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-10975:
---
Summary: Add support for TimeAttribute in Map/FlatMap operator
Key: FLINK-10975
URL: https://issues.apache.org/jira/browse/FLINK-10975
Project: Flink
Issue
sunjincheng created FLINK-10974:
---
Summary: Add FlatMap to TableAPI
Key: FLINK-10974
URL: https://issues.apache.org/jira/browse/FLINK-10974
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-10973:
---
Summary: Add Map operator to Table API
Key: FLINK-10973
URL: https://issues.apache.org/jira/browse/FLINK-10973
Project: Flink
Issue Type: Sub-task
sunjincheng created FLINK-10972:
---
Summary: Enhancements to Flink Table API
Key: FLINK-10972
URL: https://issues.apache.org/jira/browse/FLINK-10972
Project: Flink
Issue Type: Improvement
sunjincheng created FLINK-10875:
---
Summary: Add `toTableWithTimestamp` method in
`DataStreamConversions`
Key: FLINK-10875
URL: https://issues.apache.org/jira/browse/FLINK-10875
Project: Flink
sunjincheng created FLINK-10834:
---
Summary: TableAPI flatten calculated value error
Key: FLINK-10834
URL: https://issues.apache.org/jira/browse/FLINK-10834
Project: Flink
Issue Type: Bug
1 - 100 of 186 matches
Mail list logo
