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();
 

Reply via email to