Jingsong Lee created FLINK-13049:
Summary: Port planner expressions to blink-planner from
flink-planner
Key: FLINK-13049
URL: https://issues.apache.org/jira/browse/FLINK-13049
Project: Flink
Jingsong Lee created FLINK-13070:
Summary: Remove TableImpl and use api.internal.TableImpl in blink
Key: FLINK-13070
URL: https://issues.apache.org/jira/browse/FLINK-13070
Project: Flink
Issu
Jingsong Lee created FLINK-13089:
Summary: Implement batch nested loop join in blink
Key: FLINK-13089
URL: https://issues.apache.org/jira/browse/FLINK-13089
Project: Flink
Issue Type: New Fea
Jingsong Lee created FLINK-13112:
Summary: Support LocalZonedTimestampType in blink
Key: FLINK-13112
URL: https://issues.apache.org/jira/browse/FLINK-13112
Project: Flink
Issue Type: New Feat
Jingsong Lee created FLINK-13113:
Summary: Introduce range partition in blink
Key: FLINK-13113
URL: https://issues.apache.org/jira/browse/FLINK-13113
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-13118:
Summary: Introduce JDBC table factory
Key: FLINK-13118
URL: https://issues.apache.org/jira/browse/FLINK-13118
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-13210:
Summary: Hive connector test should dependent on blink planner
instead of legacy planner
Key: FLINK-13210
URL: https://issues.apache.org/jira/browse/FLINK-13210
Proje
Jingsong Lee created FLINK-13225:
Summary: Introduce type inference for hive functions in blink
Key: FLINK-13225
URL: https://issues.apache.org/jira/browse/FLINK-13225
Project: Flink
Issue T
Jingsong Lee created FLINK-13229:
Summary: ExpressionReducer with udf bug in blink
Key: FLINK-13229
URL: https://issues.apache.org/jira/browse/FLINK-13229
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-13237:
Summary: Add expression table api test to blink
Key: FLINK-13237
URL: https://issues.apache.org/jira/browse/FLINK-13237
Project: Flink
Issue Type: New Featur
Jingsong Lee created FLINK-13253:
Summary: Deadlock may occur in JDBCUpsertOutputFormat
Key: FLINK-13253
URL: https://issues.apache.org/jira/browse/FLINK-13253
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-13257:
Summary: blink runner should avoid stream operator implementing
BoundedOneInput
Key: FLINK-13257
URL: https://issues.apache.org/jira/browse/FLINK-13257
Project: Flink
Jingsong Lee created FLINK-13285:
Summary: Connectors need to get rid of flink-table-planner
dependence
Key: FLINK-13285
URL: https://issues.apache.org/jira/browse/FLINK-13285
Project: Flink
Jingsong Lee created FLINK-13286:
Summary: Port SchemaValidator and others validators to table-common
Key: FLINK-13286
URL: https://issues.apache.org/jira/browse/FLINK-13286
Project: Flink
Is
Jingsong Lee created FLINK-13287:
Summary: Port ExistingField to api-java and use new Expression in
FieldComputer
Key: FLINK-13287
URL: https://issues.apache.org/jira/browse/FLINK-13287
Project: Flink
Jingsong Lee created FLINK-13315:
Summary: Port wmstrategies to api-java
Key: FLINK-13315
URL: https://issues.apache.org/jira/browse/FLINK-13315
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-13330:
Summary: Remove unnecessary to reduce testing time in blink
Key: FLINK-13330
URL: https://issues.apache.org/jira/browse/FLINK-13330
Project: Flink
Issue Type
Jingsong Lee created FLINK-13331:
Summary: Add TestMiniClusters to maintain cache share cluster
between Tests
Key: FLINK-13331
URL: https://issues.apache.org/jira/browse/FLINK-13331
Project: Flink
Jingsong Lee created FLINK-13349:
Summary: Flink sinks should implement consumeDataStream instead of
emitDataStream
Key: FLINK-13349
URL: https://issues.apache.org/jira/browse/FLINK-13349
Project: Fli
Jingsong Lee created FLINK-13376:
Summary: FileInputFormat can not be used in blink-planner
Key: FLINK-13376
URL: https://issues.apache.org/jira/browse/FLINK-13376
Project: Flink
Issue Type:
Jingsong Lee created FLINK-13391:
Summary: Blink-planner should not invoke deprecated getReturnType
Key: FLINK-13391
URL: https://issues.apache.org/jira/browse/FLINK-13391
Project: Flink
Issu
Jingsong Lee created FLINK-13393:
Summary: Blink-planner not support generic TableSource
Key: FLINK-13393
URL: https://issues.apache.org/jira/browse/FLINK-13393
Project: Flink
Issue Type: Sub
Jingsong Lee created FLINK-13402:
Summary: RelOptCluster's constructor can not be accessed when
connector dependent both flink-planner and blink-planner
Key: FLINK-13402
URL: https://issues.apache.org/jira/browse/
Jingsong Lee created FLINK-13427:
Summary: HiveCatalog's createFunction not work when function name
is upper
Key: FLINK-13427
URL: https://issues.apache.org/jira/browse/FLINK-13427
Project: Flink
Jingsong Lee created FLINK-13495:
Summary: blink-planner should support decimal precision to table
source
Key: FLINK-13495
URL: https://issues.apache.org/jira/browse/FLINK-13495
Project: Flink
Jingsong Lee created FLINK-13539:
Summary: DDL do not support CSV tableFactory because CSV require
format.fields
Key: FLINK-13539
URL: https://issues.apache.org/jira/browse/FLINK-13539
Project: Flink
Jingsong Lee created FLINK-13540:
Summary: DDL do not support key of properties contains number or
"-"
Key: FLINK-13540
URL: https://issues.apache.org/jira/browse/FLINK-13540
Project: Flink
Jingsong Lee created FLINK-13561:
Summary: Verify and correct builtin time function's semantic for
Blink planner
Key: FLINK-13561
URL: https://issues.apache.org/jira/browse/FLINK-13561
Project: Flink
Jingsong Lee created FLINK-13580:
Summary: Add overload support for user defined function to
blink-planner
Key: FLINK-13580
URL: https://issues.apache.org/jira/browse/FLINK-13580
Project: Flink
Jingsong Lee created FLINK-13584:
Summary: RankLikeAggFunctionBase should respect type to construct
literal
Key: FLINK-13584
URL: https://issues.apache.org/jira/browse/FLINK-13584
Project: Flink
Jingsong Lee created FLINK-13780:
Summary: Introduce ExpressionConverter to legacy planner
Key: FLINK-13780
URL: https://issues.apache.org/jira/browse/FLINK-13780
Project: Flink
Issue Type: S
Jingsong Lee created FLINK-13781:
Summary: Use new Expression in RexNodeToExpressionConverter
Key: FLINK-13781
URL: https://issues.apache.org/jira/browse/FLINK-13781
Project: Flink
Issue Type
Jingsong Lee created FLINK-13782:
Summary: Implement type inference for logic functions
Key: FLINK-13782
URL: https://issues.apache.org/jira/browse/FLINK-13782
Project: Flink
Issue Type: Sub-
Jingsong Lee created FLINK-13783:
Summary: Implement type inference for string functions
Key: FLINK-13783
URL: https://issues.apache.org/jira/browse/FLINK-13783
Project: Flink
Issue Type: Sub
Jingsong Lee created FLINK-13786:
Summary: Implement type inference for other functions
Key: FLINK-13786
URL: https://issues.apache.org/jira/browse/FLINK-13786
Project: Flink
Issue Type: Sub-
Jingsong Lee created FLINK-13785:
Summary: Implement type inference for time functions
Key: FLINK-13785
URL: https://issues.apache.org/jira/browse/FLINK-13785
Project: Flink
Issue Type: Sub-t
Jingsong Lee created FLINK-13784:
Summary: Implement type inference for math functions
Key: FLINK-13784
URL: https://issues.apache.org/jira/browse/FLINK-13784
Project: Flink
Issue Type: Sub-t
Jingsong Lee created FLINK-13902:
Summary: Can not use index to convert FieldReferenceExpression to
RexNode
Key: FLINK-13902
URL: https://issues.apache.org/jira/browse/FLINK-13902
Project: Flink
Jingsong Lee created FLINK-13952:
Summary: PartitionableTableSink can not work with
OverwritableTableSink
Key: FLINK-13952
URL: https://issues.apache.org/jira/browse/FLINK-13952
Project: Flink
Jingsong Lee created FLINK-14079:
Summary: Full data type support in planner
Key: FLINK-14079
URL: https://issues.apache.org/jira/browse/FLINK-14079
Project: Flink
Issue Type: New Feature
Jingsong Lee created FLINK-14081:
Summary: Support precision of TimeType
Key: FLINK-14081
URL: https://issues.apache.org/jira/browse/FLINK-14081
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14080:
Summary: Support precision of TimestampType
Key: FLINK-14080
URL: https://issues.apache.org/jira/browse/FLINK-14080
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14082:
Summary: Support precision of DayTimeIntervalType and
YearMonthIntervalType
Key: FLINK-14082
URL: https://issues.apache.org/jira/browse/FLINK-14082
Project: Flink
Jingsong Lee created FLINK-14083:
Summary: Support StructuredType
Key: FLINK-14083
URL: https://issues.apache.org/jira/browse/FLINK-14083
Project: Flink
Issue Type: Sub-task
Compone
Jingsong Lee created FLINK-14084:
Summary: Support ZonedTimestampType
Key: FLINK-14084
URL: https://issues.apache.org/jira/browse/FLINK-14084
Project: Flink
Issue Type: Sub-task
Com
Jingsong Lee created FLINK-15932:
Summary: Add download url to hive dependencies
Key: FLINK-15932
URL: https://issues.apache.org/jira/browse/FLINK-15932
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-15981:
Summary: Control the direct memory in
FileChannelBoundedData.FileBufferReader
Key: FLINK-15981
URL: https://issues.apache.org/jira/browse/FLINK-15981
Project: Flink
Jingsong Lee created FLINK-15990:
Summary: Remove register source and sink in ConnectTableDescriptor
Key: FLINK-15990
URL: https://issues.apache.org/jira/browse/FLINK-15990
Project: Flink
Iss
Jingsong Lee created FLINK-16026:
Summary: Travis failed due to python setup
Key: FLINK-16026
URL: https://issues.apache.org/jira/browse/FLINK-16026
Project: Flink
Issue Type: Bug
C
Jingsong Lee created FLINK-16032:
Summary: Depends on core classifier hive-exec in hive connector
Key: FLINK-16032
URL: https://issues.apache.org/jira/browse/FLINK-16032
Project: Flink
Issue
Jingsong Lee created FLINK-16161:
Summary: Statistics zero should be unknown in HiveCatalog
Key: FLINK-16161
URL: https://issues.apache.org/jira/browse/FLINK-16161
Project: Flink
Issue Type:
Jingsong Lee created FLINK-16165:
Summary: NestedLoopJoin fallback to HashJoin when build records
number is very large
Key: FLINK-16165
URL: https://issues.apache.org/jira/browse/FLINK-16165
Project:
Jingsong Lee created FLINK-16179:
Summary: Use configuration from TableFactory in hive connector
Key: FLINK-16179
URL: https://issues.apache.org/jira/browse/FLINK-16179
Project: Flink
Issue T
Jingsong Lee created FLINK-16270:
Summary: Use LogicalType to equals/hashcode in TableSchema
Key: FLINK-16270
URL: https://issues.apache.org/jira/browse/FLINK-16270
Project: Flink
Issue Type:
Jingsong Lee created FLINK-16295:
Summary: Optimize BinaryString.copy to not materialize if there is
javaObject
Key: FLINK-16295
URL: https://issues.apache.org/jira/browse/FLINK-16295
Project: Flink
Jingsong Lee created FLINK-16359:
Summary: Introduce WritableVectors for abstract writing
Key: FLINK-16359
URL: https://issues.apache.org/jira/browse/FLINK-16359
Project: Flink
Issue Type: Su
Jingsong Lee created FLINK-16368:
Summary: ZooKeeperHighAvailabilityITCase test fail
Key: FLINK-16368
URL: https://issues.apache.org/jira/browse/FLINK-16368
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-16413:
Summary: Reduce hive source parallelism when limit push down
Key: FLINK-16413
URL: https://issues.apache.org/jira/browse/FLINK-16413
Project: Flink
Issue Typ
Jingsong Lee created FLINK-16418:
Summary: Hide hive version to avoid user confuse
Key: FLINK-16418
URL: https://issues.apache.org/jira/browse/FLINK-16418
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-16434:
Summary: Add document to explain how to pack hive with their own
hive dependencies
Key: FLINK-16434
URL: https://issues.apache.org/jira/browse/FLINK-16434
Project: Fl
Jingsong Lee created FLINK-16450:
Summary: Integrate parquet columnar row reader to hive
Key: FLINK-16450
URL: https://issues.apache.org/jira/browse/FLINK-16450
Project: Flink
Issue Type: Sub
Jingsong Lee created FLINK-16455:
Summary: Introduce flink-sql-connector-hive modules to provide
hive uber jars
Key: FLINK-16455
URL: https://issues.apache.org/jira/browse/FLINK-16455
Project: Flink
Jingsong Lee created FLINK-16500:
Summary: Hive get primary key should not throw exception when
Invalid method name
Key: FLINK-16500
URL: https://issues.apache.org/jira/browse/FLINK-16500
Project: Fli
Jingsong Lee created FLINK-16581:
Summary: Minibatch deduplication lack state TTL
Key: FLINK-16581
URL: https://issues.apache.org/jira/browse/FLINK-16581
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-16632:
Summary: Cast string to timestamp fail
Key: FLINK-16632
URL: https://issues.apache.org/jira/browse/FLINK-16632
Project: Flink
Issue Type: Bug
Compo
Jingsong Lee created FLINK-16688:
Summary: Hive-connector should set SessionState for hive
Key: FLINK-16688
URL: https://issues.apache.org/jira/browse/FLINK-16688
Project: Flink
Issue Type: B
Jingsong Lee created FLINK-16711:
Summary: ParquetColumnarRowSplitReader read footer from wrong end
Key: FLINK-16711
URL: https://issues.apache.org/jira/browse/FLINK-16711
Project: Flink
Issu
Jingsong Lee created FLINK-16743:
Summary: Introduce datagen, print, blackhole connectors
Key: FLINK-16743
URL: https://issues.apache.org/jira/browse/FLINK-16743
Project: Flink
Issue Type: Ne
Jingsong Lee created FLINK-16787:
Summary: Provide an assigner strategy of average splits allocation
Key: FLINK-16787
URL: https://issues.apache.org/jira/browse/FLINK-16787
Project: Flink
Iss
Jingsong Lee created FLINK-16857:
Summary: Support partition prune for PartitionableTableSource with
getPartitions
Key: FLINK-16857
URL: https://issues.apache.org/jira/browse/FLINK-16857
Project: Flin
Jingsong Lee created FLINK-16858:
Summary: Expose partitioned by grammar
Key: FLINK-16858
URL: https://issues.apache.org/jira/browse/FLINK-16858
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-16859:
Summary: Introduce FileSystemTableFactory, FileSystemTableSource,
FileSystemTableSink
Key: FLINK-16859
URL: https://issues.apache.org/jira/browse/FLINK-16859
Project:
Jingsong Lee created FLINK-16877:
Summary: SingleDirectoryWriter should not produce file when no
input record
Key: FLINK-16877
URL: https://issues.apache.org/jira/browse/FLINK-16877
Project: Flink
Jingsong Lee created FLINK-16903:
Summary: Add sink.parallelism for file system factory
Key: FLINK-16903
URL: https://issues.apache.org/jira/browse/FLINK-16903
Project: Flink
Issue Type: Sub-
Jingsong Lee created FLINK-16904:
Summary: Migrate FileSystem descriptor to new table factory
Key: FLINK-16904
URL: https://issues.apache.org/jira/browse/FLINK-16904
Project: Flink
Issue Type
Jingsong Lee created FLINK-16912:
Summary: Introduce table row write support for parquet writer
Key: FLINK-16912
URL: https://issues.apache.org/jira/browse/FLINK-16912
Project: Flink
Issue Ty
Jingsong Lee created FLINK-16922:
Summary: Decimal.toUnscaledBytes should be consistent with
BigDecimla.unscaledValue.toByteArray
Key: FLINK-16922
URL: https://issues.apache.org/jira/browse/FLINK-16922
Jingsong Lee created FLINK-16937:
Summary: ParquetTableSource should generate correct
isFilterPushedDown
Key: FLINK-16937
URL: https://issues.apache.org/jira/browse/FLINK-16937
Project: Flink
Jingsong Lee created FLINK-16951:
Summary: Integrate parquet to file system connector
Key: FLINK-16951
URL: https://issues.apache.org/jira/browse/FLINK-16951
Project: Flink
Issue Type: Sub-ta
Jingsong Lee created FLINK-16952:
Summary: Parquet file system format support filter pushdown
Key: FLINK-16952
URL: https://issues.apache.org/jira/browse/FLINK-16952
Project: Flink
Issue Typ
Jingsong Lee created FLINK-17128:
Summary: Add isBounded to TableSinkFactory#Context
Key: FLINK-17128
URL: https://issues.apache.org/jira/browse/FLINK-17128
Project: Flink
Issue Type: Sub-tas
Jingsong Lee created FLINK-17145:
Summary: AggregateRemoveITCase.testAggregateRemove failed in travis
Key: FLINK-17145
URL: https://issues.apache.org/jira/browse/FLINK-17145
Project: Flink
Is
Jingsong Lee created FLINK-17286:
Summary: Integrate json to file system connector
Key: FLINK-17286
URL: https://issues.apache.org/jira/browse/FLINK-17286
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-17325:
Summary: Integrate orc to file system connector
Key: FLINK-17325
URL: https://issues.apache.org/jira/browse/FLINK-17325
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-17391:
Summary: sink.rolling-policy.time.interval default value should be
bigger
Key: FLINK-17391
URL: https://issues.apache.org/jira/browse/FLINK-17391
Project: Flink
Jingsong Lee created FLINK-17397:
Summary: Filesystem support lookup table source
Key: FLINK-17397
URL: https://issues.apache.org/jira/browse/FLINK-17397
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-17398:
Summary: Support flexible path reading
Key: FLINK-17398
URL: https://issues.apache.org/jira/browse/FLINK-17398
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14133:
Summary: Improve batch sql and hive integrate performance
Key: FLINK-14133
URL: https://issues.apache.org/jira/browse/FLINK-14133
Project: Flink
Issue Type:
Jingsong Lee created FLINK-14134:
Summary: Introduce LimitableTableSource to optimize limit
Key: FLINK-14134
URL: https://issues.apache.org/jira/browse/FLINK-14134
Project: Flink
Issue Type:
Jingsong Lee created FLINK-14135:
Summary: Introduce vectorized orc InputFormat for blink runtime
Key: FLINK-14135
URL: https://issues.apache.org/jira/browse/FLINK-14135
Project: Flink
Issue
Jingsong Lee created FLINK-14249:
Summary: Rework table partition support
Key: FLINK-14249
URL: https://issues.apache.org/jira/browse/FLINK-14249
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-14253:
Summary: Add hash distribution and sort grouping only when dynamic
partition insert
Key: FLINK-14253
URL: https://issues.apache.org/jira/browse/FLINK-14253
Project: F
Jingsong Lee created FLINK-14254:
Summary: Introduce FileSystemOutputFormat
Key: FLINK-14254
URL: https://issues.apache.org/jira/browse/FLINK-14254
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14255:
Summary: Introduce StreamingFileSystemSink
Key: FLINK-14255
URL: https://issues.apache.org/jira/browse/FLINK-14255
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14256:
Summary: Introduce FileSystemTableFactory
Key: FLINK-14256
URL: https://issues.apache.org/jira/browse/FLINK-14256
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14258:
Summary: Integrate hive to FileSystemTableFactory
Key: FLINK-14258
URL: https://issues.apache.org/jira/browse/FLINK-14258
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14257:
Summary: Integrate csv to FileSystemTableFactory
Key: FLINK-14257
URL: https://issues.apache.org/jira/browse/FLINK-14257
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-14265:
Summary: Don't use ContinuousFileReaderOperator to support
multiple paths
Key: FLINK-14265
URL: https://issues.apache.org/jira/browse/FLINK-14265
Project: Flink
Jingsong Lee created FLINK-14267:
Summary: Introduce RowCsvOutputFormat to new CSV module
Key: FLINK-14267
URL: https://issues.apache.org/jira/browse/FLINK-14267
Project: Flink
Issue Type: Su
Jingsong Lee created FLINK-14266:
Summary: Introduce RowCsvInputFormat to new CSV module
Key: FLINK-14266
URL: https://issues.apache.org/jira/browse/FLINK-14266
Project: Flink
Issue Type: Sub
1 - 100 of 655 matches
Mail list logo
