We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4700974 commit d907c3aCopy full SHA for d907c3a
python/pytest.ini
python/tests/flink/test_flink_registration.py
@@ -21,10 +21,9 @@
21
from tests.flink.conftest import has_pyflink
22
23
if not has_pyflink():
24
- pytest.skip("PyFlink is not installed. Skipping tests that require PyFlink.")
+ pytest.skip("PyFlink is not installed. Skipping tests that require PyFlink.", allow_module_level=True)
25
26
27
-@pytest.mark.flink
28
def test_register(table_env):
29
result = (
30
table_env.sql_query("SELECT ST_ASBinary(ST_Point(1.0, 2.0))")
@@ -35,7 +34,6 @@ def test_register(table_env):
35
34
assert 1 == len([el for el in result])
36
37
38
39
def test_register_udf(table_env):
40
from pyflink.table.udf import ScalarFunction, udf
41
0 commit comments