[GitHub] [flink] nicolasraga1 commented on pull request #16946: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations

nicolasraga1 commented on pull request #16946: URL: https://github.com/apache/flink/pull/16946#issuecomment-907368750 Publish an amended commit with the requested changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405946#comment-17405946 ] Till Rohrmann commented on FLINK-23954: --- The fewer entries could be caused that we count the

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

flinkbot edited a comment on pull request #16575: URL: https://github.com/apache/flink/pull/16575#issuecomment-885295771 ## CI report: * e17fff1f519cb0b7e8f20dd97ff8d78a0f1391b5 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

fapaul commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r697377025 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/AbstractCommitterHandler.java ## @@ -19,18 +19,58 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 35e6540f3d6eb63811b1b4809889000cc217a7d9 Azure:

[jira] [Commented] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405922#comment-17405922 ] Till Rohrmann commented on FLINK-23954: --- This is very strange. In the logs it looks as if we are

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[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: * 9740204dd6b8740b09c3c0e5ff612c546522c267 Azure:

[jira] [Closed] (FLINK-23967) Remove scala references in OneInputStreamTaskTest

[ https://issues.apache.org/jira/browse/FLINK-23967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23967. Resolution: Fixed master: 2e8ab139dcdeb5ee6c89d844db1a09f3c8b1f4a6 > Remove scala

[GitHub] [flink] zentol merged pull request #16985: [FLINK-23967][tests] Remove Scala references in OneInputStreamTaskTest

zentol merged pull request #16985: URL: https://github.com/apache/flink/pull/16985 -- 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-23561) Detail the container completed message

[ https://issues.apache.org/jira/browse/FLINK-23561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23561. - Resolution: Fixed Fixed via 9049728c715c97c46b88f83d00dce339b5111839

[GitHub] [flink] tillrohrmann closed pull request #16847: [FLINK-23561][yarn]Detail the container completed message

tillrohrmann closed pull request #16847: URL: https://github.com/apache/flink/pull/16847 -- 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-23945) Cannot start the cluster using S3 as the file system

[ https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23945. - Fix Version/s: 1.13.3 1.12.6 1.14.0 Resolution:

[GitHub] [flink] tillrohrmann merged pull request #17018: [BP-1.12][FLINK-23945][docs] Correct S3 URI in K8s ha documentation

tillrohrmann merged pull request #17018: URL: https://github.com/apache/flink/pull/17018 -- 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] tillrohrmann merged pull request #17017: [BP-1.13][FLINK-23945][docs] Correct s3 URI in K8s ha documentation

tillrohrmann merged pull request #17017: URL: https://github.com/apache/flink/pull/17017 -- 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] tillrohrmann closed pull request #17016: [FLINK-23945][docs] Correct s3 URI in K8s ha documentation

tillrohrmann closed pull request #17016: URL: https://github.com/apache/flink/pull/17016 -- 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] tillrohrmann commented on pull request #17016: [FLINK-23945][docs] Correct s3 URI in K8s ha documentation

tillrohrmann commented on pull request #17016: URL: https://github.com/apache/flink/pull/17016#issuecomment-907335813 Thanks for the review @leonardBang. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-24015) Dispatcher does not log JobMaster initialization error on info level

[ https://issues.apache.org/jira/browse/FLINK-24015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24015. - Resolution: Fixed Fixed via 1.14.0: d7ef5a10fe54033592e7bc3a5e62e114ab1f8080 1.13.3:

[GitHub] [flink] tillrohrmann closed pull request #17013: [BP-1.13][FLINK-24015] Log failure cause of failed jobs on the Dispatcher

tillrohrmann closed pull request #17013: URL: https://github.com/apache/flink/pull/17013 -- 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] tillrohrmann closed pull request #17012: [FLINK-24015] Log failure cause of failed jobs on the Dispatcher

tillrohrmann closed pull request #17012: URL: https://github.com/apache/flink/pull/17012 -- 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] tillrohrmann commented on pull request #17013: [BP-1.13][FLINK-24015] Log failure cause of failed jobs on the Dispatcher

tillrohrmann commented on pull request #17013: URL: https://github.com/apache/flink/pull/17013#issuecomment-907332958 Thanks for the review @zentol. The test failure is unrelated. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405912#comment-17405912 ] Till Rohrmann commented on FLINK-20420: --- Another instance:

[GitHub] [flink] tillrohrmann commented on pull request #17012: [FLINK-24015] Log failure cause of failed jobs on the Dispatcher

tillrohrmann commented on pull request #17012: URL: https://github.com/apache/flink/pull/17012#issuecomment-907330667 Thanks for the review @zentol. 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

[GitHub] [flink] tillrohrmann commented on pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

tillrohrmann commented on pull request #16915: URL: https://github.com/apache/flink/pull/16915#issuecomment-907328516 I've updated this PR @zentol. What I effectively did is to introduce a `ServerConnection` class that encapsulates the logic for a pending and established

[jira] [Updated] (FLINK-23457) Sending the buffer of the right size for broadcast

[ https://issues.apache.org/jira/browse/FLINK-23457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23457: --- Labels: pull-request-available (was: ) > Sending the buffer of the right size for

[GitHub] [flink] flinkbot edited a comment on pull request #17023: [Hotfix][runtime] Reuse the code of 'check savepoint preconditions'.

flinkbot edited a comment on pull request #17023: URL: https://github.com/apache/flink/pull/17023#issuecomment-907189438 ## CI report: * fba8300874292568c3cdc723af1106f165fc9f31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * b86319824d4e8f11d8ad66658eb8297b3c12debf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * e2ca022e98686d0ffcf5bc61ac512cce6210b596 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 35e6540f3d6eb63811b1b4809889000cc217a7d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17009: [FLINK-23466][network] Fix the bug that buffer listeners may not be notified when recycling buffers

flinkbot edited a comment on pull request #17009: URL: https://github.com/apache/flink/pull/17009#issuecomment-906989802 ## CI report: * 163cda99f66d5a782b2d1ccb3364eebdbca64828 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint and final checkpoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 35e6540f3d6eb63811b1b4809889000cc217a7d9 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: * 1c8a52b99e58b4ed30a74e5a85bd75642d57f25e Azure:

[jira] [Commented] (FLINK-23600) Rework StateFun's remote module parsing and binding

[ https://issues.apache.org/jira/browse/FLINK-23600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405880#comment-17405880 ] Seth Wiesman commented on FLINK-23600: -- fixed in master: e1bb1518d309be62260f758b34c808eb90cb81e1

[GitHub] [flink-statefun] sjwiesman closed pull request #263: [FLINK-23600] [docs] Restructure module configuration docs

sjwiesman closed pull request #263: URL: https://github.com/apache/flink-statefun/pull/263 -- 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-statefun] sjwiesman commented on pull request #263: [FLINK-23600] [docs] Restructure module configuration docs

sjwiesman commented on pull request #263: URL: https://github.com/apache/flink-statefun/pull/263#issuecomment-907287311 As all my comments are grammar nits, I'm going to go ahead and apply them while merging. Thanks for your work on this! -- This is an automated message from the Apache

[GitHub] [flink] XComp commented on a change in pull request #16987: [FLINK-23968][tests] Remove unused code from TestBaseUtils

XComp commented on a change in pull request #16987: URL: https://github.com/apache/flink/pull/16987#discussion_r697524041 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java ## @@ -76,15 +68,8 @@ protected

[jira] [Comment Edited] (FLINK-24032) StreamSink does not receive periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405874#comment-17405874 ] Piotr Nowojski edited comment on FLINK-24032 at 8/27/21, 3:22 PM: -- This

[jira] [Comment Edited] (FLINK-24032) StreamSink does not receive periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405874#comment-17405874 ] Piotr Nowojski edited comment on FLINK-24032 at 8/27/21, 3:21 PM: -- This

[jira] [Closed] (FLINK-24032) StreamSink does not receive periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24032. -- Resolution: Not A Bug This is not a bug, but a case of an extreme backpressure. You have tiny

[jira] [Closed] (FLINK-23951) Add golang examples to playground

[ https://issues.apache.org/jira/browse/FLINK-23951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-23951. Resolution: Fixed > Add golang examples to playground > - > >

[jira] [Commented] (FLINK-23951) Add golang examples to playground

[ https://issues.apache.org/jira/browse/FLINK-23951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405873#comment-17405873 ] Seth Wiesman commented on FLINK-23951: -- resolved in dev: f09617426baf77e9d8354fdb779f7ccead524bf0

[GitHub] [flink-statefun-playground] sjwiesman closed pull request #12: [FLINK-23951] Add golang examples to playground

sjwiesman closed pull request #12: URL: https://github.com/apache/flink-statefun-playground/pull/12 -- 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,

[GitHub] [flink-statefun-playground] sjwiesman commented on pull request #12: [FLINK-23951] Add golang examples to playground

sjwiesman commented on pull request #12: URL: https://github.com/apache/flink-statefun-playground/pull/12#issuecomment-907279564 merged into dev -- 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

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #263: [FLINK-23600] [docs] Restructure module configuration docs

sjwiesman commented on a change in pull request #263: URL: https://github.com/apache/flink-statefun/pull/263#discussion_r697510518 ## File path: docs/content/docs/modules/http-endpoint.md ## @@ -0,0 +1,206 @@ +--- +title: 'HTTP Function Endpoint' +weight: 2 +type: docs +--- +

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

flinkbot edited a comment on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087 ## CI report: * f954017eb4d81acc1283bae464d7247bda38d904 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17021: [FLINK-24026][misc] Fix FLIP-XXX link can't be recognized correctly by IDEA

flinkbot edited a comment on pull request #17021: URL: https://github.com/apache/flink/pull/17021#issuecomment-907133687 ## CI report: * 2171e30cf0f9d68125d4afdfd5dacaeed441d2d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17011: [FLINK-23663][table-planner] Reduce state size of ChangelogNormalize

flinkbot edited a comment on pull request #17011: URL: https://github.com/apache/flink/pull/17011#issuecomment-907015222 ## CI report: * e13ee18ff9f927cb23c670236f83956873cfcc1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * dcacef3ba513cfbf327155c561288b8495e08653 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17009: [FLINK-23466][network] Fix the bug that buffer listeners may not be notified when recycling buffers

flinkbot edited a comment on pull request #17009: URL: https://github.com/apache/flink/pull/17009#issuecomment-906989802 ## CI report: * 111b579e0e6014d5bae5df4e4c72642ac32c5319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16990: [FLINK-23776][datastream] Optimize source metric calculation

flinkbot edited a comment on pull request #16990: URL: https://github.com/apache/flink/pull/16990#issuecomment-905813755 ## CI report: * 022379b1fe2d7f14991897b745d185f83e33393f UNKNOWN * 67df481df6fd8ce523d30ac287043527efe9baeb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16989: [FLINK-23611][yarn-tests] Refactors yarn tests and enable hadoop logs

flinkbot edited a comment on pull request #16989: URL: https://github.com/apache/flink/pull/16989#issuecomment-905813692 ## CI report: * e31501c3a9118aedfe5e98e4d08e04129ea17940 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16847: [FLINK-23561][yarn]Detail the container completed message

flinkbot edited a comment on pull request #16847: URL: https://github.com/apache/flink/pull/16847#issuecomment-899526800 ## CI report: * 771a380d56c1084fba88c426bdef02b9f0706dae UNKNOWN * 50864bf8e0b21bc06d7a5f5ebb63ec50fd3b6401 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: * 424c4076623b98ab84f56510310e538dc1eb4acb Azure:

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #31: [FLINK-23653] exercise and test rework

alpinegizmo commented on a change in pull request #31: URL: https://github.com/apache/flink-training/pull/31#discussion_r697512116 ## File path: common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java ## @@ -156,7 +156,9 @@ public int

[jira] [Commented] (FLINK-24030) PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits failed

[ https://issues.apache.org/jira/browse/FLINK-24030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405864#comment-17405864 ] Yufan Sheng commented on FLINK-24030: - [~pnowojski] This is a duplicated issue comparing to

[jira] [Updated] (FLINK-23984) 'Run kubernetes pyflink application test' fail with "Package 'python3.7' has no installation candidate"

[ https://issues.apache.org/jira/browse/FLINK-23984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23984: Fix Version/s: 1.13.3 1.12.6 > 'Run kubernetes pyflink application test' fail with

[jira] [Closed] (FLINK-23984) 'Run kubernetes pyflink application test' fail with "Package 'python3.7' has no installation candidate"

[ https://issues.apache.org/jira/browse/FLINK-23984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23984. --- Resolution: Fixed Fixed in: - master via 83987dd090b7fed0158e6ab952cdc8669e08d029 - release-1.13 via

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #263: [FLINK-23600] [docs] Restructure module configuration docs

sjwiesman commented on a change in pull request #263: URL: https://github.com/apache/flink-statefun/pull/263#discussion_r697486471 ## File path: docs/content/docs/modules/overview.md ## @@ -0,0 +1,66 @@ +--- +title: 'Overview' +weight: 1 +type: docs +aliases: + - /modules/

[GitHub] [flink] zhpgaokeji closed pull request #17026: Update and rename docs/content.zh/docs/dev/dataset/cluster_execution.…

zhpgaokeji closed pull request #17026: URL: https://github.com/apache/flink/pull/17026 -- 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] zhpgaokeji opened a new pull request #17026: Update and rename docs/content.zh/docs/dev/dataset/cluster_execution.…

zhpgaokeji opened a new pull request #17026: URL: https://github.com/apache/flink/pull/17026 …md to 文档/内容.zh/文档/开发/数据集/cluster_execution.md ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather

[jira] [Commented] (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:comment-tabpanel=17405857#comment-17405857 ] Chesnay Schepler commented on FLINK-24025: -- * commons-compress: FLINK-24034 * slf4j: Either

[GitHub] [flink] dianfu closed pull request #17014: [FLINK-23984][python][tests] Update test_kubernetes_pyflink_application to use conda to install Python

dianfu closed pull request #17014: URL: https://github.com/apache/flink/pull/17014 -- 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] [Created] (FLINK-24034) Upgrade commons-compress to 1.21

Chesnay Schepler created FLINK-24034: Summary: Upgrade commons-compress to 1.21 Key: FLINK-24034 URL: https://issues.apache.org/jira/browse/FLINK-24034 Project: Flink Issue Type:

[jira] [Updated] (FLINK-23996) Make Scala 2.12 default build target

[ https://issues.apache.org/jira/browse/FLINK-23996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23996: - Affects Version/s: (was: 1.13.2) (was: 1.12.5)

[jira] [Updated] (FLINK-23996) Make Scala 2.12 default build target

[ https://issues.apache.org/jira/browse/FLINK-23996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23996: - Affects Version/s: (was: 1.14.1) (was: 1.13.3)

[jira] [Updated] (FLINK-24033) Propagate unique keys for fromChangelogStream

[ https://issues.apache.org/jira/browse/FLINK-24033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24033: - Fix Version/s: 1.13.3 > Propagate unique keys for fromChangelogStream >

[jira] [Updated] (FLINK-24033) Propagate unique keys for fromChangelogStream

[ https://issues.apache.org/jira/browse/FLINK-24033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24033: - Fix Version/s: 1.14.0 > Propagate unique keys for fromChangelogStream >

[jira] [Updated] (FLINK-24033) Propagate unique keys for fromChangelogStream

[ https://issues.apache.org/jira/browse/FLINK-24033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24033: - Affects Version/s: 1.13.2 > Propagate unique keys for fromChangelogStream >

[jira] [Created] (FLINK-24033) Propagate unique keys for fromChangelogStream

Timo Walther created FLINK-24033: Summary: Propagate unique keys for fromChangelogStream Key: FLINK-24033 URL: https://issues.apache.org/jira/browse/FLINK-24033 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-24005) Resource requirements declaration may be incorrect if JobMaster disconnects with a TaskManager with available slots in the SlotPool

[ https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24005: Assignee: Chesnay Schepler > Resource requirements declaration may be incorrect

[GitHub] [flink] flinkbot edited a comment on pull request #17010: [FLINK-24003][python] Fix lookback mode doesn't work when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #17010: URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888 ## CI report: * 334937746f0388cbe54266784b23331675936e38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17009: [FLINK-23466][network] Fix the bug that buffer listeners may not be notified when recycling buffers

flinkbot edited a comment on pull request #17009: URL: https://github.com/apache/flink/pull/17009#issuecomment-906989802 ## CI report: * 111b579e0e6014d5bae5df4e4c72642ac32c5319 Azure:

[jira] [Assigned] (FLINK-24032) StreamSink does not receive periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24032: -- Assignee: Piotr Nowojski > StreamSink does not receive periodic watermarks >

[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: * 424c4076623b98ab84f56510310e538dc1eb4acb Azure:

[GitHub] [flink-statefun] igalshilman closed pull request #262: [hotfix] Add Java 11 profile to make StateFun work in IDEs (IntelliJ) that use JDK 11+

igalshilman closed pull request #262: URL: https://github.com/apache/flink-statefun/pull/262 -- 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-statefun] igalshilman commented on pull request #261: [hotfix][build] Add version for build helper plugin in statefun-protobuf-shaded

igalshilman commented on pull request #261: URL: https://github.com/apache/flink-statefun/pull/261#issuecomment-907225069 Thanks @StephanEwen! merged. -- 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] [Closed] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23049. -- Resolution: Cannot Reproduce As the test has changed and the issue waiting for _metadata file

[GitHub] [flink-statefun] igalshilman merged pull request #261: [hotfix][build] Add version for build helper plugin in statefun-protobuf-shaded

igalshilman merged pull request #261: URL: https://github.com/apache/flink-statefun/pull/261 -- 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-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Pérez updated FLINK-24031: Priority: Blocker (was: Major) > I am trying to deploy Flink in kubernetes but when I launch the

[jira] [Updated] (FLINK-24032) StreamSink does not receive periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24032: Description: In the following scenario, the sink will never receive watermarks    {code:java}

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24031: - Labels: (was: flink kubernetes) > I am trying to deploy Flink in kubernetes but when

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24031: - Language: (was: English english) > I am trying to deploy Flink in kubernetes but when

[jira] [Created] (FLINK-24032) StreamSink does not receive periodic watermarks

Fabian Paul created FLINK-24032: --- Summary: StreamSink does not receive periodic watermarks Key: FLINK-24032 URL: https://issues.apache.org/jira/browse/FLINK-24032 Project: Flink Issue Type:

[jira] [Commented] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405844#comment-17405844 ] Yingjie Cao commented on FLINK-23466: - Previously, the buffer listener will be removed from the

[GitHub] [flink] zentol commented on a change in pull request #17007: [FLINK-17495][metrics] Add additional variables config for metric reporters

zentol commented on a change in pull request #17007: URL: https://github.com/apache/flink/pull/17007#discussion_r697438721 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java ## @@ -116,6 +117,34 @@ public ReporterSetup( }

[jira] [Commented] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405842#comment-17405842 ] Roman Khachatryan commented on FLINK-23049: --- It seems unrelated to FLINK-23647: there, an

[GitHub] [flink] wsry commented on pull request #17009: [FLINK-23466][network] Fix the bug that buffer listeners may not be notified when recycling buffers

wsry commented on pull request #17009: URL: https://github.com/apache/flink/pull/17009#issuecomment-907216077 @pnowojski Thanks for the review and feedback. I have updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405838#comment-17405838 ] Roman Khachatryan commented on FLINK-23049: --- That function can stuck apparently when no

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Pérez updated FLINK-24031: Description:  I explain here -> https://github.com/apache/flink/pull/17020 I have a problem when

[jira] [Commented] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405839#comment-17405839 ] Piotr Nowojski commented on FLINK-23049: Isn't this related some somehow to FLINK-23647? >

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Pérez updated FLINK-24031: Description:  I explain here -> https://github.com/apache/flink/pull/17020 I have a problem when

[jira] [Created] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

Julio Pérez created FLINK-24031: --- Summary: I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception Key: FLINK-24031 URL:

[GitHub] [flink] pnowojski commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

pnowojski commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r697436574 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PrioritizedOperatorSubtaskState.java ## @@ -71,7 +75,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * b86319824d4e8f11d8ad66658eb8297b3c12debf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17023: [Hotfix][runtime] Reuse the code of 'check savepoint preconditions'.

flinkbot edited a comment on pull request #17023: URL: https://github.com/apache/flink/pull/17023#issuecomment-907189438 ## CI report: * fba8300874292568c3cdc723af1106f165fc9f31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23973] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * e2ca022e98686d0ffcf5bc61ac512cce6210b596 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17009: [FLINK-23466][network] Fix the bug that buffer listeners may not be notified when recycling buffers

flinkbot edited a comment on pull request #17009: URL: https://github.com/apache/flink/pull/17009#issuecomment-906989802 ## CI report: * 111b579e0e6014d5bae5df4e4c72642ac32c5319 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16959: [FLINK-23912] Remove unnecessary "Clearing resource requirements of job" in SlotManager

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

[GitHub] [flink] fapaul commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

fapaul commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r697362882 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedInitializationContext.java ## @@ -33,11 +35,16 @@ */ public interface

<    1   2   3   4   5   6   >