[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804161#comment-17804161 ] ude commented on FLINK-28693: - same problem

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Description: After submit the following flink sql by sql-client.sh will throw an exception: {code:java}

[jira] [Updated] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-07 Thread JJJJude (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ude updated FLINK-34016: Description: After submit the following flink sql by sql-client.sh will throw an exception: {code:java}

[jira] [Created] (FLINK-34016) Janino compile failed when watermark with column by udf

2024-01-07 Thread Jude Zhu (Jira)
Jude Zhu created FLINK-34016: Summary: Janino compile failed when watermark with column by udf Key: FLINK-34016 URL: https://issues.apache.org/jira/browse/FLINK-34016 Project: Flink Issue Type:

[jira] [Closed] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-34012. Resolution: Fixed Merged into master via 639deeca33757c7380d474d43b8a70bacb84dd20 > Flink python

[jira] [Updated] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34012: - Issue Type: Technical Debt (was: Bug) > Flink python fails with can't read file >

Re: [PR] [FLINK-34012][python] Fix mypy error [flink]

2024-01-07 Thread via GitHub
HuangXingBo merged PR #24043: URL: https://github.com/apache/flink/pull/24043 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

2024-01-07 Thread Renxiang Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804147#comment-17804147 ] Renxiang Zhou commented on FLINK-34015: --- [~JunRuiLi] Many thanks for your reply, I have also

Re: [PR] [FLINK-33738][Scheduler] Make exponential-delay restart-strategy the default restart strategy [flink]

2024-01-07 Thread via GitHub
1996fanrui commented on code in PR #24040: URL: https://github.com/apache/flink/pull/24040#discussion_r1444232288 ## flink-core/src/main/java/org/apache/flink/configuration/RestartStrategyOptions.java: ## @@ -89,11 +89,10 @@ public class RestartStrategyOptions {

Re: [PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
LadyForest commented on PR #24039: URL: https://github.com/apache/flink/pull/24039#issuecomment-1880476143 The CI failure is caused by FLINK-34012 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [PR] [FLINK-33970] Add necessary checks for connector document (#78) [flink-connector-pulsar]

2024-01-07 Thread via GitHub
tisonkun closed pull request #80: [FLINK-33970] Add necessary checks for connector document (#78) URL: https://github.com/apache/flink-connector-pulsar/pull/80 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804141#comment-17804141 ] Jane Chan commented on FLINK-34012: ---

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

2024-01-07 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804140#comment-17804140 ] Junrui Li commented on FLINK-34015: --- If the jobmanager log reflects your actual input and it shows a

[jira] [Updated] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

2024-01-07 Thread Renxiang Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renxiang Zhou updated FLINK-34015: -- Summary: Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when

Re: [PR] [FLINK-33970] Add necessary checks for connector document (#78) [flink-connector-pulsar]

2024-01-07 Thread via GitHub
GOODBOY008 commented on PR #80: URL: https://github.com/apache/flink-connector-pulsar/pull/80#issuecomment-1880464103 @tisonkun Hi, tison. This check should be add to `flink-connector-shared-utils/ci_utils` and also hugo build check should be included. As we discussed in [jira

Re: [PR] [hotfix] Set copyright year to 2024 [flink-connector-pulsar]

2024-01-07 Thread via GitHub
tisonkun merged PR #81: URL: https://github.com/apache/flink-connector-pulsar/pull/81 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]

2024-01-07 Thread via GitHub
gyfora commented on code in PR #749: URL: https://github.com/apache/flink-kubernetes-operator/pull/749#discussion_r1444205943 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonCRStatus.java: ## @@ -0,0 +1,52 @@ +/* + *

[jira] [Updated] (FLINK-34015) execution.savepoint.ignore-unclaimed-state is invalid when passing this parameter by dynamic properties

2024-01-07 Thread Renxiang Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renxiang Zhou updated FLINK-34015: -- Attachment: (was: image-2024-01-08-14-29-04-347.png) >

[jira] [Created] (FLINK-34015) execution.savepoint.ignore-unclaimed-state is invalid when passing this parameter by dynamic properties

2024-01-07 Thread Renxiang Zhou (Jira)
Renxiang Zhou created FLINK-34015: - Summary: execution.savepoint.ignore-unclaimed-state is invalid when passing this parameter by dynamic properties Key: FLINK-34015 URL:

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2024-01-07 Thread via GitHub
gyfora commented on code in PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#discussion_r1444204137 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/MutatorUtils.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the

Re: [PR] [hotfix] Set copyright year to 2024 [flink-connector-pulsar]

2024-01-07 Thread via GitHub
GOODBOY008 commented on PR #81: URL: https://github.com/apache/flink-connector-pulsar/pull/81#issuecomment-1880441534 @tisonkun PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-33115) AbstractHadoopRecoverableWriterITCase is hanging with timeout on AZP

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804136#comment-17804136 ] Sergey Nuyanzin commented on FLINK-33115: -

Re: [PR] [FLINK-34012][python] Fix mypy error [flink]

2024-01-07 Thread via GitHub
flinkbot commented on PR #24043: URL: https://github.com/apache/flink/pull/24043#issuecomment-1880440945 ## CI report: * 571f01449171798b8e88c8cbf38c875ef885bdc9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-33535) Support autoscaler for session jobs

2024-01-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33535. -- Resolution: Fixed merged to main 66e143362174491cef4b1d251b3fa21058fcf1c1 > Support autoscaler for

[jira] [Assigned] (FLINK-33535) Support autoscaler for session jobs

2024-01-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33535: -- Assignee: Gyula Fora > Support autoscaler for session jobs >

Re: [PR] [FLINK-33535] Support autoscaler for session jobs [flink-kubernetes-operator]

2024-01-07 Thread via GitHub
gyfora merged PR #739: URL: https://github.com/apache/flink-kubernetes-operator/pull/739 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34012: --- Labels: pull-request-available test-stability (was: test-stability) > Flink python fails

[jira] [Assigned] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-34012: Assignee: Xingbo Huang > Flink python fails with can't read file >

[PR] [FLINK-34012][python] Fix mypy error [flink]

2024-01-07 Thread via GitHub
HuangXingBo opened a new pull request, #24043: URL: https://github.com/apache/flink/pull/24043 ## What is the purpose of the change *This pull request will fix mypy error* ## Brief change log - *ignore google package import error* ## Verifying this

Re: [PR] [FLINK-33988][configuration] Fix the invalid configuration when using initialized root logger level on yarn deployment mode [flink]

2024-01-07 Thread via GitHub
flinkbot commented on PR #24042: URL: https://github.com/apache/flink/pull/24042#issuecomment-1880416774 ## CI report: * 09af1b68e8bf66b0c07c760f2c879c0a364469d4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
LadyForest commented on PR #24039: URL: https://github.com/apache/flink/pull/24039#issuecomment-1880416354 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
LadyForest commented on PR #24039: URL: https://github.com/apache/flink/pull/24039#issuecomment-1880416082 The CI failure is not relevant to the changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Updated] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33988: --- Labels: pull-request-available (was: ) > Invalid configuration when using initialized root

[PR] [FLINK-33988][configuration] Fix the invalid configuration when using initialized root logger level on yarn deployment mode [flink]

2024-01-07 Thread via GitHub
RocMarshal opened a new pull request, #24042: URL: https://github.com/apache/flink/pull/24042 ## What is the purpose of the change Fix the invalid configuration when using initialized root logger level on yarn deployment mode ## Brief change log - Fill the

Re: [PR] [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API [flink]

2024-01-07 Thread via GitHub
flinkbot commented on PR #24041: URL: https://github.com/apache/flink/pull/24041#issuecomment-1880408069 ## CI report: * 785c67752eaef9d7a13fdd48f613190c9e6ecb82 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34009) Apache flink: Checkpoint restoration issue on Application Mode of deployment

2024-01-07 Thread Vijay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804118#comment-17804118 ] Vijay commented on FLINK-34009: --- As flink support multi-job execution on Application mode of deployment

Re: [PR] [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API [flink]

2024-01-07 Thread via GitHub
yuchen-ecnu commented on PR #24041: URL: https://github.com/apache/flink/pull/24041#issuecomment-1880405288 Hi @Myasuka , do you have time to help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-33434) Support invoke async-profiler on Taskmanager through REST API

2024-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33434: --- Labels: pull-request-available (was: ) > Support invoke async-profiler on Taskmanager

[PR] [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API [flink]

2024-01-07 Thread via GitHub
yuchen-ecnu opened a new pull request, #24041: URL: https://github.com/apache/flink/pull/24041 ## What is the purpose of the change This is a subtask of [FLIP-375](https://cwiki.apache.org/confluence/x/64lEE), which introduces the async-profiler for profiling Jobmanager.

Re: [PR] [FLINK-33738][Scheduler] Make exponential-delay restart-strategy the default restart strategy [flink]

2024-01-07 Thread via GitHub
flinkbot commented on PR #24040: URL: https://github.com/apache/flink/pull/24040#issuecomment-1880359291 ## CI report: * 897dba2811c190461951040a2bd696fca4a18c88 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33738) Make exponential-delay restart-strategy the default restart strategy

2024-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33738: --- Labels: pull-request-available (was: ) > Make exponential-delay restart-strategy the

[jira] [Commented] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same sub project field.

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804102#comment-17804102 ] Jane Chan commented on FLINK-33996: --- I tend to agree with [~libenchao]. Splitting calc into two layers

[jira] [Created] (FLINK-34014) Jdbc connector can avoid send empty insert to database when there's no buffer data

2024-01-07 Thread luoyuxia (Jira)
luoyuxia created FLINK-34014: Summary: Jdbc connector can avoid send empty insert to database when there's no buffer data Key: FLINK-34014 URL: https://issues.apache.org/jira/browse/FLINK-34014 Project:

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2024-01-07 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804098#comment-17804098 ] Yao Zhang commented on FLINK-26760: --- Hi community, I got the same issue with Flink 1.15.4 when

Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink]

2024-01-07 Thread via GitHub
ljw-hit commented on code in PR #23323: URL: https://github.com/apache/flink/pull/23323#discussion_r1444139332 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigPbProtoToRowTest.java: ## @@ -82,9 +82,52 @@ public void testSimple() throws

Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink]

2024-01-07 Thread via GitHub
ljw-hit commented on code in PR #23323: URL: https://github.com/apache/flink/pull/23323#discussion_r1444139332 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigPbProtoToRowTest.java: ## @@ -82,9 +82,52 @@ public void testSimple() throws

[jira] [Commented] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same sub project field.

2024-01-07 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804093#comment-17804093 ] Benchao Li commented on FLINK-33996: Instead of solving this in optimization phase, I lean to solve

[jira] [Commented] (FLINK-34001) Fix ambiguous document description towards the default value for configuring operator-level state TTL

2024-01-07 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804092#comment-17804092 ] yong yang commented on FLINK-34001: --- left table is(tb1) 100/s input. and large id  not exists in

[jira] [Commented] (FLINK-33565) The concurrentExceptions doesn't work

2024-01-07 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804091#comment-17804091 ] Rui Fan commented on FLINK-33565: - Hey [~mapohl] , I have summited the PR[1] for this JIRA. I didn't

Re: [PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
flinkbot commented on PR #24039: URL: https://github.com/apache/flink/pull/24039#issuecomment-1880311788 ## CI report: * 0025867642132f37810d2abf6679a0cad3de3ea3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
xuyangzhong commented on PR #24039: URL: https://github.com/apache/flink/pull/24039#issuecomment-1880311358 LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Updated] (FLINK-34001) Fix ambiguous document description towards the default value for configuring operator-level state TTL

2024-01-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34001: --- Labels: pull-request-available (was: ) > Fix ambiguous document description towards the

[PR] [FLINK-34001][docs][table] Fix ambiguous document description towards the default value for configuring operator-level state TTL [flink]

2024-01-07 Thread via GitHub
LadyForest opened a new pull request, #24039: URL: https://github.com/apache/flink/pull/24039 ## What is the purpose of the change This is a trivial PR to eliminate the ambiguous description about the meaning of 0ms when configuring operator-level state TTL for SQL/TableAPI using

[jira] [Commented] (FLINK-34001) Fix ambiguous document description towards the default value for configuring operator-level state TTL

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804090#comment-17804090 ] xuyang commented on FLINK-34001: [~luca.yang] I guess what you want is that all( or part) data in

[jira] [Updated] (FLINK-34001) Fix ambiguous document description towards the default value for configuring operator-level state TTL

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34001: -- Summary: Fix ambiguous document description towards the default value for configuring operator-level

[jira] [Updated] (FLINK-34001) Fix ambiguous document descriptions towards the default value for configuring operator-level state TTL

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34001: -- Summary: Fix ambiguous document descriptions towards the default value for configuring operator-level

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804089#comment-17804089 ] yong yang commented on FLINK-34001: --- My dimension table has only a few million rows and is suitable

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804088#comment-17804088 ] yong yang commented on FLINK-34001: --- tb1 join tb2(dim table); The amount of data in tb1 is very large,

[jira] [Assigned] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan reassigned FLINK-34001: - Assignee: Jane Chan > doc of "Configure Operator-level State TTL" error >

[jira] [Updated] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34001: -- Issue Type: Improvement (was: Bug) > doc of "Configure Operator-level State TTL" error >

[jira] [Comment Edited] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804079#comment-17804079 ] Jane Chan edited comment on FLINK-34001 at 1/8/24 2:22 AM: --- Hi [~luca.yang]

[jira] [Comment Edited] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804079#comment-17804079 ] Jane Chan edited comment on FLINK-34001 at 1/8/24 2:22 AM: --- Hi [~luca.yang]

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804087#comment-17804087 ] xuyang commented on FLINK-34001: [~luca.yang] not to close it, but change the type to 'improvement' >

[jira] [Commented] (FLINK-33737) Merge multiple Exceptions into one attempt for exponential-delay restart-strategy

2024-01-07 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804086#comment-17804086 ] Rui Fan commented on FLINK-33737: - Merged to master(1.19) via : f9738d63391668396072570454fdc1eb61699098

[jira] [Resolved] (FLINK-33737) Merge multiple Exceptions into one attempt for exponential-delay restart-strategy

2024-01-07 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33737. - Resolution: Fixed > Merge multiple Exceptions into one attempt for exponential-delay >

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804085#comment-17804085 ] xuyang commented on FLINK-34001: [~luca.yang] Can you give a scenario as an example of why you want one

Re: [PR] [FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy [flink]

2024-01-07 Thread via GitHub
1996fanrui merged PR #23867: URL: https://github.com/apache/flink/pull/23867 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804083#comment-17804083 ] yong yang commented on FLINK-34001: --- ok.  its not a error. i will close jira. > doc of "Configure

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread yong yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804082#comment-17804082 ] yong yang commented on FLINK-34001: --- Two data streams, how to achieve one stream does not retain the

[jira] [Comment Edited] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804081#comment-17804081 ] xuyang edited comment on FLINK-34001 at 1/8/24 2:12 AM: [~qingyue] User may be

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804081#comment-17804081 ] xuyang commented on FLINK-34001: [~qingyue] User may be confused, and will think that "State retention

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

2024-01-07 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804080#comment-17804080 ] Benchao Li commented on FLINK-33611: [~dsaisharath] Thanks for the analysis and the effort trying to

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804079#comment-17804079 ] Jane Chan commented on FLINK-34001: --- Hi [~luca.yang] and [~xuyangzhong]; please correct me if I'm

[jira] [Commented] (FLINK-24024) Support session Window TVF

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804078#comment-17804078 ] xuyang commented on FLINK-24024: Hi, [~Sergey Nuyanzin] Would you like to review this pr? The pr is

[jira] [Commented] (FLINK-34001) doc of "Configure Operator-level State TTL" error

2024-01-07 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804076#comment-17804076 ] xuyang commented on FLINK-34001: [~luca.yang] Would you like to fix it? cc [~qingyue] for the double

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444114157 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/writer/ExactlyOnceJdbcWriterTest.java: ## @@ -0,0 +1,105 @@ +package

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444114075 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/writer/AlLeastOnceJdbcWriterTest.java: ## @@ -0,0 +1,88 @@ +package

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444113959 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JobSubtask.java: ## @@ -0,0 +1,50 @@ +package org.apache.flink.connector.jdbc.xa; +

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444113628 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/committer/JdbcCommitter.java: ## @@ -0,0 +1,62 @@ +package

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444113533 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/committer/JdbcCommitable.java: ## @@ -0,0 +1,39 @@ +package

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444113024 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/writer/JdbcWriterState.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-01-07 Thread via GitHub
snuyanzin commented on code in PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1444112306 ## pom.xml: ## @@ -47,7 +47,7 @@ under the License. -1.16.2 +1.18.0 Review Comment: Are we going to drop support for flink

[jira] [Commented] (FLINK-34013) ProfilingServiceTest.testRollingDeletion is unstable on AZP

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804073#comment-17804073 ] Sergey Nuyanzin commented on FLINK-34013: - I think it is related to FLINK-33433 [~Yu Chen],

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804071#comment-17804071 ] Sergey Nuyanzin commented on FLINK-22765: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804067#comment-17804067 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804070#comment-17804070 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804072#comment-17804072 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804065#comment-17804065 ] Sergey Nuyanzin commented on FLINK-31472: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804068#comment-17804068 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804066#comment-17804066 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804064#comment-17804064 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Commented] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804063#comment-17804063 ] Sergey Nuyanzin commented on FLINK-34012: -

[jira] [Created] (FLINK-34013) ProfilingServiceTest.testRollingDeletion is unstable on AZP

2024-01-07 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34013: --- Summary: ProfilingServiceTest.testRollingDeletion is unstable on AZP Key: FLINK-34013 URL: https://issues.apache.org/jira/browse/FLINK-34013 Project: Flink

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804062#comment-17804062 ] Sergey Nuyanzin commented on FLINK-22765: -

[jira] [Created] (FLINK-34012) Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google

2024-01-07 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34012: --- Summary: Flink python fails with can't read file '/__w/2/s/flink-python/dev/.conda/lib/python3.10/site-packages//google Key: FLINK-34012 URL:

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804061#comment-17804061 ] Sergey Nuyanzin commented on FLINK-31472: - 1.18:

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804060#comment-17804060 ] Sergey Nuyanzin commented on FLINK-22765: -

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804059#comment-17804059 ] Sergey Nuyanzin commented on FLINK-27756: -

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804058#comment-17804058 ] Sergey Nuyanzin commented on FLINK-22765: -

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2024-01-07 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804057#comment-17804057 ] Sergey Nuyanzin commented on FLINK-27756: -

  1   2   >