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

2023-08-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759476#comment-17759476 ] Nicholas Jiang commented on FLINK-30593: [~gyfora], does this reply on the stop time of the

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

2023-08-27 Thread Nicholas Jiang (Jira)
[ 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

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

2023-08-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759452#comment-17759452 ] Nicholas Jiang commented on FLINK-30593: [~gyfora], does this rely on the stop time of scale

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

2023-03-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697846#comment-17697846 ] Nicholas Jiang edited comment on FLINK-31364 at 3/8/23 11:23 AM: - [~Ming

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

2023-03-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697846#comment-17697846 ] Nicholas Jiang commented on FLINK-31364: [~Ming Li], this ticket is duplicated by

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

2023-03-08 Thread Nicholas Jiang (Jira)
[ 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

2023-03-08 Thread Nicholas Jiang (Jira)
[ 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

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

2023-03-08 Thread Nicholas Jiang (Jira)
[ 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

2023-03-08 Thread Nicholas Jiang (Jira)
[ 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

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

2023-03-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2023-03-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696460#comment-17696460 ] Nicholas Jiang commented on FLINK-31310: [~lzljs3620320], the `dropTable` interface is invoked

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

2023-03-02 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696048#comment-17696048 ] Nicholas Jiang commented on FLINK-31310: [~lzljs3620320], could you assign this to me? > Force

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

2023-03-02 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696029#comment-17696029 ] Nicholas Jiang commented on FLINK-25986: [~dianfu], help to assign to [~qingyue]. > Add

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

2023-02-27 Thread Nicholas Jiang (Jira)
[ 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

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

2023-02-27 Thread Nicholas Jiang (Jira)
[ 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

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

2023-02-27 Thread Nicholas Jiang (Jira)
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

2023-02-26 Thread Nicholas Jiang (Jira)
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

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

2023-02-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693489#comment-17693489 ] Nicholas Jiang commented on FLINK-31224: [~zhangjun], could you firstly add the design of the

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

2023-02-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693322#comment-17693322 ] Nicholas Jiang commented on FLINK-22793: [~thw] , of course could assign to [~lemonjing]. >

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

2023-02-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693321#comment-17693321 ] Nicholas Jiang commented on FLINK-31040: [~Juntao Hu], [~martijnvisser], thanks for the

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

2023-02-22 Thread Nicholas Jiang (Jira)
[ 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

2023-02-22 Thread Nicholas Jiang (Jira)
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

2023-02-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692494#comment-17692494 ] Nicholas Jiang commented on FLINK-31190: [~lzljs3620320], could you assign this ticket to me? I

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

2023-02-22 Thread Nicholas Jiang (Jira)
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

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

2023-02-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691013#comment-17691013 ] Nicholas Jiang commented on FLINK-30723: [~zjureel], [~lzljs3620320], this is duplicated by 

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

2023-02-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17689530#comment-17689530 ] Nicholas Jiang commented on FLINK-31009: [~lzljs3620320], I'm working for this feature. Please

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

2023-02-14 Thread Nicholas Jiang (Jira)
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

2023-02-14 Thread Nicholas Jiang (Jira)
[ 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

2023-02-14 Thread Nicholas Jiang (Jira)
[ 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

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

2023-02-13 Thread Nicholas Jiang (Jira)
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.

2023-01-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655416#comment-17655416 ] Nicholas Jiang commented on FLINK-30414: [~Aiden Gong], it isn't needed to add test timeout for

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

2023-01-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2023-01-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655414#comment-17655414 ] Nicholas Jiang commented on FLINK-30590: [~zjureel], IMO, it's needed for users to reduce the

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

2022-10-25 Thread Nicholas Jiang (Jira)
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

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

2022-09-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602059#comment-17602059 ] Nicholas Jiang commented on FLINK-29226: [~lzljs3620320], could you please assign this ticket to

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

2022-08-14 Thread Nicholas Jiang (Jira)
[ 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

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

2022-08-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578893#comment-17578893 ] Nicholas Jiang commented on FLINK-28817: [~thw], IMO, this pull request could also fixed the bug

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

2022-08-11 Thread Nicholas Jiang (Jira)
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

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

2022-08-11 Thread Nicholas Jiang (Jira)
[ 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

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

2022-08-11 Thread Nicholas Jiang (Jira)
[ 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

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

2022-08-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578291#comment-17578291 ] Nicholas Jiang commented on FLINK-28903: [~lzljs3620320] , when the value of

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

2022-08-10 Thread Nicholas Jiang (Jira)
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

2022-08-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17577376#comment-17577376 ] Nicholas Jiang commented on FLINK-28574: [~ConradJam], the Java Operator SDK 3.1.1 has been

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

2022-08-05 Thread Nicholas Jiang (Jira)
[ 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

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

2022-08-05 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575833#comment-17575833 ] Nicholas Jiang commented on FLINK-28840: [~lzljs3620320] , could you please help to assign this

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

2022-08-05 Thread Nicholas Jiang (Jira)
[ 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

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

2022-08-05 Thread Nicholas Jiang (Jira)
[ 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

2022-08-05 Thread Nicholas Jiang (Jira)
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

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

2022-08-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17575237#comment-17575237 ] Nicholas Jiang commented on FLINK-28594: [~matyas] , what are the most of the blocking

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

2022-07-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572716#comment-17572716 ] Nicholas Jiang commented on FLINK-28727: [~lzljs3620320], could you please assign this ticket to

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

2022-07-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572253#comment-17572253 ] Nicholas Jiang commented on FLINK-28594: [~matyas] , are you working for this? > Add metrics

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

2022-07-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571828#comment-17571828 ] Nicholas Jiang commented on FLINK-28705: [~lzljs3620320], please help to assign this ticket to

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

2022-07-27 Thread Nicholas Jiang (Jira)
[ 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

2022-07-27 Thread Nicholas Jiang (Jira)
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

2022-07-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569875#comment-17569875 ] Nicholas Jiang commented on FLINK-28086: [~lzljs3620320], could you please assign this ticket to

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

2022-07-17 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567768#comment-17567768 ] Nicholas Jiang commented on FLINK-28578: [~lzljs3620320], please help to assign this ticket to

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

2022-07-17 Thread Nicholas Jiang (Jira)
[ 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

[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

2022-07-17 Thread Nicholas Jiang (Jira)
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

2022-07-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567122#comment-17567122 ] Nicholas Jiang commented on FLINK-28560: [~lzljs3620320], please help to assign this to me and

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

2022-07-14 Thread Nicholas Jiang (Jira)
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:

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

2022-07-14 Thread Nicholas Jiang (Jira)
[ 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

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

2022-07-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565330#comment-17565330 ] Nicholas Jiang commented on FLINK-28480: [~gyfora], please help to assign this ticket to me. I

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

2022-07-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2022-07-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564329#comment-17564329 ] Nicholas Jiang commented on FLINK-28364: [~bgeng777], the users build a custom image which has

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

2022-07-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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

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

2022-06-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555355#comment-17555355 ] Nicholas Jiang commented on FLINK-28100: [~SOD_DOB], I'm the RocketMQ connector owner. What's

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

2022-06-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552629#comment-17552629 ] Nicholas Jiang commented on FLINK-27914: [~gyfora], I'm working for the implementation of the

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

2022-06-09 Thread Nicholas Jiang (Jira)
[ 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

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

2022-06-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552487#comment-17552487 ] Nicholas Jiang commented on FLINK-27259: [~wangyang0918], after FLINK-27257 was closed, IMO this

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

2022-06-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550432#comment-17550432 ] Nicholas Jiang commented on FLINK-27913: [~gyfora], I will work for this ticket. Please help to

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

2022-06-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544720#comment-17544720 ] Nicholas Jiang commented on FLINK-27257: [~gyfora], I don't mind. I will take a look at the

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

2022-05-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543414#comment-17543414 ] Nicholas Jiang commented on FLINK-27668: [~gyfora], could you please assign this ticket to me? I

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

2022-05-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541784#comment-17541784 ] Nicholas Jiang commented on FLINK-27759: [~wangyang0918], I will investigate the better way to

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

2022-05-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2022-05-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

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

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

2022-05-24 Thread Nicholas Jiang (Jira)
[ 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

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

2022-05-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541409#comment-17541409 ] Nicholas Jiang commented on FLINK-27746: [~tison], if we simply remove "COPY .git", the git info

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

2022-05-17 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538539#comment-17538539 ] Nicholas Jiang edited comment on FLINK-27257 at 5/18/22 5:21 AM: - I have

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

2022-05-17 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538539#comment-17538539 ] Nicholas Jiang edited comment on FLINK-27257 at 5/18/22 1:44 AM: - I have

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

2022-05-17 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538539#comment-17538539 ] Nicholas Jiang commented on FLINK-27257: I have offline discussed with [~wangyang0918]. It's

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

2022-05-17 Thread Nicholas Jiang (Jira)
[ 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

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

2022-05-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17535850#comment-17535850 ] Nicholas Jiang commented on FLINK-27257: [~gyfora], sorry for later reply. I will push a pull

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

2022-05-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534358#comment-17534358 ] Nicholas Jiang commented on FLINK-27499: [~gyfora], could you please assign this ticket to me? I

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

2022-04-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529674#comment-17529674 ] Nicholas Jiang commented on FLINK-27364: [~lsy], IMO, the pull request for FLINK-25177 has been

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

2022-04-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528471#comment-17528471 ] Nicholas Jiang commented on FLINK-27412: [~wangyang0918], how many version would be supported in

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

2022-04-25 Thread Nicholas Jiang (Jira)
[ 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

2022-04-25 Thread Nicholas Jiang (Jira)
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

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

2022-04-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527418#comment-17527418 ] Nicholas Jiang commented on FLINK-27392: [~dwysakowicz], WDYT? > CEP Pattern supports

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

2022-04-25 Thread Nicholas Jiang (Jira)
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:

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

2022-04-24 Thread Nicholas Jiang (Jira)
[ 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

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

2022-04-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527281#comment-17527281 ] Nicholas Jiang commented on FLINK-27364: This issue is deplicated with the FLINK-25177. >

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

2022-04-21 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526085#comment-17526085 ] Nicholas Jiang commented on FLINK-27334: [~gyfora] [~aitozi], I have pushed a pull request for

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

2022-04-20 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2022-04-20 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525083#comment-17525083 ] Nicholas Jiang commented on FLINK-26926: [~gyfora], I have push a PR for this ticket. Please

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

2022-04-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524352#comment-17524352 ] Nicholas Jiang commented on FLINK-26926: [~gyfora], IMO, the

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

2022-04-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524348#comment-17524348 ] Nicholas Jiang commented on FLINK-27023: [~gyfora], I am also working on this issue, my other

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

2022-04-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521045#comment-17521045 ] Nicholas Jiang commented on FLINK-27183: [~danderson], I mainly maintain Flink CEP. How much

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

2022-04-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519993#comment-17519993 ] Nicholas Jiang commented on FLINK-27153: [~gyfora], is the

  1   2   3   4   5   6   7   >