You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/07/12 06:39:00 UTC
[jira] [Reopened] (FLINK-28176) test_es_sink_dynamic failed in jdk11
[ https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martijn Visser reopened FLINK-28176:
------------------------------------
Re-opened, a new failed run:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=37772&view=logs&j=e92ecf6d-e207-5a42-7ff7-528ff0c5b259&t=40fc352e-9b4c-5fd8-363f-628f24b01ec2&l=27201
> 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
> Assignee: Huang Xingbo
> Priority: Critical
> Labels: pull-request-available, test-stability
> Fix For: 1.16.0
>
>
> {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.10#820010)