[GitHub] [flink] flinkbot edited a comment on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

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

[GitHub] [flink] flinkbot edited a comment on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

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

[GitHub] [flink] shenzhu commented on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

shenzhu commented on pull request #18926: URL: https://github.com/apache/flink/pull/18926#issuecomment-1053302845 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

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

[jira] [Updated] (FLINK-26336) Deletion should remove HA related configmaps also

[ https://issues.apache.org/jira/browse/FLINK-26336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26336: --- Labels: pull-request-available (was: ) > Deletion should remove HA related configmaps also

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

LadyForest commented on a change in pull request #23: URL: https://github.com/apache/flink-table-store/pull/23#discussion_r815399355 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/GlobalCommittingSinkTranslator.java #

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

LadyForest commented on a change in pull request #23: URL: https://github.com/apache/flink-table-store/pull/23#discussion_r815399269 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/GlobalCommittingSinkTranslator.java #

[GitHub] [flink] RocMarshal commented on a change in pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

RocMarshal commented on a change in pull request #18655: URL: https://github.com/apache/flink/pull/18655#discussion_r815380032 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -88,95 +86,101 @@ path ├── part-0.parquet ``` -The file system tabl

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

LadyForest commented on a change in pull request #23: URL: https://github.com/apache/flink-table-store/pull/23#discussion_r815396671 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/FileStorePathFactory.java ## @@ -130,7 +130,17 @@ pub

[jira] [Comment Edited] (FLINK-26358) Operator maxParallelism is lost during chaining

[ https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498532#comment-17498532 ] Shen Zhu edited comment on FLINK-26358 at 2/27/22, 6:38 AM:

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498534#comment-17498534 ] Thomas Weise commented on FLINK-26377: -- [~aitozi] please see [https://github.com/a

[jira] [Commented] (FLINK-26358) Operator maxParallelism is lost during chaining

[ https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498532#comment-17498532 ] Shen Zhu commented on FLINK-26358: -- Hi Fabian, I did some investigations about this is

[GitHub] [flink] flinkbot edited a comment on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

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

[GitHub] [flink] flinkbot commented on pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

flinkbot commented on pull request #18926: URL: https://github.com/apache/flink/pull/18926#issuecomment-1053107115 ## CI report: * 0acff08ec7d1397d4c2c9de23dfe4e92888161eb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26358) Operator maxParallelism is lost during chaining

[ https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26358: --- Labels: pull-request-available (was: ) > Operator maxParallelism is lost during chaining >

[GitHub] [flink] shenzhu opened a new pull request #18926: [FLINK-26358][Runtime / Coordination] Operator maxParallelism is lost during chaining

shenzhu opened a new pull request #18926: URL: https://github.com/apache/flink/pull/18926 ## What is the purpose of the change FLINK-26358: https://issues.apache.org/jira/browse/FLINK-26358 This pull request fixes the maxParallelism issue in operator chaining ## Brief ch

[jira] [Commented] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498523#comment-17498523 ] Thomas Weise commented on FLINK-26139: -- Good to see this, it is a basic requirement

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498493#comment-17498493 ] Fil Karnicki commented on FLINK-25866: -- Hi [~igal] I'm almost ready to make a pull

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

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

[jira] [Updated] (FLINK-26380) java.lang.IllegalStateException:Pending record count must be zero at this point: 5592

[ https://issues.apache.org/jira/browse/FLINK-26380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-26380: -- Summary: java.lang.IllegalStateException:Pending record count must be zero at this point: 5592

[jira] [Updated] (FLINK-26380) Exception:Pending record count must be zero at this point: 5592

[ https://issues.apache.org/jira/browse/FLINK-26380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-26380: -- Summary: Exception:Pending record count must be zero at this point: 5592 (was: Pending record

[jira] [Updated] (FLINK-26380) Pending record count must be zero at this point: 5592

[ https://issues.apache.org/jira/browse/FLINK-26380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-26380: -- Description: Hi,[~lzljs3620320], [~becket_qin] ,[~jark] . Help introduce students who are fam

[jira] [Created] (FLINK-26381) Wrong document order of Chinese version

tonny created FLINK-26381: - Summary: Wrong document order of Chinese version Key: FLINK-26381 URL: https://issues.apache.org/jira/browse/FLINK-26381 Project: Flink Issue Type: Bug Component

[jira] [Updated] (FLINK-26380) Pending record count must be zero at this point: 5592

[ https://issues.apache.org/jira/browse/FLINK-26380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fangliang Liu updated FLINK-26380: -- Affects Version/s: 1.13.2 > Pending record count must be zero at this point: 5592 > --

[jira] [Created] (FLINK-26380) Pending record count must be zero at this point: 5592

Fangliang Liu created FLINK-26380: - Summary: Pending record count must be zero at this point: 5592 Key: FLINK-26380 URL: https://issues.apache.org/jira/browse/FLINK-26380 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

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

[GitHub] [flink] MrWhiteSike commented on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

MrWhiteSike commented on pull request #18655: URL: https://github.com/apache/flink/pull/18655#issuecomment-1052030732 [@RocMarshal](https://github.com/RocMarshal) Thanks for the comments. Please review it again. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

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

[jira] [Updated] (FLINK-25452) FlinkKafkaProducerITCase.testRestoreUsingDifferentTransactionalIdPrefix failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25452: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots

[ https://issues.apache.org/jira/browse/FLINK-25939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25939: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-25448) TaskManagerRunnerTest.testShouldShutdownIfRegistrationWithJobManagerFails failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25448: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25938: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-22800) EXACTLY_ONCE KAFKA consumer (FLINK-6988) has not set isolation.level

[ https://issues.apache.org/jira/browse/FLINK-22800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22800: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor (wa

[jira] [Updated] (FLINK-22848) Deprecate unquoted options for SET / RESET

[ https://issues.apache.org/jira/browse/FLINK-22848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22848: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-23072) Add benchmarks for SQL internal and external serializers

[ https://issues.apache.org/jira/browse/FLINK-23072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23072: --- Labels: auto-deprioritized-major stale-minor starter (was: auto-deprioritized-major starter

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16908: --- Labels: auto-deprioritized-major stale-assigned test-stability (was: auto-deprioritized-maj

[GitHub] [flink] flinkbot edited a comment on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

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

[GitHub] [flink] snuyanzin commented on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

snuyanzin commented on pull request #17830: URL: https://github.com/apache/flink/pull/17830#issuecomment-1051796129 @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 specif