Zhijiang created FLINK-16690:
Summary: Refactor StreamTaskTest to reuse TestTaskBuilder and
MockStreamTaskBuilder
Key: FLINK-16690
URL: https://issues.apache.org/jira/browse/FLINK-16690
Project: Flink
Huang Xingbo created FLINK-16691:
Summary: Adjust Python UDF document to remind users to install
PyFlink on the cluster
Key: FLINK-16691
URL: https://issues.apache.org/jira/browse/FLINK-16691
Project:
jackylau created FLINK-16692:
Summary: flink joblistener can register from config
Key: FLINK-16692
URL: https://issues.apache.org/jira/browse/FLINK-16692
Project: Flink
Issue Type: Improvement
Paul Lin created FLINK-16693:
Summary: Legacy planner incompatible with Timestamp backed by
LocalDateTime
Key: FLINK-16693
URL: https://issues.apache.org/jira/browse/FLINK-16693
Project: Flink
I
Piotr Nowojski created FLINK-16694:
--
Summary: Resuming Externalized Checkpoint end-to-end test failed
on travis
Key: FLINK-16694
URL: https://issues.apache.org/jira/browse/FLINK-16694
Project: Flink
Roman Khachatryan created FLINK-16696:
-
Summary: Incomplete REST API docs
Key: FLINK-16696
URL: https://issues.apache.org/jira/browse/FLINK-16696
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-16695:
--
Summary: PrometheusReporterEndToEndITCase failed on travis
Key: FLINK-16695
URL: https://issues.apache.org/jira/browse/FLINK-16695
Project: Flink
Issue T
Colm O hEigeartaigh created FLINK-16697:
---
Summary: Disable JMX rebinding
Key: FLINK-16697
URL: https://issues.apache.org/jira/browse/FLINK-16697
Project: Flink
Issue Type: Improvement
jackylau created FLINK-16698:
Summary: fllink need catalog listener to do such as
preCreate/PreDrop* afterCreate/AfterDrop* things
Key: FLINK-16698
URL: https://issues.apache.org/jira/browse/FLINK-16698
P
Canbin Zheng created FLINK-16699:
Summary: Support accessing secured services via K8s secrets
Key: FLINK-16699
URL: https://issues.apache.org/jira/browse/FLINK-16699
Project: Flink
Issue Type
Hi Tison & Till,
Changing *thenAccept *into *thenAcceptAsync *in the
MiniDispatcher#cancelJob does not help to solve the problem in my
environment. However, I have found that adding a* Thread.sleep(2000) *before
the return of JobCancellationHandler#handleRequest solved the problem (at
least the sy
Yes you are right that `thenAcceptAsync` only breaks the control flow but
it does not guarantee that the `RestServer` has actually sent the response
to the client. Maybe we also need something similar to FLINK-10309 [1]. The
problem I see with this approach is that it makes all RestHandlers statefu
+1 for the list of proposed changes
- What is "Stateful Functions"? link
- Documentation -> Stateful Functions Docs
- StateFun on GitHub
Cheers,
Till
On Thu, Mar 12, 2020 at 12:22 PM Stephan Ewen wrote:
> Thank you all, for chiming in!
>
> I like the ideas suggested to update the website,
Seth Wiesman created FLINK-16700:
Summary: Document Kinesis I/O Module
Key: FLINK-16700
URL: https://issues.apache.org/jira/browse/FLINK-16700
Project: Flink
Issue Type: Improvement
Hi Rong Rong,
you are right that it JMX is quite hard to use in production due to the
mentioned problems with discovering the port. There is actually already a
JIRA ticket [1] discussing this problem. It just never gained enough
traction to be tackled.
In general, I agree that it would be nice to
Leonard Xu created FLINK-16701:
--
Summary: Elasticsearch sink support alias for indices.
Key: FLINK-16701
URL: https://issues.apache.org/jira/browse/FLINK-16701
Project: Flink
Issue Type: Improve
Bowen Li created FLINK-16702:
Summary: develop JDBCCatalogFactory for service discovery
Key: FLINK-16702
URL: https://issues.apache.org/jira/browse/FLINK-16702
Project: Flink
Issue Type: Sub-task
Dmitri Chmelev created FLINK-16703:
--
Summary: AkkaRpcActor state machine does record transition to
terminating state.
Key: FLINK-16703
URL: https://issues.apache.org/jira/browse/FLINK-16703
Project:
+1.
I would suggest to take a step even further and see what users really need
to test/try/play with table API and Flink SQL. Besides this one, here're
some more sources and sinks that I have developed or used previously to
facilitate building Flink table/SQL pipelines.
1. random input data s
Hi All,
Here is the status update of issues in 1.10.1 watch list:
* Blockers (7)
- [Under Discussion] FLINK-16018 Improve error reporting when submitting
batch job (instead of AskTimeoutException)
- [Under Discussion] FLINK-16142 Memory Leak causes Metaspace OOM error
on repeated job submis
20 matches
Mail list logo