[jira] [Commented] (FLINK-30593) Determine restart time on the fly for Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759476#comment-17759476 ] Nicholas Jiang commented on FLINK-30593: [~gyfora], does this reply on the stop

[jira] (FLINK-30593) Determine restart time on the fly for Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30593 ] Nicholas Jiang deleted comment on FLINK-30593: was (Author: nicholasjiang): [~gyfora], does this rely on the stop time of scale operations? JobStatus only records the observed start time

[jira] [Commented] (FLINK-30593) Determine restart time on the fly for Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759452#comment-17759452 ] Nicholas Jiang commented on FLINK-30593: [~gyfora], does this rely on the stop t

[jira] [Comment Edited] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697846#comment-17697846 ] Nicholas Jiang edited comment on FLINK-31364 at 3/8/23 11:23 AM: -

[jira] [Commented] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697846#comment-17697846 ] Nicholas Jiang commented on FLINK-31364: [~Ming Li], this ticket is duplicated b

[jira] [Updated] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31364: --- Attachment: image-2023-03-08-19-21-24-801.png > [Flink] add metrics for TableStore > ---

[jira] [Updated] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31364: --- Attachment: (was: image-2023-03-08-19-21-42-291.png) > [Flink] add metrics for TableStor

[jira] [Updated] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31364: --- Attachment: image-2023-03-08-19-21-42-291.png > [Flink] add metrics for TableStore > ---

[jira] [Updated] (FLINK-31364) [Flink] add metrics for TableStore

