Hi jincheng,
Thanks for activating this discussion again.
I personally look forward to your design draft.
Best,
Vino
jincheng sun 于2019年3月28日周四 下午12:16写道：
> Hi everyone,
> Sorry to join in this discussion late.
>
> Thanks to Xianda Ke for initiating this discussion. I also enjoy the
> discussi
Paul Lin created FLINK-12042:
Summary: RocksDBStateBackend mistakenly uses default filesystem
Key: FLINK-12042
URL: https://issues.apache.org/jira/browse/FLINK-12042
Project: Flink
Issue Type: Bu
This proposal mentioned that SplitEnumerator might run on the JobManager or
in a single task on a TaskManager.
if enumerator is a single task on a taskmanager, then the job DAG can never
been embarrassingly parallel anymore. That will nullify the leverage of
fine-grained recovery for embarrassingl
Hi everyone,
Sorry to join in this discussion late.
Thanks to Xianda Ke for initiating this discussion. I also enjoy the
discussions&suggestions by Max, Austin, Thomas, Shaoxuan and others.
Recently, I did feel the desire of the community and Flink users for Python
support. Stephan also pointed o
Jingsong Lee created FLINK-12041:
Summary: Introduce ResettableExternalBuffer to blink batch
Key: FLINK-12041
URL: https://issues.apache.org/jira/browse/FLINK-12041
Project: Flink
Issue Type:
By now, I'm reasonably sure that the test instabilities on the end-to-end test
are only instabilities. I pushed changes to increase timeouts to make the tests
more stable. As in any project, there will always be bugs but I think we could
release this RC4 and be reasonably sure that it works well
TisonKun created FLINK-12040:
Summary: Remove unused akka dependencies in pom.xml
Key: FLINK-12040
URL: https://issues.apache.org/jira/browse/FLINK-12040
Project: Flink
Issue Type: Improvement
Hi everyone,
some of you might have already read FLIP-32 [1] where we've described an
approximate roadmap of how to handle the big Blink SQL contribution and
how we can make the Table & SQL API equally important to the existing
DataStream API.
As mentioned there (Advance the API and Unblock
Hi all,
thanks for the great feedback! I see a clear majority for a new Java DSL.
I agree with Dawid that we should aim for 1.9. Compared to other
efforts, this is a relatively small change ;-)
I will further develop my protoype and come back to you once I have a
production-ready solution.
Andrey Zagrebin created FLINK-12039:
---
Summary: Remove ASSIGNED_SLOT_UPDATER in
Execution.tryAssignResource
Key: FLINK-12039
URL: https://issues.apache.org/jira/browse/FLINK-12039
Project: Flink
Chesnay Schepler created FLINK-12038:
Summary: YARNITCase stalls on travis
Key: FLINK-12038
URL: https://issues.apache.org/jira/browse/FLINK-12038
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-12037:
Summary: High parallelism E2E test failed on Travis
Key: FLINK-12037
URL: https://issues.apache.org/jira/browse/FLINK-12037
Project: Flink
Issue Type
Till Rohrmann created FLINK-12036:
-
Summary: Simplify ExecutionGraph by removing legacy concurrency
code
Key: FLINK-12036
URL: https://issues.apache.org/jira/browse/FLINK-12036
Project: Flink
Chesnay Schepler created FLINK-12035:
Summary: StreamingFileSink E2E failed on Travis
Key: FLINK-12035
URL: https://issues.apache.org/jira/browse/FLINK-12035
Project: Flink
Issue Type: Bu
Till Rohrmann created FLINK-12034:
-
Summary: KafkaITCase.testAllDeletes failed on Travis
Key: FLINK-12034
URL: https://issues.apache.org/jira/browse/FLINK-12034
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-12033:
-
Summary: KafkaITCase.testCancelingFullTopic failed on Travis
Key: FLINK-12033
URL: https://issues.apache.org/jira/browse/FLINK-12033
Project: Flink
Issue T
Till Rohrmann created FLINK-12032:
-
Summary: KafkaProducerAtLeastOnceITCase failed to bind to address
Key: FLINK-12032
URL: https://issues.apache.org/jira/browse/FLINK-12032
Project: Flink
Is
frank wang created FLINK-12031:
--
Summary: the registerFactory method of TypeExtractor Should not
be private
Key: FLINK-12031
URL: https://issues.apache.org/jira/browse/FLINK-12031
Project: Flink
Aljoscha Krettek created FLINK-12030:
Summary: KafkaITCase.testMultipleSourcesOnePartition is unstable
Key: FLINK-12030
URL: https://issues.apache.org/jira/browse/FLINK-12030
Project: Flink
19 matches
Mail list logo
