Huang Xingbo created FLINK-28176:
------------------------------------
Summary: test_es_sink_dynamic failed in jdk11
Key: FLINK-28176
URL: https://issues.apache.org/jira/browse/FLINK-28176
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.16.0
Reporter: Huang Xingbo
{code:java}
2022-06-21T03:01:35.4707985Z Jun 21 03:01:35 _________________
FlinkElasticsearch7Test.test_es_sink_dynamic _________________
2022-06-21T03:01:35.4709206Z Jun 21 03:01:35
2022-06-21T03:01:35.4710708Z Jun 21 03:01:35 self =
<pyflink.datastream.tests.test_connectors.FlinkElasticsearch7Test
testMethod=test_es_sink_dynamic>
2022-06-21T03:01:35.4711754Z Jun 21 03:01:35
2022-06-21T03:01:35.4712481Z Jun 21 03:01:35 def test_es_sink_dynamic(self):
2022-06-21T03:01:35.4715653Z Jun 21 03:01:35 ds =
self.env.from_collection(
2022-06-21T03:01:35.4718082Z Jun 21 03:01:35 [{'name': 'ada', 'id':
'1'}, {'name': 'luna', 'id': '2'}],
2022-06-21T03:01:35.4719972Z Jun 21 03:01:35
type_info=Types.MAP(Types.STRING(), Types.STRING()))
2022-06-21T03:01:35.4721209Z Jun 21 03:01:35
2022-06-21T03:01:35.4722120Z Jun 21 03:01:35 > es_dynamic_index_sink =
Elasticsearch7SinkBuilder() \
2022-06-21T03:01:35.4723876Z Jun 21 03:01:35
.set_emitter(ElasticsearchEmitter.dynamic_index('name', 'id')) \
2022-06-21T03:01:35.4725448Z Jun 21 03:01:35
.set_hosts(['localhost:9200']) \
2022-06-21T03:01:35.4726419Z Jun 21 03:01:35 .build()
2022-06-21T03:01:35.4727430Z Jun 21 03:01:35
2022-06-21T03:01:35.4877335Z Jun 21 03:01:35
pyflink/datastream/tests/test_connectors.py:132:
2022-06-21T03:01:35.4882723Z Jun 21 03:01:35 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2022-06-21T03:01:35.4884972Z Jun 21 03:01:35
pyflink/datastream/connectors/elasticsearch.py:130: in set_hosts
2022-06-21T03:01:35.4886124Z Jun 21 03:01:35 j_http_hosts_array =
to_jarray(JHttpHost, j_http_hosts_list)
2022-06-21T03:01:35.4887527Z Jun 21 03:01:35 pyflink/util/java_utils.py:37: in
to_jarray
2022-06-21T03:01:35.4888600Z Jun 21 03:01:35 j_arr[i] = arr[i]
2022-06-21T03:01:35.4890812Z Jun 21 03:01:35
.tox/py39-cython/lib/python3.9/site-packages/py4j/java_collections.py:238: in
__setitem__
2022-06-21T03:01:35.4892201Z Jun 21 03:01:35 return self.__set_item(key,
value)
2022-06-21T03:01:35.4893842Z Jun 21 03:01:35
.tox/py39-cython/lib/python3.9/site-packages/py4j/java_collections.py:221: in
__set_item
2022-06-21T03:01:35.4895153Z Jun 21 03:01:35 return
get_return_value(answer, self._gateway_client)
2022-06-21T03:01:35.4896282Z Jun 21 03:01:35 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2022-06-21T03:01:35.4897191Z Jun 21 03:01:35
2022-06-21T03:01:35.4900656Z Jun 21 03:01:35 answer =
'zsorg.apache.flink.api.python.shaded.py4j.Py4JException: Cannot convert
org.apache.flink.elasticsearch7.shaded.org.ap...haded.py4j.GatewayConnection.run(GatewayConnection.java:238)\\n\tat
java.base/java.lang.Thread.run(Thread.java:829)\\n'
2022-06-21T03:01:35.4903369Z Jun 21 03:01:35 gateway_client =
<py4j.java_gateway.GatewayClient object at 0x7f7dd5b8b580>
2022-06-21T03:01:35.4904543Z Jun 21 03:01:35 target_id = None, name = None
2022-06-21T03:01:35.4905404Z Jun 21 03:01:35
2022-06-21T03:01:35.4906381Z Jun 21 03:01:35 def get_return_value(answer,
gateway_client, target_id=None, name=None):
2022-06-21T03:01:35.4908583Z Jun 21 03:01:35 """Converts an answer
received from the Java gateway into a Python object.
2022-06-21T03:01:35.4909687Z Jun 21 03:01:35
2022-06-21T03:01:35.4910838Z Jun 21 03:01:35 For example, string
representation of integers are converted to Python
2022-06-21T03:01:35.4912061Z Jun 21 03:01:35 integer, string
representation of objects are converted to JavaObject
2022-06-21T03:01:35.4913137Z Jun 21 03:01:35 instances, etc.
2022-06-21T03:01:35.4913921Z Jun 21 03:01:35
2022-06-21T03:01:35.4914859Z Jun 21 03:01:35 :param answer: the string
returned by the Java gateway
2022-06-21T03:01:35.4916648Z Jun 21 03:01:35 :param gateway_client: the
gateway client used to communicate with the Java
2022-06-21T03:01:35.4918294Z Jun 21 03:01:35 Gateway. Only
necessary if the answer is a reference (e.g., object,
2022-06-21T03:01:35.4919591Z Jun 21 03:01:35 list, map)
2022-06-21T03:01:35.4920758Z Jun 21 03:01:35 :param target_id: the name
of the object from which the answer comes from
2022-06-21T03:01:35.4921963Z Jun 21 03:01:35 (e.g., *object1* in
`object1.hello()`). Optional.
2022-06-21T03:01:35.4923122Z Jun 21 03:01:35 :param name: the name of
the member from which the answer comes from
2022-06-21T03:01:35.4924246Z Jun 21 03:01:35 (e.g., *hello* in
`object1.hello()`). Optional.
2022-06-21T03:01:35.4925140Z Jun 21 03:01:35 """
2022-06-21T03:01:35.4925981Z Jun 21 03:01:35 if is_error(answer)[0]:
2022-06-21T03:01:35.4926846Z Jun 21 03:01:35 if len(answer) > 1:
2022-06-21T03:01:35.4927828Z Jun 21 03:01:35 type = answer[1]
2022-06-21T03:01:35.4928784Z Jun 21 03:01:35 value =
OUTPUT_CONVERTER[type](answer[2:], gateway_client)
2022-06-21T03:01:35.4929792Z Jun 21 03:01:35 if answer[1] ==
REFERENCE_TYPE:
2022-06-21T03:01:35.4930858Z Jun 21 03:01:35 raise
Py4JJavaError(
2022-06-21T03:01:35.4931806Z Jun 21 03:01:35 "An error
occurred while calling {0}{1}{2}.\n".
2022-06-21T03:01:35.4932792Z Jun 21 03:01:35
format(target_id, ".", name), value)
2022-06-21T03:01:35.4933346Z Jun 21 03:01:35 else:
2022-06-21T03:01:35.4933841Z Jun 21 03:01:35 > raise
Py4JError(
2022-06-21T03:01:35.4934829Z Jun 21 03:01:35 "An error
occurred while calling {0}{1}{2}. Trace:\n{3}\n".
2022-06-21T03:01:35.4935466Z Jun 21 03:01:35
format(target_id, ".", name, value))
2022-06-21T03:01:35.4936110Z Jun 21 03:01:35 E
py4j.protocol.Py4JError: An error occurred while calling None.None. Trace:
2022-06-21T03:01:35.4937114Z Jun 21 03:01:35 E
org.apache.flink.api.python.shaded.py4j.Py4JException: Cannot convert
org.apache.flink.elasticsearch7.shaded.org.apache.http.HttpHost to
org.apache.flink.elasticsearch7.shaded.org.apache.http.HttpHost
2022-06-21T03:01:35.4938983Z Jun 21 03:01:35 E at
org.apache.flink.api.python.shaded.py4j.commands.ArrayCommand.convertArgument(ArrayCommand.java:166)
2022-06-21T03:01:35.4940139Z Jun 21 03:01:35 E at
org.apache.flink.api.python.shaded.py4j.commands.ArrayCommand.setArray(ArrayCommand.java:144)
2022-06-21T03:01:35.4941251Z Jun 21 03:01:35 E at
org.apache.flink.api.python.shaded.py4j.commands.ArrayCommand.execute(ArrayCommand.java:97)
2022-06-21T03:01:35.4942313Z Jun 21 03:01:35 E at
org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
2022-06-21T03:01:35.4943334Z Jun 21 03:01:35 E at
java.base/java.lang.Thread.run(Thread.java:829)
2022-06-21T03:01:35.4943905Z Jun 21 03:01:35
2022-06-21T03:01:35.4945225Z Jun 21 03:01:35
.tox/py39-cython/lib/python3.9/site-packages/py4j/protocol.py:330: Py4JError
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36979&view=logs&j=e92ecf6d-e207-5a42-7ff7-528ff0c5b259&t=40fc352e-9b4c-5fd8-363f-628f24b01ec2
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
