Skip to content

[ZEPPELIN-6276] Replace Deprecated Number Constructors for Java 11 #5027

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.

Sign up for GitHub

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

Merged
merged 2 commits into from
Aug 19, 2025
Merged

[ZEPPELIN-6276] Replace Deprecated Number Constructors for Java 11 #5027

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
7303e7a
[ZEPPELIN-6276] Replace Deprecated Number Constructors for Java 11
celinayk Aug 16, 2025
f0bdb35
[ZEPPELIN-6276] Fix: catch only NumberFormatException for KINIT_FAIL_…
celinayk Aug 17, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions rlang/src/main/java/org/apache/zeppelin/r/ZeppelinR.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,14 +49,14 @@ public class ZeppelinR {
* Request to R repl
*/
private Request rRequestObject = null;
private Integer rRequestNotifier = new Integer(0);
private Integer rRequestNotifier = Integer.valueOf(0);

/**
* Response from R repl
*/
private Object rResponseValue = null;
private boolean rResponseError = false;
private Integer rResponseNotifier = new Integer(0);
private Integer rResponseNotifier = Integer.valueOf(0);

public ZeppelinR(RInterpreter rInterpreter) {
this.rInterpreter = rInterpreter;
Expand Down
4 changes: 2 additions & 2 deletions zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/KerberosInterpreter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,8 +95,8 @@ private Integer kinitFailThreshold() {
//defined in zeppelin-env.sh, if not initialized then the default value is 5.
if (System.getenv("KINIT_FAIL_THRESHOLD") != null) {
try {
kinitFailThreshold = new Integer(System.getenv("KINIT_FAIL_THRESHOLD"));
} catch (Exception e) {
kinitFailThreshold = Integer.valueOf(System.getenv("KINIT_FAIL_THRESHOLD"));
} catch (NumberFormatException e) {
LOGGER.error("Cannot get integer value from the given string, " + System
.getenv("KINIT_FAIL_THRESHOLD") + " defaulting to " + kinitFailThreshold, e);
}
Expand Down
4 changes: 2 additions & 2 deletions zeppelin-interpreter/src/test/java/org/apache/zeppelin/resource/ResourceSetTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ void testFilterByName() {
ResourceSet set = new ResourceSet();

set.add(new Resource(null, new ResourceId("poo1", "resource1"), "value1"));
set.add(new Resource(null, new ResourceId("poo1", "resource2"), new Integer(2)));
set.add(new Resource(null, new ResourceId("poo1", "resource2"), Integer.valueOf(2)));
assertEquals(2, set.filterByNameRegex(".*").size());
assertEquals(1, set.filterByNameRegex("resource1").size());
assertEquals(1, set.filterByNameRegex("resource2").size());
Expand All @@ -43,7 +43,7 @@ void testFilterByClassName() {
ResourceSet set = new ResourceSet();

set.add(new Resource(null, new ResourceId("poo1", "resource1"), "value1"));
set.add(new Resource(null, new ResourceId("poo1", "resource2"), new Integer(2)));
set.add(new Resource(null, new ResourceId("poo1", "resource2"), Integer.valueOf(2)));

assertEquals(1, set.filterByClassnameRegex(".*String").size());
assertEquals(1, set.filterByClassnameRegex(String.class.getName()).size());
Expand Down
8 changes: 4 additions & 4 deletions ...elin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/AppendOutputRunner.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,9 @@
public class AppendOutputRunner implements Runnable {

private static final Logger LOGGER = LoggerFactory.getLogger(AppendOutputRunner.class);
public static final Long BUFFER_TIME_MS = new Long(100);
private static final Long SAFE_PROCESSING_TIME = new Long(10);
private static final Long SAFE_PROCESSING_STRING_SIZE = new Long(100000);
public static final Long BUFFER_TIME_MS = Long.valueOf(100);
private static final Long SAFE_PROCESSING_TIME = Long.valueOf(10);
private static final Long SAFE_PROCESSING_STRING_SIZE = Long.valueOf(100000);

private final BlockingQueue<AppendOutputBuffer> queue = new LinkedBlockingQueue<>();
private final RemoteInterpreterProcessListener listener;
Expand Down Expand Up @@ -90,7 +90,7 @@ public void run() {
LOGGER.debug("Processing time for append-output took {} milliseconds", processingTime);
}

Long sizeProcessed = new Long(0);
Long sizeProcessed = Long.valueOf(0);
for (Entry<String, StringBuilder> stringBufferMapEntry : stringBufferMap.entrySet()) {
String stringBufferKey = stringBufferMapEntry.getKey();
StringBuilder buffer = stringBufferMapEntry.getValue();
Expand Down
Loading