Stephan Ewen created FLINK-19205:
Summary: SourceReaderContext should give access to Configuration
and Hostbame
Key: FLINK-19205
URL: https://issues.apache.org/jira/browse/FLINK-19205
Project: Flink
I could try and come up with a longer name if you need it ... ;-)
Aljoscha
On 11.09.20 16:25, Seth Wiesman wrote:
Having thought about it more, HashMapStateBackend has won me over. I'll
update the FLIP. If there aren't any more comments I'll open it up for
voting on monday.
Seth
On Wed, Sep
Having thought about it more, HashMapStateBackend has won me over. I'll
update the FLIP. If there aren't any more comments I'll open it up for
voting on monday.
Seth
On Wed, Sep 9, 2020 at 9:09 AM Seth Wiesman wrote:
> @Yun yes, this is really about making CheckpointStorage an orthogonal
>
Hi all,
after the discussion in [1], I would like to open a voting thread for
FLIP-136 [2] which covers different topic to improve the back-and-forth
communication between DataStream API and Table API.
The vote will be open until September 16th (72h + weekend), unless there
is an objection
Big +1 to drop Scala 2.11
This would mean that we can finally use Java 8 language features that
are integrated with Scala.
Regards,
Timo
On 11.09.20 13:15, Igal Shilman wrote:
@Galen FYI: the upcoming StateFun release would use Scala2.12
On Thu, Sep 10, 2020 at 5:14 PM Seth Wiesman
Timo Walther created FLINK-19204:
Summary: Improve warning during a Table.execute()
Key: FLINK-19204
URL: https://issues.apache.org/jira/browse/FLINK-19204
Project: Flink
Issue Type:
Thanks for the thoughtful comments! I'll try and address them inline
below. I'm hoping to start a VOTE thread soon if there are no other
comments by the end of today.
On 10.09.20 15:40, David Anderson wrote:
Having just re-read FLIP-134, I think it mostly makes sense, though I'm not
exactly
Hi Sunitha,
(Note: You've emailed both the dev@ and user@ mailing list. Please only use
the user@ mailing list for questions on how to use Flink. I'm moving the
dev@ list to bcc)
Flink does not have facilities for scheduling batch jobs, and there are no
plans to add such a feature (this is not
@Galen FYI: the upcoming StateFun release would use Scala2.12
On Thu, Sep 10, 2020 at 5:14 PM Seth Wiesman wrote:
> @glen
>
> Yes, we would absolutely migrate statefun. StateFun can be compiled with
> Scala 2.12 today, I'm not sure why it's not cross released.
>
> @aljoscha :)
>
> @mathieu Its
Igal Shilman created FLINK-19203:
Summary: Use Flink-*-scala2.12 variants for StateFun
Key: FLINK-19203
URL: https://issues.apache.org/jira/browse/FLINK-19203
Project: Flink
Issue Type:
Regarding the FLIP itself, I like the motivation section and the
What/How/When/Where section a lot!
I don't understand why we need the "Drain and Snapshot" section. It
seems to be some details about stop-with-savepoint and drain, and the
relation to BATCH execution but I don't know if it is
Hi Everyone,
thanks to Guowei for publishing the FLIP, and thanks Steven for the very
thoughtful email!
We thought a lot internally about some of the questions you posted but
left a lot (almost all) of the implementation details out of the FLIP
for now because we wanted to focus on
Dian Fu created FLINK-19202:
---
Summary: HadoopS3FileSystemITCase.testSimpleFileWriteAndRead
failed with "FileNotFoundException: No such file or directory:
s3://***/temp/tests-7ebc11df-9160-4403-85a7-c484da44f335/test.txt"
Key:
Dian Fu created FLINK-19201:
---
Summary: PyFlink e2e tests is instable and failed with "Connection
broken: OSError"
Key: FLINK-19201
URL: https://issues.apache.org/jira/browse/FLINK-19201
Project: Flink
leslieyuan created FLINK-19200:
--
Summary: UNIX_TIMESTAMP function support return in millisecond
Key: FLINK-19200
URL: https://issues.apache.org/jira/browse/FLINK-19200
Project: Flink
Issue
15 matches
Mail list logo
