Fabrizzio Chavez created FLINK-38237:
Summary: MongoDB CDC - row_kind virtual column is returning
incorrect operation Type
Key: FLINK-38237
URL: https://issues.apache.org/jira/browse/FLINK-38237
P
pnowojski commented on code in PR #26888:
URL: https://github.com/apache/flink/pull/26888#discussion_r2272197729
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MiscSemanticTests.java:
##
@@ -31,6 +32,7 @@ public class MiscS
[
https://issues.apache.org/jira/browse/FLINK-38188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs resolved FLINK-38188.
Fix Version/s: cdc-3.5.0
Resolution: Fixed
> PostgreSQL connector database name validation logic is
[
https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013589#comment-18013589
]
Feng Jin commented on FLINK-36377:
--
[~dezhouliyang] Thank you for following up on thi
Poorvankbhatia commented on PR #26818:
URL: https://github.com/apache/flink/pull/26818#issuecomment-3182322047
Hey @fapaul . Could you help merge it? I rebased it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
GitHub user xintongsong edited a discussion: Community Sync
There's a community sync for discussing developing progress, technical designs
and community issues about Flink Agents.
Everyone is welcome to join.
* Schedule: 3am Wed UTC
* [Google
Calendar](https://calendar.google.com/calendar/u/
[
https://issues.apache.org/jira/browse/FLINK-38232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv reassigned FLINK-38232:
--
Assignee: suhwan
> [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgre
lvyanquan merged PR #4075:
URL: https://github.com/apache/flink-cdc/pull/4075
--
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: issues-unsubscr...@flink.a
flinkbot commented on PR #26898:
URL: https://github.com/apache/flink/pull/26898#issuecomment-3182168905
## CI report:
* 6a43df5709cf3e05c56b637cf409dc235c7a6336 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] commented on PR #26788:
URL: https://github.com/apache/flink/pull/26788#issuecomment-3182158672
Superseded by #26898.
--
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
dependabot[bot] closed pull request #26788: Bump com.nimbusds:nimbus-jose-jwt
from 4.41.1 to 10.0.2 in /flink-end-to-end-tests/flink-end-to-end-tests-sql
URL: https://github.com/apache/flink/pull/26788
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
dependabot[bot] opened a new pull request, #26898:
URL: https://github.com/apache/flink/pull/26898
Bumps
[com.nimbusds:nimbus-jose-jwt](https://bitbucket.org/connect2id/nimbus-jose-jwt)
from 4.41.1 to 9.37.4.
Commits
https://bitbucket.org/connect2id/nimbus-jose-jwt/commits/f64
[
https://issues.apache.org/jira/browse/FLINK-38235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013577#comment-18013577
]
Max Feng commented on FLINK-38235:
--
Thanks for the reply. We're not quite sure we under
tchivs commented on code in PR #4075:
URL: https://github.com/apache/flink-cdc/pull/4075#discussion_r2268693894
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFacto
[
https://issues.apache.org/jira/browse/FLINK-37395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37395.
Fix Version/s: cdc-3.5.0
Assignee: wuzexian
Resolution: Fixed
Fixed in master via
[
https://issues.apache.org/jira/browse/FLINK-37835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37835.
Fix Version/s: cdc-3.5.0
Resolution: Fixed
Fixed in master via b937fdcf6ad7ebdefa2a2a3ee23b
lvyanquan merged PR #4091:
URL: https://github.com/apache/flink-cdc/pull/4091
--
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: issues-unsubscr...@flink.a
dianfu commented on PR #26897:
URL: https://github.com/apache/flink/pull/26897#issuecomment-3182030452
@autophagy
1) The purpose of `apache-flink-libraries`:
The purpose of `apache-flink-libraries` is to split the JAR files(which are
huge) into a separate project. Otherwise, when we r
GitHub user letaoj edited a discussion: WIP: Replay-based Per Action State
Consistency
# Background
Flink Agents execute various actions during record processing, including model
inference and tool invocation. Model inference involves calling LLMs for
reasoning, classification, or generation
GitHub user letaoj edited a discussion: WIP: Replay-based Per Action State
Consistency
# Background
Flink Agents execute various actions during record processing, including model
inference and tool invocation. Model inference involves calling LLMs for
reasoning, classification, or generation
liuyongvs commented on PR #26896:
URL: https://github.com/apache/flink/pull/26896#issuecomment-3181972080
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-38235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013565#comment-18013565
]
Leonard Xu commented on FLINK-38235:
Yes, it's a limitation by design. The underlyin
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1: Week 1-3 (Jun 12 - Jul 2)
- [x] Preparation
xintongsong closed issue #46: [Feature] Optimize PythonFunction instantiation
in `call_python_function`
URL: https://github.com/apache/flink-agents/issues/46
--
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 t
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1: Week 1-3 (Jun 12 - Jul 2)
- [x] Preparation
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1: Week 1-3 (Jun 12 - Jul 2)
- [x] Preparation
xintongsong opened a new issue, #111:
URL: https://github.com/apache/flink-agents/issues/111
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
Support leveraging tools and
qinf commented on PR #1003:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1003#issuecomment-318136
@gyfora Thanks for your kind reminder, I'd like working on this. And I will
create a new issue to following this.
--
This is an automated message from the Apache Git Ser
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1: Week 1-3 (Jun 12 - Jul 2)
- [x] Preparation
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1: Week 1-3 (Jun 12 - Jul 2)
- [x] Preparation
GitHub user letaoj edited a discussion: WIP: Replay-based Per Action State
Consistency
# Background
Flink Agents execute various actions during record processing, including model
inference and tool invocation. Model inference involves calling LLMs for
reasoning, classification, or generation
GitHub user letaoj edited a discussion: WIP: Replay-based Per Action State
Consistency
# Background
Flink Agents execute various actions during record processing, including model
inference and tool invocation. Model inference involves calling LLMs for
reasoning, classification, or generation
github-actions[bot] closed pull request #3211: [FLINK-34944] Use Incremental
Source Framework in Flink CDC OceanBase Source Connector
URL: https://github.com/apache/flink-cdc/pull/3211
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
github-actions[bot] commented on PR #3211:
URL: https://github.com/apache/flink-cdc/pull/3211#issuecomment-3181623011
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
github-actions[bot] closed pull request #3915:
[FLINK-37293][pipeline-connector][oceanbase] Fix type converting and
refactoring test cases
URL: https://github.com/apache/flink-cdc/pull/3915
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
github-actions[bot] commented on PR #3915:
URL: https://github.com/apache/flink-cdc/pull/3915#issuecomment-3181621712
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
snuyanzin commented on code in PR #26895:
URL: https://github.com/apache/flink/pull/26895#discussion_r2271531160
##
flink-table/pom.xml:
##
@@ -78,8 +78,8 @@ under the License.
- 1.36.0
-
snuyanzin commented on code in PR #26895:
URL: https://github.com/apache/flink/pull/26895#discussion_r2271518122
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -3951,6 +3958,43 @@ SqlNode Expression3(ExprContext exprContext) :
}
}
+/**
+ * Pa
Fabrizzio Chavez created FLINK-38236:
Summary: MongoDB CDC - Include Full Document as Metadata Field
Key: FLINK-38236
URL: https://issues.apache.org/jira/browse/FLINK-38236
Project: Flink
AmenAdem commented on code in PR #94:
URL: https://github.com/apache/flink-agents/pull/94#discussion_r2271404702
##
api/src/main/java/org/apache/flink/agents/api/tool/ToolRegistry.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
snuyanzin commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2271394043
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java:
##
@@ -166,9 +166,13 @@ prot
snuyanzin commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2271384587
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java:
##
@@ -531,6 +531,8 @@ void testFromChan
snuyanzin commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2271384587
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java:
##
@@ -531,6 +531,8 @@ void testFromChan
snuyanzin commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2271384159
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/utils/DeduplicateFunctionHelper.java:
##
@@ -292,6 +292,20 @@ pu
AmenAdem commented on code in PR #94:
URL: https://github.com/apache/flink-agents/pull/94#discussion_r2271362640
##
api/src/main/java/org/apache/flink/agents/api/tool/ToolMetadata.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
AmenAdem commented on code in PR #94:
URL: https://github.com/apache/flink-agents/pull/94#discussion_r2271339280
##
api/src/main/java/org/apache/flink/agents/api/tool/ToolRegistry.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
AmenAdem commented on code in PR #94:
URL: https://github.com/apache/flink-agents/pull/94#discussion_r2271299129
##
api/src/main/java/org/apache/flink/agents/api/chat/messages/AbstractMessage.java:
##
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
snuyanzin commented on PR #26885:
URL: https://github.com/apache/flink/pull/26885#issuecomment-3180939501
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Max Feng created FLINK-38235:
Summary: Unable to reliably detect newly added tables with MySQL
CDC
Key: FLINK-38235
URL: https://issues.apache.org/jira/browse/FLINK-38235
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-38235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Max Feng updated FLINK-38235:
-
Description:
It appears to not be possible to configure the MySQL CDC 3.3.0 source such that
newly adde
autophagy commented on PR #26897:
URL: https://github.com/apache/flink/pull/26897#issuecomment-3180718948
@dianfu @HuangXingBo While i'm digging around the build/releasing stuff - do
you know why we build/publish a wheel and an sdist for `apache-flink`, but only
an sdist for `apache-flink-l
[
https://issues.apache.org/jira/browse/FLINK-38148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013491#comment-18013491
]
Thomas Weise commented on FLINK-38148:
--
We run into this also. Although it is techn
autophagy opened a new pull request, #26897:
URL: https://github.com/apache/flink/pull/26897
## What is the purpose of the change
With [FLINK-37775](https://issues.apache.org/jira/browse/FLINK-37775) and
[FLINK-36900](https://issues.apache.org/jira/browse/FLINK-36900) we have
started
flinkbot commented on PR #26897:
URL: https://github.com/apache/flink/pull/26897#issuecomment-3180126602
## CI report:
* 591750041e14f2422d48b1b5f81b458aa21d3d14 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38231:
---
Labels: pull-request-available (was: )
> Standardise use of uv for PyFlink building/testing
gyfora commented on PR #1003:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1003#issuecomment-3179685160
@qinf , I think we should cache the last checkpoint info somewhere even
after `unregister` so that the JM can return this information. I would be happy
to review if you
[
https://issues.apache.org/jira/browse/FLINK-37869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin closed FLINK-37869.
Resolution: Won't Do
> FINISHED bouned job can't be cleanup by the Flink Kuberenetes Operator
> --
qinf commented on PR #1003:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1003#issuecomment-3179606863
@gyfora Got it, thanks for you response.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
qinf closed pull request #1003: [FLINK-37869][Observer] Fix finished bounded
stream jobs can't be cle…
URL: https://github.com/apache/flink-kubernetes-operator/pull/1003
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
snuyanzin commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2270051294
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/utils/DeduplicateFunctionHelper.java:
##
@@ -292,6 +292,20 @@ pu
[
https://issues.apache.org/jira/browse/FLINK-38234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-38234:
-
Component/s: Table SQL / Planner
> Enable nondeterministic update strategy by default in Semanti
[
https://issues.apache.org/jira/browse/FLINK-38230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38230:
--
Affects Version/s: 2.1.0
(was: 2.1)
> Implement visitMultiJ
[
https://issues.apache.org/jira/browse/FLINK-38230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38230:
--
Fix Version/s: 2.2.0
(was: 2.2)
> Implement visitMultiJoin for
[
https://issues.apache.org/jira/browse/FLINK-38234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38234:
--
Fix Version/s: 2.2.0
(was: 2.2)
> Enable nondeterministic updat
[
https://issues.apache.org/jira/browse/FLINK-38234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38234:
--
Affects Version/s: 2.1.0
(was: 2.1)
> Enable nondeterminist
[
https://issues.apache.org/jira/browse/FLINK-38233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38233:
--
Affects Version/s: 2.1.0
(was: 2.1)
> Implement visitProces
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2270012326
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinSemanticTests.java:
##
@@ -26,6 +28,14 @@
/** S
[
https://issues.apache.org/jira/browse/FLINK-38233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais updated FLINK-38233:
--
Fix Version/s: 2.2.0
(was: 2.2)
> Implement visitProcessTableFu
Gustavo de Morais created FLINK-38234:
-
Summary: Enable nondeterministic update strategy by default in
SemanticTestBase
Key: FLINK-38234
URL: https://issues.apache.org/jira/browse/FLINK-38234
Proj
twalthr commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2270008810
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/utils/DeduplicateFunctionHelper.java:
##
@@ -292,6 +292,20 @@ publ
twalthr commented on code in PR #26893:
URL: https://github.com/apache/flink/pull/26893#discussion_r2269989301
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java:
##
@@ -531,6 +531,8 @@ void testFromChange
Gustavo de Morais created FLINK-38233:
-
Summary: Implement visitProcessTableFunction for
StreamNonDeterministicUpdatePlanVisitor
Key: FLINK-38233
URL: https://issues.apache.org/jira/browse/FLINK-38233
twalthr commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269930472
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinSemanticTests.java:
##
@@ -26,6 +28,14 @@
/** Semantic
ferenc-csaky commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269916423
##
flink-connector-hbase-base/src/test/resources/log4j.properties:
##
Review Comment:
If it only affects the minicluster, then it's fine. I got the
[
https://issues.apache.org/jira/browse/FLINK-38232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18013434#comment-18013434
]
suhwan commented on FLINK-38232:
I would like to take this.
> [docs] Update “Pipeline C
ferenc-csaky commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269903011
##
pom.xml:
##
@@ -524,10 +529,28 @@ under the License.
${assertj.version}
+
[
https://issues.apache.org/jira/browse/FLINK-38232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suhwan updated FLINK-38232:
---
Priority: Minor (was: Major)
> [docs] Update “Pipeline Connectors > Overview” to include Iceberg, Postgres,
suhwan created FLINK-38232:
--
Summary: [docs] Update “Pipeline Connectors > Overview” to include
Iceberg, Postgres, Fluss
Key: FLINK-38232
URL: https://issues.apache.org/jira/browse/FLINK-38232
Project: Flink
ferenc-csaky commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269903011
##
pom.xml:
##
@@ -524,10 +529,28 @@ under the License.
${assertj.version}
+
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269900472
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.java:
##
@@ -417,8 +486,8 @@ void tes
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269893401
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinSemanticTests.java:
##
@@ -26,6 +28,14 @@
/** S
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269891365
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.java:
##
@@ -417,8 +486,8 @@ void tes
twalthr commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269862198
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.java:
##
@@ -178,22 +175,21 @@ void testCdcWi
twalthr commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269860910
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzerTest.java:
##
@@ -417,8 +486,8 @@ void testOverAgg
qinf commented on PR #1003:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1003#issuecomment-3179363878
> @qinf , I am not talking about that feature. I am talking in general. If a
bounded streaming job has checkpointing enabled, when inputs are finished a
final checkpoint i
twalthr commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269854343
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinSemanticTests.java:
##
@@ -26,6 +28,14 @@
/** Semantic
mateczagany commented on PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#issuecomment-3179305248
Thank you very much for the review!
I will spend some time to investigate removing log4j completely in the
tests.
I like the idea of dropping the minor versio
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269812448
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MultiJoinSemanticTests.java:
##
@@ -26,6 +28,14 @@
/** S
mateczagany commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269801679
##
docs/data/hbase.yml:
##
Review Comment:
Did not know that, I have reverted this change.
--
This is an automated message from the Apache Git S
mateczagany commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269798483
##
flink-connector-hbase-base/src/test/resources/log4j.properties:
##
Review Comment:
I will try to look into it, but last time I looked I could not
mateczagany commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269796599
##
pom.xml:
##
@@ -387,12 +398,6 @@ under the License.
${scala.version}
-
mateczagany commented on code in PR #56:
URL:
https://github.com/apache/flink-connector-hbase/pull/56#discussion_r2269793239
##
pom.xml:
##
@@ -524,10 +529,28 @@ under the License.
${assertj.version}
+
gustavodemorais commented on code in PR #26894:
URL: https://github.com/apache/flink/pull/26894#discussion_r2269783389
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/SemanticTestBase.java:
##
@@ -81,6 +81,8 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-38231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mika Naylor reassigned FLINK-38231:
---
Assignee: Mika Naylor
> Standardise use of uv for PyFlink building/testing/tooling
> -
Mika Naylor created FLINK-38231:
---
Summary: Standardise use of uv for PyFlink
building/testing/tooling
Key: FLINK-38231
URL: https://issues.apache.org/jira/browse/FLINK-38231
Project: Flink
Is
gyfora commented on PR #995:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/995#issuecomment-3179250708
subsumed by https://github.com/apache/flink-kubernetes-operator/pull/1001
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
gyfora closed pull request #995: docs: update overview.md
URL: https://github.com/apache/flink-kubernetes-operator/pull/995
--
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 u
Kavishankarks commented on issue #46:
URL: https://github.com/apache/flink-agents/issues/46#issuecomment-3179250040
we can close this, pr got merged for this.
https://github.com/apache/flink-agents/pull/72
--
This is an automated message from the Apache Git Service.
To respond to the mess
[
https://issues.apache.org/jira/browse/FLINK-38207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-38207.
--
Fix Version/s: kubernetes-operator-1.13.0
Assignee: Attila Mészáros
Resolution: Fixed
gyfora merged PR #1005:
URL: https://github.com/apache/flink-kubernetes-operator/pull/1005
--
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: issues-unsubs
1 - 100 of 142 matches
Mail list logo
