[jira] [Updated] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

2024-12-18 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-36604: -- Description: Currently {{StreamingJobGraphGenerator::setOperatorConfig}} does not check the i

[jira] [Commented] (FLINK-34369) Elasticsearch connector supports SSL context

2024-12-11 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904897#comment-17904897 ] Mingliang Liu commented on FLINK-34369: --- [~Sergey Nuyanzin] I think we can close t

[jira] (FLINK-34369) Elasticsearch connector supports SSL context

2024-12-11 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369 ] Mingliang Liu deleted comment on FLINK-34369: --- was (Author: liuml07): Can we close this now? > Elasticsearch connector supports SSL context > >

[jira] [Commented] (FLINK-36780) Kafka source disable partition discovery unexpectedly

2024-11-22 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17900545#comment-17900545 ] Mingliang Liu commented on FLINK-36780: --- CC:[~markcho] > Kafka source disable par

[jira] [Created] (FLINK-36780) Kafka source disable partition discovery unexpectedly

2024-11-22 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-36780: - Summary: Kafka source disable partition discovery unexpectedly Key: FLINK-36780 URL: https://issues.apache.org/jira/browse/FLINK-36780 Project: Flink Issue

[jira] [Updated] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-11 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-36679: -- Description: Currently we expose multiple metrics for the checkpoint size. One specific inter

[jira] [Updated] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-08 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-36679: -- Description: Currently we expose multiple metrics for the checkpoint size. One specific inter

[jira] [Updated] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-08 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-36679: -- Description: Currently we expose multiple metrics for the checkpoint size. One specific inter

[jira] [Commented] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-08 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896756#comment-17896756 ] Mingliang Liu commented on FLINK-36679: --- We have a in-progress patch in our intern

[jira] [Created] (FLINK-36679) Add a metric to track checkpoint _metadata size

2024-11-08 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-36679: - Summary: Add a metric to track checkpoint _metadata size Key: FLINK-36679 URL: https://issues.apache.org/jira/browse/FLINK-36679 Project: Flink Issue Type:

[jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

2024-10-25 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-36604: - Summary: StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Key: FLINK-36604 URL: https://issues.apache.org/jira/browse/FLINK-36604 Project

[jira] [Created] (FLINK-36579) mysql cdc charset collation sort not equals java string compare.

2024-10-22 Thread LIU (Jira)
LIU created FLINK-36579: --- Summary: mysql cdc charset collation sort not equals java string compare. Key: FLINK-36579 URL: https://issues.apache.org/jira/browse/FLINK-36579 Project: Flink Issue Type: I

[jira] [Created] (FLINK-36567) Planner module didn't use the setting from flink-conf.yaml

2024-10-17 Thread liting liu (Jira)
liting liu created FLINK-36567: -- Summary: Planner module didn't use the setting from flink-conf.yaml Key: FLINK-36567 URL: https://issues.apache.org/jira/browse/FLINK-36567 Project: Flink Issue

[jira] [Commented] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-19 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883025#comment-17883025 ] Liu Liu commented on FLINK-35764: - [~pnowojski] Hello, I see you edited the TimerGauge c

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Affects Version/s: 1.20.0 > TimerGauge is incorrect when update is called during a measurement > -

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] [Updated] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-09-18 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu Liu updated FLINK-35764: Description: *Description* Currently in {{{}TimerGauge{}}}, the timer measures the time spent in a state

[jira] (FLINK-34369) Elasticsearch connector supports SSL context

2024-08-16 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369 ] Mingliang Liu deleted comment on FLINK-34369: --- was (Author: liuml07): Can we close this now? > Elasticsearch connector supports SSL context > >

[jira] [Commented] (FLINK-34369) Elasticsearch connector supports SSL context

2024-08-16 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874427#comment-17874427 ] Mingliang Liu commented on FLINK-34369: --- Can we close this now? > Elasticsearch c

[jira] [Created] (FLINK-35795) FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-09 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-35795: --- Summary: FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2 Key: FLINK-35795 URL: https://issues.apache.org/jira/browse/FLINK-35795 Project: Flink

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-07-08 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Release Note: New Features: fullWindowPartition Method: Introduced in the DataStream class to enab

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-07-08 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Release Note: Support Full Partition Processing On Non-keyed DataStream New Features: fullWindowPa

