[GitHub] [flink-connector-opensearch] boring-cyborg[bot] commented on pull request #14: [hotfix] Update flink, flink-shaded, archunit

boring-cyborg[bot] commented on PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#issuecomment-1496956606 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-connector-opensearch] snuyanzin merged pull request #14: [hotfix] Update flink, flink-shaded, archunit

snuyanzin merged PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14 -- 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-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1

[ https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31724: Priority: Critical (was: Major) > SqlClientITCase.testMatchRecognize fails with "bash -c

[jira] [Updated] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1

[ https://issues.apache.org/jira/browse/FLINK-31724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-31724: Labels: test-stability (was: ) > SqlClientITCase.testMatchRecognize fails with "bash -c

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

mas-chen commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1158044725 ## flink-formats-confluent/flink-avro-confluent-registry/pom.xml: ## @@ -0,0 +1,184 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

mas-chen commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1158044388 ## flink-formats-confluent/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactory.java:

[GitHub] [flink-connector-opensearch] snuyanzin commented on pull request #14: [hotfix] Update flink, flink-shaded, archunit

snuyanzin commented on PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#issuecomment-1496945665 looks like nightly failure relates to archunt changes, should be fixed with archunit config change done within this PR -- This is an automated message from the Apache

[GitHub] [flink-connector-opensearch] snuyanzin commented on a diff in pull request #14: [hotfix] Update flink, flink-shaded, archunit

snuyanzin commented on code in PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#discussion_r1158043671 ## pom.xml: ## @@ -58,12 +58,13 @@ under the License. - 1.16.1 - 15.0 + 1.17.0 +

[GitHub] [flink] flinkbot commented on pull request #22353: [FLINK-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs

flinkbot commented on PR #22353: URL: https://github.com/apache/flink/pull/22353#issuecomment-1496937031 ## CI report: * 0161f9e216b37f8c47322b9dfad54522c569ea73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31320) Modify DATE_FORMAT system (built-in) function to accepts DATEs

[ https://issues.apache.org/jira/browse/FLINK-31320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31320: --- Labels: pull-request-available (was: ) > Modify DATE_FORMAT system (built-in) function to

[GitHub] [flink] clownxc opened a new pull request, #22353: [FLINK-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs

clownxc opened a new pull request, #22353: URL: https://github.com/apache/flink/pull/22353 ## What is the purpose of the change The current DATE_FORMAT function only supports TIMESTAMPs. Ideally, it should be able to format DATE's as well as TIMESTAMPs. Like Spark DATE_FORMAT

[jira] [Assigned] (FLINK-31636) Upstream supports reading buffers from tiered store

[ https://issues.apache.org/jira/browse/FLINK-31636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31636: - Assignee: Wencong Liu > Upstream supports reading buffers from tiered store >

[GitHub] [flink-connector-pulsar] tisonkun opened a new pull request, #42: [hotfix] Improve CI trigger and cancel strategy

tisonkun opened a new pull request, #42: URL: https://github.com/apache/flink-connector-pulsar/pull/42 Avoid main branch CI jobs being canceled. -- 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] flinkbot commented on pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

flinkbot commented on PR #22352: URL: https://github.com/apache/flink/pull/22352#issuecomment-1496914217 ## CI report: * 45012e9dc367a09fcc21ce668265c0f80af2c35a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31639) Introduce tiered store memory manager

[ https://issues.apache.org/jira/browse/FLINK-31639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31639: --- Labels: pull-request-available (was: ) > Introduce tiered store memory manager >

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22352: [FLINK-31639][network] Introduce tiered store memory manager

TanYuxin-tyx opened a new pull request, #22352: URL: https://github.com/apache/flink/pull/22352 ## What is the purpose of the change *We should introduce a new manager to manage the memory of the tiered store. The change introduces `TieredStoreMemoryManager` and

[jira] [Assigned] (FLINK-31639) Introduce tiered store memory manager

[ https://issues.apache.org/jira/browse/FLINK-31639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31639: - Assignee: Yuxin Tan > Introduce tiered store memory manager >

[jira] [Commented] (FLINK-31699) JDBC nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708640#comment-17708640 ] Hang Ruan commented on FLINK-31699: --- Thanks for suggestions. Actually I apply the changes in PR#31 and

[GitHub] [flink] Samrat002 commented on a diff in pull request #22308: [FLINK-31518][Runtime / REST] Fix StandaloneHaServices#getClusterRestEndpointLeaderRetreiver to return correct rest port

Samrat002 commented on code in PR #22308: URL: https://github.com/apache/flink/pull/22308#discussion_r1157953690 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneHaServices.java: ## @@ -134,9 +136,13 @@ public

[jira] [Created] (FLINK-31732) flink-ml-uber module should include statefun as a dependency

Zhipeng Zhang created FLINK-31732: - Summary: flink-ml-uber module should include statefun as a dependency Key: FLINK-31732 URL: https://issues.apache.org/jira/browse/FLINK-31732 Project: Flink

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708631#comment-17708631 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] This ticket is open because we have not updated

[GitHub] [flink-kubernetes-operator] HuangZhenQiu commented on a diff in pull request #561: [FLINK-30609] Add ephemeral storage to CRD

HuangZhenQiu commented on code in PR #561: URL: https://github.com/apache/flink-kubernetes-operator/pull/561#discussion_r1157873527 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -391,31 +399,87 @@ private

[jira] [Comment Edited] (FLINK-31593) Update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708612#comment-17708612 ] Roman Khachatryan edited comment on FLINK-31593 at 4/4/23 11:28 PM:

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708612#comment-17708612 ] Roman Khachatryan commented on FLINK-31593: --- [~mapohl] I looked into

[GitHub] [flink-kubernetes-operator] HuangZhenQiu commented on a diff in pull request #561: [FLINK-30609] Add ephemeral storage to CRD

HuangZhenQiu commented on code in PR #561: URL: https://github.com/apache/flink-kubernetes-operator/pull/561#discussion_r1157758601 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -391,31 +399,87 @@ private

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

tzulitai commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1157803740 ## flink-formats-confluent/pom.xml: ## @@ -0,0 +1,41 @@ + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

tzulitai commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r115291 ## docs/content.zh/docs/connectors/table/formats/avro-confluent.md: ## Review Comment: Does the "Debezium" format docs need to be migrated here as

[jira] [Closed] (FLINK-31716) Event UID field is missing the first time that an event is consumed

[ https://issues.apache.org/jira/browse/FLINK-31716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-31716. -- Fix Version/s: kubernetes-operator-1.5.0 Resolution: Fixed 658ad63 in main > Event

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #560: [FLINK-31716] Event UID field is missing the first time that an event…

mbalassi merged PR #560: URL: https://github.com/apache/flink-kubernetes-operator/pull/560 -- 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-kubernetes-operator] HuangZhenQiu commented on a diff in pull request #561: [FLINK-30609] Add ephemeral storage to CRD

HuangZhenQiu commented on code in PR #561: URL: https://github.com/apache/flink-kubernetes-operator/pull/561#discussion_r1157758601 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java: ## @@ -391,31 +399,87 @@ private

[GitHub] [flink] aristofun commented on pull request #22291: [FLINK-31632] maxAllowedWatermark overflow

aristofun commented on PR #22291: URL: https://github.com/apache/flink/pull/22291#issuecomment-1496586609 Hi there. Thanks for your amazing work and fixing this. Any ETA when can it get into 1.16 branch? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-connector-opensearch] MartijnVisser commented on pull request #14: [hotfix] Update flink, flink-shaded, archunit

MartijnVisser commented on PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#issuecomment-1496498492 > I am wondering if you or @dannycranmer could trigger Nightly GA manually to check that? I've just done so at

[jira] [Commented] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708551#comment-17708551 ] Tzu-Li (Gordon) Tai commented on FLINK-31731: - We'll piggy-back the fix for this as part of

[jira] [Created] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

Martijn Visser created FLINK-31731: -- Summary: No suitable constructor found for DebeziumAvroSerializationSchema Key: FLINK-31731 URL: https://issues.apache.org/jira/browse/FLINK-31731 Project: Flink

[jira] [Updated] (FLINK-31731) No suitable constructor found for DebeziumAvroSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-31731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31731: --- Priority: Critical (was: Major) > No suitable constructor found for

[GitHub] [flink] Samrat002 commented on pull request #22226: [FLINK-31214][python] Add support for new cli option -py.pythonpath

Samrat002 commented on PR #6: URL: https://github.com/apache/flink/pull/6#issuecomment-1496473392 thanks for reviewing the changes. i have made changes as per previous review comments. can you please review whenever time . @dannycranmer -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #22351: [FLINK-17337][table] Support emitting UPDATE_BEFORE and UPDATE_AFTER records in streaming LEFT/RIGHT/FULL OUTER JOIN

flinkbot commented on PR #22351: URL: https://github.com/apache/flink/pull/22351#issuecomment-1496432760 ## CI report: * 83d7c54a3823200d43720560d3dbe9306f86bcc1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

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

[GitHub] [flink] SmirAlex opened a new pull request, #22351: [FLINK-17337][table] Support emitting UPDATE_BEFORE and UPDATE_AFTER records in streaming LEFT/RIGHT/FULL OUTER JOIN

SmirAlex opened a new pull request, #22351: URL: https://github.com/apache/flink/pull/22351 ## What is the purpose of the change This pull request adds a support of emitting UPDATE_BEFORE and UPDATE_AFTER records in streaming LEFT/RIGHT/FULL OTHER JOIN. Previously, we explicitly

[jira] [Closed] (FLINK-31624) [Connectors/Jdbc] Update flink to 1.17.0

[ https://issues.apache.org/jira/browse/FLINK-31624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31624. -- Resolution: Duplicate > [Connectors/Jdbc] Update flink to 1.17.0 >

[GitHub] [flink-connector-jdbc] MartijnVisser closed pull request #30: [FLINK-31624] Bump Flink version to 1.17.0

MartijnVisser closed pull request #30: [FLINK-31624] Bump Flink version to 1.17.0 URL: https://github.com/apache/flink-connector-jdbc/pull/30 -- 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-connector-jdbc] MartijnVisser commented on pull request #30: [FLINK-31624] Bump Flink version to 1.17.0

MartijnVisser commented on PR #30: URL: https://github.com/apache/flink-connector-jdbc/pull/30#issuecomment-1496367838 @eskabetxe Thanks, but this has been superseded by https://github.com/apache/flink-connector-jdbc/pull/37 -- This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-31699) JDBC nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31699. -- Fix Version/s: jdbc-3.1.0 Resolution: Fixed Fixed in main:

[GitHub] [flink-connector-jdbc] MartijnVisser merged pull request #37: [FLINK-31699] Fix JDBC nightly CI failure

MartijnVisser merged PR #37: URL: https://github.com/apache/flink-connector-jdbc/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-connector-kafka] MartijnVisser merged pull request #21: [hotfix] Correct and/or synchronize multiple dependencies/versions

MartijnVisser merged PR #21: URL: https://github.com/apache/flink-connector-kafka/pull/21 -- 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-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708518#comment-17708518 ] Martijn Visser commented on FLINK-25509: [~ruanhang1993] [~lindong] This ticket is currently

[jira] [Created] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

Zhenqiu Huang created FLINK-31730: - Summary: Support Ephemeral Storage in KubernetesConfigOptions Key: FLINK-31730 URL: https://issues.apache.org/jira/browse/FLINK-31730 Project: Flink Issue

[jira] [Commented] (FLINK-31487) Add targetColumns to DynamicTableSink#Context

[ https://issues.apache.org/jira/browse/FLINK-31487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708514#comment-17708514 ] Martijn Visser commented on FLINK-31487: [~lincoln.86xy] Is this breaking existing connectors?

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't

[jira] [Updated] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

[ https://issues.apache.org/jira/browse/FLINK-31729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Smirnov updated FLINK-31729: -- Description: Currently, in streaming LEFT/RIGHT/FULL OUTER JOIN Flink SQL doesn't

[jira] [Created] (FLINK-31729) Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN

Alexander Smirnov created FLINK-31729: - Summary: Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN Key: FLINK-31729 URL: https://issues.apache.org/jira/browse/FLINK-31729 Project: Flink

[GitHub] [flink-connector-elasticsearch] MartijnVisser merged pull request #55: [hotfix] Fix Elasticsearch nightly CI failure

MartijnVisser merged PR #55: URL: https://github.com/apache/flink-connector-elasticsearch/pull/55 -- 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 #22350: [FLINK-31471] Allow setting JobResourceRequirements through WEB UI.

flinkbot commented on PR #22350: URL: https://github.com/apache/flink/pull/22350#issuecomment-1496190730 ## CI report: * e04d9eac0868dc0b940bdcd7f5bba54788cd96c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-31717) Unit tests running with local kube config

[ https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-31717: - Assignee: Matyas Orhidi > Unit tests running with local kube config >

[jira] [Updated] (FLINK-31471) Allow changing per-vertex desired parallelism through WEB UI

[ https://issues.apache.org/jira/browse/FLINK-31471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31471: --- Labels: pull-request-available (was: ) > Allow changing per-vertex desired parallelism

[GitHub] [flink-connector-opensearch] reta commented on pull request #14: [hotfix] Update flink, flink-shaded, archunit

reta commented on PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#issuecomment-1496185391 @MartijnVisser the ArchUnit issue should be fixed, but it's very likely that we would need an update to 1.17 (this pull request) as well, the e2e tests would very likely

[GitHub] [flink] dmvk opened a new pull request, #22350: [FLINK-31471] Allow setting JobResourceRequirements through WEB UI.

dmvk opened a new pull request, #22350: URL: https://github.com/apache/flink/pull/22350 https://issues.apache.org/jira/browse/FLINK-31471 -- 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-connector-gcp-pubsub] MartijnVisser closed pull request #4: [FLINK-30880][Connector/Google PubSub] Update to Flink 1.16.1

MartijnVisser closed pull request #4: [FLINK-30880][Connector/Google PubSub] Update to Flink 1.16.1 URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/4 -- 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-connector-gcp-pubsub] MartijnVisser commented on pull request #4: [FLINK-30880][Connector/Google PubSub] Update to Flink 1.16.1

MartijnVisser commented on PR #4: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/4#issuecomment-1496183861 Superseded by https://github.com/apache/flink-connector-gcp-pubsub/pull/6 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-connector-gcp-pubsub] MartijnVisser merged pull request #6: [hotfix] Fix GCP PubSub Nightly Builds failures

MartijnVisser merged PR #6: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/6 -- 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] [Assigned] (FLINK-31335) using sql-gateway to submit job to yarn cluster, sql-gateway don't support kerberos

[ https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31335: Assignee: felixzh > using sql-gateway to submit job to yarn cluster, sql-gateway don't

[GitHub] [flink] JingsongLi commented on a diff in pull request #22118: [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos

JingsongLi commented on code in PR #22118: URL: https://github.com/apache/flink/pull/22118#discussion_r1157390215 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/SqlGateway.java: ## @@ -109,18 +113,21 @@ static void startSqlGateway(PrintStream

[GitHub] [flink-connector-cassandra] dannycranmer commented on a diff in pull request #5: [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies

dannycranmer commented on code in PR #5: URL: https://github.com/apache/flink-connector-cassandra/pull/5#discussion_r1157335544 ## .github/workflows/push_pr.yml: ## @@ -25,4 +25,4 @@ jobs: compile_and_test: uses:

[jira] [Closed] (FLINK-31303) k8s operator should gather job cpu and memory utilization metrics

[ https://issues.apache.org/jira/browse/FLINK-31303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-31303. -- Fix Version/s: kubernetes-operator-1.5.0 Resolution: Fixed

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #558: [FLINK-31303] Expose Flink application resource usage via metrics and status

mbalassi merged PR #558: URL: https://github.com/apache/flink-kubernetes-operator/pull/558 -- 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] [Assigned] (FLINK-31699) JDBC nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31699: -- Assignee: Martijn Visser (was: Hang Ruan) > JDBC nightly CI failure >

[GitHub] [flink-connector-jdbc] MartijnVisser opened a new pull request, #37: [hotfix] Correct and/or synchronize multiple dependencies/versions

MartijnVisser opened a new pull request, #37: URL: https://github.com/apache/flink-connector-jdbc/pull/37 1. Set the correct groupId for flink-connector-parent 2. Update to Flink 1.17 and match other dependencies to the version used in that Flink version 3. Remove archunit to avoid

[jira] [Updated] (FLINK-31728) Remove Scala API dependencies from batch/streaming examples

[ https://issues.apache.org/jira/browse/FLINK-31728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31728: --- Labels: pull-request-available (was: ) > Remove Scala API dependencies from

[GitHub] [flink-connector-kafka] MartijnVisser opened a new pull request, #21: [hotfix] Correct and/or synchronize multiple dependencies/versions

MartijnVisser opened a new pull request, #21: URL: https://github.com/apache/flink-connector-kafka/pull/21 1. Test CI builds against Flink 1.17.0 instead of Flink 1.17-SNAPSHOT 2. Run the weekly builds against 1.17-SNAPSHOT and 1.18-SNAPSHOT, while dropping 1.16-SNAPSHOT since it's

[GitHub] [flink] flinkbot commented on pull request #22349: [FLINK-31728][examples] Remove scala api dependency

flinkbot commented on PR #22349: URL: https://github.com/apache/flink/pull/22349#issuecomment-1496013617 ## CI report: * 367e598457f50988ad125831cf48eacb5f1ec3d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-jdbc] ruanhang1993 closed pull request #36: [FLINK-31699][connector/jdbc] Use ORACLE_18 for OracleXaDatabase instead of ORACLE_21 to fix CI failure

ruanhang1993 closed pull request #36: [FLINK-31699][connector/jdbc] Use ORACLE_18 for OracleXaDatabase instead of ORACLE_21 to fix CI failure URL: https://github.com/apache/flink-connector-jdbc/pull/36 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-31728) Remove Scala API dependencies from batch/streaming examples

Chesnay Schepler created FLINK-31728: Summary: Remove Scala API dependencies from batch/streaming examples Key: FLINK-31728 URL: https://issues.apache.org/jira/browse/FLINK-31728 Project: Flink

[jira] [Created] (FLINK-31727) Source parallelism should match number of Kafka partitions

Yordan Pavlov created FLINK-31727: - Summary: Source parallelism should match number of Kafka partitions Key: FLINK-31727 URL: https://issues.apache.org/jira/browse/FLINK-31727 Project: Flink

[GitHub] [flink] twalthr commented on a diff in pull request #22313: [FLINK-31660][connector-kafka] fix kafka connector pom so ITCases run in IDE

twalthr commented on code in PR #22313: URL: https://github.com/apache/flink/pull/22313#discussion_r1157216570 ## flink-connectors/flink-connector-kafka/pom.xml: ## @@ -68,6 +67,22 @@ under the License. true + +

[GitHub] [flink-connector-opensearch] MartijnVisser commented on a diff in pull request #14: [hotfix] Update flink, flink-shaded, archunit

MartijnVisser commented on code in PR #14: URL: https://github.com/apache/flink-connector-opensearch/pull/14#discussion_r1157216188 ## pom.xml: ## @@ -58,12 +58,13 @@ under the License. - 1.16.1 - 15.0 + 1.17.0 +

[GitHub] [flink-connector-cassandra] MartijnVisser commented on a diff in pull request #5: [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies

MartijnVisser commented on code in PR #5: URL: https://github.com/apache/flink-connector-cassandra/pull/5#discussion_r1157209885 ## .github/workflows/push_pr.yml: ## @@ -25,4 +25,4 @@ jobs: compile_and_test: uses:

[GitHub] [flink-connector-cassandra] boring-cyborg[bot] commented on pull request #5: [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies

boring-cyborg[bot] commented on PR #5: URL: https://github.com/apache/flink-connector-cassandra/pull/5#issuecomment-1495926206 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-connector-cassandra] MartijnVisser merged pull request #5: [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies

MartijnVisser merged PR #5: URL: https://github.com/apache/flink-connector-cassandra/pull/5 -- 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-kubernetes-operator] mbalassi commented on pull request #558: [FLINK-31303] Expose Flink application resource usage via metrics and status

mbalassi commented on PR #558: URL: https://github.com/apache/flink-kubernetes-operator/pull/558#issuecomment-1495907324 Thanks @mateczagany this is great. I squashed your work into 1 commit and will merge later today. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] clownxc commented on pull request #22301: [FLINK-31426][table] Upgrade the deprecated UniqueConstraint to the n…

clownxc commented on PR #22301: URL: https://github.com/apache/flink/pull/22301#issuecomment-1495903365 I applied the suggested code changes.Can you please do another review @luoyuxia -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-31717) Unit tests running with local kube config

[ https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708408#comment-17708408 ] Matyas Orhidi commented on FLINK-31717: --- SGTM > Unit tests running with local kube config >

[GitHub] [flink-connector-cassandra] dannycranmer commented on a diff in pull request #5: [FLINK-31698][Connector/Cassandra] Upgrade and sync related dependencies

dannycranmer commented on code in PR #5: URL: https://github.com/apache/flink-connector-cassandra/pull/5#discussion_r1157179543 ## .github/workflows/push_pr.yml: ## @@ -25,4 +25,4 @@ jobs: compile_and_test: uses:

[jira] [Commented] (FLINK-31701) RabbitMQ nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708402#comment-17708402 ] Martijn Visser commented on FLINK-31701: Remove versioned Archunit:

[jira] [Updated] (FLINK-31726) PyFlink module java.base does not "opens java.lang" to unnamed module

[ https://issues.apache.org/jira/browse/FLINK-31726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31726: Description: I want to run simple example from Flink documentation. And after start i got exception:

[jira] [Created] (FLINK-31726) PyFlink module java.base does not "opens java.lang" to unnamed module

padavan created FLINK-31726: --- Summary: PyFlink module java.base does not "opens java.lang" to unnamed module Key: FLINK-31726 URL: https://issues.apache.org/jira/browse/FLINK-31726 Project: Flink

[GitHub] [flink-connector-rabbitmq] MartijnVisser merged pull request #8: [FLINK-31701][Connector/RabbitMQ] Remove versioned dependency on Archunit

MartijnVisser merged PR #8: URL: https://github.com/apache/flink-connector-rabbitmq/pull/8 -- 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 a diff in pull request #22343: [FLINK-31470] Add integration tests for Externalized Declarative Reso…

zentol commented on code in PR #22343: URL: https://github.com/apache/flink/pull/22343#discussion_r1157145077 ## flink-tests/src/test/java/org/apache/flink/test/recovery/UpdateJobResourceRequirementsRecoveryITCase.java: ## @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache

[GitHub] [flink-connector-jdbc] boring-cyborg[bot] commented on pull request #36: [FLINK-31699][connector/jdbc] Use ORACLE_18 for OracleXaDatabase instead of ORACLE_21 to fix CI failure

boring-cyborg[bot] commented on PR #36: URL: https://github.com/apache/flink-connector-jdbc/pull/36#issuecomment-1495873436 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[jira] [Updated] (FLINK-31699) JDBC nightly CI failure

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

[GitHub] [flink-connector-jdbc] ruanhang1993 opened a new pull request, #36: [FLINK-31699][connector/jdbc] Use ORACLE_18 for OracleXaDatabase instead of ORACLE_21 to fix CI failure

ruanhang1993 opened a new pull request, #36: URL: https://github.com/apache/flink-connector-jdbc/pull/36 This PR fixed the test failure in the OracleExactlyOnceSinkE2eTest. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-31717) Unit tests running with local kube config

[ https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708399#comment-17708399 ] Márton Balassi commented on FLINK-31717: To clarify the errors only appear when your local k8s

[GitHub] [flink-connector-rabbitmq] MartijnVisser opened a new pull request, #8: [FLINK-31701][Connector/RabbitMQ] Remove versioned dependency on Archunit

MartijnVisser opened a new pull request, #8: URL: https://github.com/apache/flink-connector-rabbitmq/pull/8 Verified locally with: `mvn clean deploy -Dflink.version=1.16-SNAPSHOT -Dscala-2.12 -Prun-end-to-end-tests -DdistDir=/Users/mvisser/Downloads/flink-1.16-SNAPSHOT

[GitHub] [flink] sigalite closed pull request #22348: [FLINK-28171] [flink-kubernates] support appProtocol in order to work with istio

sigalite closed pull request #22348: [FLINK-28171] [flink-kubernates] support appProtocol in order to work with istio URL: https://github.com/apache/flink/pull/22348 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #22348: [FLINK-28171] [flink-kubernates] support appProtocol in order to work with istio

flinkbot commented on PR #22348: URL: https://github.com/apache/flink/pull/22348#issuecomment-1495818953 ## CI report: * 08dbb6d5eff46e72af412643f80ac353636821de UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28171: --- Labels: pull-request-available (was: ) > Adjust Job and Task manager port definitions to

[GitHub] [flink] sigalite opened a new pull request, #22348: [FLINK-28171] [flink-kubernates] support appProtocol in order to work with istio

sigalite opened a new pull request, #22348: URL: https://github.com/apache/flink/pull/22348 ## What is the purpose of the change This pull request allows definition of the appProtocol on the job manager to allow integration with istio ## Brief change log change in

[jira] [Closed] (FLINK-31725) Synchronize dependency version between Flink and flink-connector-pulsar

[ https://issues.apache.org/jira/browse/FLINK-31725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31725. -- Fix Version/s: pulsar-4.0.0 Resolution: Fixed Fixed in main:

  1   2   3   >