Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug][Manager] Workflow initialization threw IllegalArgumentException: Unsupported FieldType text or keyword #6804

Closed
2 tasks done
wangpeix opened this issue Dec 9, 2022 · 0 comments · Fixed by #6809
Closed
2 tasks done
Assignees
Labels
Milestone

Comments

@wangpeix
Copy link
Contributor

wangpeix commented Dec 9, 2022

What happened

When the data type of ES is text or keyword, an IllegalArgumentException exception is thrown.

What you expected to happen

When the data type is text, the following exception occurs.

java.lang.IllegalArgumentException: Unsupported FieldType : text
	at org.apache.inlong.manager.common.enums.FieldType.forName(FieldType.java:63) ~[manager-common-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.convertFieldFormat(FieldInfoUtils.java:162) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.getFieldInfo(FieldInfoUtils.java:125) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.parseSinkFieldInfo(FieldInfoUtils.java:68) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.lambda$createLoadNode$1(LoadNodeUtils.java:108) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_151]
	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1380) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[?:1.8.0_151]
	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_151]
	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[?:1.8.0_151]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.createLoadNode(LoadNodeUtils.java:109) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.lambda$createLoadNodes$0(LoadNodeUtils.java:99) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_151]
	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1380) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[?:1.8.0_151]
	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_151]
	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[?:1.8.0_151]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.createLoadNodes(LoadNodeUtils.java:100) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]

When the data type is keyword, the following exception occurs.

java.lang.IllegalArgumentException: Unsupported FieldType : keyword
	at org.apache.inlong.manager.common.enums.FieldType.forName(FieldType.java:63) ~[manager-common-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.convertFieldFormat(FieldInfoUtils.java:162) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.getFieldInfo(FieldInfoUtils.java:125) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.FieldInfoUtils.parseSinkFieldInfo(FieldInfoUtils.java:68) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.lambda$createLoadNode$1(LoadNodeUtils.java:108) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_151]
	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1380) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471) ~[?:1.8.0_151]
	at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_151]
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_151]
	at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) ~[?:1.8.0_151]
	at org.apache.inlong.manager.pojo.sort.util.LoadNodeUtils.createLoadNode(LoadNodeUtils.java:109) ~[manager-pojo-1.5.0-SNAPSHOT.jar:1.5.0-SNAPSHOT]

How to reproduce

Use the following configuration to reproduce the problem.

image

Environment

No response

InLong version

master

InLong Component

InLong Manager

Are you willing to submit PR?

  • Yes, I am willing to submit a PR!

Code of Conduct

@wangpeix wangpeix added the type/bug Something is wrong label Dec 9, 2022
@wangpeix wangpeix changed the title [Bug][Manager] Sink ES IllegalArgumentException: Unsupported FieldType text or keyword [Bug][Manager] Workflow initialization threw IllegalArgumentException: Unsupported FieldType text or keyword Dec 9, 2022
@dockerzhang dockerzhang added this to the 1.5.0 milestone Dec 9, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
2 participants