[jira] [Assigned] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-34147: -- Assignee: Yunhong Zheng > TimestampData to/from LocalDateTime is ambiguous >

[jira] [Commented] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814581#comment-17814581 ] Rui Li commented on FLINK-34147: Thanks [~337361...@qq.com], just assigned to you! > Ti

[jira] [Commented] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810347#comment-17810347 ] Rui Li commented on FLINK-34147: I think having two separate classes is fine, but it mig

[jira] [Created] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

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

[jira] [Commented] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617444#comment-17617444 ] Rui Li commented on FLINK-29527: [~suns] Assigned. Thanks for taking the issue > Make u

[jira] [Assigned] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-29527: -- Assignee: Sun Shun > Make unknownFieldsIndices work for single ParquetReader > --

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605597#comment-17605597 ] Rui Li commented on FLINK-26043: Got it, thanks [~gaborgsomogyi]! > Add periodic kerber

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605341#comment-17605341 ] Rui Li commented on FLINK-26043: I mean what if delegation token is disabled, i.e. {{se

[jira] [Commented] (FLINK-26043) Add periodic kerberos relogin to DelegationTokenManager

[ https://issues.apache.org/jira/browse/FLINK-26043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17605315#comment-17605315 ] Rui Li commented on FLINK-26043: Hey [~gaborgsomogyi], just curious, does the periodical

[jira] [Resolved] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-28247. Fix Version/s: 1.16.0 Resolution: Fixed > Exception will be thrown when over window contains groupi

[jira] [Commented] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564078#comment-17564078 ] Rui Li commented on FLINK-28247: Fixed in master: a069a306a0c95ba62bbc63f6afc995fd3216a3

[jira] [Assigned] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-28247: -- Assignee: luoyuxia > Exception will be thrown when over window contains grouping in Hive Dialect > --

[jira] [Resolved] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-20951. Resolution: Duplicate > IllegalArgumentException when reading Hive parquet table if condition not > conta

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518606#comment-17518606 ] Rui Li commented on FLINK-20951: Thanks [~hackergin] for verifying the fix. I'll close t

[jira] [Assigned] (FLINK-19004) Fail to call Hive percentile function together with distinct aggregate call

[ https://issues.apache.org/jira/browse/FLINK-19004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-19004: -- Assignee: luoyuxia > Fail to call Hive percentile function together with distinct aggregate call > --

[jira] [Assigned] (FLINK-15854) Use the new type inference for hive udtf

[ https://issues.apache.org/jira/browse/FLINK-15854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-15854: -- Assignee: luoyuxia > Use the new type inference for hive udtf > -

[jira] [Commented] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

[ https://issues.apache.org/jira/browse/FLINK-25023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467078#comment-17467078 ] Rui Li commented on FLINK-25023: Hey [~keremulutas], when I investigated FLINK-15239, mo

[jira] [Commented] (FLINK-14588) Support Hive version 1.0.0 and 1.0.1

[ https://issues.apache.org/jira/browse/FLINK-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17428794#comment-17428794 ] Rui Li commented on FLINK-14588: [~camilesing] Yes that's because we want a single hive

[jira] [Resolved] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23316. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 1b1d6fc2518b78e34d69c5f17fcf6b21ae0f2182

[jira] [Commented] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415498#comment-17415498 ] Rui Li commented on FLINK-23316: Hey [~jackwangcs], I think what you proposed can be som

[jira] [Assigned] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23316: -- Assignee: jackwangcs > There's no test for custom PartitionCommitPolicy > ---

[jira] [Commented] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412942#comment-17412942 ] Rui Li commented on FLINK-23316: [~jackwangcs] Thanks for volunteering to help. Assignin

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410952#comment-17410952 ] Rui Li commented on FLINK-23857: OK, I tried with an empty source table w/o the {{1 != 1

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410356#comment-17410356 ] Rui Li commented on FLINK-23857: [~luoyuxia] Please also verify with different hive vers

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407788#comment-17407788 ] Rui Li commented on FLINK-23857: bq. insert overwrite table t1 partition(f2=1) select *

[jira] [Assigned] (FLINK-23715) Support for reading fields that do not exist in Parquet files

[ https://issues.apache.org/jira/browse/FLINK-23715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23715: -- Assignee: tartarus > Support for reading fields that do not exist in Parquet files >

[jira] [Resolved] (FLINK-23715) Support for reading fields that do not exist in Parquet files

[ https://issues.apache.org/jira/browse/FLINK-23715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23715. Fix Version/s: 1.15.0 Resolution: Fixed Pushed to master: 8abf8c627ca5ceab7a7e4f5b40f89b7ccceb9ceb

[jira] [Resolved] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23857. Fix Version/s: (was: 1.13.3) 1.15.0 Resolution: Fixed Fixed in master: 6f599

[jira] [Resolved] (FLINK-23897) Fix obsolete doc about creating hive table with flink dialect

[ https://issues.apache.org/jira/browse/FLINK-23897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23897. Resolution: Fixed Fixed in master: 5d5565523283332414fb25f4f8765a7268c11b83 Fixed in release-1.14: d3e5553

[jira] [Updated] (FLINK-23897) Fix obsolete doc about creating hive table with flink dialect

[ https://issues.apache.org/jira/browse/FLINK-23897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23897: --- Fix Version/s: 1.15.0 1.14.0 > Fix obsolete doc about creating hive table with flink dial

[jira] [Assigned] (FLINK-23897) Fix obsolete doc about creating hive table with flink dialect

[ https://issues.apache.org/jira/browse/FLINK-23897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23897: -- Assignee: Rui Li > Fix obsolete doc about creating hive table with flink dialect > --

[jira] [Updated] (FLINK-23897) Fix obsolete doc about creating hive table with flink dialect

[ https://issues.apache.org/jira/browse/FLINK-23897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23897: --- Component/s: Documentation Connectors / Hive > Fix obsolete doc about creating hive table w

[jira] [Created] (FLINK-23897) Fix obsolete doc about creating hive table with flink

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

[jira] [Updated] (FLINK-23897) Fix obsolete doc about creating hive table with flink dialect

[ https://issues.apache.org/jira/browse/FLINK-23897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23897: --- Summary: Fix obsolete doc about creating hive table with flink dialect (was: Fix obsolete doc about creatin

[jira] [Assigned] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23857: -- Assignee: Rui Li > insert overwirite table select * from t where 1 != 1, Unable to clear table > dat

[jira] [Updated] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23857: --- Component/s: (was: Table SQL / Planner) Connectors / Hive Connectors /

[jira] [Resolved] (FLINK-22914) Use Kafka new source in Table/SQL connector

[ https://issues.apache.org/jira/browse/FLINK-22914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22914. Resolution: Fixed Pushed to master: 4c8f3a7036f5aecfba88381c50b285566bcbcbd5 > Use Kafka new source in Ta

[jira] [Commented] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398466#comment-17398466 ] Rui Li commented on FLINK-22334: bq. Is expected that cluster by isn't supported in stre

[jira] [Created] (FLINK-23752) Add document for using HiveSource API

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

[jira] [Resolved] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23032. Resolution: Fixed > Refactor HiveSource to make it usable in data stream job > ---

[jira] [Commented] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398415#comment-17398415 ] Rui Li commented on FLINK-23032: Pushed to master: c4bdcac8ea255fd5a3eb6d49e349c6c5b9270

[jira] [Commented] (FLINK-23650) A sql contains 'Case when' could not run successfully when choose Hive Dialect

[ https://issues.apache.org/jira/browse/FLINK-23650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397194#comment-17397194 ] Rui Li commented on FLINK-23650: This is actually a known issue of how hive dialect hand

[jira] [Commented] (FLINK-23650) A sql contains 'Case when' could not run successfully when choose Hive Dialect

[ https://issues.apache.org/jira/browse/FLINK-23650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397131#comment-17397131 ] Rui Li commented on FLINK-23650: Thanks [~qingru zhang] for reporting the issue. I tried

[jira] [Resolved] (FLINK-22606) Simplify the usage of SessionState

[ https://issues.apache.org/jira/browse/FLINK-22606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22606. Fix Version/s: 1.13.3 Resolution: Fixed Pushed to master: a5847e3871ffb9515af9c754bd10c42611976c82

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394611#comment-17394611 ] Rui Li commented on FLINK-22246: [~luoyuxia] Creating Hive {{SessionState}} involves hea

[jira] [Commented] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391910#comment-17391910 ] Rui Li commented on FLINK-23567: [~wuyang09] I have pushed a fix for this issue. Please

[jira] [Resolved] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23567. Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in master: 48cd889b1de39080

[jira] [Assigned] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23567: -- Assignee: Rui Li > Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was > no

[jira] [Updated] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23567: --- Fix Version/s: (was: 1.13.1) > Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class

[jira] [Commented] (FLINK-23567) Hive 1.1.0 failed to write using flink sql 1.13.1 because the JSON class was not found

[ https://issues.apache.org/jira/browse/FLINK-23567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17391274#comment-17391274 ] Rui Li commented on FLINK-23567: [~wuyang09] The filter is there because the JSON depend

[jira] [Resolved] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23239. Resolution: Fixed > HiveTableSinkITCase hangs on azure > -- > >

[jira] [Commented] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17390336#comment-17390336 ] Rui Li commented on FLINK-23239: [~liyu] Thanks for the reminder. I'm closing this one.

[jira] [Updated] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23239: --- Fix Version/s: 1.13.3 > HiveTableSinkITCase hangs on azure > -- > >

[jira] [Commented] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17389912#comment-17389912 ] Rui Li commented on FLINK-23239: Fixed in master: 65f3197cf055630ec35dc660e7ca99364eb50d

[jira] [Resolved] (FLINK-22657) HiveParserDDLSemanticAnalyzer can directly return operations

[ https://issues.apache.org/jira/browse/FLINK-22657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22657. Fix Version/s: 1.13.3 Resolution: Fixed Pushed to master: c3088af32543c807a69eced7129f89284204c2af

[jira] [Assigned] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23239: -- Assignee: Rui Li > HiveTableSinkITCase hangs on azure > -- > >

[jira] [Commented] (FLINK-23239) HiveTableSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17387344#comment-17387344 ] Rui Li commented on FLINK-23239: I examined the test log and guess I've found the cause.

[jira] [Commented] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383347#comment-17383347 ] Rui Li commented on FLINK-20975: Pushed a fix to: * master: a846a4856549a0992f2172fec9d1

[jira] [Resolved] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22898. Resolution: Fixed > HiveParallelismInference limit return wrong parallelism >

[jira] [Commented] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381294#comment-17381294 ] Rui Li commented on FLINK-22898: Fixed in release-1.13: 004d3b58e4f4637efb09e3c7c84f01c3

[jira] [Updated] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22898: --- Fix Version/s: 1.13.3 1.12.6 > HiveParallelismInference limit return wrong parallelism >

[jira] [Assigned] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-20975: -- Assignee: Rui Li > HiveTableSourceITCase.testPartitionFilter fails on AZP > -

[jira] [Commented] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17379174#comment-17379174 ] Rui Li commented on FLINK-20975: I tried the test locally dozens of times but didn't rep

[jira] [Commented] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378892#comment-17378892 ] Rui Li commented on FLINK-20975: Sure I'll look into this. > HiveTableSourceITCase.test

[jira] [Assigned] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-13400: -- Assignee: frank wang > Remove Hive and Hadoop dependencies from SQL Client >

[jira] [Commented] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377965#comment-17377965 ] Rui Li commented on FLINK-13400: [~frank wang] Thanks for offering to help with this. As

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23074: --- Fix Version/s: 1.13.2 1.12.5 > There is a class conflict between flink-connector-hive and

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377786#comment-17377786 ] Rui Li commented on FLINK-23074: Fixed in release-1.13: 8359fa8a9149392d964f52e7492b4dc2

[jira] [Commented] (FLINK-22402) Add hive dialect test in sql-client

[ https://issues.apache.org/jira/browse/FLINK-22402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377369#comment-17377369 ] Rui Li commented on FLINK-22402: Hey [~frank wang], I don't think anyone is working on t

[jira] [Updated] (FLINK-23316) There's no test for custom PartitionCommitPolicy

[ https://issues.apache.org/jira/browse/FLINK-23316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23316: --- Description: We support custom PartitionCommitPolicy but currently there's no test coverage for that use cas

[jira] [Created] (FLINK-23316) There's no test for custom PartitionCommitPolicy

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

[jira] [Resolved] (FLINK-23178) Raise an error for writing stream data into partitioned hive tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23178. Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed Pushed to master: a94745ec85bf9e8

[jira] [Resolved] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23298. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: e9cc49a31fc384bff1c84372788f14a173cd94b0

[jira] [Assigned] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23298: -- Assignee: fhan > [datagen] Normalize parameter names in RandomGeneratorVisitor and > SequenceGenerat

[jira] [Commented] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376309#comment-17376309 ] Rui Li commented on FLINK-23032: Hi [~frank wang], thanks for your interests in this! Ho

[jira] [Assigned] (FLINK-22657) HiveParserDDLSemanticAnalyzer can directly return operations

[ https://issues.apache.org/jira/browse/FLINK-22657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22657: -- Assignee: luoyuxia > HiveParserDDLSemanticAnalyzer can directly return operations > -

[jira] [Updated] (FLINK-23032) Refactor HiveSource to make it usable in data stream job

[ https://issues.apache.org/jira/browse/FLINK-23032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23032: --- Labels: (was: stale-assigned) > Refactor HiveSource to make it usable in data stream job > ---

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375674#comment-17375674 ] Rui Li commented on FLINK-23074: [~ana4] If you want this fix in release 1.13 or 1.12, p

[jira] [Resolved] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23074. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 78bafc55363d11e33143f1769248b85eaec2ee5a

[jira] [Commented] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375292#comment-17375292 ] Rui Li commented on FLINK-22898: Fixed in master: a765da5dc9bc7f56971d1714abc8bce4796f96

[jira] [Resolved] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22884. Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in master: 0b686824c33ad976

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375141#comment-17375141 ] Rui Li commented on FLINK-23074: How about just {{org.apache.hive.shaded.parquet}}, as w

[jira] [Updated] (FLINK-23178) Raise an error for writing stream data into partitioned hive tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23178: --- Component/s: (was: Connectors / FileSystem) > Raise an error for writing stream data into partitioned hi

[jira] [Updated] (FLINK-23178) Raise an error for writing stream data into partitioned hive tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23178: --- Summary: Raise an error for writing stream data into partitioned hive tables without a partition committer

[jira] [Assigned] (FLINK-23178) Raise an error for writing stream data into partitioned hive/FS tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23178: -- Assignee: Rui Li > Raise an error for writing stream data into partitioned hive/FS tables > without

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17374459#comment-17374459 ] Rui Li commented on FLINK-23074: I think we can relocate parquet in sql-connector-hive j

[jira] [Commented] (FLINK-23175) Write data to hive table in batch mode throws FileNotFoundException.

[ https://issues.apache.org/jira/browse/FLINK-23175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373516#comment-17373516 ] Rui Li commented on FLINK-23175: [~chrismartin] The staging dir is created on client sid

[jira] [Created] (FLINK-23224) Support timestamp_ltz type in hive connector

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

[jira] [Comment Edited] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation

[ https://issues.apache.org/jira/browse/FLINK-23168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373501#comment-17373501 ] Rui Li edited comment on FLINK-23168 at 7/2/21, 12:54 PM: -- Fixe

[jira] [Resolved] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation

[ https://issues.apache.org/jira/browse/FLINK-23168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23168. Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in master: * 37cd345c729016

[jira] [Updated] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation

[ https://issues.apache.org/jira/browse/FLINK-23168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23168: --- Summary: Catalog shouldn't merge properties for alter DB operation (was: GenericInMemoryCatalog shouldn't m

[jira] [Assigned] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

[ https://issues.apache.org/jira/browse/FLINK-22898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22898: -- Assignee: luoyuxia > HiveParallelismInference limit return wrong parallelism > --

[jira] [Updated] (FLINK-23178) Raise an error for writing stream data into partitioned hive/FS tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-23178: --- Description: If a user writes streaming data into hive but forgets to specify a partition commit policy, the

[jira] [Created] (FLINK-23178) Raise an error for writing stream data into partitioned hive/FS tables without a partition committer

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

[jira] [Created] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation

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

[jira] [Resolved] (FLINK-23010) HivePartitionFetcherContextBase::getComparablePartitionValueList can return partitions that don't exist

[ https://issues.apache.org/jira/browse/FLINK-23010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23010. Fix Version/s: 1.13.2 1.12.5 1.14.0 Resolution: Fixed Fixed i

[jira] [Resolved] (FLINK-22617) Add log when create bulk format

[ https://issues.apache.org/jira/browse/FLINK-22617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22617. Fix Version/s: 1.14.0 Resolution: Fixed Pushed to master: e58f7dd342846549949cdd9946cf0837e1b96cb5

[jira] [Commented] (FLINK-23096) HiveParser could not attach the sessionstate of hive

[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368590#comment-17368590 ] Rui Li commented on FLINK-23096: This is actually a different issue from FLINK-16688, un

[jira] [Resolved] (FLINK-23096) HiveParser could not attach the sessionstate of hive

[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23096. Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed Fixed in master: 36a05834f0aa0e94

[jira] [Assigned] (FLINK-23096) HiveParser could not attach the sessionstate of hive

[ https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23096: -- Assignee: shizhengchao > HiveParser could not attach the sessionstate of hive > -

  1   2   3   4   5   6   7   8   9   10   >