This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
The following commit(s) were added to refs/heads/main by this push:
new 14f2b890 [docs] Fix uncompilable x::getId in integrate_with_flink
DataStream snippet (#791)
14f2b890 is described below
commit 14f2b8906779cb1704c20ad93c61c153518a4d7b
Author: bosiew.tian <[email protected]>
AuthorDate: Mon Jun 8 14:47:12 2026 +0800
[docs] Fix uncompilable x::getId in integrate_with_flink DataStream snippet
(#791)
Co-authored-by: bosiew.tian <[email protected]>
---
docs/content/docs/development/integrate_with_flink.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/content/docs/development/integrate_with_flink.md
b/docs/content/docs/development/integrate_with_flink.md
index d59894ad..b3bc193f 100644
--- a/docs/content/docs/development/integrate_with_flink.md
+++ b/docs/content/docs/development/integrate_with_flink.md
@@ -80,7 +80,7 @@ DataStream<YourPojo> inputStream = env.fromSource(...);
// integrate agent with input datastream, and return output datastream
DataStream<Object> outputStream =
agentsEnv
- .fromDataStream(inputStream, (KeySelector<YourPojo, String>)
x::getId)
+ .fromDataStream(inputStream, (KeySelector<YourPojo, String>)
YourPojo::getId)
.apply(yourAgent)
.toDataStream();