Huang Xingbo created FLINK-20507:
Summary: Support Aggregate Operation in Python Table API
Key: FLINK-20507
URL: https://issues.apache.org/jira/browse/FLINK-20507
Project: Flink
Issue Type: S
Huang Xingbo created FLINK-20506:
Summary: Support FlatMap Operation in Python Table API
Key: FLINK-20506
URL: https://issues.apache.org/jira/browse/FLINK-20506
Project: Flink
Issue Type: Sub
+1 (non-binding)
- checked/verified signatures and hashes
- built from source code with scala 2.11 succeeded
- checked that there are no missing artifacts
- started a cluster, WebUI was accessible, submitted a wordcount job and ran
succeeded, no suspicious log output
- tested using SQL Client to
Thanks Rui for starting this discussion.
I can see the benefit that we improve hive compatibility further, as quite
some users are asking for this
feature in mailing lists [1][2][3] and some online chatting tools such as
DingTalk.
I have 3 comments regarding to the design doc:
a) Could you add a
Xintong Song created FLINK-20505:
Summary: Yarn provided lib does not work with http paths.
Key: FLINK-20505
URL: https://issues.apache.org/jira/browse/FLINK-20505
Project: Flink
Issue Type:
zhuxiaoshang created FLINK-20504:
Summary: NPE when writing to hive and fail over happened
Key: FLINK-20504
URL: https://issues.apache.org/jira/browse/FLINK-20504
Project: Flink
Issue Type: B
Xintong Song created FLINK-20503:
Summary: Internal cpu configuration option is leaked in logs
Key: FLINK-20503
URL: https://issues.apache.org/jira/browse/FLINK-20503
Project: Flink
Issue Typ
+1(non-binding)
- build from source
- build a docker image
- start a session from local k8s cluster
- submit a wordcount job in streaming mode.
- submit a wordcount job in batch mode.
Best,
Guowei
On Sat, Dec 5, 2020 at 3:13 PM Zhu Zhu wrote:
> +1 (binding)
>
> - verified signature and checksum
Leonard Xu created FLINK-20502:
--
Summary: Reduce the uploading time of hadoop jars in hbase e2e
test
Key: FLINK-20502
URL: https://issues.apache.org/jira/browse/FLINK-20502
Project: Flink
Iss
Huang Xingbo created FLINK-20501:
Summary:
FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with
"Delete test topic :
flink-kafka-producer-fail-and-recover-same-checkpoint-twice"
Key: FLINK-20501
Huang Xingbo created FLINK-20500:
Summary: UpsertKafkaTableITCase.testTemporalJoin test failed
Key: FLINK-20500
URL: https://issues.apache.org/jira/browse/FLINK-20500
Project: Flink
Issue Typ
11 matches
Mail list logo