flinkbot commented on PR #22208:
URL: https://github.com/apache/flink/pull/22208#issuecomment-1474732693
## CI report:
* 5d7e324b18d000d6f46e3bfde2dbd654c3dda08c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xuzhiwen1255 commented on PR #22208:
URL: https://github.com/apache/flink/pull/22208#issuecomment-1474732352
@wuchong wu @luoyuxia luo Please take a look, thank you very much.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-31499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31499:
---
Labels: pull-request-available (was: )
> Move SqlCreateTable conversion logic to
xuzhiwen1255 opened a new pull request, #22208:
URL: https://github.com/apache/flink/pull/22208
## What is the purpose of the change
Similar to [FLINK-31368](https://issues.apache.org/jira/browse/FLINK-31368),
the SqlToOperationConverter is a bit bloated.
This PR moves the conversion
fredia commented on PR #21822:
URL: https://github.com/apache/flink/pull/21822#issuecomment-1474697817
@zoltar9264 Thanks for the review and suggestion, I updated the PR based on
the comment. Currently, the `LocalChangelogRegistryImpl#prune()` is removed.
--
This is an automated message
fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140930335
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryImpl.java:
##
@@ -115,4 +116,32 @@ private void
fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140928595
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/DuplicatingStateChangeFsUploader.java:
##
@@ -51,12 +52,12 @@
* Store the meta of files
fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140928577
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java:
##
@@ -167,6 +167,7 @@ public FsStateChangelogWriter
fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140928508
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryImpl.java:
##
@@ -87,8 +88,8 @@ public void discardUpToCheckpoint(long
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702051#comment-17702051
]
Weijie Guo edited comment on FLINK-29298 at 3/18/23 3:27 AM:
-
Hi
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702051#comment-17702051
]
Weijie Guo commented on FLINK-29298:
Hi [~lichen1109]. Unfortunately, this bug is only possible to
fredia commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1140919763
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/LocalChangelogRegistryImpl.java:
##
@@ -58,23 +59,23 @@ public void register(StreamStateHandle
chucheng92 commented on PR #22179:
URL: https://github.com/apache/flink/pull/22179#issuecomment-1474659993
because execution of operation has changed in
[FLINK-31507](https://issues.apache.org/jira/browse/FLINK-31507) . I will
rebase it.
--
This is an automated message from the Apache
[ https://issues.apache.org/jira/browse/FLINK-31380 ]
Ran Tao deleted comment on FLINK-31380:
-
was (Author: lemonjing):
Hi, [~jark] . Currently there are three ways to support these auxiliary sql
statements.
1.change every operation to support
flinkbot commented on PR #22207:
URL: https://github.com/apache/flink/pull/22207#issuecomment-1474563109
## CI report:
* e6835649ed601e22536f0550e52c089aa4e06da9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31510:
---
Labels: pull-request-available (was: )
> Use getMemorySize instead of getMemory
>
slfan1989 opened a new pull request, #22207:
URL: https://github.com/apache/flink/pull/22207
## What is the purpose of the change
JIRA: FLINK-31510. Use getMemorySize instead of getMemory
In [YARN-4844](https://issues.apache.org/jira/browse/YARN-4844), use
Shilun Fan created FLINK-31510:
--
Summary: Use getMemorySize instead of getMemory
Key: FLINK-31510
URL: https://issues.apache.org/jira/browse/FLINK-31510
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702031#comment-17702031
]
Lee chen commented on FLINK-29298:
--
We alse faced to this problem, how to reproduce this problem with
[
https://issues.apache.org/jira/browse/FLINK-23159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702027#comment-17702027
]
Deepyaman Datta commented on FLINK-23159:
-
Hello! I believe I'm affected by this issue, as
robsonpeixoto commented on PR #93:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/93#issuecomment-1474533148
This solution is amazing! Thanks a lot =D
But add this feature in annotation os very useful, for example:
```
ingress:
template:
Emmanuel Leroy created FLINK-31509:
--
Summary: REST Service missing sessionAffinity causes job run
failure with HA cluster
Key: FLINK-31509
URL: https://issues.apache.org/jira/browse/FLINK-31509
gyfora commented on code in PR #549:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/549#discussion_r1140649362
##
docs/layouts/shortcodes/generated/dynamic_section.html:
##
@@ -86,6 +86,12 @@
Duration
Interval at which periodic
Panagiotis Garefalakis created FLINK-31508:
--
Summary: FLIP-304: Pluggable failure handling for Apache Flink
Key: FLINK-31508
URL: https://issues.apache.org/jira/browse/FLINK-31508
Project:
[
https://issues.apache.org/jira/browse/FLINK-31502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31502:
---
Labels: pull-request-available (was: )
> Limit the number of concurrent scale operations
mxm opened a new pull request, #549:
URL: https://github.com/apache/flink-kubernetes-operator/pull/549
Until we move to using the upcoming Rescale API which recycles pods, we need
to be mindful with how many deployments we scale at the same time because each
of them is going to give up all
[
https://issues.apache.org/jira/browse/FLINK-31490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701917#comment-17701917
]
Chesnay Schepler commented on FLINK-31490:
--
But FLINK-27848 was fixed in 1.17.0; if that change
zentol commented on PR #22052:
URL: https://github.com/apache/flink/pull/22052#issuecomment-1474175255
I'd suggest to instead somewhat profile the runtime tests instead.
Add a special test that runs last (see
https://stackoverflow.com/questions/57624495/junit-test-class-order) that
[
https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701912#comment-17701912
]
Ran Tao edited comment on FLINK-31380 at 3/17/23 5:26 PM:
--
Hi, [~jark] .
zentol commented on PR #22052:
URL: https://github.com/apache/flink/pull/22052#issuecomment-1474170781
Still I don't see what this gets you. The test running into the OOM isn't
necessarily who's causing it. If some test allocates 99% of memory but
finishes, then some subsequent test may
[
https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701912#comment-17701912
]
Ran Tao edited comment on FLINK-31380 at 3/17/23 5:24 PM:
--
Hi, [~jark] .
[
https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701912#comment-17701912
]
Ran Tao commented on FLINK-31380:
-
Hi, [~jark] . Currently there are three ways to support these
zentol commented on PR #22052:
URL: https://github.com/apache/flink/pull/22052#issuecomment-1474164411
wait a minute. Why is the basic nightly run using `'ubuntu-20.04'` as the
pool`?
A because of FLINK-18370...
--
This is an automated message from the Apache Git Service.
To respond
zentol commented on PR #22052:
URL: https://github.com/apache/flink/pull/22052#issuecomment-1474157633
What makes you think they are on azure-owned hosts? They are both scheduled
builds in flink-ci, which do use the alibaba machines.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-31504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-31504:
---
Assignee: Jark Wu
> Move execution logic of CreateOperation out from TableEnvironmentImpl
>
Jark Wu created FLINK-31507:
---
Summary: Move execution logic of ShowOperation out from
TableEnvironmentImpl
Key: FLINK-31507
URL: https://issues.apache.org/jira/browse/FLINK-31507
Project: Flink
echauchot commented on PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1474052060
@zentol I pushed for security reasons, I have only the addSplitsBack case to
deal with in lazy splits generation scenario. You can start to take a look at
the other things
Jark Wu created FLINK-31505:
---
Summary: Move execution logic of DropOperation out from
TableEnvironmentImpl
Key: FLINK-31505
URL: https://issues.apache.org/jira/browse/FLINK-31505
Project: Flink
Jark Wu created FLINK-31506:
---
Summary: Move execution logic of AlterOperation out from
TableEnvironmentImpl
Key: FLINK-31506
URL: https://issues.apache.org/jira/browse/FLINK-31506
Project: Flink
Jark Wu created FLINK-31504:
---
Summary: Move execution logic of CreateOperation out from
TableEnvironmentImpl
Key: FLINK-31504
URL: https://issues.apache.org/jira/browse/FLINK-31504
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-31494.
---
Fix Version/s: 1.18.0
Resolution: Fixed
Fixed in master: ba03d4db7ca01c7a2436253b9f9429a2a3fb3219
>
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701863#comment-17701863
]
Jark Wu edited comment on FLINK-31494 at 3/17/23 3:42 PM:
--
Fixed in master:
wuchong merged PR #22205:
URL: https://github.com/apache/flink/pull/22205
--
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:
wuchong commented on PR #22205:
URL: https://github.com/apache/flink/pull/22205#issuecomment-1474031293
Thank you for the review @xuzhiwen1255 . Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
wuchong commented on code in PR #22205:
URL: https://github.com/apache/flink/pull/22205#discussion_r1140393596
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java:
##
@@ -285,11 +287,18 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701861#comment-17701861
]
Dian Fu commented on FLINK-31503:
-
If your Flink version doesn't contain this fix, you could simply work
[
https://issues.apache.org/jira/browse/FLINK-31499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-31499:
---
Assignee: xuzhiwen
> Move SqlCreateTable conversion logic to SqlCreateTableConverter
>
[
https://issues.apache.org/jira/browse/FLINK-31478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31478.
---
Fix Version/s: 1.16.2
1.18.0
1.17.1
Resolution: Fixed
Fixed
dianfu closed pull request #22190: [FLINK-31478][python] Fix
ds.execute_and_collect to support nested tuple
URL: https://github.com/apache/flink/pull/22190
--
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
flinkbot commented on PR #22206:
URL: https://github.com/apache/flink/pull/22206#issuecomment-1473992293
## CI report:
* a0428979c1e0b2870fe6e2710e2584e0ae531420 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31503:
---
Labels: pull-request-available (was: )
>
dianfu opened a new pull request, #22206:
URL: https://github.com/apache/flink/pull/22206
…
## 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
reswqa commented on PR #22161:
URL: https://github.com/apache/flink/pull/22161#issuecomment-1473941258
@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 comment.
Dian Fu created FLINK-31503:
---
Summary: "org.apache.beam.sdk.options.PipelineOptionsRegistrar:
Provider org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar not a
subtype" is thrown when executing Python UDFs in SQL Client
Key:
xuzhiwen1255 commented on PR #22205:
URL: https://github.com/apache/flink/pull/22205#issuecomment-1473881727
LGTM. Thank you @wuchong for contribution.
--
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
xuzhiwen1255 commented on code in PR #22205:
URL: https://github.com/apache/flink/pull/22205#discussion_r1140254867
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java:
##
@@ -285,11 +287,18 @@ public
dmvk commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1140236168
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -1050,6 +1055,14 @@ public
dmvk commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1140235833
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -1050,6 +1055,14 @@ public
dmvk commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1140223431
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -1213,4 +1268,17 @@ T transitionToState(StateFactory
[
https://issues.apache.org/jira/browse/FLINK-31499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701719#comment-17701719
]
xuzhiwen commented on FLINK-31499:
--
[~jark] Can you assign it to me.
> Move SqlCreateTable conversion
Maximilian Michels created FLINK-31502:
--
Summary: Limit the number of concurrent scale operations to reduce
cluster churn
Key: FLINK-31502
URL: https://issues.apache.org/jira/browse/FLINK-31502
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701683#comment-17701683
]
Jark Wu commented on FLINK-31494:
-
[~xzw0223], the key idea is not putting all the conversion logic in a
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701681#comment-17701681
]
Maximilian Michels commented on FLINK-31135:
Oh, just realized this is unrelated to
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-31135:
> ConfigMap DataSize went > 1 MB and cluster stopped working
>
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-31135.
Resolution: Duplicate
Closing because this has been resolved already on the main
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701679#comment-17701679
]
Maximilian Michels commented on FLINK-31135:
This has been addressed in FLINK-31345.
>
luoyuxia commented on code in PR #22202:
URL: https://github.com/apache/flink/pull/22202#discussion_r1140150472
##
flink-connectors/flink-sql-connector-hive-2.3.9/pom.xml:
##
@@ -115,6 +115,10 @@ under the License.
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1140149272
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,485 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date:
luoyuxia commented on code in PR #22202:
URL: https://github.com/apache/flink/pull/22202#discussion_r1140146575
##
flink-connectors/flink-sql-connector-hive-2.3.9/pom.xml:
##
@@ -115,6 +115,10 @@ under the License.
luoyuxia commented on code in PR #22197:
URL: https://github.com/apache/flink/pull/22197#discussion_r1139990233
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java:
##
@@ -167,6 +168,26 @@ interface Context {
*
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1140145036
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,485 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date:
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1140138561
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,485 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date:
leonardBang commented on code in PR #618:
URL: https://github.com/apache/flink-web/pull/618#discussion_r1140137456
##
docs/content/posts/2023-03-09-release-1.17.0.md:
##
@@ -0,0 +1,485 @@
+---
+authors:
+- LeonardXu:
+ name: "Leonard Xu"
+ twitter: Leonardxbj
+date:
Jark Wu created FLINK-31501:
---
Summary: Move SqlCreateView conversion logic to
SqlCreateViewConverter
Key: FLINK-31501
URL: https://issues.apache.org/jira/browse/FLINK-31501
Project: Flink
Issue
Jark Wu created FLINK-31500:
---
Summary: Move SqlAlterTableSchema conversion logic to
AlterTableSchemaConverter
Key: FLINK-31500
URL: https://issues.apache.org/jira/browse/FLINK-31500
Project: Flink
Jark Wu created FLINK-31499:
---
Summary: Move SqlCreateTable conversion logic to
SqlCreateTableConverter
Key: FLINK-31499
URL: https://issues.apache.org/jira/browse/FLINK-31499
Project: Flink
Issue
flinkbot commented on PR #22205:
URL: https://github.com/apache/flink/pull/22205#issuecomment-1473709150
## CI report:
* c91d41a200babd67477dd8288f41cf77936ee318 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wuchong commented on PR #22205:
URL: https://github.com/apache/flink/pull/22205#issuecomment-1473704387
@luoyuxia @xuzhiwen1255 , would be appreciated if you could help to review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31494:
---
Labels: pull-request-available (was: )
> Introduce SqlNodeConverter for
wuchong opened a new pull request, #22205:
URL: https://github.com/apache/flink/pull/22205
## What is the purpose of the change
Similar to [FLINK-31368](https://issues.apache.org/jira/browse/FLINK-31368),
the `SqlToOperationConverter` is a bit bloated. This PR is aiming to
[
https://issues.apache.org/jira/browse/FLINK-31489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31489:
---
Fix Version/s: 1.17.1
> OperationManagerTest.testCloseOperation failed because it couldn't find a
[
https://issues.apache.org/jira/browse/FLINK-31489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-31489.
Fix Version/s: 1.18.0
(was: 1.17.0)
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-31489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701652#comment-17701652
]
Leonard Xu edited comment on FLINK-31489 at 3/17/23 11:35 AM:
--
Fixed in :
leonardBang merged PR #22200:
URL: https://github.com/apache/flink/pull/22200
--
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:
zoltar9264 commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1139825377
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/DuplicatingStateChangeFsUploader.java:
##
@@ -51,12 +52,12 @@
* Store the meta of
zoltar9264 commented on code in PR #21822:
URL: https://github.com/apache/flink/pull/21822#discussion_r1139807707
##
flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java:
##
@@ -199,15 +200,21 @@ public SequenceNumber
[
https://issues.apache.org/jira/browse/FLINK-31489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701652#comment-17701652
]
Leonard Xu commented on FLINK-31489:
Fixed in :
master: ff08c7b1d7fb9334d624aa74bc5788d4d7ac1edc
[
https://issues.apache.org/jira/browse/FLINK-31489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31489:
---
Priority: Major (was: Critical)
> OperationManagerTest.testCloseOperation failed because it
leonardBang merged PR #22199:
URL: https://github.com/apache/flink/pull/22199
--
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:
Aitozi commented on code in PR #22179:
URL: https://github.com/apache/flink/pull/22179#discussion_r1140063123
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SupportsShowLikeOperation.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache
flinkbot commented on PR #22204:
URL: https://github.com/apache/flink/pull/22204#issuecomment-1473630712
## CI report:
* c2ef221f4397634df80b1dd2372bc9c423c2627b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
BoYiZhang opened a new pull request, #22204:
URL: https://github.com/apache/flink/pull/22204
## What is the purpose of the change
- *Fix spelling errors in the create table statement*
## Brief change log
- *The create table statement provided by the document is
dannycranmer commented on code in PR #58:
URL:
https://github.com/apache/flink-connector-aws/pull/58#discussion_r1140050195
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java:
##
@@ -313,6 +313,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701631#comment-17701631
]
xuzhiwen edited comment on FLINK-31494 at 3/17/23 10:14 AM:
Hi [~jark] ,
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701631#comment-17701631
]
xuzhiwen commented on FLINK-31494:
--
hi [~jark] , Will SqlNodeConverters register all SQLnodes? My
leonardBang commented on PR #22201:
URL: https://github.com/apache/flink/pull/22201#issuecomment-1473599179
@ruanhang1993 Could we can create a new JIRA issue to track the translation
for all sql function? I found some content of these function is outdated.
--
This is an automated
Weihua Hu created FLINK-31498:
-
Summary: DeclartiveSlotManager always request redundant task
manager when resource is not enough
Key: FLINK-31498
URL: https://issues.apache.org/jira/browse/FLINK-31498
[
https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700745#comment-17700745
]
Leonard Xu edited comment on FLINK-30959 at 3/17/23 10:09 AM:
--
Resolved in:
[
https://issues.apache.org/jira/browse/FLINK-31494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-31494:
Description:
Introduce {{SqlNodeConverter}} for {{SqlToOperationConverter}}, following
Timo's idea in
leonardBang merged PR #22186:
URL: https://github.com/apache/flink/pull/22186
--
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:
1 - 100 of 198 matches
Mail list logo