[jira] [Commented] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-07-05 Thread Liu Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863148#comment-17863148 ] Liu Liu commented on FLINK-35764: - Could someone assign this to me please? > TimerGauge

[jira] [Created] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

2024-07-05 Thread Liu Liu (Jira)
Liu Liu created FLINK-35764: --- Summary: TimerGauge is incorrect when update is called during a measurement Key: FLINK-35764 URL: https://issues.apache.org/jira/browse/FLINK-35764 Project: Flink Iss

[jira] [Commented] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items

2024-06-06 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853036#comment-17853036 ] Mingliang Liu commented on FLINK-35546: --- I plan to submit a PR for discussion. I t

[jira] [Created] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items

2024-06-06 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35546: - Summary: Elasticsearch 8 connector fails fast for non-retryable bulk request items Key: FLINK-35546 URL: https://issues.apache.org/jira/browse/FLINK-35546 Project:

[jira] [Commented] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

2024-06-04 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852132#comment-17852132 ] Mingliang Liu commented on FLINK-35502: --- I guess in my day job I don't see user re

[jira] [Commented] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

2024-06-03 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851744#comment-17851744 ] Mingliang Liu commented on FLINK-35502: --- When would you need to restore from check

[jira] [Updated] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35504: -- Description: Currently all logs are in DEBUG level. Some of those messages are very helpful t

[jira] [Updated] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35504: -- Description: Currently all logs are in DEBUG level. Some of those messages are very helpful t

[jira] [Updated] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35504: -- Description: Currently all logs are in DEBUG level. Some of those messages are very helpful t

[jira] [Updated] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35504: -- Description: Currently all logs are in DEBUG level. Some of those messages are very helpful t

[jira] [Created] (FLINK-35504) Improve Elasticsearch 8 connector observability

2024-06-01 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35504: - Summary: Improve Elasticsearch 8 connector observability Key: FLINK-35504 URL: https://issues.apache.org/jira/browse/FLINK-35504 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35472) Improve tests for Elasticsearch 8 connector

2024-05-28 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35472: -- Affects Version/s: elasticsearch-3.2.0 > Improve tests for Elasticsearch 8 connector > ---

[jira] [Commented] (FLINK-34369) Elasticsearch connector supports SSL context

2024-05-28 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849908#comment-17849908 ] Mingliang Liu commented on FLINK-34369: --- Can we close this now? > Elasticsearch c

[jira] [Created] (FLINK-35472) Improve tests for Elasticsearch 8 connector

2024-05-28 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35472: - Summary: Improve tests for Elasticsearch 8 connector Key: FLINK-35472 URL: https://issues.apache.org/jira/browse/FLINK-35472 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-23 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35424: -- Parent: FLINK-34369 Issue Type: Sub-task (was: Improvement) > Elasticsearch connector

