[GitHub] [flink] flinkbot edited a comment on pull request #19102: [FLINK-26652][runtime] Makes Flink cluster not fail in case of the cleanup retries being exhausted

flinkbot edited a comment on pull request #19102: URL: https://github.com/apache/flink/pull/19102#issuecomment-1068161025 ## CI report: * df9034e8981222f4cfa7c9c106b14ff3cea81a2a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19102: [FLINK-26652][runtime] Makes Flink cluster not fail in case of the cleanup retries being exhausted

flinkbot edited a comment on pull request #19102: URL: https://github.com/apache/flink/pull/19102#issuecomment-1068161025 ## CI report: * df9034e8981222f4cfa7c9c106b14ff3cea81a2a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] XComp commented on pull request #19102: [FLINK-26652][runtime] Makes Flink cluster not fail in case of the cleanup retries being exhausted

XComp commented on pull request #19102: URL: https://github.com/apache/flink/pull/19102#issuecomment-1068796110 I fixed the docs issue in the force push. Don't know why ci didn't pick it up 🤔 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] XComp commented on pull request #19102: [FLINK-26652][runtime] Makes Flink cluster not fail in case of the cleanup retries being exhausted

XComp commented on pull request #19102: URL: https://github.com/apache/flink/pull/19102#issuecomment-1068795921 @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 c

[jira] [Closed] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26030. - Resolution: Fixed Fixed via: master(1.16):  5bf4b072c31e799c91f171f0dcd56319728aec5a b95037b4d9c2be2e

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26030: -- Fix Version/s: 1.16.0 > Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers >

[GitHub] [flink] wangyang0918 merged pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

wangyang0918 merged pull request #18739: URL: https://github.com/apache/flink/pull/18739 -- 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: issues-un

[GitHub] [flink] wangyang0918 commented on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

wangyang0918 commented on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1068793090 Merging this PR now. -- 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 sp

[jira] [Updated] (FLINK-25648) Redundant to query deployment when creating task manager pods

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-25648: -- Fix Version/s: 1.16.0 > Redundant to query deployment when creating task manager pods > --

[jira] [Commented] (FLINK-25648) Redundant to query deployment when creating task manager pods

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507370#comment-17507370 ] Yang Wang commented on FLINK-25648: --- [~Yu.an] Thanks for your contribution. > Redunda

[jira] [Closed] (FLINK-25648) Redundant to query deployment when creating task manager pods

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-25648. - Resolution: Fixed Fixed via: master(1.16): 2691e0f9c2370b55a2e13215f75bcf8b3b53247b > Redundant to que

[GitHub] [flink] wangyang0918 commented on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

wangyang0918 commented on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1068786251 @maxCodeVector Maybe you need to add the email `yuan.hu...@bytedance.com` to your github account or use primary email of github so that your contributions could be account

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507368#comment-17507368 ] Lijie Wang commented on FLINK-26668: I know the code is the flink-tpcds-test module

[GitHub] [flink] wangyang0918 merged pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

wangyang0918 merged pull request #18854: URL: https://github.com/apache/flink/pull/18854 -- 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: issues-un

[GitHub] [flink] wangyang0918 commented on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

wangyang0918 commented on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1068784452 Merging this PR now. -- 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 sp

[jira] [Comment Edited] (FLINK-26663) Pod augmentation for the operator

