[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r701629220 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/architecture/Predicates.java ## @@ -0,0 +1,158

[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r701627771 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/architecture/ApiRules.java ## @@ -0,0 +1,93 @@

[GitHub] [flink] Airblader commented on a change in pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader commented on a change in pull request #17133: URL: https://github.com/apache/flink/pull/17133#discussion_r701627280 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/architecture/ArchitectureTests.java ## @@ -0,0 +1,100 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

flinkbot commented on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912300387 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

[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-912299502 Oh I missed that you were going to address your own commends! I have already made the changes already as well : ). I'll update with changes made from your comments! --

[jira] [Assigned] (FLINK-24120) The memory will rise a little after each savepoint ends

[ https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24120: - Assignee: Jiayi Liao > The memory will rise a little after each savepoint ends >

[GitHub] [flink] tillrohrmann commented on pull request #16994: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is…

tillrohrmann commented on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-912298675 @gaborgsomogyi do you have time to take a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-24138) Automated architectural tests

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

[GitHub] [flink] Airblader opened a new pull request #17133: [Proof of Concept][FLINK-24138] Architectural tests

Airblader opened a new pull request #17133: URL: https://github.com/apache/flink/pull/17133 ## What is the purpose of the change This is a proof of concept PR for investigating the idea of automating certain architectural tests and serves as a ground for discussion. I decided

[GitHub] [flink] SteNicholas commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r701624586 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -347,6 +375,7 @@ private

[GitHub] [flink] flinkbot commented on pull request #17132: [FLINK-24120] Add docs for using environment variable MALLOC_ARENA_MA…

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

[GitHub] [flink] lirui-apache commented on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

lirui-apache commented on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-912297884 Thanks @wuchong for taking care of this :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17124: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

flinkbot edited a comment on pull request #17124: URL: https://github.com/apache/flink/pull/17124#issuecomment-911685108 ## CI report: * 95d0f84847c20d6403db7cb702d25a8cceb4143e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17122: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

flinkbot edited a comment on pull request #17122: URL: https://github.com/apache/flink/pull/17122#issuecomment-911635840 ## CI report: * 081c7e401de258ffcd49bc5005ae37fe19708c92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17121: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

flinkbot edited a comment on pull request #17121: URL: https://github.com/apache/flink/pull/17121#issuecomment-911635717 ## CI report: * a1b116b1a8beddb4e8d9ce594dd59d2fdc1d67c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17117: [FLINK-24023][runtime-web] The names of metrics are incomplete

flinkbot edited a comment on pull request #17117: URL: https://github.com/apache/flink/pull/17117#issuecomment-911516830 ## CI report: * f3efff0d0df3652545e98e02ecd1b3dbfd3ba65f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * f4b4b598c81f921d1547f83c92ea12757573ad55 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 * cfe260b81d988558bb94554c04cf6bb0cd5f7003 UNKNOWN *

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

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701623456 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServicesTest.java ## @@ -0,0 +1,161 @@ +/* + *

[jira] [Created] (FLINK-24138) Automated architectural tests

Ingo Bürk created FLINK-24138: - Summary: Automated architectural tests Key: FLINK-24138 URL: https://issues.apache.org/jira/browse/FLINK-24138 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24138) Automated architectural tests

[ https://issues.apache.org/jira/browse/FLINK-24138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409305#comment-17409305 ] Ingo Bürk commented on FLINK-24138: --- I'm currently working on a draft for this. > Automated

[GitHub] [flink] SteNicholas commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r701622906 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -457,4 +486,79 @@ private void

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

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701622647 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -331,6 +331,22 @@

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

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701622420 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServicesTest.java ## @@ -0,0 +1,161 @@ +/* + *

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

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701452922 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServicesTest.java ## @@ -0,0 +1,161 @@ +/* + *

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

nicolasraga1 commented on a change in pull request #16946: URL: https://github.com/apache/flink/pull/16946#discussion_r701622517 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -148,7 +149,9 @@ private final

[GitHub] [flink] SteNicholas commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r700846480 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -457,4 +486,79 @@ private void

[jira] [Created] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

Dawid Wysakowicz created FLINK-24137: Summary: Python tests fail with "Exception in thread read_grpc_client_inputs" Key: FLINK-24137 URL: https://issues.apache.org/jira/browse/FLINK-24137

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

dawidwys commented on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-912292715 Let's wait for a green Azure and merge it. Could you please create a sub-task in https://issues.apache.org/jira/browse/FLINK-23883 listing the missing cases you are

[GitHub] [flink] dawidwys commented on a change in pull request #17103: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first on

dawidwys commented on a change in pull request #17103: URL: https://github.com/apache/flink/pull/17103#discussion_r701613277 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/IgnoreInFlightDataITCase.java ## @@ -68,13 +70,15 @@

[GitHub] [flink] leonardBang commented on pull request #17121: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

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

[GitHub] [flink] leonardBang commented on pull request #17124: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

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

[GitHub] [flink] leonardBang commented on pull request #17122: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

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

[jira] [Closed] (FLINK-23907) Type Migration: introducing primitive functional interfaces

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

[jira] [Updated] (FLINK-23907) Type Migration: introducing primitive functional interfaces

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

[GitHub] [flink] SteNicholas commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

SteNicholas commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r700844612 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -347,6 +375,7 @@ private

[GitHub] [flink] zentol merged pull request #16967: [FLINK-23907] Type Migration: introducing primitive functional interfaces

zentol merged pull request #16967: URL: https://github.com/apache/flink/pull/16967 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-15648) Support to configure limit for CPU and memory requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409292#comment-17409292 ] Yang Wang commented on FLINK-15648: --- [~nuculabs] I appreciate for your contribution and patience. If

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

gaoyunhaii commented on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-912286831 Hi @dawidwys~ the current tests are in good state from my side, we might enhance the tests to also cover cases like new source api / special state types in the future, but

[jira] [Commented] (FLINK-22859) Wordcount on Docker test (custom fs plugin) fails due to output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-22859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409289#comment-17409289 ] Chesnay Schepler commented on FLINK-22859: -- git failed: {code} fatal: unable to access

[GitHub] [flink] flinkbot commented on pull request #17132: [FLINK-24120] Add docs for using environment variable MALLOC_ARENA_MA…

flinkbot commented on pull request #17132: URL: https://github.com/apache/flink/pull/17132#issuecomment-912282996 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

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

[jira] [Updated] (FLINK-24120) The memory will rise a little after each savepoint ends

[ https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24120: --- Labels: pull-request-available (was: ) > The memory will rise a little after each

[GitHub] [flink] Jiayi-Liao opened a new pull request #17132: [FLINK-24120] Add docs for using environment variable MALLOC_ARENA_MA…

Jiayi-Liao opened a new pull request #17132: URL: https://github.com/apache/flink/pull/17132 ## What is the purpose of the change For users that uses `glibc` memory allocator and enables memory controlling, it's very easy to trigger the [glibc

[GitHub] [flink] flinkbot edited a comment on pull request #16870: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher

flinkbot edited a comment on pull request #16870: URL: https://github.com/apache/flink/pull/16870#issuecomment-900905170 ## CI report: * 1e812199f76d734bbd35740ae1a05bcce6424ab5 Azure:

[jira] [Commented] (FLINK-23433) Metrics cannot be initialized in format

[ https://issues.apache.org/jira/browse/FLINK-23433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409286#comment-17409286 ] Arvid Heise commented on FLINK-23433: - Maybe this was an issue in 1.11 (now unsupported) or is

<    1   2   3   4   5