[GitHub] [flink] flinkbot edited a comment on pull request #17079: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible

flinkbot edited a comment on pull request #17079: URL: https://github.com/apache/flink/pull/17079#issuecomment-909337010 ## CI report: * a413c4c1bd4ae9251c5f5f8085afb66d7ffe2da2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 371e8744569d180669b538e27bcdd355914571a6 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

dmvk commented on a change in pull request #16941: URL: https://github.com/apache/flink/pull/16941#discussion_r700178988 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java ## @@ -61,13 +62,25 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

flinkbot edited a comment on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-907834154 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis`

[GitHub] [flink] flinkbot edited a comment on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

flinkbot edited a comment on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-851863905 ## CI report: * 104bc233bc2003180da19e9096c842141383066a UNKNOWN * 7a1fb1bc1c67ccc7889f95bf7ceba6561fbcd4e3 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #16941: [FLINK-23839][connectors-kafka] Give a more descriptive warnings on I…

dmvk commented on a change in pull request #16941: URL: https://github.com/apache/flink/pull/16941#discussion_r700175231 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -848,4 +848,9 @@ clash with the ones that have already been used by other

[GitHub] [flink] CrynetLogistics commented on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

CrynetLogistics commented on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-910238842 > ## CI report: > * [752c9db](https://github.com/apache/flink/commit/752c9db951f0ba3f26695b873b1f81dc6e830cab) Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

CrynetLogistics commented on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-910238479 > ## CI report: > * [752c9db](https://github.com/apache/flink/commit/752c9db951f0ba3f26695b873b1f81dc6e830cab) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17094: [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment

flinkbot edited a comment on pull request #17094: URL: https://github.com/apache/flink/pull/17094#issuecomment-910007555 ## CI report: * e90160213be511681039c4905a7fa8c0c634b67e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17097: [FLINK-24047][tests] Retry if leader election is in progress

flinkbot edited a comment on pull request #17097: URL: https://github.com/apache/flink/pull/17097#issuecomment-910200050 ## CI report: * 9b27cc0b4a03e389b297eb3325328bc73726042e UNKNOWN * 29fd058bb1bcb381b1b6d7420d5a019a56d67dda UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #17079: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible

flinkbot edited a comment on pull request #17079: URL: https://github.com/apache/flink/pull/17079#issuecomment-909337010 ## CI report: * a413c4c1bd4ae9251c5f5f8085afb66d7ffe2da2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17059: [FLINK-24005][coordination] Only return fulfilled requirements for reserved slots

flinkbot edited a comment on pull request #17059: URL: https://github.com/apache/flink/pull/17059#issuecomment-908449643 ## CI report: * fd7e7c85051ecbd38d4b1c3c2f1aa07c1e13e6ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

flinkbot edited a comment on pull request #17007: URL: https://github.com/apache/flink/pull/17007#issuecomment-906871869 ## CI report: * 9c73dcb14a05c4ba7991cad370d3fc1a7db3b642 Azure:

[jira] [Created] (FLINK-24104) incorrect validation of sink schema

Spongebob created FLINK-24104: - Summary: incorrect validation of sink schema Key: FLINK-24104 URL: https://issues.apache.org/jira/browse/FLINK-24104 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408138#comment-17408138 ] ming li commented on FLINK-24086: -   Hi, [~pnowojski], We implemented a new failover strategy (by

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408136#comment-17408136 ] Jark Wu commented on FLINK-24103: - An alternative (or more SQL standarnd compiliant way) can be using

[jira] [Commented] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408134#comment-17408134 ] Chesnay Schepler commented on FLINK-23983: -- Found this in one of the .dumpstream files:

[GitHub] [flink] dawidwys commented on a change in pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

dawidwys commented on a change in pull request #17055: URL: https://github.com/apache/flink/pull/17055#discussion_r700147535 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -450,7 +450,10 @@ private void

[GitHub] [flink] dmvk commented on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-910221417 @tillrohrmann I've addressed rest of your concerns. I think we should merge this after https://issues.apache.org/jira/browse/FLINK-24038 is fixed. WDYT? -- This is an automated

[jira] [Created] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

Timo Walther created FLINK-24103: Summary: Create time-based LAST_VALUE / FIRST_VALUE Key: FLINK-24103 URL: https://issues.apache.org/jira/browse/FLINK-24103 Project: Flink Issue Type:

[jira] [Closed] (FLINK-20131) Error when using LAST_VALUE on two different datatypes in same query with over window

[ https://issues.apache.org/jira/browse/FLINK-20131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20131. Resolution: Duplicate Should have been fixed in FLINK-21070. Please reopen if not. > Error when

[jira] [Closed] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23525. Fix Version/s: (was: 1.14.0) Resolution: Duplicate Let's assume this was also

[jira] [Updated] (FLINK-23794) InMemoryReporter leaks memory

[ https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23794: - Component/s: (was: Connectors / JDBC) Tests > InMemoryReporter

[jira] [Updated] (FLINK-23794) InMemoryReporter leaks memory

[ https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23794: - Summary: InMemoryReporter leaks memory (was: JdbcExactlyOnceSinkE2eTest JVM crash on

[jira] [Closed] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22885. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 1b764ceda4ac96f719c34aaa6ffb3d1e7dbf1f4a >

[GitHub] [flink] wuchong merged pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

wuchong merged pull request #16723: URL: https://github.com/apache/flink/pull/16723 -- 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:

[GitHub] [flink] wuchong commented on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

wuchong commented on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-910214808 The failed test is tracked by FLINK-24096. -- 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-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408120#comment-17408120 ] Till Rohrmann commented on FLINK-24091: --- I think the problem is that we restart the job before the

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408119#comment-17408119 ] Jark Wu commented on FLINK-24096: - Another instance:

[jira] [Closed] (FLINK-23415) Shade kryo library to reduce class conflict

[ https://issues.apache.org/jira/browse/FLINK-23415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23415. Resolution: Won't Fix Currently not possible. It is technically feasible, but not without

[jira] [Assigned] (FLINK-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24091: - Assignee: Till Rohrmann >

[jira] [Commented] (FLINK-23814) Test FLIP-143 KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408115#comment-17408115 ] Hang Ruan commented on FLINK-23814: --- Besides the normal situations as before, I add the logic to throw

[GitHub] [flink] dmvk commented on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-910211974 ZooKeeperLeaderElectionITCase is still flaky. I'm not sure if I can stabilize it without actually solving https://issues.apache.org/jira/browse/FLINK-24038 -- This is an

[GitHub] [flink] zentol merged pull request #17004: [docs] Fix small typo in ValueState Javadocs

zentol merged pull request #17004: URL: https://github.com/apache/flink/pull/17004 -- 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] [Closed] (FLINK-24025) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-24025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24025. Resolution: Information Provided > The components on which Flink depends may contain

[jira] [Updated] (FLINK-24044) Errors are output when compiling flink-runtime-web

[ https://issues.apache.org/jira/browse/FLINK-24044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24044: - Priority: Not a Priority (was: Minor) > Errors are output when compiling

[jira] [Updated] (FLINK-24044) Errors are output when compiling flink-runtime-web

[ https://issues.apache.org/jira/browse/FLINK-24044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24044: - Issue Type: Technical Debt (was: Bug) > Errors are output when compiling

[jira] [Updated] (FLINK-23859) Fix typos

[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23859: - Summary: Fix typos (was: [typo][flink-core][flink-connectors]fix typo for code ) >

[jira] [Updated] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code

[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23859: - Priority: Not a Priority (was: Minor) > [typo][flink-core][flink-connectors]fix typo

[jira] [Closed] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code

[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23859. Fix Version/s: 1.15.0 Assignee: wuguihu Resolution: Fixed >

[jira] [Updated] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code

[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23859: - Issue Type: Technical Debt (was: Improvement) >

[jira] [Updated] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code

[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23859: - Issue Type: Improvement (was: Bug) > [typo][flink-core][flink-connectors]fix typo for

[GitHub] [flink] zentol merged pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

zentol merged pull request #16878: URL: https://github.com/apache/flink/pull/16878 -- 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:

[GitHub] [flink] flinkbot commented on pull request #17097: [FLINK-24047][tests] Retry if leader election is in progress

flinkbot commented on pull request #17097: URL: https://github.com/apache/flink/pull/17097#issuecomment-910200050 ## CI report: * 9b27cc0b4a03e389b297eb3325328bc73726042e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

flinkbot edited a comment on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909842605 ## CI report: * 485a949b351a4df7a691740bcdf9f8e5e6e4a7f5 Azure:

[GitHub] [flink-statefun] igalshilman opened a new pull request #264: [FLINK-23964] Use shaded tcnative in dev docker image

igalshilman opened a new pull request #264: URL: https://github.com/apache/flink-statefun/pull/264 This PR adds Netty's shaded tcnative artifact and thus makes openssl available for Netty. It is a back port of https://github.com/apache/flink-statefun-docker/pull/16 -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

flinkbot edited a comment on pull request #17091: URL: https://github.com/apache/flink/pull/17091#issuecomment-909872649 ## CI report: * 3d07a044a408ce7ad03c9c90925e8fb7dc0b2014 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17059: [FLINK-24005][coordination] Only return fulfilled requirements for reserved slots

flinkbot edited a comment on pull request #17059: URL: https://github.com/apache/flink/pull/17059#issuecomment-908449643 ## CI report: * fd7e7c85051ecbd38d4b1c3c2f1aa07c1e13e6ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * 39b79177120026cfffd939e45fa0f9ee08ae77cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16995: [FLINK-22002][tests] Let taskmanager.slot.timeout fall back to akka.ask.timeout

flinkbot edited a comment on pull request #16995: URL: https://github.com/apache/flink/pull/16995#issuecomment-906282886 ## CI report: * c827323ae4472e4f8bd8a8e33d32ed240e9318db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9f2221ecfa1ee3020b8dd9be624bce434c62df41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * 6d61423f713c8db8a9f346fee37a56c16d8f8d14 Azure:

[jira] [Created] (FLINK-24102) unknown Fields error when flink doesn't recognize a field on protobuf

Gabriele Lorencini created FLINK-24102: -- Summary: unknown Fields error when flink doesn't recognize a field on protobuf Key: FLINK-24102 URL: https://issues.apache.org/jira/browse/FLINK-24102

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r700125061 ## File path: flink-clients/src/test/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrapITCase.java ## @@ -0,0 +1,149 @@ +/*

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r700124308 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -147,35 +147,41 @@

[GitHub] [flink] dmvk commented on a change in pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

dmvk commented on a change in pull request #17000: URL: https://github.com/apache/flink/pull/17000#discussion_r700122463 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -451,12 +451,23 @@ private void

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408101#comment-17408101 ] Yun Gao commented on FLINK-24096: - I should have found the reason, I'll open a PR for this issue~ >

[jira] [Closed] (FLINK-24087) Kafka connector StartupMode requires a table dependency

[ https://issues.apache.org/jira/browse/FLINK-24087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24087. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] twalthr closed pull request #17082: [FLINK-24087][connectors/kafka] Avoid importing table API class in DataStream API package

twalthr closed pull request #17082: URL: https://github.com/apache/flink/pull/17082 -- 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:

[GitHub] [flink-training] NicoK merged pull request #37: [hotfix] test imports wrong solution class

NicoK merged pull request #37: URL: https://github.com/apache/flink-training/pull/37 -- 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:

[GitHub] [flink] zentol commented on pull request #17095: Fix a variable name in the common.md

zentol commented on pull request #17095: URL: https://github.com/apache/flink/pull/17095#issuecomment-910177630 @liujqian It is usually a good idea to check whether a typo has been fixed on the master branch already. If so, then we can instead look into backport that fix to previous

[GitHub] [flink] zentol closed pull request #17095: Fix a variable name in the common.md

zentol closed pull request #17095: URL: https://github.com/apache/flink/pull/17095 -- 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:

[GitHub] [flink] zentol commented on pull request #17095: Fix a variable name in the common.md

zentol commented on pull request #17095: URL: https://github.com/apache/flink/pull/17095#issuecomment-910177208 I backported FLINK-22895 instead, which also fixed similar instances. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-22895) Example typo in "Table Concepts & Common API" page

[ https://issues.apache.org/jira/browse/FLINK-22895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22895: - Fix Version/s: 1.13.3 > Example typo in "Table Concepts & Common API" page >

[jira] [Commented] (FLINK-22895) Example typo in "Table Concepts & Common API" page

[ https://issues.apache.org/jira/browse/FLINK-22895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408094#comment-17408094 ] Chesnay Schepler commented on FLINK-22895: -- 1.13: b7f71ca75ee209fceef8199699387aa5c5bf6487  >

[GitHub] [flink] flinkbot edited a comment on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

flinkbot edited a comment on pull request #17089: URL: https://github.com/apache/flink/pull/17089#issuecomment-909842605 ## CI report: * 485a949b351a4df7a691740bcdf9f8e5e6e4a7f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16995: [FLINK-22002][tests] Let taskmanager.slot.timeout fall back to akka.ask.timeout

flinkbot edited a comment on pull request #16995: URL: https://github.com/apache/flink/pull/16995#issuecomment-906282886 ## CI report: * c827323ae4472e4f8bd8a8e33d32ed240e9318db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

flinkbot edited a comment on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 9f2221ecfa1ee3020b8dd9be624bce434c62df41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e32f648fe510d187688168a7d83828017fff5659 Azure:

[jira] [Updated] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24096: --- Component/s: (was: Table SQL / Planner) Runtime / Checkpointing >

[GitHub] [flink] flinkbot commented on pull request #17097: [FLINK-24047][tests] Retry if leader election is in progress

flinkbot commented on pull request #17097: URL: https://github.com/apache/flink/pull/17097#issuecomment-910166465 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-16428) Fine-grained network buffer management for backpressure

[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408092#comment-17408092 ] Piotr Nowojski commented on FLINK-16428: We are adding a new network memory tuning guide page as

[jira] [Updated] (FLINK-24047) SavepointITCase.testStopWithSavepointWithDrainCallsFinishBeforeSnapshotState fails due to 'Service temporarily unavailable due to an ongoing leader election.'

[ https://issues.apache.org/jira/browse/FLINK-24047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24047: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] zentol opened a new pull request #17097: [FLINK-24047][tests] Retry if leader election is in progress

zentol opened a new pull request #17097: URL: https://github.com/apache/flink/pull/17097 SavepointITCase#waitUntilAllTasksAreRunning is querying the REST API, but did not account for the possibility of requests failing due to leader elections being in progress. If the startup of the

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408090#comment-17408090 ] Piotr Nowojski commented on FLINK-24086: Thanks for reporting this. Can you share what code path

[jira] [Commented] (FLINK-24098) Document FLIP-147 capabiliites and limitations

[ https://issues.apache.org/jira/browse/FLINK-24098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408088#comment-17408088 ] Piotr Nowojski commented on FLINK-24098: A couple of comments from my side * UnionList * General

[GitHub] [flink] flinkbot edited a comment on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

flinkbot edited a comment on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473 ## CI report: * 64652a612587229163e00d740031f8b303308c86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 43d4529418e7acc1aeed1effd0d3bca44543671f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e32f648fe510d187688168a7d83828017fff5659 Azure:

[jira] [Assigned] (FLINK-24047) SavepointITCase.testStopWithSavepointWithDrainCallsFinishBeforeSnapshotState fails due to 'Service temporarily unavailable due to an ongoing leader election.'

[ https://issues.apache.org/jira/browse/FLINK-24047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24047: Assignee: Chesnay Schepler >

[GitHub] [flink] dawidwys commented on a change in pull request #17055: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to…

dawidwys commented on a change in pull request #17055: URL: https://github.com/apache/flink/pull/17055#discussion_r700081546 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1264,6 +1265,42 @@ public void

[GitHub] [flink] xuyangzhong commented on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression.

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

[jira] [Updated] (FLINK-23883) Follow up tasks and code improvements for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-23883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23883: - Description: This issue is an umbrella issue to tracking the remaining bug fix and code

[jira] [Updated] (FLINK-23883) Follow up tasks and code improvements for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-23883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23883: - Affects Version/s: (was: 1.14.0) > Follow up tasks and code improvements for

[GitHub] [flink] pnowojski commented on a change in pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

pnowojski commented on a change in pull request #17081: URL: https://github.com/apache/flink/pull/17081#discussion_r700070572 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -206,6 +206,7 @@ private void

[jira] [Assigned] (FLINK-24073) Statefun 2.2 documentation build fails on buildbot

[ https://issues.apache.org/jira/browse/FLINK-24073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24073: Assignee: Chesnay Schepler > Statefun 2.2 documentation build fails on buildbot

[GitHub] [flink] pnowojski commented on a change in pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

pnowojski commented on a change in pull request #17081: URL: https://github.com/apache/flink/pull/17081#discussion_r700070572 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ## @@ -206,6 +206,7 @@ private void

[GitHub] [flink] zoltar9264 commented on a change in pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

zoltar9264 commented on a change in pull request #16969: URL: https://github.com/apache/flink/pull/16969#discussion_r700069390 ## File path:

[GitHub] [flink] dmvk commented on a change in pull request #16989: [FLINK-23611][yarn-tests] Refactors yarn tests and enable hadoop logs

dmvk commented on a change in pull request #16989: URL: https://github.com/apache/flink/pull/16989#discussion_r699084138 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ## @@ -937,6 +937,7 @@ private static boolean

[GitHub] [flink] pnowojski commented on a change in pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

pnowojski commented on a change in pull request #16988: URL: https://github.com/apache/flink/pull/16988#discussion_r700061022 ## File path: docs/content/docs/deployment/memory/network_mem_tuning.md ## @@ -0,0 +1,160 @@ +--- +title: "Network Buffer Tuning" +weight: 100 +type:

[jira] [Commented] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408072#comment-17408072 ] Aitozi commented on FLINK-24063: [~trohrmann] I also meant to change the 

[jira] [Commented] (FLINK-23816) Test new (Kafka) metrics in cluster

[ https://issues.apache.org/jira/browse/FLINK-23816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408071#comment-17408071 ] Arvid Heise commented on FLINK-23816: - Hi [~hxb], we have updated docs and the connector. It's

[jira] [Resolved] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-23971. -- Resolution: Fixed PR merged to master: ad052cc056c7d6e63d8356dbd22d6a98b54743c3

[GitHub] [flink] flinkbot edited a comment on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

flinkbot edited a comment on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473 ## CI report: * 64652a612587229163e00d740031f8b303308c86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * 7946c81ed917e01c43cae2384bcc3986ec15e37b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17004: [docs] Fix small typo in ValueState Javadocs

flinkbot edited a comment on pull request #17004: URL: https://github.com/apache/flink/pull/17004#issuecomment-906643400 ## CI report: * ebb7e15012d7ff5cc247ac07a78cc5e5302ffc2f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 43d4529418e7acc1aeed1effd0d3bca44543671f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e32f648fe510d187688168a7d83828017fff5659 Azure:

[GitHub] [flink] pnowojski merged pull request #17078: [FLINK-23468][test] Do not hide original exception if SSL is not available

pnowojski merged pull request #17078: URL: https://github.com/apache/flink/pull/17078 -- 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:

[GitHub] [flink] becketqin commented on pull request #17049: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits

becketqin commented on pull request #17049: URL: https://github.com/apache/flink/pull/17049#issuecomment-910122414 Merged to master: ad052cc056c7d6e63d8356dbd22d6a98b54743c3 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

<    1   2   3   4   5   6   7   8   >