godfrey he created FLINK-20705:
--
Summary: Separate the implementation of BatchExecValues and
StreamExecValues
Key: FLINK-20705
URL: https://issues.apache.org/jira/browse/FLINK-20705
Project: Flink
godfrey he created FLINK-20693:
--
Summary: Port BatchExecPythonCorrelate and
StreamExecPythonCorrelate to Java
Key: FLINK-20693
URL: https://issues.apache.org/jira/browse/FLINK-20693
Project: Flink
godfrey he created FLINK-20690:
--
Summary: Separate the implementation of BatchExecCorrelate and
StreamExecCorrelate
Key: FLINK-20690
URL: https://issues.apache.org/jira/browse/FLINK-20690
Project: Flink
godfrey he created FLINK-20673:
--
Summary: ExecNode#getOutputType method should return LogicalType
instead of RowType
Key: FLINK-20673
URL: https://issues.apache.org/jira/browse/FLINK-20673
Project:
godfrey he created FLINK-20668:
--
Summary: Introduce translateToExecNode method for FlinkPhysicalRel
Key: FLINK-20668
URL: https://issues.apache.org/jira/browse/FLINK-20668
Project: Flink
Issue
godfrey he created FLINK-20623:
--
Summary: Separate the implementation of StreamExecWatermarkAssigner
Key: FLINK-20623
URL: https://issues.apache.org/jira/browse/FLINK-20623
Project: Flink
Issue
godfrey he created FLINK-20622:
--
Summary: Separate the implementation of
StreamExecChangelogNormalize
Key: FLINK-20622
URL: https://issues.apache.org/jira/browse/FLINK-20622
Project: Flink
godfrey he created FLINK-20620:
--
Summary: Port StreamExecPythonCalc to java
Key: FLINK-20620
URL: https://issues.apache.org/jira/browse/FLINK-20620
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20610:
--
Summary: Separate the implementation of BatchExecCalc and
StreamExecCalc
Key: FLINK-20610
URL: https://issues.apache.org/jira/browse/FLINK-20610
Project: Flink
godfrey he created FLINK-20609:
--
Summary: Separate the implementation of BatchExecDataStreamScan
and StreamExecDataStreamScan
Key: FLINK-20609
URL: https://issues.apache.org/jira/browse/FLINK-20609
godfrey he created FLINK-20608:
--
Summary: Separate the implementation of
BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan
Key: FLINK-20608
URL: https://issues.apache.org/jira/browse/FLINK-20608
godfrey he created FLINK-20516:
--
Summary: Separate the implementation of BatchExecTableSourceScan
and StreamExecTableSourceScan
Key: FLINK-20516
URL: https://issues.apache.org/jira/browse/FLINK-20516
godfrey he created FLINK-20515:
--
Summary: Separate the implementation of BatchExecMultipleInput and
StreamExecMultipleInput
Key: FLINK-20515
URL: https://issues.apache.org/jira/browse/FLINK-20515
godfrey he created FLINK-20513:
--
Summary: Separate the implementation of BatchExecExchange and
StreamExecExchange
Key: FLINK-20513
URL: https://issues.apache.org/jira/browse/FLINK-20513
Project: Flink
godfrey he created FLINK-20512:
--
Summary: Introduce getDescription, getOutputType, replaceInputEdge
methods for ExecNode
Key: FLINK-20512
URL: https://issues.apache.org/jira/browse/FLINK-20512
Project:
godfrey he created FLINK-20511:
--
Summary: Deprecate the classes in scala `nodes.exec` package
Key: FLINK-20511
URL: https://issues.apache.org/jira/browse/FLINK-20511
Project: Flink
Issue Type:
godfrey he created FLINK-20509:
--
Summary: Refactor verifyPlan method in TableTestBase
Key: FLINK-20509
URL: https://issues.apache.org/jira/browse/FLINK-20509
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20490:
--
Summary: Don't share inputs between FlinkPhysicalRel and ExecNode
Key: FLINK-20490
URL: https://issues.apache.org/jira/browse/FLINK-20490
Project: Flink
Issue
godfrey he created FLINK-20478:
--
Summary: Show "Optimized Execution Plan" instead of "Physical
Execution Plan" in explain result
Key: FLINK-20478
URL: https://issues.apache.org/jira/browse/FLINK-20478
godfrey he created FLINK-20437:
--
Summary: Port ExecNode to Java
Key: FLINK-20437
URL: https://issues.apache.org/jira/browse/FLINK-20437
Project: Flink
Issue Type: Sub-task
Reporter:
godfrey he created FLINK-20436:
--
Summary: Simplify type parameter of ExecNod
Key: FLINK-20436
URL: https://issues.apache.org/jira/browse/FLINK-20436
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-20435:
--
Summary: Refactor ExecNode
Key: FLINK-20435
URL: https://issues.apache.org/jira/browse/FLINK-20435
Project: Flink
Issue Type: Improvement
Reporter:
godfrey he created FLINK-20322:
--
Summary: Rename table.optimizer.union-all-as-breakpoint-disabled
to table.optimizer.union-all-as-breakpoint.enabled
Key: FLINK-20322
URL:
godfrey he created FLINK-20293:
--
Summary: Remove the useless constructor of
ContinuousFileMonitoringFunction
Key: FLINK-20293
URL: https://issues.apache.org/jira/browse/FLINK-20293
Project: Flink
godfrey he created FLINK-20255:
--
Summary: Nested decorrelate failed
Key: FLINK-20255
URL: https://issues.apache.org/jira/browse/FLINK-20255
Project: Flink
Issue Type: Bug
Components:
godfrey he created FLINK-20070:
--
Summary: NPE in
SourceCoordinatorProviderTest.testCheckpointAndReset
Key: FLINK-20070
URL: https://issues.apache.org/jira/browse/FLINK-20070
Project: Flink
godfrey he created FLINK-19925:
--
Summary: Errors$NativeIoException: readAddress(..) failed:
Connection reset by peer
Key: FLINK-19925
URL: https://issues.apache.org/jira/browse/FLINK-19925
Project:
godfrey he created FLINK-19822:
--
Summary: remove redundant shuffle for stream
Key: FLINK-19822
URL: https://issues.apache.org/jira/browse/FLINK-19822
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-19737:
--
Summary: Introduce TableOperatorWrapperGenerator to translate
transformation DAG in a multiple-input node to TableOperatorWrapper DAG
Key: FLINK-19737
URL:
godfrey he created FLINK-18853:
--
Summary: Supports properties from flink-conf.yaml for SET command
in sql client
Key: FLINK-18853
URL: https://issues.apache.org/jira/browse/FLINK-18853
Project: Flink
godfrey he created FLINK-18791:
--
Summary: Simplify the logic of SqlCommandParser and CliClient
Key: FLINK-18791
URL: https://issues.apache.org/jira/browse/FLINK-18791
Project: Flink
Issue Type:
godfrey he created FLINK-18789:
--
Summary: Use TableEnvironment#executeSql to execute insert
statement in sql client
Key: FLINK-18789
URL: https://issues.apache.org/jira/browse/FLINK-18789
Project: Flink
godfrey he created FLINK-18788:
--
Summary: Refactor sql-client based the proposed interfaces of
FLIP-84
Key: FLINK-18788
URL: https://issues.apache.org/jira/browse/FLINK-18788
Project: Flink
godfrey he created FLINK-18731:
--
Summary: The monotonicity of UNIX_TIMESTAMP function is not correct
Key: FLINK-18731
URL: https://issues.apache.org/jira/browse/FLINK-18731
Project: Flink
Issue
godfrey he created FLINK-18717:
--
Summary: reuse MiniCluster in table integration test class ?
Key: FLINK-18717
URL: https://issues.apache.org/jira/browse/FLINK-18717
Project: Flink
Issue Type:
godfrey he created FLINK-18651:
--
Summary: implicitly cast the time attribute to regular TIMESTAMP
type in regular join
Key: FLINK-18651
URL: https://issues.apache.org/jira/browse/FLINK-18651
Project:
godfrey he created FLINK-18621:
--
Summary: Simplify the methods of Executor interface in sql client
Key: FLINK-18621
URL: https://issues.apache.org/jira/browse/FLINK-18621
Project: Flink
Issue
godfrey he created FLINK-18550:
--
Summary: use TableResult#collect to get select result for sql
client
Key: FLINK-18550
URL: https://issues.apache.org/jira/browse/FLINK-18550
Project: Flink
godfrey he created FLINK-18399:
--
Summary: TableResult#print can not print the result of unbounded
stream query
Key: FLINK-18399
URL: https://issues.apache.org/jira/browse/FLINK-18399
Project: Flink
godfrey he created FLINK-18337:
--
Summary: Introduce TableResult#await method to wait data ready
Key: FLINK-18337
URL: https://issues.apache.org/jira/browse/FLINK-18337
Project: Flink
Issue
godfrey he created FLINK-18180:
--
Summary: unify the logic of time attribute derivation for both
batch and streaming
Key: FLINK-18180
URL: https://issues.apache.org/jira/browse/FLINK-18180
Project: Flink
godfrey he created FLINK-18061:
--
Summary: TableResult#collect should return closeable iterator to
avoid resource leak
Key: FLINK-18061
URL: https://issues.apache.org/jira/browse/FLINK-18061
Project:
godfrey he created FLINK-18059:
--
Summary: Can not execute create/drop catalog statement in sql
client
Key: FLINK-18059
URL: https://issues.apache.org/jira/browse/FLINK-18059
Project: Flink
godfrey he created FLINK-18055:
--
Summary: Catalog does not exist in SQL Client
Key: FLINK-18055
URL: https://issues.apache.org/jira/browse/FLINK-18055
Project: Flink
Issue Type: Bug
godfrey he created FLINK-17996:
--
Summary: NEP in
CatalogTableStatisticsConverter.convertToColumnStats method
Key: FLINK-17996
URL: https://issues.apache.org/jira/browse/FLINK-17996
Project: Flink
godfrey he created FLINK-17774:
--
Summary: Support all kinds of changes for select result
Key: FLINK-17774
URL: https://issues.apache.org/jira/browse/FLINK-17774
Project: Flink
Issue Type:
godfrey he created FLINK-17753:
--
Summary: watermark defined in ddl does not work in Table api
Key: FLINK-17753
URL: https://issues.apache.org/jira/browse/FLINK-17753
Project: Flink
Issue Type:
godfrey he created FLINK-17751:
--
Summary: proctime defined in ddl can't work with over window in
Table api
Key: FLINK-17751
URL: https://issues.apache.org/jira/browse/FLINK-17751
Project: Flink
godfrey he created FLINK-17728:
--
Summary: use sql parser to parse a statement in sql client
Key: FLINK-17728
URL: https://issues.apache.org/jira/browse/FLINK-17728
Project: Flink
Issue Type:
godfrey he created FLINK-17405:
--
Summary: add test cases for cancel job in SQL client
Key: FLINK-17405
URL: https://issues.apache.org/jira/browse/FLINK-17405
Project: Flink
Issue Type:
godfrey he created FLINK-17399:
--
Summary: CsvTableSink should also extend from OverwritableTableSink
Key: FLINK-17399
URL: https://issues.apache.org/jira/browse/FLINK-17399
Project: Flink
Issue
godfrey he created FLINK-17383:
--
Summary: flink legacy planner should not use CollectionEnvironment
any more
Key: FLINK-17383
URL: https://issues.apache.org/jira/browse/FLINK-17383
Project: Flink
godfrey he created FLINK-17267:
--
Summary: supports EXPLAIN statement in TableEnvironment#executeSql
and Table#explain api
Key: FLINK-17267
URL: https://issues.apache.org/jira/browse/FLINK-17267
Project:
godfrey he created FLINK-17252:
--
Summary: TableEnvironment#executeSql supports SELECT statement and
Table introduces execute method
Key: FLINK-17252
URL: https://issues.apache.org/jira/browse/FLINK-17252
godfrey he created FLINK-17251:
--
Summary: TableEnvironment#executeSql supports INSERT statement
Key: FLINK-17251
URL: https://issues.apache.org/jira/browse/FLINK-17251
Project: Flink
Issue
godfrey he created FLINK-17126:
--
Summary: Correct the execution behavior of BatchTableEnvironment
Key: FLINK-17126
URL: https://issues.apache.org/jira/browse/FLINK-17126
Project: Flink
Issue
godfrey he created FLINK-17052:
--
Summary: Introduce PlanGenerator
Key: FLINK-17052
URL: https://issues.apache.org/jira/browse/FLINK-17052
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-16881:
--
Summary: use Catalog's total size info in planner
Key: FLINK-16881
URL: https://issues.apache.org/jira/browse/FLINK-16881
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-16822:
--
Summary: The config set by SET command does not work
Key: FLINK-16822
URL: https://issues.apache.org/jira/browse/FLINK-16822
Project: Flink
Issue Type: Bug
godfrey he created FLINK-16535:
--
Summary: BatchTableSink#emitDataSet returns DataSink
Key: FLINK-16535
URL: https://issues.apache.org/jira/browse/FLINK-16535
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-16533:
--
Summary: ExecutionEnvironment supports executing plan
Key: FLINK-16533
URL: https://issues.apache.org/jira/browse/FLINK-16533
Project: Flink
Issue Type:
godfrey he created FLINK-16519:
--
Summary: CheckpointCoordinatorFailureTest logs LinkageErrors
Key: FLINK-16519
URL: https://issues.apache.org/jira/browse/FLINK-16519
Project: Flink
Issue Type:
godfrey he created FLINK-16367:
--
Summary: Introduce createDmlBatch method in TableEnvironment
Key: FLINK-16367
URL: https://issues.apache.org/jira/browse/FLINK-16367
Project: Flink
Issue Type:
godfrey he created FLINK-16366:
--
Summary: Introduce executeStatement method in TableEnvironment
Key: FLINK-16366
URL: https://issues.apache.org/jira/browse/FLINK-16366
Project: Flink
Issue
godfrey he created FLINK-16364:
--
Summary: Deprecate the methods in TableEnvironment proposed by
FLIP-84
Key: FLINK-16364
URL: https://issues.apache.org/jira/browse/FLINK-16364
Project: Flink
godfrey he created FLINK-16363:
--
Summary: Correct the execution behavior of TableEnvironment and
StreamTableEnvironment
Key: FLINK-16363
URL: https://issues.apache.org/jira/browse/FLINK-16363
Project:
godfrey he created FLINK-16362:
--
Summary: remove deprecated method in StreamTableSink
Key: FLINK-16362
URL: https://issues.apache.org/jira/browse/FLINK-16362
Project: Flink
Issue Type:
godfrey he created FLINK-16361:
--
Summary: FLIP-84: Improve & Refactor API of TableEnvironment
Key: FLINK-16361
URL: https://issues.apache.org/jira/browse/FLINK-16361
Project: Flink
Issue Type:
godfrey he created FLINK-16322:
--
Summary: wrong result after filter push down in parquet table
source
Key: FLINK-16322
URL: https://issues.apache.org/jira/browse/FLINK-16322
Project: Flink
godfrey he created FLINK-16315:
--
Summary: throw JsonMappingException when using
BatchTableEnvironment#explain to get the plan of sql with constant string
Key: FLINK-16315
URL:
godfrey he created FLINK-16195:
--
Summary: append constant field to unique key set on project when
deriving unique keys in FlinkRelMdUniqueKeys
Key: FLINK-16195
URL: https://issues.apache.org/jira/browse/FLINK-16195
godfrey he created FLINK-16110:
--
Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*"
and TIMESTAMP(3) *PROCTIME*
Key: FLINK-16110
URL: https://issues.apache.org/jira/browse/FLINK-16110
godfrey he created FLINK-15669:
--
Summary: SQL client can't cancel flink job
Key: FLINK-15669
URL: https://issues.apache.org/jira/browse/FLINK-15669
Project: Flink
Issue Type: Bug
godfrey he created FLINK-15472:
--
Summary: Support SQL Client Gateway
Key: FLINK-15472
URL: https://issues.apache.org/jira/browse/FLINK-15472
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-15123:
--
Summary: remove uniqueKeys from FlinkStatistic in blink planner
Key: FLINK-15123
URL: https://issues.apache.org/jira/browse/FLINK-15123
Project: Flink
Issue
godfrey he created FLINK-15095:
--
Summary: bridge table schema's primary key to metadata handler in
blink planner
Key: FLINK-15095
URL: https://issues.apache.org/jira/browse/FLINK-15095
Project: Flink
godfrey he created FLINK-15004:
--
Summary: Choose SortMergeJoin instead of HashJoin if the
statistics is unknown
Key: FLINK-15004
URL: https://issues.apache.org/jira/browse/FLINK-15004
Project: Flink
godfrey he created FLINK-15001:
--
Summary: The digest of sub-plan reuse should contain RelNode's
trait
Key: FLINK-15001
URL: https://issues.apache.org/jira/browse/FLINK-15001
Project: Flink
godfrey he created FLINK-14999:
--
Summary: sub-plan reuse should consider
Key: FLINK-14999
URL: https://issues.apache.org/jira/browse/FLINK-14999
Project: Flink
Issue Type: Bug
godfrey he created FLINK-14899:
--
Summary: can not be translated to StreamExecDeduplicate when
PROCTIME is defined in query
Key: FLINK-14899
URL: https://issues.apache.org/jira/browse/FLINK-14899
godfrey he created FLINK-14874:
--
Summary: add local aggregate to solve data skew for ROLLUP/CUBE
case
Key: FLINK-14874
URL: https://issues.apache.org/jira/browse/FLINK-14874
Project: Flink
godfrey he created FLINK-14789:
--
Summary: extends max/min type in ColumnStats from Number to
Comparable
Key: FLINK-14789
URL: https://issues.apache.org/jira/browse/FLINK-14789
Project: Flink
godfrey he created FLINK-14724:
--
Summary: Join condition could be simplified in logical phase
Key: FLINK-14724
URL: https://issues.apache.org/jira/browse/FLINK-14724
Project: Flink
Issue Type:
godfrey he created FLINK-14656:
--
Summary: blink planner should convert catalog statistics to
TableStats for permanent table instead of temporary table
Key: FLINK-14656
URL:
godfrey he created FLINK-13708:
--
Summary: transformations should be cleared because a table
environment could execute multiple job
Key: FLINK-13708
URL: https://issues.apache.org/jira/browse/FLINK-13708
godfrey he created FLINK-13611:
--
Summary: Introduce analyze statistic utility to generate table &
column statistics
Key: FLINK-13611
URL: https://issues.apache.org/jira/browse/FLINK-13611
Project: Flink
godfrey he created FLINK-13563:
--
Summary: TumblingGroupWindow should implement toString method
Key: FLINK-13563
URL: https://issues.apache.org/jira/browse/FLINK-13563
Project: Flink
Issue Type:
godfrey he created FLINK-13562:
--
Summary: throws exception when FlinkRelMdColumnInterval meets two
stage stream group aggregate
Key: FLINK-13562
URL: https://issues.apache.org/jira/browse/FLINK-13562
godfrey he created FLINK-13545:
--
Summary: JoinToMultiJoinRule should not match SEMI/ANTI LogicalJoin
Key: FLINK-13545
URL: https://issues.apache.org/jira/browse/FLINK-13545
Project: Flink
Issue
godfrey he created FLINK-13502:
--
Summary: CatalogTableStatisticsConverter should be in
planner.utils package
Key: FLINK-13502
URL: https://issues.apache.org/jira/browse/FLINK-13502
Project: Flink
godfrey he created FLINK-13404:
--
Summary: Port csv factories & validator from flink-table-planner
to flink-csv
Key: FLINK-13404
URL: https://issues.apache.org/jira/browse/FLINK-13404
Project: Flink
godfrey he created FLINK-13403:
--
Summary: Correct package name after relocation
Key: FLINK-13403
URL: https://issues.apache.org/jira/browse/FLINK-13403
Project: Flink
Issue Type: Bug
godfrey he created FLINK-13347:
--
Summary: should handle new JoinRelType(SEMI/ANTI) in switch case
Key: FLINK-13347
URL: https://issues.apache.org/jira/browse/FLINK-13347
Project: Flink
Issue
godfrey he created FLINK-13269:
--
Summary: copy RelDecorrelator from blink planner to flink planner
to fix CALCITE-3169 & CALCITE-3170
Key: FLINK-13269
URL: https://issues.apache.org/jira/browse/FLINK-13269
godfrey he created FLINK-13268:
--
Summary: revert SqlSplittableAggFunction to make two planners
available in one jar
Key: FLINK-13268
URL: https://issues.apache.org/jira/browse/FLINK-13268
Project: Flink
godfrey he created FLINK-13263:
--
Summary: supports explain DAG plan in flink-python
Key: FLINK-13263
URL: https://issues.apache.org/jira/browse/FLINK-13263
Project: Flink
Issue Type: New
godfrey he created FLINK-13185:
--
Summary: Bump Calcite dependency to 1.20.0 in sql parser & flink
planner
Key: FLINK-13185
URL: https://issues.apache.org/jira/browse/FLINK-13185
Project: Flink
godfrey he created FLINK-13168:
--
Summary: clarify isBatch/isStreaming/isBounded flag in flink
planner and blink planner
Key: FLINK-13168
URL: https://issues.apache.org/jira/browse/FLINK-13168
Project:
godfrey he created FLINK-13116:
--
Summary: supports catalog statistic in blink planner
Key: FLINK-13116
URL: https://issues.apache.org/jira/browse/FLINK-13116
Project: Flink
Issue Type: New
godfrey he created FLINK-13115:
--
Summary: Introduce planner rule to support partition pruning for
PartitionableTableSource
Key: FLINK-13115
URL: https://issues.apache.org/jira/browse/FLINK-13115
101 - 200 of 276 matches
Mail list logo
