Paul Lin created FLINK-17403:
Summary: Fix invalid classpath in BashJavaUtilsITCase
Key: FLINK-17403
URL: https://issues.apache.org/jira/browse/FLINK-17403
Project: Flink
Issue Type: Bug
chaganti spurthi created FLINK-17402:
Summary: Add User to Task Manager
Key: FLINK-17402
URL: https://issues.apache.org/jira/browse/FLINK-17402
Project: Flink
Issue Type: Bug
C
chaganti spurthi created FLINK-17401:
Summary: Add Labels to Mesos TM taskinfo
Key: FLINK-17401
URL: https://issues.apache.org/jira/browse/FLINK-17401
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-17400:
--
Summary: LocalStandaloneKafkaResource.setupKafkaDist fails due to
download timeout
Key: FLINK-17400
URL: https://issues.apache.org/jira/browse/FLINK-17400
Project
godfrey he created FLINK-17399:
--
Summary: CsvTableSink should also extend from OverwritableTableSink
Key: FLINK-17399
URL: https://issues.apache.org/jira/browse/FLINK-17399
Project: Flink
Issue
Hi all,
Why my flink checkpoint always expired, I used RocksDB checkpoint,
and I can’t get any useful messages for this. Could you help me ? Thanks very
much.
Jingsong Lee created FLINK-17398:
Summary: Support flexible path reading
Key: FLINK-17398
URL: https://issues.apache.org/jira/browse/FLINK-17398
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-17397:
Summary: Filesystem support lookup table source
Key: FLINK-17397
URL: https://issues.apache.org/jira/browse/FLINK-17397
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-17396:
---
Summary: Support SHOW MODULES in Flink SQL
Key: FLINK-17396
URL: https://issues.apache.org/jira/browse/FLINK-17396
Project: Flink
Issue Type: New Feature
Huang Xingbo created FLINK-17395:
Summary: Add the sign and sha logic for PyFlink wheel packages
Key: FLINK-17395
URL: https://issues.apache.org/jira/browse/FLINK-17395
Project: Flink
Issue T
Hi jinhai,
I think it is a good improvement to also add groupingKey to
PrometheusReporter.And making
the PrometheusPushGatewayReporter and PrometheusReporter always share the
same logics
is important. AFAIK, they should not have differences except for the
metrics exposing mechanism
pulling/pushing
Huang Xingbo created FLINK-17394:
Summary: Add RemoteEnvironment and RemoteStreamEnvironment in
Python
Key: FLINK-17394
URL: https://issues.apache.org/jira/browse/FLINK-17394
Project: Flink
Thanks Dian for managing this release!
Best,
Jingsong Lee
On Sun, Apr 26, 2020 at 7:17 PM Jark Wu wrote:
> Thanks Dian for being the release manager and thanks all who make this
> possible.
>
> Best,
> Jark
>
> On Sun, 26 Apr 2020 at 18:06, Leonard Xu wrote:
>
> > Thanks Dian for the release a
Jiangjie Qin created FLINK-17393:
Summary: Improve the `FutureCompletingBlockingQueue` to wakeup
blocking put() more elegantly.
Key: FLINK-17393
URL: https://issues.apache.org/jira/browse/FLINK-17393
Bowen Li created FLINK-17392:
Summary: enable configuring minicluster in Flink SQL in IDE
Key: FLINK-17392
URL: https://issues.apache.org/jira/browse/FLINK-17392
Project: Flink
Issue Type: Improv
Indeed, that would be the assumption, that Hadoop does not expose its
transitive libraries on its public API surface.
>From vague memory, I think that pretty much true so far. I only remember
Kinesis and Calcite as counter examples, who exposed Guava classes as part
of the public API.
But that is
That makes sense, thanks for clarifying.
Best,
Stephan
On Fri, Apr 24, 2020 at 2:15 PM Dawid Wysakowicz
wrote:
> Hi Stephan,
>
> I fully agree with what you said. Also as far as I can tell what was
> suggested in the FLIP-124 does not contradict with what you are saying. Let
> me clarify it a
Jingsong Lee created FLINK-17391:
Summary: sink.rolling-policy.time.interval default value should be
bigger
Key: FLINK-17391
URL: https://issues.apache.org/jira/browse/FLINK-17391
Project: Flink
Xintong Song created FLINK-17390:
Summary: Container resource cannot be mapped on Hadoop 2.10+
Key: FLINK-17390
URL: https://issues.apache.org/jira/browse/FLINK-17390
Project: Flink
Issue Typ
Dear community,
happy to share this week's community digest with an update on Flink 1.11,
Flink 1.10.1 and Flink 1.9.3, the revival of FLIP-36 to support interactive
programming, a new FLIP to unify (& separate) TimestampAssigners and a bit
more.
Flink Development
==
Releases
^^
Thanks Dian for being the release manager and thanks all who make this
possible.
Best,
Jark
On Sun, 26 Apr 2020 at 18:06, Leonard Xu wrote:
> Thanks Dian for the release and being the release manager !
>
> Best，
> Leonard Xu
>
>
> 在 2020年4月26日，17:58，Benchao Li 写道：
>
> Thanks Dian for the effor
Thanks Dian for the release and being the release manager !
Best，
Leonard Xu
> 在 2020年4月26日，17:58，Benchao Li 写道：
>
> Thanks Dian for the effort, and all who make this release possible. Great
> work!
>
> Konstantin Knauf mailto:konstan...@ververica.com>>
> 于2020年4月26日周日 下午5:21写道：
> Thanks fo
Thanks Dian for the effort, and all who make this release possible. Great
work!
Konstantin Knauf 于2020年4月26日周日 下午5:21写道：
> Thanks for managing this release!
>
> On Sun, Apr 26, 2020 at 3:58 AM jincheng sun
> wrote:
>
>> Thanks for your great job, Dian!
>>
>> Best,
>> Jincheng
>>
>>
>> Hequn Che
Thanks for managing this release!
On Sun, Apr 26, 2020 at 3:58 AM jincheng sun
wrote:
> Thanks for your great job, Dian!
>
> Best,
> Jincheng
>
>
> Hequn Cheng 于2020年4月25日周六 下午8:30写道：
>
>> @Dian, thanks a lot for the release and for being the release manager.
>> Also thanks to everyone who made
Zhijiang created FLINK-17389:
Summary: LocalExecutorITCase.testBatchQueryCancel asserts error
Key: FLINK-17389
URL: https://issues.apache.org/jira/browse/FLINK-17389
Project: Flink
Issue Type: Bu
cloudzhao created FLINK-17388:
-
Summary: flink sql The custom function in ROW type is executed
multiple times
Key: FLINK-17388
URL: https://issues.apache.org/jira/browse/FLINK-17388
Project: Flink
Rui Li created FLINK-17387:
--
Summary: Implement LookupableTableSource for Hive connector
Key: FLINK-17387
URL: https://issues.apache.org/jira/browse/FLINK-17387
Project: Flink
Issue Type: New Featur
27 matches
Mail list logo