[ https://issues.apache.org/jira/browse/FLINK-26663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507366#comment-17507366 ] Matyas Orhidi edited comment on FLINK-26663 at 3/16/22, 6:32 AM: -

[jira] [Updated] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work

[ https://issues.apache.org/jira/browse/FLINK-26672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RuiLin-Zhang updated FLINK-26672: - Description: I created a table structure {color:#ff}tabEnv.getConfig.getConfiguration.setSt

[jira] [Created] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work

RuiLin-Zhang created FLINK-26672: Summary: In Table/SQL API, Table configuration ' table.local-time-zone' does not work Key: FLINK-26672 URL: https://issues.apache.org/jira/browse/FLINK-26672 Project:

[jira] [Commented] (FLINK-26663) Pod augmentation for the operator

[ https://issues.apache.org/jira/browse/FLINK-26663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507366#comment-17507366 ] Matyas Orhidi commented on FLINK-26663: --- [~wangyang0918] yes, basically. It seems

[GitHub] [flink] hehuiyuan commented on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

hehuiyuan commented on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1068782445 Hi @wuchong , take a look when you are free. -- 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] [Assigned] (FLINK-26671) Update 'Developer Guide' in README

[ https://issues.apache.org/jira/browse/FLINK-26671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26671: -- Assignee: Biao Geng > Update 'Developer Guide' in README > --

[GitHub] [flink] gaoyunhaii closed pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

gaoyunhaii closed pull request #19097: URL: https://github.com/apache/flink/pull/19097 -- 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: issues-unsu

[GitHub] [flink] gaoyunhaii commented on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

gaoyunhaii commented on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1068775592 I'll first merge this PR since it should be a part of creating new branch. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Created] (FLINK-26671) Update 'Developer Guide' in README

Biao Geng created FLINK-26671: - Summary: Update 'Developer Guide' in README Key: FLINK-26671 URL: https://issues.apache.org/jira/browse/FLINK-26671 Project: Flink Issue Type: Sub-task C

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 91a5a156671f5b97479e9b284678912ace3ac51d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] zjureel commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1068766499 Thank you for your comments @xintongsong , ignore the tasks directly when the scheduled executor is shutdown is better, I have updated the test cases too. Please review them a

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 91a5a156671f5b97479e9b284678912ace3ac51d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26670) Rescaling api not working

Aarsh Shah created FLINK-26670: -- Summary: Rescaling api not working Key: FLINK-26670 URL: https://issues.apache.org/jira/browse/FLINK-26670 Project: Flink Issue Type: Bug Components: R

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507350#comment-17507350 ] kangTwang commented on FLINK-26668: --- [~wanglijie95] Code is the flink-tpcds-test modu

[GitHub] [flink] flinkbot edited a comment on pull request #19079: [FLINK-26573][test] Do not resolve the metadata file which is in prog…

flinkbot edited a comment on pull request #19079: URL: https://github.com/apache/flink/pull/19079#issuecomment-1066785702 ## CI report: * adec79c5f117baf8208159396747b1daaae5b8ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

flinkbot edited a comment on pull request #19101: URL: https://github.com/apache/flink/pull/19101#issuecomment-1068157547 ## CI report: * bf791e88442bcbe34f6dead59a37659958d47c09 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * 53b2ea4c4d17d6e195695aab4059ed676f3ee07b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * 183293c8d6cc788d92de34bc97c48784dc731acf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19095: [FLINK-26641] Optimize the time of fetching job status in the job submission of session cluster

flinkbot edited a comment on pull request #19095: URL: https://github.com/apache/flink/pull/19095#issuecomment-1067790182 ## CI report: * af186afde985d67d26ae04fff2aecc0a0a186aea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * 183293c8d6cc788d92de34bc97c48784dc731acf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507344#comment-17507344 ] Yang Wang commented on FLINK-26647: --- Hmm... What I mean is maybe we could also use sub

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * 361e719b3e2e37c27f54869ba77314c58c1c8bb8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

flinkbot edited a comment on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1067851691 ## CI report: * 1c525255b319cd4273f9ce3a255233b25855e5af Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

flinkbot edited a comment on pull request #19045: URL: https://github.com/apache/flink/pull/19045#issuecomment-1064089331 ## CI report: * d5a8084e6656702adbe1a9671e825a682a21beb3 UNKNOWN * 210bb6bf8056a880e9426addb5068179faebdc85 Azure: [SUCCESS](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18816: [FLINK-26027][pulsar] add sink metrics to pulsar sink

flinkbot edited a comment on pull request #18816: URL: https://github.com/apache/flink/pull/18816#issuecomment-1042851613 ## CI report: * 26366818f1c6a7b29ddb063414d1b3a2eaf34408 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18816: [FLINK-26027][pulsar] add sink metrics to pulsar sink

flinkbot edited a comment on pull request #18816: URL: https://github.com/apache/flink/pull/18816#issuecomment-1042851613 ## CI report: * 26366818f1c6a7b29ddb063414d1b3a2eaf34408 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26669) Refactor ReadWriteITCase and add more test cases

[ https://issues.apache.org/jira/browse/FLINK-26669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26669: -- Parent: FLINK-26653 Issue Type: Sub-task (was: Improvement) > Refactor ReadWriteITCase and ad

[jira] [Updated] (FLINK-26669) Refactor ReadWriteITCase and add more test cases

[ https://issues.apache.org/jira/browse/FLINK-26669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26669: -- Parent: (was: FLINK-26116) Issue Type: Improvement (was: Sub-task) > Refactor ReadWriteIT

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507332#comment-17507332 ] Lijie Wang commented on FLINK-26668: Thanks, [~kingWang]. Can you post the commit id

[GitHub] [flink] flinkbot edited a comment on pull request #19104: [FLINK-26395][docs] Correct the wrong description of RAND_INTEGER.

flinkbot edited a comment on pull request #19104: URL: https://github.com/apache/flink/pull/19104#issuecomment-1068655357 ## CI report: * df788c895ad1f8874813be696777520ef49776ef Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19105: fix hive statement issue

flinkbot edited a comment on pull request #19105: URL: https://github.com/apache/flink/pull/19105#issuecomment-1068702985 ## CI report: * 79b5481c04c3af319c9fc4146f8d7b36418a98aa Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingsongLi commented on pull request #19072: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

JingsongLi commented on pull request #19072: URL: https://github.com/apache/flink/pull/19072#issuecomment-1068703763 You can create a JIRA for updating document in: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/filesystem/ -- This is an automated m

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507330#comment-17507330 ] kangTwang commented on FLINK-26668: --- Hi [~wanglijie95] ,： _*client log：*_ org.apache

[GitHub] [flink] flinkbot commented on pull request #19105: fix hive statement issue

flinkbot commented on pull request #19105: URL: https://github.com/apache/flink/pull/19105#issuecomment-1068702985 ## CI report: * 79b5481c04c3af319c9fc4146f8d7b36418a98aa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-26669) Refactor ReadWriteITCase and add more test cases

[ https://issues.apache.org/jira/browse/FLINK-26669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26669: Assignee: Jane Chan > Refactor ReadWriteITCase and add more test cases >

[GitHub] [flink] luoyuxia opened a new pull request #19105: fix hive statement issue

luoyuxia opened a new pull request #19105: URL: https://github.com/apache/flink/pull/19105 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] flinkbot edited a comment on pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

flinkbot edited a comment on pull request #19054: URL: https://github.com/apache/flink/pull/19054#issuecomment-1064837015 ## CI report: * 7d95b4714a85b0435ef78757e200c2ba92ee22e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26669) Refactor ReadWriteITCase and add more test cases

Jane Chan created FLINK-26669: - Summary: Refactor ReadWriteITCase and add more test cases Key: FLINK-26669 URL: https://issues.apache.org/jira/browse/FLINK-26669 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] flinkbot edited a comment on pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

flinkbot edited a comment on pull request #19054: URL: https://github.com/apache/flink/pull/19054#issuecomment-1064837015 ## CI report: * 7d95b4714a85b0435ef78757e200c2ba92ee22e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingsongLi commented on a change in pull request #19072: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

JingsongLi commented on a change in pull request #19072: URL: https://github.com/apache/flink/pull/19072#discussion_r827599320 ## File path: flink-filesystems/flink-fs-common/pom.xml ## @@ -0,0 +1,42 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http:/

[GitHub] [flink] JingsongLi commented on a change in pull request #19072: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

JingsongLi commented on a change in pull request #19072: URL: https://github.com/apache/flink/pull/19072#discussion_r827599320 ## File path: flink-filesystems/flink-fs-common/pom.xml ## @@ -0,0 +1,42 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http:/

[GitHub] [flink] flinkbot edited a comment on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

flinkbot edited a comment on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1067851691 ## CI report: * 1c525255b319cd4273f9ce3a255233b25855e5af Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

flinkbot edited a comment on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1067851691 ## CI report: * 1c525255b319cd4273f9ce3a255233b25855e5af Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] gaoyunhaii commented on pull request #19097: [hotfix][release] Add 1.16 to the flink versions enum

gaoyunhaii commented on pull request #19097: URL: https://github.com/apache/flink/pull/19097#issuecomment-1068696046 @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 speci

[GitHub] [flink] imaffe commented on a change in pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

imaffe commented on a change in pull request #19099: URL: https://github.com/apache/flink/pull/19099#discussion_r827590927 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/sink/PulsarSinkTestContext.java ## @@ -0,0

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507328#comment-17507328 ] Lijie Wang commented on FLINK-26668: Thanks for feedback [~kingWang]. Can you post y

[GitHub] [flink] JingsongLi commented on a change in pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

JingsongLi commented on a change in pull request #19007: URL: https://github.com/apache/flink/pull/19007#discussion_r827592695 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/hint/OptionsHintTest.scala ## @@ -142,9 +143,12 @@ cl

[jira] [Commented] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

[ https://issues.apache.org/jira/browse/FLINK-26650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507326#comment-17507326 ] Yun Tang commented on FLINK-26650: -- merged in release-1.14: b2ff6543e6c2a6b6c6710281915

[jira] [Updated] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

[ https://issues.apache.org/jira/browse/FLINK-26650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26650: - Fix Version/s: 1.14.5 > Avoid to print stack trace for checkpoint trigger failure if not all tasks > ar

[GitHub] [flink] Myasuka commented on a change in pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

Myasuka commented on a change in pull request #19033: URL: https://github.com/apache/flink/pull/19033#discussion_r827588561 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -135,14 +146,16 @@ public void setup() throws Exce

[jira] [Commented] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507322#comment-17507322 ] kangTwang commented on FLINK-26668: --- Hi [~wanglijie95] , can you confirm this problem?

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507321#comment-17507321 ] Zhe Wang commented on FLINK-26647: -- Thanks, solved. > Can not add extra config files o

[jira] [Closed] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhe Wang closed FLINK-26647. Resolution: Not A Problem > Can not add extra config files on native Kubernetes > ---

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: aaa.jpg > Unsupportedoperation exception caused by createActualEdge error in adaptive > b

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: (was: aaa.jpg) > Unsupportedoperation exception caused by createActualEdge error in ad

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Description: In the AdaptiveBatch TPC DS test, the following error messages appear when executing que

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: bbb.jpg > Unsupportedoperation exception caused by createActualEdge error in adaptive > b

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: (was: image-2022-03-16-10-57-03-419.png) > Unsupportedoperation exception caused by cr

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: (was: aaa-1.jpg) > Unsupportedoperation exception caused by createActualEdge error in

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Description: In the AdaptiveBatch TPC DS test, the following error messages appear when executing que

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Description: In the AdaptiveBatch TPC DS test, the following error messages appear when executing que

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: aaa.jpg > Unsupportedoperation exception caused by createActualEdge error in adaptive > b

[jira] [Created] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

kangTwang created FLINK-26668: - Summary: Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler Key: FLINK-26668 URL: https://issues.apache.org/jira/browse/FLINK-26668

[jira] [Updated] (FLINK-26668) Unsupportedoperation exception caused by createActualEdge error in adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-26668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kangTwang updated FLINK-26668: -- Attachment: (was: image-2022-03-16-10-57-19-617.png) > Unsupportedoperation exception caused by cr

[GitHub] [flink] imaffe edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

imaffe edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1068681213 I noticed that I - misuse of `The` - used lots of `would` - like to use passive voice - like to use long sentences and clauses - etc.. I'll avoid thes

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 957bd751af7febd48c2ef941ce78a8d2c49f40c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] imaffe commented on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

imaffe commented on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1068681213 I noticed that I - misuse of `The` - used lot of `would` - like to use passive voice - like to use long sentences and clauses - etc.. I'll avoid these next t

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 957bd751af7febd48c2ef941ce78a8d2c49f40c7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] JingsongLi commented on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

JingsongLi commented on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1068679010 Thanks @LadyForest for the contribution, can you add a case: - create view1 - create view2 select ... from view1 /** dynamic table hints .*/; Explain sel

[jira] [Commented] (FLINK-26663) Pod augmentation for the operator

[ https://issues.apache.org/jira/browse/FLINK-26663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507315#comment-17507315 ] Yang Wang commented on FLINK-26663: --- Since we recommend users to install the flink-kub

[GitHub] [flink] leonardBang commented on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

leonardBang commented on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1068677894 -- 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 uns

[jira] [Created] (FLINK-26667) Improve the error message that the declared type of UDF is inconsistent with the actual return type

Huang Xingbo created FLINK-26667: Summary: Improve the error message that the declared type of UDF is inconsistent with the actual return type Key: FLINK-26667 URL: https://issues.apache.org/jira/browse/FLINK-2666

[jira] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647 ] Zhe Wang deleted comment on FLINK-26647: -- was (Author: JIRAUSER286605): [~aitozi] [~wangyang0918]  I`m using a  custom image too, the "/opt/flink/conf"  path is mounted to volume (naming "flink

[jira] [Commented] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507311#comment-17507311 ] Yang Wang commented on FLINK-26655: --- We might need to rethink the timeout then. Otherw

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507312#comment-17507312 ] Zhe Wang commented on FLINK-26647: -- [~aitozi] [~wangyang0918]  I`m using a  custom imag

[jira] [Comment Edited] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507309#comment-17507309 ] Yang Wang edited comment on FLINK-26647 at 3/16/22, 2:44 AM: -

[jira] [Created] (FLINK-26666) Improve the error message of pyflink and flink version mismatch

Huang Xingbo created FLINK-2: Summary: Improve the error message of pyflink and flink version mismatch Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

flinkbot edited a comment on pull request #19101: URL: https://github.com/apache/flink/pull/19101#issuecomment-1068157547 ## CI report: * c398925014da512620ba112771877d6807a1e2f3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

flinkbot edited a comment on pull request #19101: URL: https://github.com/apache/flink/pull/19101#issuecomment-1068157547 ## CI report: * c398925014da512620ba112771877d6807a1e2f3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507309#comment-17507309 ] Yang Wang commented on FLINK-26647: --- The original design is to mount "flink-conf.yaml"

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * dc7a98116e2eb27de5f4c5a385aa6f71d5b12b70 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] imaffe commented on a change in pull request #19092: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

imaffe commented on a change in pull request #19092: URL: https://github.com/apache/flink/pull/19092#discussion_r827574474 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java ## @@ -5

[jira] [Commented] (FLINK-26539) Support dynamic partial features update in Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-26539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507308#comment-17507308 ] Jingsong Lee commented on FLINK-26539: -- CC: [~ym]  > Support dynamic partial featu

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * dc7a98116e2eb27de5f4c5a385aa6f71d5b12b70 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] masteryhx commented on a change in pull request #19079: [FLINK-26573][test] Do not resolve the metadata file which is in prog…

masteryhx commented on a change in pull request #19079: URL: https://github.com/apache/flink/pull/19079#discussion_r827574126 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationTestBase.java ## @@ -234,6 +235,25 @@ prote

  1   2   3   4   5   6   >