Tzu-Li (Gordon) Tai created FLINK-11094:
---
Summary: Restored state in RocksDBStateBackend that has not been
accessed in new execution causes NPE on snapshot
Key: FLINK-11094
URL:
xueyu created FLINK-11093:
-
Summary: Migrate flink-table runtime Function classes
Key: FLINK-11093
URL: https://issues.apache.org/jira/browse/FLINK-11093
Project: Flink
Issue Type: New Feature
xueyu created FLINK-11092:
-
Summary: Migrate flink-table runtime Selector and Collector classes
Key: FLINK-11092
URL: https://issues.apache.org/jira/browse/FLINK-11092
Project: Flink
Issue Type: New
hi Timo Walther??
I have redesigned and sorted it out. Please find the details in the
attachment and I also added it to jira.
https://issues.apache.org/jira/browse/FLINK-9740
thanks
qianjin
Hequn Cheng created FLINK-11090:
---
Summary: Unused parameter in WindowedStream.aggregate()
Key: FLINK-11090
URL: https://issues.apache.org/jira/browse/FLINK-11090
Project: Flink
Issue Type:
sunjincheng created FLINK-11091:
---
Summary: Clear the use of deprecated methods of KeyedStream in
table operators
Key: FLINK-11091
URL: https://issues.apache.org/jira/browse/FLINK-11091
Project: Flink
Hi,
You now have contributor permissions and can assign JIRAs you would like to
work on to yourself.
Welcome to the community!
Cheers,
Gordon
On Fri, Dec 7, 2018, 11:17 AM sf lee Hi there,
> Could anyone kindly give me the contributor permission?
> My JIRA id is xleesf.
>
> Thanks,
>
> xleesf
Hi there,
Could anyone kindly give me the contributor permission?
My JIRA id is xleesf.
Thanks,
xleesf
liuzhaokun created FLINK-11089:
--
Summary: Log filecache directory removed messages
Key: FLINK-11089
URL: https://issues.apache.org/jira/browse/FLINK-11089
Project: Flink
Issue Type:
dev apply
Hi Pakesh Kuma,
I think you can using the interval-join, e.g.:
orderStream
.keyBy()
.intervalJoin(invoiceStream.keyBy())
.between(Time.minutes(-5), Time.minutes(5))
The semantics of interval-join and detailed usage description can refer to
Rong Rong created FLINK-11088:
-
Summary: Improve Kerberos Authentication using Keytab in YARN
proxy user mode
Key: FLINK-11088
URL: https://issues.apache.org/jira/browse/FLINK-11088
Project: Flink
Hi,
welcome to the Flink community. If you give me your JIRA username, I can
give your contributor permissions.
Thanks,
Timo
Am 06.12.18 um 12:12 schrieb shen lei:
Hi All,
Could you give me the permission to solve the flink's jira issues? I
am interested in Flink, and I want to find
Sebastian Klemke created FLINK-11086:
Summary: flink-hadoop-compatibility tests fail for 3.x hadoop
versions
Key: FLINK-11086
URL: https://issues.apache.org/jira/browse/FLINK-11086
Project: Flink
Edward Rojas created FLINK-11087:
Summary: Broadcast state migration Incompatibility from 1.5.3 to
1.7.0
Key: FLINK-11087
URL: https://issues.apache.org/jira/browse/FLINK-11087
Project: Flink
Chesnay Schepler created FLINK-11085:
Summary: flink-s3-fs-presto
Key: FLINK-11085
URL: https://issues.apache.org/jira/browse/FLINK-11085
Project: Flink
Issue Type: Bug
Hi All,
Could you give me the permission to solve the flink's jira issues? I
am interested in Flink, and I want to find some easy jira issues to study
flink.If possible，I hope to make some contribution to flink.At the same
time , I could learn flink more deeply.Thank you.
Best wishes,
Lei
Hi,
I have two data sources one is for order data and another one is for
invoice data, these two data i am pushing into kafka topic in json form. I
wanted to delay order data for 5 mins because invoice data comes only after
order data is generated. So, for that i have written a flink program
Hi everyone,
great to have such a lively discussion. My next batch of feedback:
@Jark: We don't need to align the descriptor approach with SQL. I'm open
for different approaches as long as we can serve a broad set of use
cases and systems. The descriptor approach was a first attempt to cover
19 matches
Mail list logo
