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-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
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-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
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
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
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-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
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-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
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
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-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-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-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-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-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-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-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-18930:
--
Summary: Translate "Hive Dialect" page of "Hive Integration" into
Chinese
Key: FLINK-18930
URL: https://issues.apache.org/jira/browse/FLINK-18930
Project: F
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
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:
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
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-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
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-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-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
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
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
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-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
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-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-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-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-19702:
--
Summary: Avoid using HiveConf::hiveSiteURL
Key: FLINK-19702
URL: https://issues.apache.org/jira/browse/FLINK-19702
Project: Flink
Issue Type: Improvement
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-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
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-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
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-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
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-20448:
--
Summary: Obsolete generated avro classes
Key: FLINK-20448
URL: https://issues.apache.org/jira/browse/FLINK-20448
Project: Flink
Issue Type: Test
Components
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:
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-20549:
--
Summary: New ExecutionContext doesn't inherit classloader from
previous context
Key: FLINK-20549
URL: https://issues.apache.org/jira/browse/FLINK-20549
Project:
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-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-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-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-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-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
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-
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-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
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
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-
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
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
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-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-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: Improv
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
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-17198:
--
Summary: DDL and DML compatibility for Hive connector
Key: FLINK-17198
URL: https://issues.apache.org/jira/browse/FLINK-17198
Project: Flink
Issue Type: New Feature
Rui Li created FLINK-17209:
--
Summary: Allow users to specify dialect in sql-client yaml
Key: FLINK-17209
URL: https://issues.apache.org/jira/browse/FLINK-17209
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17210:
--
Summary: Implement database DDLs for Hive dialect
Key: FLINK-17210
URL: https://issues.apache.org/jira/browse/FLINK-17210
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17387:
--
Summary: Implement LookupableTableSource for Hive connector
Key: FLINK-17387
URL: https://issues.apache.org/jira/browse/FLINK-17387
Project: Flink
Issue Type: New
Rui Li created FLINK-17431:
--
Summary: Implement table DDLs for Hive dialect part 1
Key: FLINK-17431
URL: https://issues.apache.org/jira/browse/FLINK-17431
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17448:
--
Summary: Implement table DDLs for Hive dialect part2
Key: FLINK-17448
URL: https://issues.apache.org/jira/browse/FLINK-17448
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17449:
--
Summary: Implement ADD/DROP partitions
Key: FLINK-17449
URL: https://issues.apache.org/jira/browse/FLINK-17449
Project: Flink
Issue Type: Sub-task
Components
Rui Li created FLINK-17450:
--
Summary: Implement function DDLs for Hive dialect
Key: FLINK-17450
URL: https://issues.apache.org/jira/browse/FLINK-17450
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17451:
--
Summary: Implement view DDLs for Hive dialect
Key: FLINK-17451
URL: https://issues.apache.org/jira/browse/FLINK-17451
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17452:
--
Summary: Support creating Hive tables with constraints
Key: FLINK-17452
URL: https://issues.apache.org/jira/browse/FLINK-17452
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17456:
--
Summary: Update hive connector tests to execute DDL & DML via
TableEnvironment
Key: FLINK-17456
URL: https://issues.apache.org/jira/browse/FLINK-17456
Project: F
Rui Li created FLINK-17457:
--
Summary: Manage Hive metadata via Flink DDL
Key: FLINK-17457
URL: https://issues.apache.org/jira/browse/FLINK-17457
Project: Flink
Issue Type: Sub-task
Rui Li created FLINK-17666:
--
Summary: Insert into partitioned table can fail with select *
Key: FLINK-17666
URL: https://issues.apache.org/jira/browse/FLINK-17666
Project: Flink
Issue Type: Bug
Rui Li created FLINK-17667:
--
Summary: Implement INSERT for Hive dialect
Key: FLINK-17667
URL: https://issues.apache.org/jira/browse/FLINK-17667
Project: Flink
Issue Type: Sub-task
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
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
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
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
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:
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
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
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-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
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
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
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
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
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-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
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
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
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
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
201 - 299 of 299 matches
Mail list logo