Rui Li created FLINK-34147:
--
Summary: TimestampData to/from LocalDateTime is ambiguous
Key: FLINK-34147
URL: https://issues.apache.org/jira/browse/FLINK-34147
Project: Flink
Issue Type: Bug
Rui Li created FLINK-23897:
--
Summary: Fix obsolete doc about creating hive table with flink
Key: FLINK-23897
URL: https://issues.apache.org/jira/browse/FLINK-23897
Project: Flink
Issue Type: Bug
Rui Li created FLINK-23752:
--
Summary: Add document for using HiveSource API
Key: FLINK-23752
URL: https://issues.apache.org/jira/browse/FLINK-23752
Project: Flink
Issue Type: Improvement
C
Rui Li created FLINK-23316:
--
Summary: There's no test for custom PartitionCommitPolicy
Key: FLINK-23316
URL: https://issues.apache.org/jira/browse/FLINK-23316
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-23224:
--
Summary: Support timestamp_ltz type in hive connector
Key: FLINK-23224
URL: https://issues.apache.org/jira/browse/FLINK-23224
Project: Flink
Issue Type: New Feature
Rui Li created FLINK-23178:
--
Summary: Raise an error for writing stream data into partitioned
hive/FS tables without a partition committer
Key: FLINK-23178
URL: https://issues.apache.org/jira/browse/FLINK-23178
Rui Li created FLINK-23168:
--
Summary: Catalog shouldn't merge properties for alter DB operation
Key: FLINK-23168
URL: https://issues.apache.org/jira/browse/FLINK-23168
Project: Flink
Issue Type: Imp
Rui Li created FLINK-23032:
--
Summary: Refactor HiveSource to make it usable in data stream job
Key: FLINK-23032
URL: https://issues.apache.org/jira/browse/FLINK-23032
Project: Flink
Issue Type: Impr
Rui Li created FLINK-23010:
--
Summary:
HivePartitionFetcherContextBase::getComparablePartitionValueList can return
partitions that don't exist
Key: FLINK-23010
URL: https://issues.apache.org/jira/browse/FLINK-23010
Rui Li created FLINK-22812:
--
Summary: Fix hive issues in sql-connector-hive jars
Key: FLINK-22812
URL: https://issues.apache.org/jira/browse/FLINK-22812
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-22760:
--
Summary: HiveParser::setCurrentTimestamp fails with hive-3.1.2
Key: FLINK-22760
URL: https://issues.apache.org/jira/browse/FLINK-22760
Project: Flink
Issue Type: Bug
Rui Li created FLINK-22726:
--
Summary: Hive GROUPING__ID returns different value in older
versions
Key: FLINK-22726
URL: https://issues.apache.org/jira/browse/FLINK-22726
Project: Flink
Issue Type:
Rui Li created FLINK-22661:
--
Summary: HiveInputFormatPartitionReader can return invalid data
Key: FLINK-22661
URL: https://issues.apache.org/jira/browse/FLINK-22661
Project: Flink
Issue Type: Bug
Rui Li created FLINK-22657:
--
Summary: HiveParserDDLSemanticAnalyzer can directly return
operations
Key: FLINK-22657
URL: https://issues.apache.org/jira/browse/FLINK-22657
Project: Flink
Issue Type:
Rui Li created FLINK-22606:
--
Summary: Simplify the usage of SessionState
Key: FLINK-22606
URL: https://issues.apache.org/jira/browse/FLINK-22606
Project: Flink
Issue Type: Sub-task
Compone
Rui Li created FLINK-22512:
--
Summary: Can't call current_timestamp with hive dialect for
hive-3.1
Key: FLINK-22512
URL: https://issues.apache.org/jira/browse/FLINK-22512
Project: Flink
Issue Type:
Rui Li created FLINK-22446:
--
Summary: Relocate dependencies in hive connector uber jar
Key: FLINK-22446
URL: https://issues.apache.org/jira/browse/FLINK-22446
Project: Flink
Issue Type: Task
Rui Li created FLINK-22402:
--
Summary: Add hive dialect test in sql-client
Key: FLINK-22402
URL: https://issues.apache.org/jira/browse/FLINK-22402
Project: Flink
Issue Type: Sub-task
Compon
Rui Li created FLINK-22383:
--
Summary: HiveParser may fail to call Flink functions
Key: FLINK-22383
URL: https://issues.apache.org/jira/browse/FLINK-22383
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-22341:
--
Summary: Describe table doesn't work with hive dialect
Key: FLINK-22341
URL: https://issues.apache.org/jira/browse/FLINK-22341
Project: Flink
Issue Type: Bug
C
Rui Li created FLINK-22170:
--
Summary: Manual test for hive dialect
Key: FLINK-22170
URL: https://issues.apache.org/jira/browse/FLINK-22170
Project: Flink
Issue Type: Sub-task
Components: C
Rui Li created FLINK-22119:
--
Summary: Update document for hive dialect
Key: FLINK-22119
URL: https://issues.apache.org/jira/browse/FLINK-22119
Project: Flink
Issue Type: Sub-task
Component
Rui Li created FLINK-22107:
--
Summary: Include antlr into hive connector uber jars
Key: FLINK-22107
URL: https://issues.apache.org/jira/browse/FLINK-22107
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-22102:
--
Summary: Throw meaningful exceptions for features we don't support
Key: FLINK-22102
URL: https://issues.apache.org/jira/browse/FLINK-22102
Project: Flink
Issue Type: Sub
Rui Li created FLINK-22092:
--
Summary: Prevent HiveCatalog from reading hive-site in classpath
Key: FLINK-22092
URL: https://issues.apache.org/jira/browse/FLINK-22092
Project: Flink
Issue Type: Bug
Rui Li created FLINK-21998:
--
Summary: Copy more code from hive and move them to a dedicated
package
Key: FLINK-21998
URL: https://issues.apache.org/jira/browse/FLINK-21998
Project: Flink
Issue Type
Rui Li created FLINK-21888:
--
Summary: Maintain our own ASTNode class
Key: FLINK-21888
URL: https://issues.apache.org/jira/browse/FLINK-21888
Project: Flink
Issue Type: Sub-task
Components:
Rui Li created FLINK-21808:
--
Summary: Support DQL in HiveParser
Key: FLINK-21808
URL: https://issues.apache.org/jira/browse/FLINK-21808
Project: Flink
Issue Type: Sub-task
Components: Conn
Rui Li created FLINK-21727:
--
Summary: Support DDL in HiveParser
Key: FLINK-21727
URL: https://issues.apache.org/jira/browse/FLINK-21727
Project: Flink
Issue Type: Sub-task
Components: Conn
Rui Li created FLINK-21656:
--
Summary: Add antlr parser for hive dialect
Key: FLINK-21656
URL: https://issues.apache.org/jira/browse/FLINK-21656
Project: Flink
Issue Type: Sub-task
Componen
Rui Li created FLINK-21637:
--
Summary: Wrong results when filtering by timestamp type
Key: FLINK-21637
URL: https://issues.apache.org/jira/browse/FLINK-21637
Project: Flink
Issue Type: Bug
Rui Li created FLINK-21592:
--
Summary: RemoveSingleAggregateRule fails due to nullability
mismatch
Key: FLINK-21592
URL: https://issues.apache.org/jira/browse/FLINK-21592
Project: Flink
Issue Type:
Rui Li created FLINK-21590:
--
Summary: Avoid hive logs in the SQL client console
Key: FLINK-21590
URL: https://issues.apache.org/jira/browse/FLINK-21590
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-21531:
--
Summary: Introduce pluggable Parser
Key: FLINK-21531
URL: https://issues.apache.org/jira/browse/FLINK-21531
Project: Flink
Issue Type: Sub-task
Components: Tab
Rui Li created FLINK-21529:
--
Summary: FLIP-152: Hive Query Syntax Compatibility
Key: FLINK-21529
URL: https://issues.apache.org/jira/browse/FLINK-21529
Project: Flink
Issue Type: New Feature
Rui Li created FLINK-21185:
--
Summary: Introduce a new interface for catalog to listen on
temporary object operations
Key: FLINK-21185
URL: https://issues.apache.org/jira/browse/FLINK-21185
Project: Flink
Rui Li created FLINK-21184:
--
Summary: Support temporary table/function for hive connector
Key: FLINK-21184
URL: https://issues.apache.org/jira/browse/FLINK-21184
Project: Flink
Issue Type: New Featu
Rui Li created FLINK-21083:
--
Summary: Streaming write partitioned table needs to handle null
partition value
Key: FLINK-21083
URL: https://issues.apache.org/jira/browse/FLINK-21083
Project: Flink
I
Rui Li created FLINK-20920:
--
Summary: Document how to connect to kerberized HMS
Key: FLINK-20920
URL: https://issues.apache.org/jira/browse/FLINK-20920
Project: Flink
Issue Type: Task
Comp
Rui Li created FLINK-20844:
--
Summary: Support add jar in SQL client
Key: FLINK-20844
URL: https://issues.apache.org/jira/browse/FLINK-20844
Project: Flink
Issue Type: New Feature
Component
Rui Li created FLINK-20822:
--
Summary: Don't check whether a function is generic in hive catalog
Key: FLINK-20822
URL: https://issues.apache.org/jira/browse/FLINK-20822
Project: Flink
Issue Type: Tas
Rui Li created FLINK-20813:
--
Summary: SQL Client should create modules with user class loader
Key: FLINK-20813
URL: https://issues.apache.org/jira/browse/FLINK-20813
Project: Flink
Issue Type: Bug
Rui Li created FLINK-20765:
--
Summary: ScalarOperatorGens doesn't set proper nullability for
result type of generated expressions
Key: FLINK-20765
URL: https://issues.apache.org/jira/browse/FLINK-20765
Projec
Rui Li created FLINK-20761:
--
Summary: Cannot read hive table/partition whose location path
contains comma
Key: FLINK-20761
URL: https://issues.apache.org/jira/browse/FLINK-20761
Project: Flink
Issu
Rui Li created FLINK-20722:
--
Summary: Fail to insert into hive table due to ClassCastException
Key: FLINK-20722
URL: https://issues.apache.org/jira/browse/FLINK-20722
Project: Flink
Issue Type: Bug
Rui Li created FLINK-20680:
--
Summary: Fails to call var-arg function with no parameters
Key: FLINK-20680
URL: https://issues.apache.org/jira/browse/FLINK-20680
Project: Flink
Issue Type: Bug
Rui Li created FLINK-20667:
--
Summary: Configurable batch size for vectorized reader
Key: FLINK-20667
URL: https://issues.apache.org/jira/browse/FLINK-20667
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-20572:
--
Summary: HiveCatalog should be a standalone module
Key: FLINK-20572
URL: https://issues.apache.org/jira/browse/FLINK-20572
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-20563:
--
Summary: Support built-in functions for Hive versions prior to
1.2.0
Key: FLINK-20563
URL: https://issues.apache.org/jira/browse/FLINK-20563
Project: Flink
Issue Type:
Rui Li created FLINK-20549:
--
Summary: New ExecutionContext doesn't inherit classloader from
previous context
Key: FLINK-20549
URL: https://issues.apache.org/jira/browse/FLINK-20549
Project: Flink
I
Rui Li created FLINK-20537:
--
Summary: Failed to call Hive UDF with string literal arguments
Key: FLINK-20537
URL: https://issues.apache.org/jira/browse/FLINK-20537
Project: Flink
Issue Type: Bug
Rui Li created FLINK-20486:
--
Summary: Hive temporal join shouldn't require a minimal 1h monitor
interval
Key: FLINK-20486
URL: https://issues.apache.org/jira/browse/FLINK-20486
Project: Flink
Issue
Rui Li created FLINK-20448:
--
Summary: Obsolete generated avro classes
Key: FLINK-20448
URL: https://issues.apache.org/jira/browse/FLINK-20448
Project: Flink
Issue Type: Test
Components: Fo
Rui Li created FLINK-20419:
--
Summary: Insert fails due to failure to generate execution plan
Key: FLINK-20419
URL: https://issues.apache.org/jira/browse/FLINK-20419
Project: Flink
Issue Type: Bug
Rui Li created FLINK-20349:
--
Summary: Query fails with "A conflict is detected. This is
unexpected."
Key: FLINK-20349
URL: https://issues.apache.org/jira/browse/FLINK-20349
Project: Flink
Issue Typ
Rui Li created FLINK-20062:
--
Summary: ContinuousHiveSplitEnumerator should be lock-free
Key: FLINK-20062
URL: https://issues.apache.org/jira/browse/FLINK-20062
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-19965:
--
Summary: Refactor HiveMapredSplitReader to adapt to the new hive
source
Key: FLINK-19965
URL: https://issues.apache.org/jira/browse/FLINK-19965
Project: Flink
Issue Typ
Rui Li created FLINK-19891:
--
Summary: ScalarOperatorGens should generate a not-null type for IS
NULL and IS NOT NULL
Key: FLINK-19891
URL: https://issues.apache.org/jira/browse/FLINK-19891
Project: Flink
Rui Li created FLINK-19888:
--
Summary: Migrate Hive source to FLIP-27 source interface for
streaming
Key: FLINK-19888
URL: https://issues.apache.org/jira/browse/FLINK-19888
Project: Flink
Issue Type
Rui Li created FLINK-19867:
--
Summary: Validation fails for UDF that accepts var-args
Key: FLINK-19867
URL: https://issues.apache.org/jira/browse/FLINK-19867
Project: Flink
Issue Type: Bug
Rui Li created FLINK-19702:
--
Summary: Avoid using HiveConf::hiveSiteURL
Key: FLINK-19702
URL: https://issues.apache.org/jira/browse/FLINK-19702
Project: Flink
Issue Type: Improvement
Compo
Rui Li created FLINK-19470:
--
Summary: ParquetColumnarRowSplitReader::reachEnd returns false
after it has reached end
Key: FLINK-19470
URL: https://issues.apache.org/jira/browse/FLINK-19470
Project: Flink
Rui Li created FLINK-19406:
--
Summary: Casting row time to timestamp loses nullability info
Key: FLINK-19406
URL: https://issues.apache.org/jira/browse/FLINK-19406
Project: Flink
Issue Type: Bug
Rui Li created FLINK-19368:
--
Summary: TableEnvHiveConnectorITCase fails with Hive-3.x
Key: FLINK-19368
URL: https://issues.apache.org/jira/browse/FLINK-19368
Project: Flink
Issue Type: Test
Rui Li created FLINK-19365:
--
Summary: Migrate Hive table source to new source interface
Key: FLINK-19365
URL: https://issues.apache.org/jira/browse/FLINK-19365
Project: Flink
Issue Type: Task
Rui Li created FLINK-19361:
--
Summary: Create a synchronized metastore client to talk to a
remote HMS
Key: FLINK-19361
URL: https://issues.apache.org/jira/browse/FLINK-19361
Project: Flink
Issue Typ
Rui Li created FLINK-19292:
--
Summary: HiveCatalog should support specifying Hadoop conf dir
with configuration
Key: FLINK-19292
URL: https://issues.apache.org/jira/browse/FLINK-19292
Project: Flink
Rui Li created FLINK-19070:
--
Summary: Hive connector should throw a meaningful exception if
user reads/writes ACID tables
Key: FLINK-19070
URL: https://issues.apache.org/jira/browse/FLINK-19070
Project: Flin
Rui Li created FLINK-19071:
--
Summary: Some Hive window functions are not supported
Key: FLINK-19071
URL: https://issues.apache.org/jira/browse/FLINK-19071
Project: Flink
Issue Type: Task
C
Rui Li created FLINK-19061:
--
Summary: HiveCatalog fails to get partition column stats if
partition value contains special characters
Key: FLINK-19061
URL: https://issues.apache.org/jira/browse/FLINK-19061
Pr
Rui Li created FLINK-19042:
--
Summary: HiveTableSourceITCase fails if object reuse is enabled
Key: FLINK-19042
URL: https://issues.apache.org/jira/browse/FLINK-19042
Project: Flink
Issue Type: Test
Rui Li created FLINK-19004:
--
Summary: Fail to call Hive percentile function together with
distinct aggregate call
Key: FLINK-19004
URL: https://issues.apache.org/jira/browse/FLINK-19004
Project: Flink
Rui Li created FLINK-18999:
--
Summary: Temporary generic table doesn't work with HiveCatalog
Key: FLINK-18999
URL: https://issues.apache.org/jira/browse/FLINK-18999
Project: Flink
Issue Type: Bug
Rui Li created FLINK-18995:
--
Summary: Some Hive functions fail because they need to access
SessionState
Key: FLINK-18995
URL: https://issues.apache.org/jira/browse/FLINK-18995
Project: Flink
Issue
Rui Li created FLINK-18981:
--
Summary: Support column comment for Hive tables
Key: FLINK-18981
URL: https://issues.apache.org/jira/browse/FLINK-18981
Project: Flink
Issue Type: Task
Compone
Rui Li created FLINK-18942:
--
Summary: HiveTableSink shouldn't try to create BulkWriter factory
when using MR writer
Key: FLINK-18942
URL: https://issues.apache.org/jira/browse/FLINK-18942
Project: Flink
Rui Li created FLINK-18931:
--
Summary: Translate "Hive Streaming" page of "Hive Integration"
into Chinese
Key: FLINK-18931
URL: https://issues.apache.org/jira/browse/FLINK-18931
Project: Flink
Issue
Rui Li created FLINK-18930:
--
Summary: Translate "Hive Dialect" page of "Hive Integration" into
Chinese
Key: FLINK-18930
URL: https://issues.apache.org/jira/browse/FLINK-18930
Project: Flink
Issue T
Rui Li created FLINK-18900:
--
Summary: HiveCatalog should error out when listing partitions with
an invalid spec
Key: FLINK-18900
URL: https://issues.apache.org/jira/browse/FLINK-18900
Project: Flink
Rui Li created FLINK-18882:
--
Summary: Investigate supporting Hive interval type
Key: FLINK-18882
URL: https://issues.apache.org/jira/browse/FLINK-18882
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-18867:
--
Summary: Generic table stored in Hive catalog is incompatible
between 1.10 and 1.11
Key: FLINK-18867
URL: https://issues.apache.org/jira/browse/FLINK-18867
Project: Flink
Rui Li created FLINK-18682:
--
Summary: Vector orc reader cannot read Hive 2.0.0 table
Key: FLINK-18682
URL: https://issues.apache.org/jira/browse/FLINK-18682
Project: Flink
Issue Type: Bug
Rui Li created FLINK-18678:
--
Summary: Hive connector fails to create vector orc reader if user
specifies incorrect hive version
Key: FLINK-18678
URL: https://issues.apache.org/jira/browse/FLINK-18678
Project
Rui Li created FLINK-18644:
--
Summary: Remove scala-shell doc for hive connector
Key: FLINK-18644
URL: https://issues.apache.org/jira/browse/FLINK-18644
Project: Flink
Issue Type: Task
Comp
Rui Li created FLINK-18529:
--
Summary: Query Hive table and filter by timestamp partition
doesn't work
Key: FLINK-18529
URL: https://issues.apache.org/jira/browse/FLINK-18529
Project: Flink
Issue Ty
Rui Li created FLINK-18516:
--
Summary: Improve error message for rank function in streaming mode
Key: FLINK-18516
URL: https://issues.apache.org/jira/browse/FLINK-18516
Project: Flink
Issue Type: Imp
Rui Li created FLINK-18445:
--
Summary: Short circuit join condition for lookup join
Key: FLINK-18445
URL: https://issues.apache.org/jira/browse/FLINK-18445
Project: Flink
Issue Type: Improvement
Rui Li created FLINK-18313:
--
Summary: Hive dialect doc should mention that views created in
Flink cannot be used in Hive
Key: FLINK-18313
URL: https://issues.apache.org/jira/browse/FLINK-18313
Project: Flink
Rui Li created FLINK-18300:
--
Summary: SQL Client doesn't support ALTER VIEW
Key: FLINK-18300
URL: https://issues.apache.org/jira/browse/FLINK-18300
Project: Flink
Issue Type: Bug
Component
Rui Li created FLINK-18272:
--
Summary: FileSystemLookupFunction can fail if the file gets
updated/deleted while cache is reloaded
Key: FLINK-18272
URL: https://issues.apache.org/jira/browse/FLINK-18272
Projec
Rui Li created FLINK-18258:
--
Summary: Implement SHOW PARTITIONS for Hive dialect
Key: FLINK-18258
URL: https://issues.apache.org/jira/browse/FLINK-18258
Project: Flink
Issue Type: Task
Com
Rui Li created FLINK-18197:
--
Summary: Add more logs for hive streaming integration
Key: FLINK-18197
URL: https://issues.apache.org/jira/browse/FLINK-18197
Project: Flink
Issue Type: Task
C
Rui Li created FLINK-18046:
--
Summary: Decimal column stats not supported for Hive table
Key: FLINK-18046
URL: https://issues.apache.org/jira/browse/FLINK-18046
Project: Flink
Issue Type: Bug
Rui Li created FLINK-18030:
--
Summary: Hive UDF doesn't accept empty string literal parameter
Key: FLINK-18030
URL: https://issues.apache.org/jira/browse/FLINK-18030
Project: Flink
Issue Type: Bug
Rui Li created FLINK-18009:
--
Summary: Select an invalid column crashes the SQL CLI
Key: FLINK-18009
URL: https://issues.apache.org/jira/browse/FLINK-18009
Project: Flink
Issue Type: Bug
Co
Rui Li created FLINK-17965:
--
Summary: Hive dialect doesn't properly handle special character
escaping with SQL CLI
Key: FLINK-17965
URL: https://issues.apache.org/jira/browse/FLINK-17965
Project: Flink
Rui Li created FLINK-17941:
--
Summary: Switching database doesn't work from SQL CLI
Key: FLINK-17941
URL: https://issues.apache.org/jira/browse/FLINK-17941
Project: Flink
Issue Type: Bug
Co
Rui Li created FLINK-17937:
--
Summary: Change some hive connector tests to IT cases
Key: FLINK-17937
URL: https://issues.apache.org/jira/browse/FLINK-17937
Project: Flink
Issue Type: Test
C
Rui Li created FLINK-17867:
--
Summary: Fix Hive-3.1.1 test
Key: FLINK-17867
URL: https://issues.apache.org/jira/browse/FLINK-17867
Project: Flink
Issue Type: Test
Components: Connectors / H
Rui Li created FLINK-17786:
--
Summary: Cannot switch dialect in SQL CLI
Key: FLINK-17786
URL: https://issues.apache.org/jira/browse/FLINK-17786
Project: Flink
Issue Type: Bug
Components: Ta
1 - 100 of 203 matches
Mail list logo