flinkbot commented on PR #19416:
URL: https://github.com/apache/flink/pull/19416#issuecomment-1094171778
## CI report:
* eec5d45d62c8991bdf7975ef9698e3b3308313cd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
whitecloud6688 opened a new pull request, #19416:
URL: https://github.com/apache/flink/pull/19416
### FlinkSQL中创建的表结构信息在SparkSQL中不可见
FlinkSQL中创建的表结构信息在SparkSQL中不可见、字段的注释信息不可见，导致在SparkSQL中不能查询FlinkSQL定义的表数据。请问是配置错误还是什么原因，谢谢。
**FlinkSQL中创建hudi表和mysql表，在FlinkSQL能够看到表结构信息。**
[
https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520062#comment-17520062
]
Yufei Zhang commented on FLINK-27009:
-
I agree, submitting SQL jobs in application mode seems a big
flinkbot commented on PR #19415:
URL: https://github.com/apache/flink/pull/19415#issuecomment-1094160917
## CI report:
* 66d896081ae9c9572972ec13cef8169d57391444 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
whitecloud6688 opened a new pull request, #19415:
URL: https://github.com/apache/flink/pull/19415
### Illegal use of 'NULL'
需要将 NULL 赋值给一个字段，然后写入表，但报语法错误。版本：flink-1.13.6。
请问类似需求该怎么规避或解决呢？谢谢。
Flink SQL> select if(1>2,1,NULL) as col1;
[ERROR] Could not execute SQL
[
https://issues.apache.org/jira/browse/FLINK-26486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leinenglian closed FLINK-26486.
---
Resolution: Fixed
> The operator restart ingress is lost
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-14917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14917:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15424:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14748:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the
[
https://issues.apache.org/jira/browse/FLINK-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14848:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14729:
---
Labels: auto-deprioritized-major features pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15004:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15343:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-14990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-14990:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-24342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24342:
---
Labels: pull-request-available stale-minor (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-25835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25835:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24586:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15674:
---
Labels: auto-deprioritized-major auto-unassigned stale-minor usability
(was:
[
https://issues.apache.org/jira/browse/FLINK-15964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15964:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-26590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26590:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
Almog Tavor created FLINK-27156:
---
Summary: [FLIP-171] MongoDB implementation of Async Sink
Key: FLINK-27156
URL: https://issues.apache.org/jira/browse/FLINK-27156
Project: Flink
Issue Type:
Feifan Wang created FLINK-27155:
---
Summary: Reduce multiple reads to the same Changelog file in the
same taskmanager during restore
Key: FLINK-27155
URL: https://issues.apache.org/jira/browse/FLINK-27155
[
https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519993#comment-17519993
]
Nicholas Jiang commented on FLINK-27153:
[~gyfora], is the
zoltar9264 commented on code in PR #19403:
URL: https://github.com/apache/flink/pull/19403#discussion_r846649572
##
docs/content.zh/docs/dev/configuration/overview.md:
##
@@ -85,25 +86,31 @@ plugins {
// artifact properties
group = 'org.quickstart'
version = '0.1-SNAPSHOT'
zoltar9264 commented on code in PR #19403:
URL: https://github.com/apache/flink/pull/19403#discussion_r846649572
##
docs/content.zh/docs/dev/configuration/overview.md:
##
@@ -85,25 +86,31 @@ plugins {
// artifact properties
group = 'org.quickstart'
version = '0.1-SNAPSHOT'
[
https://issues.apache.org/jira/browse/FLINK-27154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27154:
---
Labels: Starter pull-request-available (was: Starter)
> Disable web.cancel.enable for
SteNicholas opened a new pull request, #163:
URL: https://github.com/apache/flink-kubernetes-operator/pull/163
`web.cancel.enable` should be set to false for application deployments to
avoid users accidentally cancelling jobs.
**The brief change log**
- `FlinkConfigBuilder`
[
https://issues.apache.org/jira/browse/FLINK-27154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519990#comment-17519990
]
Nicholas Jiang commented on FLINK-27154:
[~gyfora], I have worked this configuration. Please
RocMarshal commented on code in PR #19401:
URL: https://github.com/apache/flink/pull/19401#discussion_r846646275
##
docs/content.zh/docs/dev/table/concepts/overview.md:
##
@@ -34,106 +34,79 @@ Flink 的 [Table API]({{< ref "docs/dev/table/tableApi" >}})
和 [SQL]({{< ref "
Gyula Fora created FLINK-27154:
--
Summary: Disable web.cancel.enable for application clusters
Key: FLINK-27154
URL: https://issues.apache.org/jira/browse/FLINK-27154
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-27153:
---
Description:
In many cases users would prefer to take a savepoint if the job is healthy
before
[
https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519983#comment-17519983
]
Gyula Fora edited comment on FLINK-26926 at 4/9/22 2:07 PM:
[
https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519983#comment-17519983
]
Gyula Fora commented on FLINK-26926:
`kubernetes.operator.upgrade.ignore-pending-savepoint`
> Allow
Gyula Fora created FLINK-27153:
--
Summary: Allow optional last-state fallback for savepoint upgrade
mode
Key: FLINK-27153
URL: https://issues.apache.org/jira/browse/FLINK-27153
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519981#comment-17519981
]
zhouenning commented on FLINK-27053:
hi Matthias Pohl
I see the source code which to use
RocMarshal commented on code in PR #19403:
URL: https://github.com/apache/flink/pull/19403#discussion_r846629724
##
docs/content.zh/docs/dev/configuration/overview.md:
##
@@ -85,25 +86,31 @@ plugins {
// artifact properties
group = 'org.quickstart'
version = '0.1-SNAPSHOT'
smattheis commented on PR #19398:
URL: https://github.com/apache/flink/pull/19398#issuecomment-1094008704
@pnowojski There was a merge conflict. Therefore, I pushed an update and
reran the ci check which succeeded.
--
This is an automated message from the Apache Git Service.
To respond
RocMarshal commented on PR #19401:
URL: https://github.com/apache/flink/pull/19401#issuecomment-1094004365
Thanks @snailHumming for the translation and @MartijnVisser ping.
I check it ASAP.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
zhangjingcun created FLINK-27152:
Summary: Examples of state usage of various data structures
Key: FLINK-27152
URL: https://issues.apache.org/jira/browse/FLINK-27152
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27029:
---
Labels: pull-request-available starter (was: starter)
> DeploymentValidator should take
SteNicholas opened a new pull request, #162:
URL: https://github.com/apache/flink-kubernetes-operator/pull/162
`DefaultDeploymentValidator` only takes the `FlinkDeployment` object into
account and should validate the effective Flink configs. However in places
where we validate the presence
smattheis commented on PR #19398:
URL: https://github.com/apache/flink/pull/19398#issuecomment-1093891085
@flinkbot run azure
--
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 the specific
zoltar9264 commented on code in PR #19403:
URL: https://github.com/apache/flink/pull/19403#discussion_r846616288
##
docs/content.zh/docs/dev/configuration/overview.md:
##
@@ -67,7 +67,7 @@ $ curl https://flink.apache.org/q/quickstart.sh | bash -s {{<
version >}}
{{< /tab
[
https://issues.apache.org/jira/browse/FLINK-15980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-15980:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-16043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16043:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-16491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16491:
---
Labels: pull-request-available stale-minor (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16708:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16356:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the
[
https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16294:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17117:
---
Labels: auto-unassigned pull-request-available stale-minor (was:
auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17133:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17445:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17488:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16175:
---
Labels: auto-deprioritized-major auto-unassigned pull-request-available
stale-minor
[
https://issues.apache.org/jira/browse/FLINK-26389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daisy Tsang updated FLINK-26389:
External issue URL: https://github.com/apache/flink/pull/19414 (was:
flinkbot commented on PR #19414:
URL: https://github.com/apache/flink/pull/19414#issuecomment-1093869397
## CI report:
* 11e4ba949253a3894a0d264afdf929c4a35fca47 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
infoverload opened a new pull request, #19414:
URL: https://github.com/apache/flink/pull/19414
## What is the purpose of the change
(https://issues.apache.org/jira/browse/FLINK-26389)](https://issues.apache.org/jira/browse/FLINK-26389)
## Brief change log
Many operators
[
https://issues.apache.org/jira/browse/FLINK-16078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519944#comment-17519944
]
Zhuang Liu commented on FLINK-16078:
-
[~yunta]，I submitted a pr for translation of this document,
flinkbot commented on PR #19413:
URL: https://github.com/apache/flink/pull/19413#issuecomment-1093840338
## CI report:
* 5313a08b9e63d286641dc58f95101cf407278623 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-16078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16078:
---
Labels: auto-unassigned pull-request-available (was: auto-unassigned)
> Translate "Tuning
liuzhuang2017 opened a new pull request, #19413:
URL: https://github.com/apache/flink/pull/19413
…" page into Chinese
## 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
Karthik created FLINK-27151:
---
Summary: Group By Aggregation With Sorted Data
Key: FLINK-27151
URL: https://issues.apache.org/jira/browse/FLINK-27151
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519927#comment-17519927
]
Daisy Tsang commented on FLINK-26389:
-
I have made some changes, but it may relate to
[
https://issues.apache.org/jira/browse/FLINK-26389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daisy Tsang updated FLINK-26389:
External issue URL: https://github.com/infoverload/flink/tree/dt/FLINK-26389
> Many operators of
[
https://issues.apache.org/jira/browse/FLINK-26985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-26985.
---
Resolution: Fixed
Merged into master as c0936deaf99390fc727acc8633e3be22e62f4bf5,
rkhachatryan merged PR #19412:
URL: https://github.com/apache/flink/pull/19412
--
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 the specific comment.
To unsubscribe, e-mail:
rkhachatryan commented on PR #19412:
URL: https://github.com/apache/flink/pull/19412#issuecomment-1093791544
Build failure unrelated, the failed phase
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519919#comment-17519919
]
Gabor Somogyi commented on FLINK-27137:
---
Yep, Kafka community thinks that all offset management
[
https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519913#comment-17519913
]
Gyula Fora commented on FLINK-26926:
The conclusion was to include these custom configuration
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27137.
--
Resolution: Won't Do
> Remove usage of AdminClient from KafkaSource logic
>
[
https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519912#comment-17519912
]
Gyula Fora commented on FLINK-27137:
Thanks [~dengziming] , I can see that AdminClient is more
71 matches
Mail list logo
