v0.2.6

Fix typing

v0.2.5

Fix handling errors in configure_session

v0.2.4

Switch to Python 3.12 typing

v0.2.3

• Async client: FlinkSqlGatewayClient now uses httpx.AsyncClient.
  • All client methods are async def and must be awaited.
  • Added aclose() for proper cleanup.
• Async server: Converted MCP tools/resources and helper routines to async.
  • Uses asyncio.sleep in polling/loops to avoid blocking.
  • External behavior and tool schemas remain unchanged.
• Injectable HTTP client: build_server(base_url=None, http_client=None) accepts an injected httpx.AsyncClient (useful for tests/mocking).
• Tests & fixtures:
  • Unit tests use httpx.MockTransport with an injected AsyncClient.
  • Integration tests are gated by --run-integration or RUN_INTEGRATION_TESTS=1.
  • Inlined server creation in fixtures; added integration_client/integration_session_handle for live runs.

v0.2.2

• Compact run_query_collect_and_stop: return {columns, data}, stop at max_rows

v0.2.1

Summary

This release finalizes the transition from stateful server-managed sessions to a fully stateless API where clients must explicitly manage session and operation handles.

Key Changes

• New tool: open_new_session() for explicit session creation
• Breaking change: All tools now require sessionHandle parameter
• Removed: Internal session management and stream tracking state
• Enhanced: run_query_stream_start now returns both jobID and operationHandle
• Renamed: fetch_result_by_jobid → fetch_result_page with explicit token management
• Updated: All tests and documentation to reflect stateless API

API Migration

• v0.2.1: Clients must create and manage sessions explicitly

v0.2.0

Summary

• Enhanced error handling for execute_statement operations with comprehensive error payloads
• Implemented robust job status polling using DESCRIBE JOB for better job lifecycle management
• Added retry logic for jobID extraction from streaming queries to handle timing issues
• Improved job cancellation with proper status verification and debugging logs
• Consolidated and cleaned up test structure by removing redundant integration tests

0.1.1

v0.1.1

Bump version to 0.1.1 - Add ability to read error response from Flink…

Initial version

Initial version of flink-mcp