[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35424: -- Description: In  FLINK-34369, we added SSL support for the base Elasticsearch sink class that

[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35424: -- Description: In  FLINK-34369, we added SSL support for the base Elasticsearch sink class that

[jira] [Updated] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-35424: -- Description: In  (was: The current Flink ElasticSearch connector does not support SSL option,

[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context

2024-05-22 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35424: - Summary: Elasticsearch connector 8 supports SSL context Key: FLINK-35424 URL: https://issues.apache.org/jira/browse/FLINK-35424 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27054) Elasticsearch SQL connector SSL issue

2024-05-03 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843288#comment-17843288 ] Mingliang Liu commented on FLINK-27054: --- Hi, the FLINK-34369 was merged and I can

[jira] [Created] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-03 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35287: - Summary: Builder builds NetworkConfig for Elasticsearch connector 8 Key: FLINK-35287 URL: https://issues.apache.org/jira/browse/FLINK-35287 Project: Flink

[jira] [Created] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

2024-04-23 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-35221: --- Summary: Support SQL 2011 reserved keywords as identifiers in Flink HiveParser Key: FLINK-35221 URL: https://issues.apache.org/jira/browse/FLINK-35221 Project: Flink

[jira] [Updated] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

2024-04-23 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-35221: Description: According to Hive user documentation[1], starting from version 0.13.0, Hive prohibit

[jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

2024-04-17 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-35148: - Summary: Improve InstantiationUtil for checking nullary public constructor Key: FLINK-35148 URL: https://issues.apache.org/jira/browse/FLINK-35148 Project: Flink

[jira] [Commented] (FLINK-34718) KeyedPartitionWindowedStream and NonPartitionWindowedStream IllegalStateException in AZP

2024-03-18 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828019#comment-17828019 ] Wencong Liu commented on FLINK-34718: - The newly introduced DataStream operators are

[jira] [Commented] (FLINK-34718) KeyedPartitionWindowedStream and NonPartitionWindowedStream IllegalStateException in AZP

2024-03-18 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828011#comment-17828011 ] Wencong Liu commented on FLINK-34718: - Sure, I'll take a look now. [~mapohl]  > Key

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-03-12 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Description: Introduce the PartitionWindowedStream and provide multiple full window operations in

[jira] [Commented] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-08 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824890#comment-17824890 ] Mingliang Liu commented on FLINK-34632: --- CC [~markcho] > Log checkpoint Id when l

[jira] [Created] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

2024-03-08 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34632: - Summary: Log checkpoint Id when logging checkpoint processing delay Key: FLINK-34632 URL: https://issues.apache.org/jira/browse/FLINK-34632 Project: Flink

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-03-03 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Description: 1. Introduce MapParititon, SortPartition, Aggregate, Reduce API in DataStream. 2. Int

[jira] [Created] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

2024-02-28 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-34543: --- Summary: Support Full Partition Processing On Non-keyed DataStream Key: FLINK-34543 URL: https://issues.apache.org/jira/browse/FLINK-34543 Project: Flink Issue

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

2024-02-17 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818186#comment-17818186 ] Wencong Liu commented on FLINK-34448: - Maybe [~Yanfei Lei] could take a look 😄. > C

[jira] [Comment Edited] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814583#comment-17814583 ] Fangliang Liu edited comment on FLINK-34376 at 2/6/24 3:24 AM: ---

[jira] [Commented] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814583#comment-17814583 ] Fangliang Liu commented on FLINK-34376: --- Hi [~matriv] ,[~twalthr] , [~zonli]  Rel

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Description: {code:java} select cast(sum(CAST(9.11 AS DECIMAL(38,18)) *10 ) as

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Description: {code:java} select cast(sum(CAST(9.11 AS DECIMAL(38,18)) *10 ) as

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Description: {code:java} select cast(sum(CAST(9.11 AS DECIMAL(38,18)) *10 ) as

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Attachment: image-2024-02-06-11-17-03-399.png > FLINK SQL SUM() causes a precision error > ---

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Description: {code:java} select cast(sum(CAST(9.11 AS DECIMAL(38,18)) *10 ) as

[jira] [Updated] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-34376: -- Attachment: image-2024-02-06-11-15-02-669.png > FLINK SQL SUM() causes a precision error > ---

[jira] [Created] (FLINK-34376) FLINK SQL SUM() causes a precision error

2024-02-05 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-34376: - Summary: FLINK SQL SUM() causes a precision error Key: FLINK-34376 URL: https://issues.apache.org/jira/browse/FLINK-34376 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34369) Elasticsearch connector supports SSL context

2024-02-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-34369: -- Description: The current Flink ElasticSearch connector does not support SSL option, causing i

[jira] [Updated] (FLINK-34369) Elasticsearch connector supports SSL context

2024-02-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-34369: -- Description: The current Flink ElasticSearch connector does not support SSL option, causing i

[jira] [Updated] (FLINK-34369) Elasticsearch connector supports SSL context

2024-02-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-34369: -- Description: The current Flink ElasticSearch connector does not support SSL option, causing i

[jira] [Updated] (FLINK-34369) Elasticsearch connector supports SSL context

2024-02-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-34369: -- Summary: Elasticsearch connector supports SSL context (was: Elasticsearch connector supports

[jira] [Commented] (FLINK-34369) Elasticsearch connector supports SSL provider

2024-02-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814504#comment-17814504 ] Mingliang Liu commented on FLINK-34369: --- Note the Flink ElasticSearch [SQL connec

[jira] [Created] (FLINK-34369) Elasticsearch connector supports SSL provider

2024-02-05 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34369: - Summary: Elasticsearch connector supports SSL provider Key: FLINK-34369 URL: https://issues.apache.org/jira/browse/FLINK-34369 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-27054) Elasticsearch SQL connector SSL issue

2024-02-01 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813391#comment-17813391 ] Mingliang Liu commented on FLINK-27054: --- Any updates on this? My understanding is

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-02-01 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813316#comment-17813316 ] Wencong Liu commented on FLINK-34132: - Thanks for the reminding. [~zhuzh] I will add

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-30 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812213#comment-17812213 ] Wencong Liu commented on FLINK-32978: - [~martijnvisser] Thanks for the reminding. I'

[jira] [Closed] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-30 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu closed FLINK-32978. --- Release Note: The RichFunction#open(Configuration parameters) method has been deprecated and will b

[jira] [Reopened] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-30 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu reopened FLINK-32978: - > Deprecate RichFunction#open(Configuration parameters) > --

[jira] [Created] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception

2024-01-26 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-34251: - Summary: ClosureCleaner to include reference classes for non-serialization exception Key: FLINK-34251 URL: https://issues.apache.org/jira/browse/FLINK-34251 Project

[jira] [Updated] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception

2024-01-26 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mingliang Liu updated FLINK-34251: -- Priority: Minor (was: Major) > ClosureCleaner to include reference classes for non-serializat

[jira] [Commented] (FLINK-34246) Allow only archive failed job to history server

2024-01-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811468#comment-17811468 ] Wencong Liu commented on FLINK-34246: - Thanks [~qingwei91], for suggesting this. Are

[jira] [Commented] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

2024-01-25 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811101#comment-17811101 ] Wencong Liu commented on FLINK-34237: - Thanks for the reminder. I'll fix it as soon

[jira] [Commented] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

2024-01-10 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805352#comment-17805352 ] Wencong Liu commented on FLINK-33009: - I've opened a pull request and CI has passed.

[jira] [Comment Edited] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-09 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804660#comment-17804660 ] Wencong Liu edited comment on FLINK-32978 at 1/9/24 9:45 AM: -

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-09 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804660#comment-17804660 ] Wencong Liu commented on FLINK-32978: - Thanks for proposing this issue 😄. I will inv

[jira] [Closed] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2024-01-02 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu closed FLINK-33949. --- Resolution: Not A Problem > METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2024-01-02 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801988#comment-17801988 ] Wencong Liu commented on FLINK-33949: - Thanks for the explanation from [~chesnay] .

[jira] [Comment Edited] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800913#comment-17800913 ] Wencong Liu edited comment on FLINK-33949 at 12/28/23 3:45 AM: ---

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800913#comment-17800913 ] Wencong Liu commented on FLINK-33949: - Suppose we have two completely independent in

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800802#comment-17800802 ] Wencong Liu commented on FLINK-33949: - For the users have built implementations them

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800787#comment-17800787 ] Wencong Liu commented on FLINK-33949: - Thanks [~martijnvisser] for your comments. Th

[jira] [Comment Edited] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

2023-12-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:43 AM: ---

[jira] [Comment Edited] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

2023-12-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:42 AM: ---

[jira] [Commented] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

2023-12-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu commented on FLINK-33009: - Hi [~mapohl] , I've encountered the same issu

[jira] [Updated] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33949: Description: Currently  I'm trying to refactor some APIs annotated by @Public in [FLIP-382: Unify

[jira] [Updated] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33949: Description: Currently  I'm trying to refactor some APIs annotated by @Public in [FLIP-382: Unify

[jira] [Created] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-26 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33949: --- Summary: METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible Key: FLINK-33949 URL: https://issues.apache.org/jira/browse/FLINK-33949 Proj

[jira] [Commented] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2023-12-25 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800411#comment-17800411 ] Wencong Liu commented on FLINK-33939: - Thanks for raising this issue! 😄 I completely

[jira] [Created] (FLINK-33905) FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

2023-12-20 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33905: --- Summary: FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs Key: FLINK-33905 URL: https://issues.apache.org/jira/browse/FLINK-33905 Project: Flink

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-12-18 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798413#comment-17798413 ] Wencong Liu commented on FLINK-33502: - Sorry for the late reply. I've just identifie

  1   2   3   4   5   6   7   8   9   10   >