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
Issu
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-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-15123:
--
Summary: remove uniqueKeys from FlinkStatistic in blink planner
Key: FLINK-15123
URL: https://issues.apache.org/jira/browse/FLINK-15123
Project: Flink
Issue Typ
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
Com
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
Compo
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
Projec
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-16315:
--
Summary: throw JsonMappingException when using
BatchTableEnvironment#explain to get the plan of sql with constant string
Key: FLINK-16315
URL: https://issues.apache.org/jira/browse/
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
Issu
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: I
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: Improveme
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: Fl
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
Is
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 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-16519:
--
Summary: CheckpointCoordinatorFailureTest logs LinkageErrors
Key: FLINK-16519
URL: https://issues.apache.org/jira/browse/FLINK-16519
Project: Flink
Issue Type: B
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: Sub-task
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-26756:
--
Summary: Failed to deserialize for match recognize
Key: FLINK-26756
URL: https://issues.apache.org/jira/browse/FLINK-26756
Project: Flink
Issue Type: Bug
godfrey he created FLINK-27272:
--
Summary: The plan for query with local sort is incorrect if
adaptive batch scheduler is enabled
Key: FLINK-27272
URL: https://issues.apache.org/jira/browse/FLINK-27272
Pr
godfrey he created FLINK-27583:
--
Summary: Improve the plan for TPC-DS queries
Key: FLINK-27583
URL: https://issues.apache.org/jira/browse/FLINK-27583
Project: Flink
Issue Type: New Feature
godfrey he created FLINK-27591:
--
Summary: Improve the plan for batch queries when statistics is
unavailable
Key: FLINK-27591
URL: https://issues.apache.org/jira/browse/FLINK-27591
Project: Flink
godfrey he created FLINK-27815:
--
Summary: Improve the join reorder strategy for batch sql job
Key: FLINK-27815
URL: https://issues.apache.org/jira/browse/FLINK-27815
Project: Flink
Issue Type:
godfrey he created FLINK-27817:
--
Summary: TaskManager metaspace OOM for session cluster
Key: FLINK-27817
URL: https://issues.apache.org/jira/browse/FLINK-27817
Project: Flink
Issue Type: New Fea
godfrey he created FLINK-27982:
--
Summary: FLIP-231: Introduce SupportsStatisticReport to support
reporting statistics from source connectors
Key: FLINK-27982
URL: https://issues.apache.org/jira/browse/FLINK-27982
godfrey he created FLINK-27983:
--
Summary: Introduce SupportsStatisticsReport interface
Key: FLINK-27983
URL: https://issues.apache.org/jira/browse/FLINK-27983
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-27984:
--
Summary: Introduce FileBasedStatisticsReportableDecodingFormat
interface
Key: FLINK-27984
URL: https://issues.apache.org/jira/browse/FLINK-27984
Project: Flink
godfrey he created FLINK-27985:
--
Summary: Introduce FlinkRecomputeStatisticsProgram to compute
statistics after filter push and partition pruning
Key: FLINK-27985
URL: https://issues.apache.org/jira/browse/FLINK-2798
godfrey he created FLINK-27987:
--
Summary: Let FileSystemTableSource extend from
SupportsStatisticReport
Key: FLINK-27987
URL: https://issues.apache.org/jira/browse/FLINK-27987
Project: Flink
Is
godfrey he created FLINK-27988:
--
Summary: Let HiveTableSource extend from SupportsStatisticReport
Key: FLINK-27988
URL: https://issues.apache.org/jira/browse/FLINK-27988
Project: Flink
Issue Typ
godfrey he created FLINK-27989:
--
Summary: CSV format supports reporting statistics
Key: FLINK-27989
URL: https://issues.apache.org/jira/browse/FLINK-27989
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-27991:
--
Summary: ORC format supports reporting statistics
Key: FLINK-27991
URL: https://issues.apache.org/jira/browse/FLINK-27991
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-27990:
--
Summary: Parquet format supports reporting statistics
Key: FLINK-27990
URL: https://issues.apache.org/jira/browse/FLINK-27990
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-28074:
--
Summary: display
Key: FLINK-28074
URL: https://issues.apache.org/jira/browse/FLINK-28074
Project: Flink
Issue Type: New Feature
Reporter: godfrey he
godfrey he created FLINK-28075:
--
Summary: get statistics for partitioned table even without
partition pruning
Key: FLINK-28075
URL: https://issues.apache.org/jira/browse/FLINK-28075
Project: Flink
godfrey he created FLINK-24813:
--
Summary: Improve ImplicitTypeConversionITCase
Key: FLINK-24813
URL: https://issues.apache.org/jira/browse/FLINK-24813
Project: Flink
Issue Type: Improvement
godfrey he created FLINK-25474:
--
Summary: Idea Scala plugin can not compile RexExplainUtil
Key: FLINK-25474
URL: https://issues.apache.org/jira/browse/FLINK-25474
Project: Flink
Issue Type: Imp
godfrey he created FLINK-26167:
--
Summary: Explicitly set the partitioner for the sql operators
whose shuffle and sort are removed
Key: FLINK-26167
URL: https://issues.apache.org/jira/browse/FLINK-26167
P
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
Issu
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 Ty
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: Fli
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-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-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
Iss
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-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-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-19737:
--
Summary: Introduce TableOperatorWrapperGenerator to translate
transformation DAG in a multiple-input node to TableOperatorWrapper DAG
Key: FLINK-19737
URL: https://issues.apache.org/
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-19925:
--
Summary: Errors$NativeIoException: readAddress(..) failed:
Connection reset by peer
Key: FLINK-19925
URL: https://issues.apache.org/jira/browse/FLINK-19925
Project: Flink
godfrey he created FLINK-20070:
--
Summary: NPE in
SourceCoordinatorProviderTest.testCheckpointAndReset
Key: FLINK-20070
URL: https://issues.apache.org/jira/browse/FLINK-20070
Project: Flink
Issu
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-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-17052:
--
Summary: Introduce PlanGenerator
Key: FLINK-17052
URL: https://issues.apache.org/jira/browse/FLINK-17052
Project: Flink
Issue Type: Sub-task
Components
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 Typ
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 Type:
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-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-17303:
--
Summary: Return TableResult for Python TableEnvironment
Key: FLINK-17303
URL: https://issues.apache.org/jira/browse/FLINK-17303
Project: Flink
Issue Type: Improv
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-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-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: Improveme
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: Imp
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-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: B
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: Sub-ta
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-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
Co
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
Issu
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: Flin
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-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 Type:
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-22781:
--
Summary: Incorrect result for group window aggregate when
mini-batch is enabled
Key: FLINK-22781
URL: https://issues.apache.org/jira/browse/FLINK-22781
Project: Flink
godfrey he created FLINK-23094:
--
Summary: encounter thread-safe problem when using
StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads
environment
Key: FLINK-23094
URL: https://issues.apache.
godfrey he created FLINK-23217:
--
Summary: Support StreamExecValues json
serialization/deserialization
Key: FLINK-23217
URL: https://issues.apache.org/jira/browse/FLINK-23217
Project: Flink
Issu
godfrey he created FLINK-23434:
--
Summary: Inconsistent rowtypes occur in IncrementalAggregateRule
Key: FLINK-23434
URL: https://issues.apache.org/jira/browse/FLINK-23434
Project: Flink
Issue Typ
godfrey he created FLINK-23435:
--
Summary: Improve the exception message when a query has lateral
table join without 'AS' which return type is simple type
Key: FLINK-23435
URL: https://issues.apache.org/jira/browse/FL
godfrey he created FLINK-23483:
--
Summary: Add document to describe how to submit job to different
executor for sql client
Key: FLINK-23483
URL: https://issues.apache.org/jira/browse/FLINK-23483
Project:
godfrey he created FLINK-24676:
--
Summary: Schema does not match if explain insert statement with
partial column
Key: FLINK-24676
URL: https://issues.apache.org/jira/browse/FLINK-24676
Project: Flink
godfrey he created FLINK-28489:
--
Summary: FLIP-240: Introduce "ANALYZE TABLE" Syntax
Key: FLINK-28489
URL: https://issues.apache.org/jira/browse/FLINK-28489
Project: Flink
Issue Type: New Featur
godfrey he created FLINK-28490:
--
Summary: Introduce "ANALYZE TABLE" Syntax in sql parser
Key: FLINK-28490
URL: https://issues.apache.org/jira/browse/FLINK-28490
Project: Flink
Issue Type: Sub-ta
godfrey he created FLINK-28491:
--
Summary: Introduce APPROX_COUNT_DISTINCT aggregate function for
batch sql
Key: FLINK-28491
URL: https://issues.apache.org/jira/browse/FLINK-28491
Project: Flink
godfrey he created FLINK-28492:
--
Summary: Support "ANALYZE TABLE" execution
Key: FLINK-28492
URL: https://issues.apache.org/jira/browse/FLINK-28492
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-28493:
--
Summary: Add document to describe "ANALYZE TABLE" syntax
Key: FLINK-28493
URL: https://issues.apache.org/jira/browse/FLINK-28493
Project: Flink
Issue Type: Sub-t
godfrey he created FLINK-28706:
--
Summary: FLIP-248: Introduce dynamic partition pruning
Key: FLINK-28706
URL: https://issues.apache.org/jira/browse/FLINK-28706
Project: Flink
Issue Type: New Fea
godfrey he created FLINK-28707:
--
Summary: Introduce interface SupportsDynamicPartitionPruning
Key: FLINK-28707
URL: https://issues.apache.org/jira/browse/FLINK-28707
Project: Flink
Issue Type: S
godfrey he created FLINK-28708:
--
Summary: Introduce planner rules to optimize dpp pattern
Key: FLINK-28708
URL: https://issues.apache.org/jira/browse/FLINK-28708
Project: Flink
Issue Type: Sub-t
godfrey he created FLINK-28709:
--
Summary: Implement dynamic filtering operators
Key: FLINK-28709
URL: https://issues.apache.org/jira/browse/FLINK-28709
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-28710:
--
Summary: Transform dpp ExecNode to StreamGraph
Key: FLINK-28710
URL: https://issues.apache.org/jira/browse/FLINK-28710
Project: Flink
Issue Type: Sub-task
godfrey he created FLINK-28711:
--
Summary: Hive connector implements SupportsDynamicFiltering
interface
Key: FLINK-28711
URL: https://issues.apache.org/jira/browse/FLINK-28711
Project: Flink
Iss
godfrey he created FLINK-28726:
--
Summary: CompileException: BoundedOverAggregateHelper must
implement method AggsHandeFunction.setWindowSize(int)
Key: FLINK-28726
URL: https://issues.apache.org/jira/browse/FLINK-2872
godfrey he created FLINK-28753:
--
Summary: Improve FilterIntoJoinRule which could push some
predicate to another side
Key: FLINK-28753
URL: https://issues.apache.org/jira/browse/FLINK-28753
Project: Flink
godfrey he created FLINK-28787:
--
Summary: rename getUniqueKeys to getUpsertKeys in
CommonPhysicalJoin
Key: FLINK-28787
URL: https://issues.apache.org/jira/browse/FLINK-28787
Project: Flink
Issu
godfrey he created FLINK-28821:
--
Summary: Adjust join cost for dpp query pattern which could help
more plans use dpp
Key: FLINK-28821
URL: https://issues.apache.org/jira/browse/FLINK-28821
Project: Flink
godfrey he created FLINK-28858:
--
Summary: Add document to describe join hints for batch sql
Key: FLINK-28858
URL: https://issues.apache.org/jira/browse/FLINK-28858
Project: Flink
Issue Type: Sub
godfrey he created FLINK-28859:
--
Summary: FAILED
pyflink/datastream/connectors/tests/test_file_system.py::FileSinkCsvBulkWriterTests::test_csv_customize_quote_char_write
Key: FLINK-28859
URL: https://issues.apache.or
godfrey he created FLINK-28866:
--
Summary: Use DDL instead of legacy method to register the test
source in JoinITCase
Key: FLINK-28866
URL: https://issues.apache.org/jira/browse/FLINK-28866
Project: Flink
godfrey he created FLINK-28940:
--
Summary: Release Testing: Verify FLIP-248 Dynamic Partition
Prunning
Key: FLINK-28940
URL: https://issues.apache.org/jira/browse/FLINK-28940
Project: Flink
Issu
101 - 200 of 280 matches
Mail list logo
