ParkGyeongTae opened a new pull request, #4878:
URL: https://github.com/apache/zeppelin/pull/4878

   ### What is this PR for?
   There was an issue where the port was treated as a string and included `.0` 
when modifying the port of the Elasticsearch interpreter.
   
   ### What type of PR is it?
   Bug Fix
   
   ### Todos
   * [ ] - Modified HttpBasedClient.java file
   
   ### What is the Jira issue?
   * https://issues.apache.org/jira/projects/ZEPPELIN/issues/ZEPPELIN-6131
   
   ### How should this be tested?
   * Zeppelin project build and run
   ```bash
   ./mvnw clean package -DskipTests
   ```
   
   * Add a test index and test data to Elasticsearch
   ```bash
   # Create an index
   curl -X PUT "http://localhost:9200/customer?pretty";
   
   # Create a document
   curl -X \
   PUT "localhost:9200/customer/_doc/1" \
   -H 'Content-Type: application/json' \
   -d'
   {
     "field_1": "value_1"
   }'
   ```
   
   * Modify the Elasticsearch interpreter type and port
   elasticsearch.client.type: transport -> http
   elasticsearch.port: 9300 -> 9200
   
   * Previous configuration
   <img width="1228" alt="image" 
src="https://github.com/user-attachments/assets/aab69016-b982-4817-8d72-68186fdd45b8";>
   
   * New configuration
   <img width="1219" alt="image" 
src="https://github.com/user-attachments/assets/a9c44503-1ed1-43c0-89f9-19b92a1ac1e0";>
   
   * Create a Zeppelin notebook and execute a paragraph
   ```bash
   %elasticsearch
   get /customer/_doc/1
   ```
   
   * Result before modification - Error occurred
   <img width="942" alt="image" 
src="https://github.com/user-attachments/assets/00d5db2f-e1dd-46bf-96d9-eb2eb1d88072";>
   
   ```bash
   org.apache.zeppelin.interpreter.InterpreterException: 
java.lang.NumberFormatException: For input string: "9200.0"
        at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:77)
        at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:808)
        at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:716)
        at org.apache.zeppelin.scheduler.Job.run(Job.java:187)
        at 
org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:136)
        at 
org.apache.zeppelin.scheduler.FIFOScheduler.lambda$runJobInScheduler$0(FIFOScheduler.java:42)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)
   Caused by: java.lang.NumberFormatException: For input string: "9200.0"
        at 
java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
        at java.base/java.lang.Integer.parseInt(Integer.java:652)
        at java.base/java.lang.Integer.parseInt(Integer.java:770)
        at 
org.apache.zeppelin.elasticsearch.client.HttpBasedClient.<init>(HttpBasedClient.java:67)
        at 
org.apache.zeppelin.elasticsearch.ElasticsearchInterpreter.open(ElasticsearchInterpreter.java:136)
        at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:71)
        ... 8 more
   ```
   
   * Result after modification
   <img width="500" alt="image" 
src="https://github.com/user-attachments/assets/2634216c-ed42-4a1e-8c6d-d3bb378365fa";>
   
   ### Screenshots (if appropriate)
   * Refer to the above content
   
   ### Questions:
   * Does the license files need to update? No.
   * Is there breaking changes for older versions? No.
   * Does this needs documentation? No.
   


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to