Dian Fu created FLINK-7147:
--
Summary: Support greedy quantifier in CEP
Key: FLINK-7147
URL: https://issues.apache.org/jira/browse/FLINK-7147
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-7170:
--
Summary: Fix until condition when the contiguity is strict
Key: FLINK-7170
URL: https://issues.apache.org/jira/browse/FLINK-7170
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-7062:
--
Summary: Support the basic functionality of MATCH_RECOGNIZE
Key: FLINK-7062
URL: https://issues.apache.org/jira/browse/FLINK-7062
Project: Flink
Issue Type: Task
Dian Fu created FLINK-7061:
--
Summary: Fix quantifier range starting from 0
Key: FLINK-7061
URL: https://issues.apache.org/jira/browse/FLINK-7061
Project: Flink
Issue Type: Bug
Components:
Dian Fu created FLINK-7123:
--
Summary: Support timesOrMore in CEP
Key: FLINK-7123
URL: https://issues.apache.org/jira/browse/FLINK-7123
Project: Flink
Issue Type: Sub-task
Components: CEP
Dian Fu created FLINK-7479:
--
Summary: Support to retrieve the past event by an offset
Key: FLINK-7479
URL: https://issues.apache.org/jira/browse/FLINK-7479
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-6876:
--
Summary: The comment of DataStream#assignTimestampsAndWatermarks
is incorrect
Key: FLINK-6876
URL: https://issues.apache.org/jira/browse/FLINK-6876
Project: Flink
Dian Fu created FLINK-6905:
--
Summary: Support for zeroOrMore to CEP's pattern API
Key: FLINK-6905
URL: https://issues.apache.org/jira/browse/FLINK-6905
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-6904:
--
Summary: Support for quantifier range to CEP's pattern API
Key: FLINK-6904
URL: https://issues.apache.org/jira/browse/FLINK-6904
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-6933:
--
Summary: Refactor NFACompiler to reduce code duplication
Key: FLINK-6933
URL: https://issues.apache.org/jira/browse/FLINK-6933
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-7599:
--
Summary: Support aggregation functions in the define and measures
clause of MatchRecognize
Key: FLINK-7599
URL: https://issues.apache.org/jira/browse/FLINK-7599
Project: Flink
Dian Fu created FLINK-7591:
--
Summary: Support partition by and order by of MATCH_RECOGNIZE
Key: FLINK-7591
URL: https://issues.apache.org/jira/browse/FLINK-7591
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-7496:
--
Summary: Support greedy quantifier followed by an optional pattern
Key: FLINK-7496
URL: https://issues.apache.org/jira/browse/FLINK-7496
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-8147:
--
Summary: Support and to CEP's pattern API
Key: FLINK-8147
URL: https://issues.apache.org/jira/browse/FLINK-8147
Project: Flink
Issue Type: Bug
Components: CEP
Dian Fu created FLINK-8144:
--
Summary: Optimize the timer logic in RowTimeUnboundedOver
Key: FLINK-8144
URL: https://issues.apache.org/jira/browse/FLINK-8144
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-8106:
--
Summary: Optimize the timer logic in
AbstractKeyedCEPPatternOperator
Key: FLINK-8106
URL: https://issues.apache.org/jira/browse/FLINK-8106
Project: Flink
Issue Type:
Dian Fu created FLINK-8096:
--
Summary: Fix time material issue when write to TableSink
Key: FLINK-8096
URL: https://issues.apache.org/jira/browse/FLINK-8096
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-8097:
--
Summary: Add built-in support for min/max aggregation for Date/Time
Key: FLINK-8097
URL: https://issues.apache.org/jira/browse/FLINK-8097
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-7962:
--
Summary: Add built-in support for min/max aggregation for Timestamp
Key: FLINK-7962
URL: https://issues.apache.org/jira/browse/FLINK-7962
Project: Flink
Issue Type:
Dian Fu created FLINK-8226:
--
Summary: Dangling reference generated after NFA clean up timed out
SharedBufferEntry
Key: FLINK-8226
URL: https://issues.apache.org/jira/browse/FLINK-8226
Project: Flink
Dian Fu created FLINK-8227:
--
Summary: Optimize the performance of SharedBufferSerializer
Key: FLINK-8227
URL: https://issues.apache.org/jira/browse/FLINK-8227
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-11136:
---
Summary: Fix the logical of merge for DISTINCT aggregates
Key: FLINK-11136
URL: https://issues.apache.org/jira/browse/FLINK-11136
Project: Flink
Issue Type: Test
Dian Fu created FLINK-11176:
---
Summary: Improve the harness tests to use the code-generated
operator
Key: FLINK-11176
URL: https://issues.apache.org/jira/browse/FLINK-11176
Project: Flink
Issue
Dian Fu created FLINK-11214:
---
Summary: Support non mergable aggregates for group windows on
batch table
Key: FLINK-11214
URL: https://issues.apache.org/jira/browse/FLINK-11214
Project: Flink
Dian Fu created FLINK-11074:
---
Summary: Improve the harness test to make it possible test with
state backend
Key: FLINK-11074
URL: https://issues.apache.org/jira/browse/FLINK-11074
Project: Flink
Dian Fu created FLINK-10958:
---
Summary: Add overload support for user defined function
Key: FLINK-10958
URL: https://issues.apache.org/jira/browse/FLINK-10958
Project: Flink
Issue Type: Task
Dian Fu created FLINK-11009:
---
Summary: Add support for FILTER clause for non-windowed
aggregation in Table API and SQL
Key: FLINK-11009
URL: https://issues.apache.org/jira/browse/FLINK-11009
Project: Flink
Dian Fu created FLINK-11013:
---
Summary: Fix distinct aggregates for group window in Table API
Key: FLINK-11013
URL: https://issues.apache.org/jira/browse/FLINK-11013
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-11291:
---
Summary: Reorganize the package of flink-cep module
Key: FLINK-11291
URL: https://issues.apache.org/jira/browse/FLINK-11291
Project: Flink
Issue Type: Task
Dian Fu created FLINK-11285:
---
Summary: Change the modifier of
CsvTableSourceFactoryBase.createTableSource and
CsvTableSinkFactoryBase.createTableSink to private[flink]
Key: FLINK-11285
URL:
Dian Fu created FLINK-11516:
---
Summary: Port and move some Descriptor classes to
flink-table-common
Key: FLINK-11516
URL: https://issues.apache.org/jira/browse/FLINK-11516
Project: Flink
Issue
Dian Fu created FLINK-11522:
---
Summary: Deprecate ExternalCatalogTable.builder()
Key: FLINK-11522
URL: https://issues.apache.org/jira/browse/FLINK-11522
Project: Flink
Issue Type: Task
Dian Fu created FLINK-11532:
---
Summary: Remove the deprecation of ExternalCatalogTable.builder()
Key: FLINK-11532
URL: https://issues.apache.org/jira/browse/FLINK-11532
Project: Flink
Issue Type:
Dian Fu created FLINK-12716:
---
Summary: Add an interactive shell for Python Table API
Key: FLINK-12716
URL: https://issues.apache.org/jira/browse/FLINK-12716
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12717:
---
Summary: Add windows support for the Python shell script
Key: FLINK-12717
URL: https://issues.apache.org/jira/browse/FLINK-12717
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12719:
---
Summary: Add the catalog API for the Python Table API
Key: FLINK-12719
URL: https://issues.apache.org/jira/browse/FLINK-12719
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12720:
---
Summary: Add the Python Table API Sphinx docs
Key: FLINK-12720
URL: https://issues.apache.org/jira/browse/FLINK-12720
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12722:
---
Summary: Adds Python Table API tutorial
Key: FLINK-12722
URL: https://issues.apache.org/jira/browse/FLINK-12722
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12723:
---
Summary: Adds a wiki page about setting up a Python Table API
development environment
Key: FLINK-12723
URL: https://issues.apache.org/jira/browse/FLINK-12723
Project: Flink
Dian Fu created FLINK-12757:
---
Summary: Improves the Python word_count example to use the
descriptor API
Key: FLINK-12757
URL: https://issues.apache.org/jira/browse/FLINK-12757
Project: Flink
Dian Fu created FLINK-12767:
---
Summary: Support user defined connectors/format
Key: FLINK-12767
URL: https://issues.apache.org/jira/browse/FLINK-12767
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12787:
---
Summary: Allow to specify directory in option -pyfs
Key: FLINK-12787
URL: https://issues.apache.org/jira/browse/FLINK-12787
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12788:
---
Summary: Add support to run a Python job-specific cluster on
Kubernetes
Key: FLINK-12788
URL: https://issues.apache.org/jira/browse/FLINK-12788
Project: Flink
Issue
Dian Fu created FLINK-12821:
---
Summary: Fix the bug that fix time quantifier can not be the last
element of a pattern
Key: FLINK-12821
URL: https://issues.apache.org/jira/browse/FLINK-12821
Project: Flink
Dian Fu created FLINK-12910:
---
Summary: Fix the Python catalog test issue
Key: FLINK-12910
URL: https://issues.apache.org/jira/browse/FLINK-12910
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-12897:
---
Summary: Improve the Python Table API docs by adding more examples
Key: FLINK-12897
URL: https://issues.apache.org/jira/browse/FLINK-12897
Project: Flink
Issue Type:
Dian Fu created FLINK-12920:
---
Summary: Drop support for register_table_sink with field_names and
field_types parameters
Key: FLINK-12920
URL: https://issues.apache.org/jira/browse/FLINK-12920
Project:
Dian Fu created FLINK-12962:
---
Summary: Allows pyflink to be pip installed
Key: FLINK-12962
URL: https://issues.apache.org/jira/browse/FLINK-12962
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12609:
---
Summary: Align the data types of Python with Java
Key: FLINK-12609
URL: https://issues.apache.org/jira/browse/FLINK-12609
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12455:
---
Summary: Move the package of pyflink to flink-dist
Key: FLINK-12455
URL: https://issues.apache.org/jira/browse/FLINK-12455
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12409:
---
Summary: Adds from_elements in TableEnvironment
Key: FLINK-12409
URL: https://issues.apache.org/jira/browse/FLINK-12409
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-12408:
---
Summary: Support to define all kinds of types in Python API
Key: FLINK-12408
URL: https://issues.apache.org/jira/browse/FLINK-12408
Project: Flink
Issue Type:
Dian Fu created FLINK-12990:
---
Summary: Date type doesn't consider the local TimeZone
Key: FLINK-12990
URL: https://issues.apache.org/jira/browse/FLINK-12990
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-12991:
---
Summary: Correct the implementation of Catalog.get_table_factory
Key: FLINK-12991
URL: https://issues.apache.org/jira/browse/FLINK-12991
Project: Flink
Issue Type:
Dian Fu created FLINK-13743:
---
Summary: Port PythonTableUtils to flink-python module
Key: FLINK-13743
URL: https://issues.apache.org/jira/browse/FLINK-13743
Project: Flink
Issue Type: Task
Dian Fu created FLINK-14013:
---
Summary: Support Flink Python User-Defined Stateless Function for
Table
Key: FLINK-14013
URL: https://issues.apache.org/jira/browse/FLINK-14013
Project: Flink
Issue
Dian Fu created FLINK-14015:
---
Summary: Introduce PythonScalarFunctionOperator as a standalone
StreamOperator for Python ScalarFunction execution
Key: FLINK-14015
URL: https://issues.apache.org/jira/browse/FLINK-14015
Dian Fu created FLINK-14014:
---
Summary: Introduce PythonScalarFunctionRunner to handle the
communication with Python worker for Python ScalarFunction execution
Key: FLINK-14014
URL:
Dian Fu created FLINK-14016:
---
Summary: Introduce RelNodes FlinkLogicalPythonScalarFunctionExec
and DataStreamPythonScalarFunctionExec which are containers for Python
PythonScalarFunctions
Key: FLINK-14016
URL:
Dian Fu created FLINK-13999:
---
Summary: Correct the documentation of MATCH_RECOGNIZE
Key: FLINK-13999
URL: https://issues.apache.org/jira/browse/FLINK-13999
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-14027:
---
Summary: Add documentation for Python user-defined functions
Key: FLINK-14027
URL: https://issues.apache.org/jira/browse/FLINK-14027
Project: Flink
Issue Type:
Dian Fu created FLINK-14023:
---
Summary: Support accessing job parameters in Python user-defined
functions
Key: FLINK-14023
URL: https://issues.apache.org/jira/browse/FLINK-14023
Project: Flink
Dian Fu created FLINK-14022:
---
Summary: Add validation check for places where Python
ScalarFunction cannot be used
Key: FLINK-14022
URL: https://issues.apache.org/jira/browse/FLINK-14022
Project: Flink
Dian Fu created FLINK-14018:
---
Summary: Add Python building blocks to make sure the basic
functionality of Python ScalarFunction could work
Key: FLINK-14018
URL: https://issues.apache.org/jira/browse/FLINK-14018
Dian Fu created FLINK-14024:
---
Summary: Support use-defined metrics in Python user-defined
functions
Key: FLINK-14024
URL: https://issues.apache.org/jira/browse/FLINK-14024
Project: Flink
Issue
Dian Fu created FLINK-14026:
---
Summary: Manage the resource of Python worker properly
Key: FLINK-14026
URL: https://issues.apache.org/jira/browse/FLINK-14026
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14025:
---
Summary: Support to run the Python worker in docker mode
Key: FLINK-14025
URL: https://issues.apache.org/jira/browse/FLINK-14025
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14019:
---
Summary: Python environment and dependency management
Key: FLINK-14019
URL: https://issues.apache.org/jira/browse/FLINK-14019
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14017:
---
Summary: Support to start up Python worker in process mode
Key: FLINK-14017
URL: https://issues.apache.org/jira/browse/FLINK-14017
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14020:
---
Summary: User Apache Arrow as the serializer for data transmission
between Java operator and Python harness
Key: FLINK-14020
URL: https://issues.apache.org/jira/browse/FLINK-14020
Dian Fu created FLINK-14021:
---
Summary: Add rules to push down the Python ScalarFunctions
contained in the join condition of Correlate node
Key: FLINK-14021
URL: https://issues.apache.org/jira/browse/FLINK-14021
Dian Fu created FLINK-14028:
---
Summary: Support logging aggregation in Python user-defined
functions
Key: FLINK-14028
URL: https://issues.apache.org/jira/browse/FLINK-14028
Project: Flink
Issue
Dian Fu created FLINK-14269:
---
Summary: The close method does not work for UserDefinedFunction
Key: FLINK-14269
URL: https://issues.apache.org/jira/browse/FLINK-14269
Project: Flink
Issue Type:
Dian Fu created FLINK-14272:
---
Summary: Support Blink planner for Python UDF
Key: FLINK-14272
URL: https://issues.apache.org/jira/browse/FLINK-14272
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14240:
---
Summary: The configuration added via TableConfig#configuration
should be added to GlobalJobParameters for the legacy planner
Key: FLINK-14240
URL:
Dian Fu created FLINK-14222:
---
Summary: Optimize for Python UDFs with all parameters are constant
values
Key: FLINK-14222
URL: https://issues.apache.org/jira/browse/FLINK-14222
Project: Flink
Dian Fu created FLINK-12864:
---
Summary: Improves the performance of Python Table API test cases
Key: FLINK-12864
URL: https://issues.apache.org/jira/browse/FLINK-12864
Project: Flink
Issue Type:
Dian Fu created FLINK-14760:
---
Summary: Documentation links check failed on travis
Key: FLINK-14760
URL: https://issues.apache.org/jira/browse/FLINK-14760
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-14888:
---
Summary: Move the Python SqlDialect to module table
Key: FLINK-14888
URL: https://issues.apache.org/jira/browse/FLINK-14888
Project: Flink
Issue Type: Task
Dian Fu created FLINK-14891:
---
Summary: PythonScalarFunctionOperator should be chained with
upstream operators by default
Key: FLINK-14891
URL: https://issues.apache.org/jira/browse/FLINK-14891
Project:
Dian Fu created FLINK-15271:
---
Summary: Add documentation about the Python environment
requirements
Key: FLINK-15271
URL: https://issues.apache.org/jira/browse/FLINK-15271
Project: Flink
Issue
Dian Fu created FLINK-15270:
---
Summary: Add documentation about how to specify third-party
dependencies via API for Python UDFs
Key: FLINK-15270
URL: https://issues.apache.org/jira/browse/FLINK-15270
Dian Fu created FLINK-14469:
---
Summary: Drop Python 2 support
Key: FLINK-14469
URL: https://issues.apache.org/jira/browse/FLINK-14469
Project: Flink
Issue Type: Task
Components: API /
Dian Fu created FLINK-14500:
---
Summary: Support Flink Python User-Defined Stateless Function for
Table(Phase 2)
Key: FLINK-14500
URL: https://issues.apache.org/jira/browse/FLINK-14500
Project: Flink
Dian Fu created FLINK-14506:
---
Summary: Improve the release script for Python API release package
Key: FLINK-14506
URL: https://issues.apache.org/jira/browse/FLINK-14506
Project: Flink
Issue Type:
Dian Fu created FLINK-14509:
---
Summary: Improve the README.md in pyflink to prepare for PyPI
release
Key: FLINK-14509
URL: https://issues.apache.org/jira/browse/FLINK-14509
Project: Flink
Issue
Dian Fu created FLINK-14865:
---
Summary:
PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 failed
in travis
Key: FLINK-14865
URL: https://issues.apache.org/jira/browse/FLINK-14865
Dian Fu created FLINK-14866:
---
Summary: A few documentation links are broken
Key: FLINK-14866
URL: https://issues.apache.org/jira/browse/FLINK-14866
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-14944:
---
Summary: Unstable test
FlinkFnExecutionSyncTests.test_flink_fn_execution_pb2_synced
Key: FLINK-14944
URL: https://issues.apache.org/jira/browse/FLINK-14944
Project: Flink
Dian Fu created FLINK-14581:
---
Summary: Support to run Python UDF jobs in a YARN cluster
Key: FLINK-14581
URL: https://issues.apache.org/jira/browse/FLINK-14581
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14202:
---
Summary: Optimize the execution plan for Python Calc when there is
a condition
Key: FLINK-14202
URL: https://issues.apache.org/jira/browse/FLINK-14202
Project: Flink
Dian Fu created FLINK-14208:
---
Summary: Support Python UDF with parameters of constant values
Key: FLINK-14208
URL: https://issues.apache.org/jira/browse/FLINK-14208
Project: Flink
Issue Type:
Dian Fu created FLINK-14212:
---
Summary: Support Python UDFs without arguments
Key: FLINK-14212
URL: https://issues.apache.org/jira/browse/FLINK-14212
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14342:
---
Summary: Remove method FunctionDefinition#getLanguage
Key: FLINK-14342
URL: https://issues.apache.org/jira/browse/FLINK-14342
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-14388:
---
Summary: Support all the data types in Python user-defined
functions
Key: FLINK-14388
URL: https://issues.apache.org/jira/browse/FLINK-14388
Project: Flink
Issue
Dian Fu created FLINK-15046:
---
Summary: Add guideline on how to report security issues
Key: FLINK-15046
URL: https://issues.apache.org/jira/browse/FLINK-15046
Project: Flink
Issue Type: Improvement
Dian Fu created FLINK-16337:
---
Summary: Add RelNodes and Rules for vectorized Python UDF execution
Key: FLINK-16337
URL: https://issues.apache.org/jira/browse/FLINK-16337
Project: Flink
Issue Type:
Dian Fu created FLINK-16271:
---
Summary: Introduce ArrowScalarFunctionOperator for vectorized
Python UDF execution
Key: FLINK-16271
URL: https://issues.apache.org/jira/browse/FLINK-16271
Project: Flink
Dian Fu created FLINK-15929:
---
Summary: test_dependency failed on travis
Key: FLINK-15929
URL: https://issues.apache.org/jira/browse/FLINK-15929
Project: Flink
Issue Type: Test
Dian Fu created FLINK-15875:
---
Summary: Bump Beam to 2.19.0
Key: FLINK-15875
URL: https://issues.apache.org/jira/browse/FLINK-15875
Project: Flink
Issue Type: Improvement
Components: API
1 - 100 of 439 matches
Mail list logo
