waytoharish closed issue #10895: Nested object support in Hudi Table using Flink
URL: https://github.com/apache/hudi/issues/10895
--
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
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2042890195
Thanks @ad1happy2go @danny0405 its worked for me after using the
GenericRowData.
I am closing the issue
--
This is an automated message from the Apache Git Service.
To
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2042234221
I am keep getting
lang.ClassCastException: class
org.apache.flink.table.data.binary.BinaryStringData cannot be cast to class
org.apache.flink.table.data.ArrayData
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2042041118
Hi @ad1happy2go ,
I have added the -
@Override
public RowData map(Telemetry kafkaRecord) throws Exception {
GenericRowData row = new
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2031270238
HI @ad1happy2go Still facing the issue . Not able to figure out how to do
with GenericRowData
--
This is an automated message from the Apache Git Service.
To respond to the
ad1happy2go commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2029718076
@waytoharish Did you got a chance to try out GenericRowData, Are you still
facing the issue?
--
This is an automated message from the Apache Git Service.
To respond to the
danny0405 commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2019378477
Another way is to use the `GenericRowData`, it's much more simpler or just
the `Row` and convert it back to `RowData` with utility.
--
This is an automated message from the
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2019330463
@danny0405 @ad1happy2go Please can you help me to understand if this is a
Bug or I am doing anything wrong
--
This is an automated message from the Apache Git Service.
To
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2014848588
Thanks for your time @ad1happy2go
@ad1happy2go @danny0405 Here is the error which I am getting after the code
change :
14:38:06,411 INFO
ad1happy2go commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2014803349
@waytoharish As discussed on call, can you provide latest code and exception
what we were getting.
--
This is an automated message from the Apache Git Service.
To respond to
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2011376344
Thank @danny0405
I am able to map the arraytype using below but not sure if I am doing it
correctly
private static HoodiePipeline.Builder createHudiPipeline(String
danny0405 commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2011334497
Hmm, i guess it is because the HoodiePipeline clazz does not concatenate the
fiels in good shape, that might be a bug.
--
This is an automated message from the Apache Git
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2011288296
Hi @danny0405 I dont see the SQL in Flink.
Here is my code which I am trying in Java
`public static final DataType ROW_DATA_TYPE = ROW(
DataTypes.FIELD("uuid",
danny0405 commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2011275481
Can you show us the complete sql text?
--
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
waytoharish commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2011212848
@ad1happy2go I am getting following error when tried with
DataTypes.FIELD("data", DataTypes.ARRAY(
ROW(
DataTypes.FIELD("test", DataTypes.VARCHAR(256)), // record key
ad1happy2go commented on issue #10895:
URL: https://github.com/apache/hudi/issues/10895#issuecomment-2009802993
@waytoharish Can you let us know what error/issue you are facing? Or is it
giving the compilation error only?
--
This is an automated message from the Apache Git Service.
To
16 matches
Mail list logo
