mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374250013
Thanks for the speedy response @yuxiqian . passing the jar using `--jar`
worked for me.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374243091
Thanks for the speedy reply @yuxiqian . moving the jar to `Flink lib` did
not help. passing the jar with `--jar` caused the `Flink-cdc.sh` command to get
stuck with no logs, and no
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374215861
Hi @mamineturki, `flink-cdc-pipeline-udf-examples` are for testing purposes
only. If you'd like to test it, using
`org.apache.flink.cdc.udf.examples.scala.AddOneFunctionClass` should w
mamineturki commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2374187978
@yuxiqian Hi, I have been trying to run an example with this new feature but
I always get `java.lang.ClassNotFoundException:
org.example.udf.AddOneFunctionClass`
I tried load
ruanhang1993 merged PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465
--
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...@flin
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2277077343
Rebased with `master` and resolved conflicts. cc @leonardBang @ruanhang1993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2275525755
Seems CI is failing due to an expired link in Doris docs. Rebased & fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
yuxiqian commented on code in PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#discussion_r1708908351
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunction.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (A
ruanhang1993 commented on code in PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#discussion_r1708813058
##
docs/content.zh/docs/core-concept/transform.md:
##
@@ -266,6 +266,75 @@ transform:
description: classification mapping example
```
+## User-defined Fu
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2275118059
Rebased to latest `master`, cc @ruanhang1993
Minor concern: By adding more E2e test cases, now it takes nearly 1h 30min
to finish running e2e case, which is worrying since curre
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2262911364
Adjusted based on previous discussions, cleaned up changes, and added
UDF-related docs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2260265325
Updated API design & POC implementation, could @aiwenmo please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ruanhang1993 commented on code in PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#discussion_r1694814738
##
flink-cdc-runtime/src/test/java/org/apache/flink/cdc/runtime/parser/JaninoCompilerTest.java:
##
@@ -118,7 +119,7 @@ public void testJaninoTimestampFunction()
yuxiqian commented on PR #3465:
URL: https://github.com/apache/flink-cdc/pull/3465#issuecomment-2220009651
Having some difficulties getting Calcite related materials, looking for
@aiwenmo's comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
14 matches
Mail list logo
