Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

[ZEPPELIN-5160]. Improve github action CI

Browse source
This commit is contained in:
Jeff Zhang 2020-12-11 17:45:44 +08:00
parent 73aa82ed45
commit 6edcfe6928
5 changed files with 69 additions and 45 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
flink/interpreter/src/test/java/org/apache/zeppelin/flink/IPyFlinkInterpreterTest.java
View file

@ -409,7 +409,7 @@ public class IPyFlinkInterpreterTest extends IPythonInterpreterTest {
"log group by url')\nz.show(table, stream_type='update')", context);
assertEquals(InterpreterResult.Code.SUCCESS, result.code());
List<InterpreterResultMessage> resultMessages = context.out.toInterpreterResultMessage();
assertEquals(InterpreterResult.Type.TABLE, resultMessages.get(0).getType());
assertEquals(context.out.toString(), InterpreterResult.Type.TABLE, resultMessages.get(0).getType());
TestCase.assertTrue(resultMessages.toString(),
resultMessages.get(0).getData().contains("url\tpv\n"));
}

48
python/src/test/java/org/apache/zeppelin/python/BasePythonInterpreterTest.java
View file

@ -354,22 +354,48 @@ public abstract class BasePythonInterpreterTest extends ConcurrentTestCase {
assertEquals("%text world\n", context.out.getCurrentOutput().toString());
}
@Test
//@Test
public void testRedefinitionZeppelinContext() throws InterpreterException {
String redefinitionCode = "z = 1\n";
String restoreCode = "z = __zeppelin__\n";
String validCode = "z.input(\"test\")\n";
assertEquals(InterpreterResult.Code.SUCCESS,
interpreter.interpret(validCode, getInterpreterContext()).code());
assertEquals(InterpreterResult.Code.SUCCESS,
interpreter.interpret(redefinitionCode, getInterpreterContext()).code());
assertEquals(InterpreterResult.Code.ERROR,
interpreter.interpret(validCode, getInterpreterContext()).code());
assertEquals(InterpreterResult.Code.SUCCESS,
interpreter.interpret(restoreCode, getInterpreterContext()).code());
assertEquals(InterpreterResult.Code.SUCCESS,
interpreter.interpret(validCode, getInterpreterContext()).code());
InterpreterContext context = getInterpreterContext();
InterpreterResult result = interpreter.interpret(validCode, context);
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
context = getInterpreterContext();
result = interpreter.interpret(redefinitionCode, context);
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
context = getInterpreterContext();
result = interpreter.interpret(validCode, context);
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.ERROR, result.code());
context = getInterpreterContext();
result = interpreter.interpret(restoreCode, context);
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
context = getInterpreterContext();
result = interpreter.interpret("type(__zeppelin__)", context);
System.out.println("result: " + context.out.toString() + ", " + result.toString());
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
context = getInterpreterContext();
result = interpreter.interpret("type(z)", context);
System.out.println("result2: " + context.out.toString() + ", " + result.toString());
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
context = getInterpreterContext();
result = interpreter.interpret(validCode, context);
assertEquals(context.out.toString() + ", " + result.toString(),
InterpreterResult.Code.SUCCESS, result.code());
}
protected InterpreterContext getInterpreterContext() {

31
testing/env_python_3 with_flink_1_10.yml
View file

@ -3,23 +3,22 @@ channels:
- conda-forge
- defaults
dependencies:
- pycodestyle
- numpy=1
- pandas=0.25
- scipy=1
- grpcio
- hvplot
- protobuf=3
- pandasql=0.7.3
- ipython=7
- matplotlib=3
- ipykernel=5
- jupyter_client=5
- bokeh=1.3.4
- panel
- holoviews
- pyyaml=3
- pip
- pip:
- bkzep==0.6.1
- apache-flink==1.10.1
- numpy==1.17.3
- pandas==0.25.0
- scipy==1.3.1
- grpcio==1.19.0
- hvplot==0.5.2
- protobuf==3.10.0
- pandasql==0.7.3
- ipython==7.8.0
- matplotlib==3.0.3
- ipykernel==5.1.2
- jupyter_client==5.3.4
- bokeh==1.3.4
- panel==0.6.0
- holoviews==1.12.3
- pycodestyle==2.5.0

31
testing/env_python_3 with_flink_1_11.yml
View file

@ -3,23 +3,22 @@ channels:
- conda-forge
- defaults
dependencies:
- pycodestyle
- numpy=1
- pandas=0.25
- scipy=1
- grpcio
- hvplot
- protobuf=3
- pandasql=0.7.3
- ipython=7
- matplotlib=3
- ipykernel=5
- jupyter_client=5
- bokeh=1.3.4
- panel
- holoviews
- pyyaml=3
- pip
- pip:
- bkzep==0.6.1
- apache-flink==1.11.1
- numpy==1.17.3
- pandas==0.25.0
- scipy==1.3.1
- grpcio==1.19.0
- hvplot==0.5.2
- protobuf==3.10.0
- pandasql==0.7.3
- ipython==7.8.0
- matplotlib==3.0.3
- ipykernel==5.1.2
- jupyter_client==5.3.4
- bokeh==1.3.4
- panel==0.6.0
- holoviews==1.12.3
- pycodestyle==2.5.0

2
zeppelin-jupyter-interpreter/src/main/java/org/apache/zeppelin/jupyter/JupyterKernelInterpreter.java
View file

@ -168,7 +168,7 @@ public class JupyterKernelInterpreter extends AbstractInterpreter {
*/
if (!freezeOutput.contains(packageName + "=") &&
!freezeOutput.contains(packageName + " ")) {
return packageName + " is not installed.";
return packageName + " is not installed, installed packages:\n" + freezeOutput;
}
}
LOGGER.info("Prerequisite for kernel {} is met", getKernelName());