HuangZhenQiu commented on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-752880906
Thanks for the suggestion of a separate commit. I will follow the practice
in future PRs. Happy new year.
[
https://issues.apache.org/jira/browse/FLINK-20822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20822:
---
Labels: pull-request-available (was: )
> Don't check whether a function is generic in hive
lirui-apache opened a new pull request #14534:
URL: https://github.com/apache/flink/pull/14534
… catalog
## What is the purpose of the change
Don't check whether a function is generic in HiveCatalog
## Brief change log
- Stop calling
[
https://issues.apache.org/jira/browse/FLINK-20772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seongbae Chang updated FLINK-20772:
---
Summary: RocksDBValueState with TTL occurs NullPointerException when
calling update(null)
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550421330
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java
##
@@ -213,14 +235,33 @@ public
flinkbot edited a comment on pull request #14533:
URL: https://github.com/apache/flink/pull/14533#issuecomment-752874534
## CI report:
* 3e017300a6f8f5bf807493a83eb46230af0a4827 Azure:
flinkbot edited a comment on pull request #14532:
URL: https://github.com/apache/flink/pull/14532#issuecomment-752840091
## CI report:
* 91f08cb08fae546730ce88f9e0127e082a1e1a84 Azure:
flinkbot edited a comment on pull request #14524:
URL: https://github.com/apache/flink/pull/14524#issuecomment-752383882
## CI report:
* 87f9a7aac8cbd730781b7cdcbacaa30b76f506fe Azure:
flinkbot edited a comment on pull request #14399:
URL: https://github.com/apache/flink/pull/14399#issuecomment-745854885
## CI report:
* b77668657f364d87999556ee746e5d995b79443f Azure:
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550418267
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java
##
@@ -62,6 +62,8 @@ private MetricNames() {}
public
paul8263 commented on pull request #14399:
URL: https://github.com/apache/flink/pull/14399#issuecomment-752876101
@zentol Thank you for your suggestion and now I changed my code. I would be
glad if you take some time to review the updated solution.
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550417892
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java
##
@@ -230,6 +271,12 @@ public
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550417531
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java
##
@@ -301,7 +353,25 @@ private
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550417478
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java
##
@@ -301,7 +353,25 @@ private
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550417341
##
File path:
flink-metrics/flink-metrics-core/src/test/java/org/apache/flink/metrics/ThresholdMeterTest.java
##
@@ -0,0 +1,65 @@
+/*
+ * Licensed to
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550417182
##
File path:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/ThresholdMeter.java
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550416903
##
File path:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/ThresholdMeter.java
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the
flinkbot commented on pull request #14533:
URL: https://github.com/apache/flink/pull/14533#issuecomment-752874534
## CI report:
* 3e017300a6f8f5bf807493a83eb46230af0a4827 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14532:
URL: https://github.com/apache/flink/pull/14532#issuecomment-752840091
## CI report:
* 91f08cb08fae546730ce88f9e0127e082a1e1a84 Azure:
flinkbot edited a comment on pull request #14524:
URL: https://github.com/apache/flink/pull/14524#issuecomment-752383882
## CI report:
* 87f9a7aac8cbd730781b7cdcbacaa30b76f506fe Azure:
HuangXingBo commented on pull request #14524:
URL: https://github.com/apache/flink/pull/14524#issuecomment-752873339
@WeiZhong94 Thanks a lot for the review. I have addressed the comment at the
latest commit.
This is an
flinkbot commented on pull request #14533:
URL: https://github.com/apache/flink/pull/14533#issuecomment-752869503
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-19962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19962.
---
Fix Version/s: 1.13.0
Resolution: Fixed
Fixed in master: f198ebffdf0c543a667b656dc67b904289a9b63f
>
zhuxiaoshang opened a new pull request #14533:
URL: https://github.com/apache/flink/pull/14533
## What is the purpose of the change
*fix typo in Create statements page*
## Brief change log
fix typo in Create statements page
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256853#comment-17256853
]
Qingsheng Ren commented on FLINK-20777:
---
[~jark] Partition discovery is disabled by default in the
wuchong merged pull request #14527:
URL: https://github.com/apache/flink/pull/14527
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20105:
Summary: Temporal Table does not work when Kafka is used as the versioned
side (planner PK problem)
wuchong edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752864472
Besides, we can remove the optional `schema-registry.subject` option for
some test now, e.g. the `SQLClientSchemaRegistryITCase`. And please also update
the
wuchong commented on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752864472
Besides, we can remove the optional `schema-registry.subject` option for
some test now, e.g. the `SQLClientSchemaRegistryITCase`.
wuchong edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752863258
We should also take key format into account, and support this feature for
upsert-kafka too. We may also can make
`debezium-avro-confluent.schema-registry.subject` to be
flinkbot edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* 43ac067ac627cea436169ee50d8cf4769e7ccdce Azure:
wuchong commented on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752863258
We should also take key format into account, and support this feature for
upsert-kafka too.
This is an
wuchong removed a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752863052
@PatrickRen will help to review this PR.
This is an automated message from the Apache Git Service.
To
wuchong commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752863080
cc @becketqin
This is an automated message from the Apache Git Service.
To respond to the message, please log
wuchong commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752863052
@PatrickRen will help to review this PR.
This is an automated message from the Apache Git Service.
To respond
flinkbot edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* 43ac067ac627cea436169ee50d8cf4769e7ccdce Azure:
flinkbot edited a comment on pull request #14529:
URL: https://github.com/apache/flink/pull/14529#issuecomment-752798222
## CI report:
* 5789d2337a68e2ffd53419a0e317cf3f272348ec Azure:
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
xintongsong commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r550381861
##
File path:
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/ThresholdMeter.java
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the
flinkbot edited a comment on pull request #14532:
URL: https://github.com/apache/flink/pull/14532#issuecomment-752840091
## CI report:
* 91f08cb08fae546730ce88f9e0127e082a1e1a84 Azure:
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
flinkbot commented on pull request #14532:
URL: https://github.com/apache/flink/pull/14532#issuecomment-752840091
## CI report:
* 91f08cb08fae546730ce88f9e0127e082a1e1a84 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
zck573693104 commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550393596
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6
zck573693104 commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550393172
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6
flinkbot commented on pull request #14532:
URL: https://github.com/apache/flink/pull/14532#issuecomment-752837710
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
curcur opened a new pull request #14532:
URL: https://github.com/apache/flink/pull/14532
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
[
https://issues.apache.org/jira/browse/FLINK-20824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256822#comment-17256822
]
Yingjie Cao commented on FLINK-20824:
-
[~hxbks2ks] Thanks for reporting this issue, I think it is
WeiZhong94 commented on a change in pull request #14524:
URL: https://github.com/apache/flink/pull/14524#discussion_r550390434
##
File path: flink-python/pyflink/fn_execution/aggregate_fast.pyx
##
@@ -564,50 +583,68 @@ cdef class GroupTableAggFunction(GroupAggFunctionBase):
flinkbot edited a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 9dfbf0f8575de20c3c3d672ce1bf64f3c5e2ed93 Azure:
flinkbot edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* 43ac067ac627cea436169ee50d8cf4769e7ccdce Azure:
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256814#comment-17256814
]
JieFang.He edited comment on FLINK-19067 at 12/31/20, 3:39 AM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256814#comment-17256814
]
JieFang.He edited comment on FLINK-19067 at 12/31/20, 3:36 AM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256814#comment-17256814
]
JieFang.He commented on FLINK-19067:
I think the reason is that the jobFiles are upload to the
xiaoHoly commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550387370
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6 +458,29
flinkbot edited a comment on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* 43ac067ac627cea436169ee50d8cf4769e7ccdce Azure:
flinkbot edited a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 9dfbf0f8575de20c3c3d672ce1bf64f3c5e2ed93 Azure:
xiaoHoly commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550387230
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6 +458,29
xiaoHoly commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550387001
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6 +458,29
zhuxiaoshang commented on a change in pull request #14531:
URL: https://github.com/apache/flink/pull/14531#discussion_r550384551
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
##
@@ -458,6
flinkbot commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 9dfbf0f8575de20c3c3d672ce1bf64f3c5e2ed93 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* 43ac067ac627cea436169ee50d8cf4769e7ccdce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256811#comment-17256811
]
Huang Xingbo commented on FLINK-20329:
--
[
https://issues.apache.org/jira/browse/FLINK-20824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256809#comment-17256809
]
Huang Xingbo commented on FLINK-20824:
--
cc [~kevin.cyj]
> BlockingShuffleITCase.
[
https://issues.apache.org/jira/browse/FLINK-20704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-20704.
--
Resolution: Fixed
Fixed in 1.12.1: 712becde6f8f771a000f50a4ed0963d381431900
Fixed in 1.13.0:
Huang Xingbo created FLINK-20824:
Summary: BlockingShuffleITCase. testSortMergeBlockingShuffle test
failed with "Inconsistent availability: expected true"
Key: FLINK-20824
URL:
flinkbot commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752826517
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-20824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-20824:
-
Labels: test-stability (was: )
> BlockingShuffleITCase. testSortMergeBlockingShuffle test
xiaoHoly commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752826319
cc,@wuchong
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot commented on pull request #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752826258
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20777:
---
Labels: pull-request-available (was: )
> Default value of property
xiaoHoly opened a new pull request #14531:
URL: https://github.com/apache/flink/pull/14531
…l.ms" shoule be enabled by default for unbounded mode, and disable for
bounded mode
## What is the purpose of the change
Property "partition.discovery.interval.ms" shoule be
[
https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20348:
---
Labels: pull-request-available sprint (was: sprint)
> Make "schema-registry.subject"
zhuxiaoshang opened a new pull request #14530:
URL: https://github.com/apache/flink/pull/14530
…tional for Kafka sink with avro-confluent format
## What is the purpose of the change
*Autocomplete the schema-registry.subject by '-value' if not set
by user in
wangxlong commented on pull request #14280:
URL: https://github.com/apache/flink/pull/14280#issuecomment-752823642
ping @leonardBang
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256800#comment-17256800
]
Nicholas Jiang commented on FLINK-20385:
[~wangfeiair2324], this has already been merge into
[
https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256799#comment-17256799
]
Danny Chen commented on FLINK-18027:
Thanks for the check [~twalthr], let me have a check for the
[
https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20385.
---
Fix Version/s: 1.13.0
Resolution: Fixed
Implemented in master:
wuchong merged pull request #14464:
URL: https://github.com/apache/flink/pull/14464
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-20822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20822:
Fix Version/s: 1.13.0
> Don't check whether a function is generic in hive catalog
>
[
https://issues.apache.org/jira/browse/FLINK-20821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20821.
---
Fix Version/s: (was: 1.13.0)
Resolution: Duplicate
> `select row(map[1,2],'ab')` parses failed
>
[
https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256788#comment-17256788
]
Huang Xingbo commented on FLINK-20781:
--
Jark Wu created FLINK-20823:
---
Summary: Update documentation to mention Table/SQL API doesn't
provide cross-major-version state compatibility
Key: FLINK-20823
URL: https://issues.apache.org/jira/browse/FLINK-20823
[
https://issues.apache.org/jira/browse/FLINK-20822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-20822:
---
Description: We just store the function identifier and class name to hive
metastore, so it seems there's no
Rui Li created FLINK-20822:
--
Summary: Don't check whether a function is generic in hive catalog
Key: FLINK-20822
URL: https://issues.apache.org/jira/browse/FLINK-20822
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
*
V1ncentzzZ commented on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-752816613
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
V1ncentzzZ edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476
@flinkbot run azure.
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256780#comment-17256780
]
Huang Xingbo commented on FLINK-20654:
--
[
https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256779#comment-17256779
]
Huang Xingbo commented on FLINK-20781:
--
[
https://issues.apache.org/jira/browse/FLINK-19962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wong Mulan reopened FLINK-19962:
> fix doc: more examples for expanding arrays into a relation
>
[
https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256777#comment-17256777
]
Huang Xingbo commented on FLINK-20781:
--
[
https://issues.apache.org/jira/browse/FLINK-19962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wong Mulan resolved FLINK-19962.
Resolution: Fixed
> fix doc: more examples for expanding arrays into a relation
>
godfreyhe merged pull request #14451:
URL: https://github.com/apache/flink/pull/14451
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-20821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-20821:
---
Fix Version/s: 1.13.0
> `select row(map[1,2],'ab')` parses failed
>
[
https://issues.apache.org/jira/browse/FLINK-20821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256767#comment-17256767
]
godfrey he commented on FLINK-20821:
cc [~danny0405]
> `select row(map[1,2],'ab')` parses failed
>
1 - 100 of 290 matches
Mail list logo
