Hequn Cheng created FLINK-18997:
---
Summary: Rename type_info to result_type to make it more clear
Key: FLINK-18997
URL: https://issues.apache.org/jira/browse/FLINK-18997
Project: Flink
Issue
Hequn Cheng created FLINK-18985:
---
Summary: Update the Sphinx doc for Python DataStream API.
Key: FLINK-18985
URL: https://issues.apache.org/jira/browse/FLINK-18985
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18984:
---
Summary: Add tutorial documentation for Python DataStream API
Key: FLINK-18984
URL: https://issues.apache.org/jira/browse/FLINK-18984
Project: Flink
Issue
Hequn Cheng created FLINK-18966:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18966
URL: https://issues.apache.org/jira/browse/FLINK-18966
Project: Flink
Hequn Cheng created FLINK-18954:
---
Summary: Add documentation for Metrics in Python DataStream API.
Key: FLINK-18954
URL: https://issues.apache.org/jira/browse/FLINK-18954
Project: Flink
Issue
Hequn Cheng created FLINK-18953:
---
Summary: Add documentation for DataTypes in Python DataStream API
Key: FLINK-18953
URL: https://issues.apache.org/jira/browse/FLINK-18953
Project: Flink
Issue
Hequn Cheng created FLINK-18952:
---
Summary: Add 10 minutes to DataStream API documentation
Key: FLINK-18952
URL: https://issues.apache.org/jira/browse/FLINK-18952
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18949:
---
Summary: Support Streaming File Sink for Python DataStream API
Key: FLINK-18949
URL: https://issues.apache.org/jira/browse/FLINK-18949
Project: Flink
Issue
Hequn Cheng created FLINK-18948:
---
Summary: Add end to end test for Python DataStream API
Key: FLINK-18948
URL: https://issues.apache.org/jira/browse/FLINK-18948
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18947:
---
Summary: Support partitionCustom() operation for Python DataStream
API
Key: FLINK-18947
URL: https://issues.apache.org/jira/browse/FLINK-18947
Project: Flink
Hequn Cheng created FLINK-18945:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18945
URL: https://issues.apache.org/jira/browse/FLINK-18945
Project: Flink
Hequn Cheng created FLINK-18943:
---
Summary: Support connect() operation for Python DataStream API
Key: FLINK-18943
URL: https://issues.apache.org/jira/browse/FLINK-18943
Project: Flink
Issue
Hequn Cheng created FLINK-18883:
---
Summary: Support reduce() operation for Python KeyedStream.
Key: FLINK-18883
URL: https://issues.apache.org/jira/browse/FLINK-18883
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18817:
---
Summary: 'Kerberized YARN per-job on Docker test' failed
Key: FLINK-18817
URL: https://issues.apache.org/jira/browse/FLINK-18817
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18766:
---
Summary: Support add_sink() for Python DataStream API
Key: FLINK-18766
URL: https://issues.apache.org/jira/browse/FLINK-18766
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18765:
---
Summary: Support map() and flat_map() for Python DataStream API
Key: FLINK-18765
URL: https://issues.apache.org/jira/browse/FLINK-18765
Project: Flink
Issue
Hequn Cheng created FLINK-18764:
---
Summary: Support from_collection for Python DataStream API
Key: FLINK-18764
URL: https://issues.apache.org/jira/browse/FLINK-18764
Project: Flink
Issue Type:
Hequn Cheng created FLINK-18763:
---
Summary: Support basic TypeInformation for Python DataStream API
Key: FLINK-18763
URL: https://issues.apache.org/jira/browse/FLINK-18763
Project: Flink
Issue
Hequn Cheng created FLINK-18761:
---
Summary: Support Python DataStream API (Stateless part)
Key: FLINK-18761
URL: https://issues.apache.org/jira/browse/FLINK-18761
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-18655:
---
Summary: Set failOnUnableToExtractRepoInfo to false for
git-commit-id-plugin in module flink-runtime
Key: FLINK-18655
URL: https://issues.apache.org/jira/browse/FLINK-18655
Hequn Cheng created FLINK-18151:
---
Summary: Resolve CWE22 problems in pyflink_gateway_server.py
Key: FLINK-18151
URL: https://issues.apache.org/jira/browse/FLINK-18151
Project: Flink
Issue
Hequn Cheng created FLINK-18143:
---
Summary: Fix Python meter metric not correct problem
Key: FLINK-18143
URL: https://issues.apache.org/jira/browse/FLINK-18143
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-18031:
---
Summary: Update the copyright year in the NOTICE file in
flink-shaded repo
Key: FLINK-18031
URL: https://issues.apache.org/jira/browse/FLINK-18031
Project: Flink
Hequn Cheng created FLINK-17962:
---
Summary: Add document for how to define Python UDF with DDL
Key: FLINK-17962
URL: https://issues.apache.org/jira/browse/FLINK-17962
Project: Flink
Issue Type:
Hequn Cheng created FLINK-17960:
---
Summary: Improve commands in the "Common Questions" document for
PyFlink
Key: FLINK-17960
URL: https://issues.apache.org/jira/browse/FLINK-17960
Project: Flink
Hequn Cheng created FLINK-17959:
---
Summary: Exception: "CANCELLED: call already cancelled" is thrown
when run python udf
Key: FLINK-17959
URL: https://issues.apache.org/jira/browse/FLINK-17959
Project:
Hequn Cheng created FLINK-17710:
---
Summary: StreamSqlTests.test_execute_sql test is not stable
Key: FLINK-17710
URL: https://issues.apache.org/jira/browse/FLINK-17710
Project: Flink
Issue Type:
Hequn Cheng created FLINK-17318:
---
Summary: The comment is not right in
`org.apache.flink.table.planner.delegation.PlannerBase`
Key: FLINK-17318
URL: https://issues.apache.org/jira/browse/FLINK-17318
Hequn Cheng created FLINK-17215:
---
Summary: Clean the build document for Pyflink
Key: FLINK-17215
URL: https://issues.apache.org/jira/browse/FLINK-17215
Project: Flink
Issue Type: Improvement
Hequn Cheng created FLINK-16854:
---
Summary: Correct dependency versions in the NOTICE file of module
statefun-ridesharing-example-simulator
Key: FLINK-16854
URL: https://issues.apache.org/jira/browse/FLINK-16854
Hequn Cheng created FLINK-16853:
---
Summary: Update the version of protobuf-java from 3.8.0 to 3.7.1
in the NOTICE file of module statefun-flink-distribution
Key: FLINK-16853
URL:
Hequn Cheng created FLINK-16786:
---
Summary: Fix pyarrow version incompatible problem
Key: FLINK-16786
URL: https://issues.apache.org/jira/browse/FLINK-16786
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-16766:
---
Summary: Support create StreamTableEnvironment without passing
StreamExecutionEnvironment
Key: FLINK-16766
URL: https://issues.apache.org/jira/browse/FLINK-16766
Hequn Cheng created FLINK-16765:
---
Summary: Replace all BatchTableEnvironment to
StreamTableEnvironment in the document of PyFlink
Key: FLINK-16765
URL: https://issues.apache.org/jira/browse/FLINK-16765
Hequn Cheng created FLINK-16763:
---
Summary: Should not use BatchTableEnvironment for Python UDF in
the document of flink-1.10
Key: FLINK-16763
URL: https://issues.apache.org/jira/browse/FLINK-16763
Hequn Cheng created FLINK-16761:
---
Summary: Return JobExecutionResult for Python ExecutionEnvironment
and TableEnvironment
Key: FLINK-16761
URL: https://issues.apache.org/jira/browse/FLINK-16761
Hequn Cheng created FLINK-16674:
---
Summary: Add documentation about how to use user-defined metrics
for Python UDF
Key: FLINK-16674
URL: https://issues.apache.org/jira/browse/FLINK-16674
Project: Flink
Hequn Cheng created FLINK-16673:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDTF
Key: FLINK-16673
URL: https://issues.apache.org/jira/browse/FLINK-16673
Project: Flink
Hequn Cheng created FLINK-16672:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDF
Key: FLINK-16672
URL: https://issues.apache.org/jira/browse/FLINK-16672
Project: Flink
Hequn Cheng created FLINK-16671:
---
Summary: Support define scopes and variables on Python metric group
Key: FLINK-16671
URL: https://issues.apache.org/jira/browse/FLINK-16671
Project: Flink
Hequn Cheng created FLINK-16670:
---
Summary: Support User-Defined Metrics in Python UDF
Key: FLINK-16670
URL: https://issues.apache.org/jira/browse/FLINK-16670
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-16565:
---
Summary: Make Pipeline Json compitable between Java and Python if
all Pipelinestage are Java ones
Key: FLINK-16565
URL: https://issues.apache.org/jira/browse/FLINK-16565
Hequn Cheng created FLINK-16273:
---
Summary: Solve "sun.misc.Unseafe or
java.nio.DirectByteBuffer.(long, int) not available" problem for users
Key: FLINK-16273
URL: https://issues.apache.org/jira/browse/FLINK-16273
Hequn Cheng created FLINK-16250:
---
Summary: Add interfaces for PipelineStage and Pipeline
Key: FLINK-16250
URL: https://issues.apache.org/jira/browse/FLINK-16250
Project: Flink
Issue Type:
Hequn Cheng created FLINK-16249:
---
Summary: Add interfaces for Params, ParamInfo and WithParams
Key: FLINK-16249
URL: https://issues.apache.org/jira/browse/FLINK-16249
Project: Flink
Issue
Hequn Cheng created FLINK-16248:
---
Summary: Add interfaces for MLEnvironment and MLEnvironmentFactory
Key: FLINK-16248
URL: https://issues.apache.org/jira/browse/FLINK-16248
Project: Flink
Hequn Cheng created FLINK-16241:
---
Summary: Remove the license and notice file in flink-ml-lib module
on release-1.10 branch
Key: FLINK-16241
URL: https://issues.apache.org/jira/browse/FLINK-16241
Hequn Cheng created FLINK-16187:
---
Summary: Support Python ML Pipeline API
Key: FLINK-16187
URL: https://issues.apache.org/jira/browse/FLINK-16187
Project: Flink
Issue Type: New Feature
Hequn Cheng created FLINK-16119:
---
Summary: Port base RelNode classes from Scala to Java
Key: FLINK-16119
URL: https://issues.apache.org/jira/browse/FLINK-16119
Project: Flink
Issue Type:
Hequn Cheng created FLINK-15847:
---
Summary: Include flink-ml-api and flink-ml-lib in opt
Key: FLINK-15847
URL: https://issues.apache.org/jira/browse/FLINK-15847
Project: Flink
Issue Type:
Hequn Cheng created FLINK-15675:
---
Summary: Add documentation that Python UDF is not supported for
Flink Planner under batch mode
Key: FLINK-15675
URL: https://issues.apache.org/jira/browse/FLINK-15675
Hequn Cheng created FLINK-15636:
---
Summary: Support Python UDF for flink planner under batch mode
Key: FLINK-15636
URL: https://issues.apache.org/jira/browse/FLINK-15636
Project: Flink
Issue
Hequn Cheng created FLINK-15616:
---
Summary: Move boot error messages from python-udf-boot.log to
taskmanager's log file
Key: FLINK-15616
URL: https://issues.apache.org/jira/browse/FLINK-15616
Project:
Hequn Cheng created FLINK-14684:
---
Summary: Add Pinterest to Chinese Powered By page
Key: FLINK-14684
URL: https://issues.apache.org/jira/browse/FLINK-14684
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-14497:
---
Summary: Support primitive data types in Python user-defined
functions
Key: FLINK-14497
URL: https://issues.apache.org/jira/browse/FLINK-14497
Project: Flink
Hequn Cheng created FLINK-14459:
---
Summary: Python module build hangs
Key: FLINK-14459
URL: https://issues.apache.org/jira/browse/FLINK-14459
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-14385:
---
Summary: There are ClassNotFoundException when run the example in
Local Setup Tutorial
Key: FLINK-14385
URL: https://issues.apache.org/jira/browse/FLINK-14385
Project:
Hequn Cheng created FLINK-14383:
---
Summary: Support python UDFs with constant value of time interval
types
Key: FLINK-14383
URL: https://issues.apache.org/jira/browse/FLINK-14383
Project: Flink
Hequn Cheng created FLINK-13637:
---
Summary: Anchors not working in document(building.md, common.md,
queryable_state.md)
Key: FLINK-13637
URL: https://issues.apache.org/jira/browse/FLINK-13637
Project:
Hequn Cheng created FLINK-13446:
---
Summary: Row count sliding window outputs incorrectly in blink
planner
Key: FLINK-13446
URL: https://issues.apache.org/jira/browse/FLINK-13446
Project: Flink
Hequn Cheng created FLINK-13392:
---
Summary: WindowAggregate inherited from Aggregate incorrectly
Key: FLINK-13392
URL: https://issues.apache.org/jira/browse/FLINK-13392
Project: Flink
Issue
Hequn Cheng created FLINK-13196:
---
Summary: Fix Ambiguous column name exception bug for Table API
Key: FLINK-13196
URL: https://issues.apache.org/jira/browse/FLINK-13196
Project: Flink
Issue
Hequn Cheng created FLINK-13087:
---
Summary: Add group window Aggregate operator to Table API
Key: FLINK-13087
URL: https://issues.apache.org/jira/browse/FLINK-13087
Project: Flink
Issue Type:
Hequn Cheng created FLINK-13057:
---
Summary: Correct comments in ListState class
Key: FLINK-13057
URL: https://issues.apache.org/jira/browse/FLINK-13057
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-12906:
---
Summary: Port OperationTreeBuilder to Java
Key: FLINK-12906
URL: https://issues.apache.org/jira/browse/FLINK-12906
Project: Flink
Issue Type: Improvement
Hequn Cheng created FLINK-12797:
---
Summary: Remove duplicate tests in
GroupWindowTableAggregateValidationTest
Key: FLINK-12797
URL: https://issues.apache.org/jira/browse/FLINK-12797
Project: Flink
Hequn Cheng created FLINK-12789:
---
Summary: Fix java docs in UserDefinedAggregateFunction
Key: FLINK-12789
URL: https://issues.apache.org/jira/browse/FLINK-12789
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-12779:
---
Summary: Avoid field conflicts when generate field names for
non-composite Typeinformation
Key: FLINK-12779
URL: https://issues.apache.org/jira/browse/FLINK-12779
Hequn Cheng created FLINK-12778:
---
Summary: Fix deriveTableAggRowType bug for non-composite types
Key: FLINK-12778
URL: https://issues.apache.org/jira/browse/FLINK-12778
Project: Flink
Issue
Hequn Cheng created FLINK-12562:
---
Summary: Improve code in ExpandColumnFunctionsRule
Key: FLINK-12562
URL: https://issues.apache.org/jira/browse/FLINK-12562
Project: Flink
Issue Type:
Hequn Cheng created FLINK-12533:
---
Summary: Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type
Key: FLINK-12533
URL: https://issues.apache.org/jira/browse/FLINK-12533
Project: Flink
Hequn Cheng created FLINK-12402:
---
Summary: Make validation error message for CallExpression more
user friendly
Key: FLINK-12402
URL: https://issues.apache.org/jira/browse/FLINK-12402
Project: Flink
Hequn Cheng created FLINK-12401:
---
Summary: Support incremental emit for non-window streaming
FlatAggregate on Table API
Key: FLINK-12401
URL: https://issues.apache.org/jira/browse/FLINK-12401
Project:
Hequn Cheng created FLINK-12357:
---
Summary: Remove useless code in TableConfig
Key: FLINK-12357
URL: https://issues.apache.org/jira/browse/FLINK-12357
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-12271:
---
Summary: Display input field name list when throw Cannot resolve
field exception
Key: FLINK-12271
URL: https://issues.apache.org/jira/browse/FLINK-12271
Project: Flink
Hequn Cheng created FLINK-12217:
---
Summary: OperationTreeBuilder.map() should perform
ExpressionResolver.resolve()
Key: FLINK-12217
URL: https://issues.apache.org/jira/browse/FLINK-12217
Project: Flink
Hequn Cheng created FLINK-12182:
---
Summary: AggregateProjectMergeRule can not handle
LogicalWindowAggregate
Key: FLINK-12182
URL: https://issues.apache.org/jira/browse/FLINK-12182
Project: Flink
Hequn Cheng created FLINK-12174:
---
Summary: Introduce FlinkAggregateExtractProjectRule and remove
extractFieldReferences
Key: FLINK-12174
URL: https://issues.apache.org/jira/browse/FLINK-12174
Project:
Hequn Cheng created FLINK-12016:
---
Summary: Change package name in blink modules to avoid class
conflict
Key: FLINK-12016
URL: https://issues.apache.org/jira/browse/FLINK-12016
Project: Flink
Hequn Cheng created FLINK-11969:
---
Summary: Add end2end stream sql test for unbounded operators
Key: FLINK-11969
URL: https://issues.apache.org/jira/browse/FLINK-11969
Project: Flink
Issue
Hequn Cheng created FLINK-11934:
---
Summary: Remove the deprecate methods in TableEnvironment
Key: FLINK-11934
URL: https://issues.apache.org/jira/browse/FLINK-11934
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11916:
---
Summary: Join with a Temporal Table should throw exception for
left join
Key: FLINK-11916
URL: https://issues.apache.org/jira/browse/FLINK-11916
Project: Flink
Hequn Cheng created FLINK-11908:
---
Summary: Port window classes into flink-api-java
Key: FLINK-11908
URL: https://issues.apache.org/jira/browse/FLINK-11908
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11398:
---
Summary: Add a dedicated phase to materialize time indicators for
nodes produce updates
Key: FLINK-11398
URL: https://issues.apache.org/jira/browse/FLINK-11398
Hequn Cheng created FLINK-11342:
---
Summary: Add example for every built-In TableAPI Function
Key: FLINK-11342
URL: https://issues.apache.org/jira/browse/FLINK-11342
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11331:
---
Summary: Fix errors in tableApi.md and functions.md
Key: FLINK-11331
URL: https://issues.apache.org/jira/browse/FLINK-11331
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11310:
---
Summary: Convert predicates to IN or NOT_IN for Project
Key: FLINK-11310
URL: https://issues.apache.org/jira/browse/FLINK-11310
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11301:
---
Summary: Travis failed: No output has been received in the last
10m0s
Key: FLINK-11301
URL: https://issues.apache.org/jira/browse/FLINK-11301
Project: Flink
Hequn Cheng created FLINK-11222:
---
Summary: Change api.scala.DataStream to api.datastream.DataStream
in HarnessTestBase
Key: FLINK-11222
URL: https://issues.apache.org/jira/browse/FLINK-11222
Project:
Hequn Cheng created FLINK-11221:
---
Summary: Support delimited identifiers in TableAPI
Key: FLINK-11221
URL: https://issues.apache.org/jira/browse/FLINK-11221
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11210:
---
Summary: Enable auto state cleanup strategy for RANGE OVER
Key: FLINK-11210
URL: https://issues.apache.org/jira/browse/FLINK-11210
Project: Flink
Issue Type:
Hequn Cheng created FLINK-11203:
---
Summary: FunctionContext of AggregateFunction will not be
initialized for window GroupBy
Key: FLINK-11203
URL: https://issues.apache.org/jira/browse/FLINK-11203
Hequn Cheng created FLINK-11197:
---
Summary: Improve migration test comments about how to generate
snapshots
Key: FLINK-11197
URL: https://issues.apache.org/jira/browse/FLINK-11197
Project: Flink
Hequn Cheng created FLINK-11188:
---
Summary: Bounded over should not enable state retention time
Key: FLINK-11188
URL: https://issues.apache.org/jira/browse/FLINK-11188
Project: Flink
Issue
Hequn Cheng created FLINK-11150:
---
Summary: Check exception messages in ValidationTest of flink-table
Key: FLINK-11150
URL: https://issues.apache.org/jira/browse/FLINK-11150
Project: Flink
Hequn Cheng created FLINK-11147:
---
Summary: Add document for TableAggregate Function
Key: FLINK-11147
URL: https://issues.apache.org/jira/browse/FLINK-11147
Project: Flink
Issue Type: Sub-task
Hequn Cheng created FLINK-11131:
---
Summary: Enable unused import checkstyle on flink-core and
flink-runtime tests
Key: FLINK-11131
URL: https://issues.apache.org/jira/browse/FLINK-11131
Project: Flink
Hequn Cheng created FLINK-11125:
---
Summary: Remove useless import
Key: FLINK-11125
URL: https://issues.apache.org/jira/browse/FLINK-11125
Project: Flink
Issue Type: Improvement
Hequn Cheng created FLINK-11124:
---
Summary: Add private[flink] to TemporalTableFunction.create()
Key: FLINK-11124
URL: https://issues.apache.org/jira/browse/FLINK-11124
Project: Flink
Issue
Hequn Cheng created FLINK-11090:
---
Summary: Unused parameter in WindowedStream.aggregate()
Key: FLINK-11090
URL: https://issues.apache.org/jira/browse/FLINK-11090
Project: Flink
Issue Type:
1 - 100 of 135 matches
Mail list logo
