[jira] [Created] (FLINK-28639) Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator

Yunfeng Zhou created FLINK-28639: Summary: Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator Key: FLINK-28639 URL: https://issues.apache.org/jira/browse/FLINK-28639

Re: [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions

Hi Jing, I have some concerns about the isBulkGetSupported() approach. 1. Catalog developers need to learn the contract between `isBulkGetSupported()` and bulk get methods 2. The contract of isBulkGetSupported() is fragile. Because developers may forget to override `isBulkGetSupported` and be

[jira] [Created] (FLINK-28638) Restrict ALTER TABLE from setting write-mode

Jane Chan created FLINK-28638: - Summary: Restrict ALTER TABLE from setting write-mode Key: FLINK-28638 URL: https://issues.apache.org/jira/browse/FLINK-28638 Project: Flink Issue Type:

Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

+1 On Wed, Jul 20, 2022 at 10:48 PM Konstantin Knauf wrote: > +1. Thanks! > > Am Mi., 20. Juli 2022 um 16:48 Uhr schrieb Tzu-Li (Gordon) Tai < > tzuli...@apache.org>: > > > +1 > > > > On Wed, Jul 20, 2022 at 6:13 AM Danny Cranmer > > wrote: > > > > > Hi there, > > > > > > After the discussion

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

Thank you for flagging this Jim. I looked a little into this and it comes from the fabric8 client, so it affects all current operator (and flink) versions. I think it would be a bit risky for us to manually bump this dependency as the usage is not controlled by us and it's hard to test for all

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

Thanks for the release I’m continuing to test and so far it’s looking good, but I found a high security vulnerability in the /flink-kubernetes-operator/flink-kubernetes-operator-1.1.0-shaded.jar file. I’ve created issue FLINK-28637 and

[jira] [Created] (FLINK-28637) High vulnerability in flink-kubernetes-operator-1.1.0-shaded.jar

James Busche created FLINK-28637: Summary: High vulnerability in flink-kubernetes-operator-1.1.0-shaded.jar Key: FLINK-28637 URL: https://issues.apache.org/jira/browse/FLINK-28637 Project: Flink

[jira] [Created] (FLINK-28636) Add utility to test POJO compliance

Chesnay Schepler created FLINK-28636: Summary: Add utility to test POJO compliance Key: FLINK-28636 URL: https://issues.apache.org/jira/browse/FLINK-28636 Project: Flink Issue Type:

[jira] [Created] (FLINK-28635) HybridSourceReader availabilityFuture always completed

hongfei zhang created FLINK-28635: - Summary: HybridSourceReader availabilityFuture always completed Key: FLINK-28635 URL: https://issues.apache.org/jira/browse/FLINK-28635 Project: Flink

Re: [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions

Thanks Jingsong and Jark. I will create another FLIP to cover the optimization topic that partitions and partition stats could be fetched from catalog in one single call. Thanks for the hint w.r.t. the compatibility issue. I have updated the FLIP to provide all methods as default interface

[jira] [Created] (FLINK-28634) Add a simple Json (De) SerializationSchema

Chesnay Schepler created FLINK-28634: Summary: Add a simple Json (De) SerializationSchema Key: FLINK-28634 URL: https://issues.apache.org/jira/browse/FLINK-28634 Project: Flink Issue

[jira] [Created] (FLINK-28633) Allow to GetTables in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28633: - Summary: Allow to GetTables in the HiveServer2 Endpoint Key: FLINK-28633 URL: https://issues.apache.org/jira/browse/FLINK-28633 Project: Flink Issue Type:

[jira] [Created] (FLINK-28632) Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28632: - Summary: Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint Key: FLINK-28632 URL: https://issues.apache.org/jira/browse/FLINK-28632

[jira] [Created] (FLINK-28630) Allow to GetSchemas in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28630: - Summary: Allow to GetSchemas in the HiveServer2 Endpoint Key: FLINK-28630 URL: https://issues.apache.org/jira/browse/FLINK-28630 Project: Flink Issue

[jira] [Created] (FLINK-28631) Allow to GetFunctions in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28631: - Summary: Allow to GetFunctions in the HiveServer2 Endpoint Key: FLINK-28631 URL: https://issues.apache.org/jira/browse/FLINK-28631 Project: Flink Issue

[jira] [Created] (FLINK-28629) Allow to getCatalogs in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28629: - Summary: Allow to getCatalogs in the HiveServer2 Endpoint Key: FLINK-28629 URL: https://issues.apache.org/jira/browse/FLINK-28629 Project: Flink Issue

[jira] [Created] (FLINK-28628) Introduce operation execution plugin

luoyuxia created FLINK-28628: Summary: Introduce operation execution plugin Key: FLINK-28628 URL: https://issues.apache.org/jira/browse/FLINK-28628 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28627) KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 60000 milliseconds

Huang Xingbo created FLINK-28627: Summary: KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 6 milliseconds Key: FLINK-28627 URL:

[jira] [Created] (FLINK-28626) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException

Huang Xingbo created FLINK-28626: Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException Key: FLINK-28626 URL:

[jira] [Created] (FLINK-28625) Guard against changing target session deployment for sessionjob

Gyula Fora created FLINK-28625: -- Summary: Guard against changing target session deployment for sessionjob Key: FLINK-28625 URL: https://issues.apache.org/jira/browse/FLINK-28625 Project: Flink

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

+1 (binding) Verified the following: - Helm repo contents, image reference - Upgrade from 1.0.1 with running Deployments and SessionJobs to 1.1.0 without problems - Run a few examples, verify logs, basic metrics, CR status, events Cheers, Gyula On Wed, Jul 20, 2022 at 5:58 PM Geng Biao

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

Hi, Thanks for the informative discussion! Looking forward to using dynamic filtering provided by Flink. Best regards, Jing On Tue, Jul 19, 2022 at 3:22 AM godfrey he wrote: > Hi, Jingong, Jark, Jing, > > Thanks for for the important inputs. > Lake storage is a very important scenario, and

[jira] [Created] (FLINK-28624) CsvReaderFormat should accept CsvMapper factory

Chesnay Schepler created FLINK-28624: Summary: CsvReaderFormat should accept CsvMapper factory Key: FLINK-28624 URL: https://issues.apache.org/jira/browse/FLINK-28624 Project: Flink

[jira] [Created] (FLINK-28623) Optimize the use of off heap memory by blocking and hybrid shuffle reader

Weijie Guo created FLINK-28623: -- Summary: Optimize the use of off heap memory by blocking and hybrid shuffle reader Key: FLINK-28623 URL: https://issues.apache.org/jira/browse/FLINK-28623 Project: Flink

[jira] [Created] (FLINK-28622) Can't restore a flink job that uses Table API and Kafka connector with savepoint

Nathan created FLINK-28622: -- Summary: Can't restore a flink job that uses Table API and Kafka connector with savepoint Key: FLINK-28622 URL: https://issues.apache.org/jira/browse/FLINK-28622 Project: Flink

[jira] [Created] (FLINK-28621) Register JavaTimeModule in all internal object mappers

Chesnay Schepler created FLINK-28621: Summary: Register JavaTimeModule in all internal object mappers Key: FLINK-28621 URL: https://issues.apache.org/jira/browse/FLINK-28621 Project: Flink

[jira] [Created] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

Jark Wu created FLINK-28620: --- Summary: SQL Client doesn't properly print values of INTERVAL type Key: FLINK-28620 URL: https://issues.apache.org/jira/browse/FLINK-28620 Project: Flink Issue Type:

来自Howie Yang的邮件

-- Best, Howie