Messages by Thread
-
Re: [I] [Feature] Batch operation of tasks, such as batch startup. [streampark]
via GitHub
-
Re: [I] StreamPark FAQ [streampark]
via GitHub
-
[PR] [Flink] Fix Flink 2.x Flink SQL on Yarn/K8s Application mode [streampark]
via GitHub
-
[I] Fix Flink 2.x Flink SQL deployment on Yarn and Kubernetes Application mode [streampark]
via GitHub
-
[PR] [Flink] Fix REMOTE Session JobGraph submission for Flink 1.20 SQL and uploaded JAR jobs [streampark]
via GitHub
-
[I] [Flink] Fix REMOTE Session JobGraph submission for Flink 1.20 SQL and uploaded JAR jobs [streampark]
via GitHub
-
[I] Introduce automation to keep `pnpm/action-setup` up-to-date [streampark-website]
via GitHub
-
[PR] [Fix] Handle NPE when HADOOP_HOME is not set in K8s application mode (#4304) [streampark]
via GitHub
-
[PR] [Fix] Fix savepoint state stuck in SAVEPOINTING after savepoint completion (#4338) [streampark]
via GitHub
-
[PR] [BugFix] Add spring.sql.init auto-initialization for MySQL and PostgreSQL (#4340) [streampark]
via GitHub
-
[PR] [Fix] Fix memory sizes config not taking effect in Yarn mode [streampark]
via GitHub
-
[PR] [Fix] Make WebSocket ServerEndpointExporter conditional to avoid ServerContainer not available [streampark]
via GitHub
-
Re: [I] [Bug] Websocket serverContainer not available [streampark]
via GitHub
-
[PR] [Flink] Make Flink 2.x job submission work on REMOTE mode [streampark]
via GitHub
-
[I] [Bug] No Flink 2.x job can be submitted: the shims classloader is built without the per-version jars [streampark]
via GitHub
-
[PR] [Console] Report Flink and Spark job lineage to Gravitino via OpenLineage [streampark]
via GitHub
-
[PR] [Console] Fix four DTO/entity defects that break Spark and Flink SQL app management [streampark]
via GitHub
-
[PR] [Flink] Fix Flink SQL job submission failures on the client path [streampark]
via GitHub
-
[I] [Feature] Report Flink and Spark job lineage to Gravitino via OpenLineage [streampark]
via GitHub
-
[I] [Bug] Spark application list page returns 500 (SparkAppStateEnum.of unboxes a null state) [streampark]
via GitHub
-
[I] [Bug] Creating a Spark application from the UI always returns 500 (k8sImagePullPolicy primitive int) [streampark]
via GitHub
-
[I] [Bug] Saving an already-started Flink SQL application from the UI always fails (FlinkAppCreateRequest has no sqlId) [streampark]
via GitHub
-
[I] [Bug] A stock Spark distribution cannot be registered (spark-defaults.conf is absent, spark_conf is NOT NULL) [streampark]
via GitHub
-
[I] [Bug] Build result paths are silently dropped when persisted, breaking every subsequent job start [streampark]
via GitHub
-
[I] [Bug] All Flink 2.x SQL jobs fail with NoClassDefFoundError: FlinkTableInitializerV2 [streampark]
via GitHub
-
[I] [Bug] ClassLoaderUtils.runAsClassLoader restores a stale context classloader captured at class-init time [streampark]
via GitHub
-
[PR] [Flink] Fix BuildPipeline.execStep NPE on steps that return null [streampark]
via GitHub
-
[PR] [Flink] Fix shims classloader isolation and result serialization for Flink SQL verify [streampark]
via GitHub
-
[PR] [Build] Allow the legacy SecurityManager for FlinkClient#submit on JDK 18+ [streampark]
via GitHub
-
[PR] [Console] Fix streampark-flink-sqlclient artifactId mismatch in assembly packaging and jar lookup [streampark]
via GitHub
-
[I] [Bug] PipelineExecutorFactory ServiceConfigurationError when submitting a Flink job (ChildFirstClassLoader / console baseline Flink version conflict) [streampark]
via GitHub
-
[I] [Bug] Flink SQL application build fails: can't find streampark-flink-sqlclient jar in client/ [streampark]
via GitHub
-
[I] [Bug] FlinkClient#submit fails with UnsupportedOperationException on JDK 18+ (Security Manager) [streampark]
via GitHub
-
[I] [Bug] BuildPipeline.execStep throws NullPointerException for any step that legitimately returns null [streampark]
via GitHub
-
[I] [Bug] Flink SQL verify fails with NoClassDefFoundError / NotSerializableException across the shims classloader boundary [streampark]
via GitHub
-
[PR] [E2E] Migrate Flink deploy tests to REST API and expand version matrix [streampark]
via GitHub
-
[I] [Console] Migrate E2E (Selenium) to API integration tests [streampark]
via GitHub
-
[PR] Codex/managed flink volcengine [streampark]
via GitHub
-
[PR] [Console] Introduce request/response DTOs for FlinkApplicationController [streampark]
via GitHub
-
[I] [Console] Introduce typed request/response DTOs for REST controllers [streampark]
via GitHub
-
[I] Security: Shiro 1.10.0 CVEs (CVE-2023-22602 auth bypass) + Unauthenticated /actuator/** + /h2-console/** + /proxy/** [streampark]
via GitHub
-
[PR] [Build] Remove Scala build toolchain from Flink and Console modules [streampark]
via GitHub
-
[I] [Build] Remove Scala build toolchain from Flink/Console (post-migration cleanup) [streampark]
via GitHub
-
[PR] [Spark] Migrate streampark-spark from Scala to Java [streampark]
via GitHub
-
[PR] [SECURITY] Fix 7 authorization/IDOR issues across cluster, project, variable, alert, team and H2 console endpoints [streampark]
via GitHub
-
Re: [PR] [SECURITY] Fix 7 authorization/IDOR issues across cluster, project, variable, alert, team and H2 console endpoints [streampark]
via GitHub
-
Re: [PR] [SECURITY] Fix 7 authorization/IDOR issues across cluster, project, variable, alert, team and H2 console endpoints [streampark]
via GitHub
-
Re: [PR] [BUG] Fix 7 authorization/IDOR issues across cluster, project, variable, alert, team and H2 console endpoints [streampark]
via GitHub
-
Re: [PR] [Improve] Refine permission checks and resource scope validation [streampark]
via GitHub
-
Re: [PR] [Improve] Refine permission checks and resource scope validation [streampark]
via GitHub
-
[PR] [Flink] Migrate streampark-flink-client from Scala to Java [streampark]
via GitHub
-
[PR] [Improve] validate module name before file resolution [streampark]
via GitHub
-
[PR] [K8s] Migrate streampark-flink-kubernetes from Scala to Java [streampark]
via GitHub
-
[PR] [Migrate] #4450 Migrate streampark-flink-proxy from Scala to Java [streampark]
via GitHub
-
[PR] [Migrate] #4449 Migrate streampark-flink-packer from Scala to Java [streampark]
via GitHub
-
[PR] [Migrate] #4448 Migrate streampark-flink-sqlclient from Scala to Java [streampark]
via GitHub