[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31364: --- Attachment: (was: image-2023-03-08-19-21-24-801.png) > [Flink] add metrics for TableStor

[jira] [Comment Edited] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696460#comment-17696460 ] Nicholas Jiang edited comment on FLINK-31310 at 3/4/23 4:02 PM: --

[jira] [Commented] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696460#comment-17696460 ] Nicholas Jiang commented on FLINK-31310: [~lzljs3620320], the `dropTable` interf

[jira] [Commented] (FLINK-31310) Force clear directory no matter what situation in HiveCatalog.dropTable

[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696048#comment-17696048 ] Nicholas Jiang commented on FLINK-31310: [~lzljs3620320], could you assign this

[jira] [Commented] (FLINK-25986) Add FLIP-190 new API methods to python

[ https://issues.apache.org/jira/browse/FLINK-25986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696029#comment-17696029 ] Nicholas Jiang commented on FLINK-25986: [~dianfu], help to assign to [~qingyue]

[jira] [Updated] (FLINK-31250) Parquet format supports MULTISET type

[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31250: --- Description: Parquet format supports ARRAY, MAP and ROW type, doesn't support MULTISET type.

[jira] [Updated] (FLINK-31250) Parquet format supports MULTISET type

[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31250: --- Summary: Parquet format supports MULTISET type (was: ParquetSchemaConverter supports MULTIS

[jira] [Created] (FLINK-31250) ParquetSchemaConverter supports MULTISET type for parquet format

Nicholas Jiang created FLINK-31250: -- Summary: ParquetSchemaConverter supports MULTISET type for parquet format Key: FLINK-31250 URL: https://issues.apache.org/jira/browse/FLINK-31250 Project: Flink

[jira] [Created] (FLINK-31232) Parquet format supports MULTISET type for Table Store

Nicholas Jiang created FLINK-31232: -- Summary: Parquet format supports MULTISET type for Table Store Key: FLINK-31232 URL: https://issues.apache.org/jira/browse/FLINK-31232 Project: Flink Iss

[jira] [Commented] (FLINK-31224) Add metrics for flink table store

[ https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693489#comment-17693489 ] Nicholas Jiang commented on FLINK-31224: [~zhangjun], could you firstly add the

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693322#comment-17693322 ] Nicholas Jiang commented on FLINK-22793: [~thw] , of course could assign to [~le

[jira] [Commented] (FLINK-31040) Looping pattern notFollowedBy at end missing an element

[ https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693321#comment-17693321 ] Nicholas Jiang commented on FLINK-31040: [~Juntao Hu], [~martijnvisser], thanks

[jira] [Updated] (FLINK-31194) Introduces savepoint mechanism of Table Store

[ https://issues.apache.org/jira/browse/FLINK-31194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31194: --- Summary: Introduces savepoint mechanism of Table Store (was: ntroduces savepoint mechanism

[jira] [Created] (FLINK-31194) ntroduces savepoint mechanism of Table Store

Nicholas Jiang created FLINK-31194: -- Summary: ntroduces savepoint mechanism of Table Store Key: FLINK-31194 URL: https://issues.apache.org/jira/browse/FLINK-31194 Project: Flink Issue Type:

[jira] [Commented] (FLINK-31190) Supports Spark call procedure command on Table Store

[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692494#comment-17692494 ] Nicholas Jiang commented on FLINK-31190: [~lzljs3620320], could you assign this

[jira] [Created] (FLINK-31190) Supports Spark call procedure command on Table Store

Nicholas Jiang created FLINK-31190: -- Summary: Supports Spark call procedure command on Table Store Key: FLINK-31190 URL: https://issues.apache.org/jira/browse/FLINK-31190 Project: Flink Issu

[jira] [Commented] (FLINK-30723) Introduce filter pushdown for parquet format

[ https://issues.apache.org/jira/browse/FLINK-30723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691013#comment-17691013 ] Nicholas Jiang commented on FLINK-30723: [~zjureel], [~lzljs3620320], this is du

[jira] [Commented] (FLINK-31009) Add recordCount to snapshot meta

[ https://issues.apache.org/jira/browse/FLINK-31009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689530#comment-17689530 ] Nicholas Jiang commented on FLINK-31009: [~lzljs3620320], I'm working for this f

[jira] [Created] (FLINK-31076) Supports filter predicate in Parquet format of table store

Nicholas Jiang created FLINK-31076: -- Summary: Supports filter predicate in Parquet format of table store Key: FLINK-31076 URL: https://issues.apache.org/jira/browse/FLINK-31076 Project: Flink

[jira] [Updated] (FLINK-31050) Supports IN and NOT IN predicate in ORC format of table store

[ https://issues.apache.org/jira/browse/FLINK-31050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31050: --- Description: Supports IN and NOT IN predicate push down in ORC format of table store. h4.  

[jira] [Updated] (FLINK-31050) Supports IN and NOT IN predicate in ORC format of table store

[ https://issues.apache.org/jira/browse/FLINK-31050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31050: --- Summary: Supports IN and NOT IN predicate in ORC format of table store (was: Supports IN pr

[jira] [Created] (FLINK-31050) Supports IN predicate in ORC format of table store

Nicholas Jiang created FLINK-31050: -- Summary: Supports IN predicate in ORC format of table store Key: FLINK-31050 URL: https://issues.apache.org/jira/browse/FLINK-31050 Project: Flink Issue

[jira] [Commented] (FLINK-30414) Add unit test time out when run ci.

[ https://issues.apache.org/jira/browse/FLINK-30414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655416#comment-17655416 ] Nicholas Jiang commented on FLINK-30414: [~Aiden Gong], it isn't needed to add t

[jira] [Comment Edited] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655414#comment-17655414 ] Nicholas Jiang edited comment on FLINK-30590 at 1/6/23 11:54 AM: -

[jira] [Commented] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655414#comment-17655414 ] Nicholas Jiang commented on FLINK-30590: [~zjureel], IMO, it's needed for users

[jira] [Created] (FLINK-29756) Support materialized column to improve query performance for complex types

Nicholas Jiang created FLINK-29756: -- Summary: Support materialized column to improve query performance for complex types Key: FLINK-29756 URL: https://issues.apache.org/jira/browse/FLINK-29756 Projec

[jira] [Commented] (FLINK-29226) Throw exception for streaming insert overwrite

[ https://issues.apache.org/jira/browse/FLINK-29226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602059#comment-17602059 ] Nicholas Jiang commented on FLINK-29226: [~lzljs3620320], could you please assig

[jira] [Resolved] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-26938. Fix Version/s: 1.16.0 Resolution: Fixed > HybridSource recovery from savepoint fail

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578893#comment-17578893 ] Nicholas Jiang commented on FLINK-28817: [~thw], IMO, this pull request could al

[jira] [Created] (FLINK-28930) Add "What is Flink Table Store?" link to flink website

Nicholas Jiang created FLINK-28930: -- Summary: Add "What is Flink Table Store?" link to flink website Key: FLINK-28930 URL: https://issues.apache.org/jira/browse/FLINK-28930 Project: Flink Is

[jira] [Updated] (FLINK-28903) flink-table-store-hive-catalog could not shade hive-shims-0.23

[ https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28903: --- Description: flink-table-store-hive-catalog could not shade hive-shims-0.23 because artifac

[jira] [Updated] (FLINK-28903) flink-table-store-hive-catalog could not shade hive-shims-0.23

[ https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28903: --- Description: flink-table-store-hive-catalog could not shade hive-shims-0.23 because artifac

[jira] [Commented] (FLINK-28903) flink-table-store-hive-catalog could not shade hive-shims-0.23

[ https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578291#comment-17578291 ] Nicholas Jiang commented on FLINK-28903: [~lzljs3620320] , when the value of hiv

[jira] [Created] (FLINK-28903) flink-table-store-hive-catalog could not shade hive-shims-0.23

Nicholas Jiang created FLINK-28903: -- Summary: flink-table-store-hive-catalog could not shade hive-shims-0.23 Key: FLINK-28903 URL: https://issues.apache.org/jira/browse/FLINK-28903 Project: Flink

[jira] [Commented] (FLINK-28574) Bump the fabric8 kubernetes-client to 6.0.0

[ https://issues.apache.org/jira/browse/FLINK-28574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577376#comment-17577376 ] Nicholas Jiang commented on FLINK-28574: [~ConradJam], the Java Operator SDK 3.1

[jira] [Updated] (FLINK-28754) Document that Java 8 is required to build table store

[ https://issues.apache.org/jira/browse/FLINK-28754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28754: --- Summary: Document that Java 8 is required to build table store (was: document that Java 8 i

[jira] [Commented] (FLINK-28840) Introduce roadmap document of Flink Table Store

[ https://issues.apache.org/jira/browse/FLINK-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575833#comment-17575833 ] Nicholas Jiang commented on FLINK-28840: [~lzljs3620320] , could you please help

[jira] [Updated] (FLINK-28840) Introduce roadmap document of Flink Table Store

[ https://issues.apache.org/jira/browse/FLINK-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28840: --- Summary: Introduce roadmap document of Flink Table Store (was: Introduce Roadmap document o

[jira] [Updated] (FLINK-28840) Introduce Roadmap document of Flink Table Store

[ https://issues.apache.org/jira/browse/FLINK-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28840: --- Component/s: Table Store > Introduce Roadmap document of Flink Table Store > ---

[jira] [Created] (FLINK-28840) Introduce Roadmap document of Flink Table Store

Nicholas Jiang created FLINK-28840: -- Summary: Introduce Roadmap document of Flink Table Store Key: FLINK-28840 URL: https://issues.apache.org/jira/browse/FLINK-28840 Project: Flink Issue Typ

[jira] [Commented] (FLINK-28594) Add metrics for FlinkService

[ https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575237#comment-17575237 ] Nicholas Jiang commented on FLINK-28594: [~matyas] , what are the most of the bl

[jira] [Commented] (FLINK-28727) Flink Source supports SupportsLimitPushDown

[ https://issues.apache.org/jira/browse/FLINK-28727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572716#comment-17572716 ] Nicholas Jiang commented on FLINK-28727: [~lzljs3620320], could you please assig

[jira] [Commented] (FLINK-28594) Add metrics for FlinkService

[ https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572253#comment-17572253 ] Nicholas Jiang commented on FLINK-28594: [~matyas] , are you working for this?

[jira] [Commented] (FLINK-28705) Update copyright year to 2014-2022 in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-28705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571828#comment-17571828 ] Nicholas Jiang commented on FLINK-28705: [~lzljs3620320], please help to assign

[jira] [Updated] (FLINK-28705) Update copyright year to 2014-2022 in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-28705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28705: --- Description: Copyright year of the NOTICE files in Flink Table Store should be '2014-2022'.

[jira] [Created] (FLINK-28705) Update copyright year to 2014-2022 in NOTICE files

Nicholas Jiang created FLINK-28705: -- Summary: Update copyright year to 2014-2022 in NOTICE files Key: FLINK-28705 URL: https://issues.apache.org/jira/browse/FLINK-28705 Project: Flink Issue

[jira] [Commented] (FLINK-28086) Table Store Catalog supports partition methods

[ https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569875#comment-17569875 ] Nicholas Jiang commented on FLINK-28086: [~lzljs3620320], could you please assig

[jira] [Commented] (FLINK-28578) Upgrade Spark version of flink-table-store-spark to 3.2.2

[ https://issues.apache.org/jira/browse/FLINK-28578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567768#comment-17567768 ] Nicholas Jiang commented on FLINK-28578: [~lzljs3620320], please help to assign

[jira] [Updated] (FLINK-28578) Upgrade Spark version of flink-table-store-spark to 3.2.2

[ https://issues.apache.org/jira/browse/FLINK-28578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28578: --- Summary: Upgrade Spark version of flink-table-store-spark to 3.2.2 (was: Upgrade Spark vers

[jira] [Created] (FLINK-28578) Upgrade Spark version of flink-table-store-spark to 3.1.3, 3.2.2 or 3.3.0 or later

Nicholas Jiang created FLINK-28578: -- Summary: Upgrade Spark version of flink-table-store-spark to 3.1.3, 3.2.2 or 3.3.0 or later Key: FLINK-28578 URL: https://issues.apache.org/jira/browse/FLINK-28578

[jira] [Commented] (FLINK-28560) Support Spark 3.3 profile for SparkSource

[ https://issues.apache.org/jira/browse/FLINK-28560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567122#comment-17567122 ] Nicholas Jiang commented on FLINK-28560: [~lzljs3620320], please help to assign

[jira] [Created] (FLINK-28560) Support Spark 3.3 profile for SparkSource

Nicholas Jiang created FLINK-28560: -- Summary: Support Spark 3.3 profile for SparkSource Key: FLINK-28560 URL: https://issues.apache.org/jira/browse/FLINK-28560 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-28535) Support create namespace/table for SparkCatalog

[ https://issues.apache.org/jira/browse/FLINK-28535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-28535: --- Summary: Support create namespace/table for SparkCatalog (was: Support create database/tabl

[jira] [Commented] (FLINK-28480) Forward timeControllerExecution time as histogram for JOSDK Metrics interface

[ https://issues.apache.org/jira/browse/FLINK-28480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565330#comment-17565330 ] Nicholas Jiang commented on FLINK-28480: [~gyfora], please help to assign this t

[jira] [Comment Edited] (FLINK-28364) Python Job support for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564329#comment-17564329 ] Nicholas Jiang edited comment on FLINK-28364 at 7/8/22 3:35 PM: --

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564329#comment-17564329 ] Nicholas Jiang commented on FLINK-28364: [~bgeng777], the users build a custom i

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564079#comment-17564079 ] Nicholas Jiang commented on FLINK-28364: [~dianfu][~gyfora][~thw], IMO, after [

[jira] [Comment Edited] (FLINK-28364) Python Job support for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564079#comment-17564079 ] Nicholas Jiang edited comment on FLINK-28364 at 7/8/22 4:21 AM: --

[jira] [Commented] (FLINK-28100) rocketmq-flink checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555355#comment-17555355 ] Nicholas Jiang commented on FLINK-28100: [~SOD_DOB], I'm the RocketMQ connector

[jira] [Commented] (FLINK-27914) Integrate JOSDK metrics with Flink Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-27914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552629#comment-17552629 ] Nicholas Jiang commented on FLINK-27914: [~gyfora], I'm working for the implemen

[jira] [Closed] (FLINK-27259) Observer should not clear savepoint errors even though deployment is healthy

[ https://issues.apache.org/jira/browse/FLINK-27259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-27259. -- Resolution: Won't Fix > Observer should not clear savepoint errors even though deployment is h

[jira] [Commented] (FLINK-27259) Observer should not clear savepoint errors even though deployment is healthy

[ https://issues.apache.org/jira/browse/FLINK-27259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552487#comment-17552487 ] Nicholas Jiang commented on FLINK-27259: [~wangyang0918], after FLINK-27257 was

[jira] [Commented] (FLINK-27913) Remove savepointHistoryMaxCount and savepointHistoryMaxAge from FlinkOperatorConfiguration

[ https://issues.apache.org/jira/browse/FLINK-27913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550432#comment-17550432 ] Nicholas Jiang commented on FLINK-27913: [~gyfora], I will work for this ticket.

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544720#comment-17544720 ] Nicholas Jiang commented on FLINK-27257: [~gyfora], I don't mind. I will take a

[jira] [Commented] (FLINK-27668) Document dynamic operator configuration

[ https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543414#comment-17543414 ] Nicholas Jiang commented on FLINK-27668: [~gyfora], could you please assign this

[jira] [Commented] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541784#comment-17541784 ] Nicholas Jiang commented on FLINK-27759: [~wangyang0918], I will investigate the

[jira] [Comment Edited] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541412#comment-17541412 ] Nicholas Jiang edited comment on FLINK-27746 at 5/24/22 10:49 AM:

[jira] [Comment Edited] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541412#comment-17541412 ] Nicholas Jiang edited comment on FLINK-27746 at 5/24/22 10:48 AM:

[jira] [Commented] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541412#comment-17541412 ] Nicholas Jiang commented on FLINK-27746: [~tison], it's my mistake that I didn't

[jira] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

[ https://issues.apache.org/jira/browse/FLINK-27746 ] Nicholas Jiang deleted comment on FLINK-27746: was (Author: nicholasjiang): [~tison], if we simply remove "COPY .git", the git info could not be logged in the environment info of Flink j

[jira] [Commented] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541409#comment-17541409 ] Nicholas Jiang commented on FLINK-27746: [~tison], if we simply remove "COPY .gi

[jira] [Comment Edited] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538539#comment-17538539 ] Nicholas Jiang edited comment on FLINK-27257 at 5/18/22 5:21 AM: -

[jira] [Comment Edited] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538539#comment-17538539 ] Nicholas Jiang edited comment on FLINK-27257 at 5/18/22 1:44 AM: -

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17538539#comment-17538539 ] Nicholas Jiang commented on FLINK-27257: I have offline discussed with [~wangyan

[jira] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257 ] Nicholas Jiang deleted comment on FLINK-27257: was (Author: nicholasjiang): [~gyfora], sorry for later reply. I will push a pull request today. > Flink kubernetes operator triggers savep

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17535850#comment-17535850 ] Nicholas Jiang commented on FLINK-27257: [~gyfora], sorry for later reply. I wil

[jira] [Commented] (FLINK-27499) Bump base Flink version to 1.15.0

[ https://issues.apache.org/jira/browse/FLINK-27499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534358#comment-17534358 ] Nicholas Jiang commented on FLINK-27499: [~gyfora], could you please assign this

[jira] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529674#comment-17529674 ] Nicholas Jiang commented on FLINK-27364: [~lsy], IMO, the pull request for FLINK

[jira] [Commented] (FLINK-27412) Allow flinkVersion v1_13 in flink-kubernetes-operator

[ https://issues.apache.org/jira/browse/FLINK-27412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528471#comment-17528471 ] Nicholas Jiang commented on FLINK-27412: [~wangyang0918], how many version would

[jira] (FLINK-27392) CEP Pattern supports definition of the maximum time gap between events

[ https://issues.apache.org/jira/browse/FLINK-27392 ] Nicholas Jiang deleted comment on FLINK-27392: was (Author: nicholasjiang): [~dwysakowicz], WDYT? > CEP Pattern supports definition of the maximum time gap between events > -

[jira] [Created] (FLINK-27401) CEP supports AggregateFunction in IterativeCondition

Nicholas Jiang created FLINK-27401: -- Summary: CEP supports AggregateFunction in IterativeCondition Key: FLINK-27401 URL: https://issues.apache.org/jira/browse/FLINK-27401 Project: Flink Issu

[jira] [Commented] (FLINK-27392) CEP Pattern supports definition of the maximum time gap between events

[ https://issues.apache.org/jira/browse/FLINK-27392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527418#comment-17527418 ] Nicholas Jiang commented on FLINK-27392: [~dwysakowicz], WDYT? > CEP Pattern su

[jira] [Created] (FLINK-27392) CEP Pattern supports definition of the maximum time gap between events

Nicholas Jiang created FLINK-27392: -- Summary: CEP Pattern supports definition of the maximum time gap between events Key: FLINK-27392 URL: https://issues.apache.org/jira/browse/FLINK-27392 Project: F

[jira] (FLINK-27183) Optimize CepOperator by using temporal state

[ https://issues.apache.org/jira/browse/FLINK-27183 ] Nicholas Jiang deleted comment on FLINK-27183: was (Author: nicholasjiang): [~danderson], I mainly maintain Flink CEP. How much improvement can the use of temporal state bring to the per

[jira] [Commented] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527281#comment-17527281 ] Nicholas Jiang commented on FLINK-27364: This issue is deplicated with the FLINK

[jira] [Commented] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-27334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526085#comment-17526085 ] Nicholas Jiang commented on FLINK-27334: [~gyfora] [~aitozi], I have pushed a pu

[jira] [Comment Edited] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525083#comment-17525083 ] Nicholas Jiang edited comment on FLINK-26926 at 4/20/22 3:51 PM: -

[jira] [Commented] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525083#comment-17525083 ] Nicholas Jiang commented on FLINK-26926: [~gyfora], I have push a PR for this ti

[jira] [Commented] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17524352#comment-17524352 ] Nicholas Jiang commented on FLINK-26926: [~gyfora], IMO, the `kubernetes.operato

[jira] [Commented] (FLINK-27023) Merge default flink and operator configuration settings for the operator

[ https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17524348#comment-17524348 ] Nicholas Jiang commented on FLINK-27023: [~gyfora], I am also working on this is

[jira] [Commented] (FLINK-27183) Optimize CepOperator by using temporal state

[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521045#comment-17521045 ] Nicholas Jiang commented on FLINK-27183: [~danderson], I mainly maintain Flink C

[jira] [Commented] (FLINK-27153) Allow optional last-state fallback for savepoint upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519993#comment-17519993 ] Nicholas Jiang commented on FLINK-27153: [~gyfora], is the `kubernetes.operator.

  1   2   3   4   5   6   7   >