felixzh2020 commented on PR #22093:
URL: https://github.com/apache/flink/pull/22093#issuecomment-1454657716
@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
yuzelin created FLINK-31323:
---
Summary: Fix unstable merge-into E2E test
Key: FLINK-31323
URL: https://issues.apache.org/jira/browse/FLINK-31323
Project: Flink
Issue Type: Sub-task
yuzelin created FLINK-31322:
---
Summary: Improve merge-into action
Key: FLINK-31322
URL: https://issues.apache.org/jira/browse/FLINK-31322
Project: Flink
Issue Type: Improvement
XComp commented on PR #21736:
URL: https://github.com/apache/flink/pull/21736#issuecomment-1454533512
Not sure, whether I understand you in the right way here: I didn't mean to
push the generated test da in multiple commits (e.g. one commit per test
class). I meant that we want to prepare
flinkbot commented on PR #22093:
URL: https://github.com/apache/flink/pull/22093#issuecomment-1454510036
## CI report:
* e7c1a87f3ea4bc93612810e695a15bd2478b181d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
felixzh updated FLINK-31321:
Component/s: Deployment / YARN
> Yarn-session mode, securityConfiguration supports dynamic configuration
[
https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31321:
---
Labels: pull-request-available (was: )
> Yarn-session mode, securityConfiguration supports
felixzh2020 opened a new pull request, #22093:
URL: https://github.com/apache/flink/pull/22093
…ic configuration
## 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
[
https://issues.apache.org/jira/browse/FLINK-31321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
felixzh updated FLINK-31321:
Description:
when different tenants submit jobs using the same {_}flink-conf.yaml{_}, the
same user is
lindong28 commented on PR #21557:
URL: https://github.com/apache/flink/pull/21557#issuecomment-1454452696
@reswqa Can you help review this PR? Thanks!
--
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
lindong28 commented on PR #22092:
URL: https://github.com/apache/flink/pull/22092#issuecomment-1454449949
@reswqa One moment. Let me update that PR based on the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
lindong28 commented on PR #22092:
URL: https://github.com/apache/flink/pull/22092#issuecomment-1454447110
@reswqa Yes, the PR for the master branch can be found at
https://github.com/apache/flink/pull/21557. Can you also help review that PR?
Thanks!
--
This is an automated message from
reswqa commented on PR #22092:
URL: https://github.com/apache/flink/pull/22092#issuecomment-1454445020
A small question: do we need to pick the changes to the master branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lindong28 merged PR #22092:
URL: https://github.com/apache/flink/pull/22092
--
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:
lindong28 commented on PR #22092:
URL: https://github.com/apache/flink/pull/22092#issuecomment-1454431262
Thank you @reswqa for the review. I have updated the PR as suggested. Can
you take another look?
--
This is an automated message from the Apache Git Service.
To respond to the
reswqa commented on code in PR #22092:
URL: https://github.com/apache/flink/pull/22092#discussion_r1125325957
##
docs/content/docs/dev/configuration/gradle.md:
##
@@ -31,7 +31,7 @@ to automate tasks in the development process.
## Requirements
- Gradle 7.x
-- Java 11
+-
reswqa commented on code in PR #22092:
URL: https://github.com/apache/flink/pull/22092#discussion_r1125325957
##
docs/content/docs/dev/configuration/gradle.md:
##
@@ -31,7 +31,7 @@ to automate tasks in the development process.
## Requirements
- Gradle 7.x
-- Java 11
+-
reswqa commented on code in PR #22092:
URL: https://github.com/apache/flink/pull/22092#discussion_r1125325957
##
docs/content/docs/dev/configuration/gradle.md:
##
@@ -31,7 +31,7 @@ to automate tasks in the development process.
## Requirements
- Gradle 7.x
-- Java 11
+-
[
https://issues.apache.org/jira/browse/FLINK-30501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695955#comment-17695955
]
Dong Lin edited comment on FLINK-30501 at 3/4/23 3:51 AM:
--
Note that the latest
felixzh created FLINK-31321:
---
Summary: Yarn-session mode, securityConfiguration supports dynamic
configuration
Key: FLINK-31321
URL: https://issues.apache.org/jira/browse/FLINK-31321
Project: Flink
flinkbot commented on PR #22092:
URL: https://github.com/apache/flink/pull/22092#issuecomment-1454361495
## CI report:
* fd81ec2b0269b0219f2173fec7ae3e11e4e0b38c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lindong28 opened a new pull request, #22092:
URL: https://github.com/apache/flink/pull/22092
## What is the purpose of the change
Flink 1.15 and later versions require at least Java 11 to build from sources
[1], whereas the pom.xml specifies the source/target is 1.8. This
lilyevsky commented on code in PR #11:
URL:
https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1125187664
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java:
##
@@ -122,10 +128,11 @@
}
mohsenrezaeithe commented on code in PR #21849:
URL: https://github.com/apache/flink/pull/21849#discussion_r1125140028
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java:
##
@@ -1394,13 +1394,14 @@ private CompletableFuture waitForTerminatingJob(
mohsenrezaeithe commented on code in PR #21849:
URL: https://github.com/apache/flink/pull/21849#discussion_r1125140028
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java:
##
@@ -1394,13 +1394,14 @@ private CompletableFuture waitForTerminatingJob(
[ https://issues.apache.org/jira/browse/FLINK-30274 ]
Ran Tao deleted comment on FLINK-30274:
-
was (Author: lemonjing):
[~martijnvisser] Hi, Martijn I have updated the pr.
> Upgrade commons-collections 3.x to commons-collections4
>
[ https://issues.apache.org/jira/browse/FLINK-30274 ]
Ran Tao deleted comment on FLINK-30274:
-
was (Author: lemonjing):
[~martijnvisser] Hi, Can u help me to review it again?
> Upgrade commons-collections 3.x to commons-collections4
>
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696308#comment-17696308
]
Ran Tao commented on FLINK-31319:
-
Reproduce: Using bounded kafka, set partitionDiscoveryIntervalMs=0,
[
https://issues.apache.org/jira/browse/FLINK-31133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-31133.
---
Resolution: Fixed
Fix merged as
1.15 51660f840cfc505b9b9cb72530fde7f9f8a4dee2
[
https://issues.apache.org/jira/browse/FLINK-27169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27169:
--
Affects Version/s: 1.15.3
> PartiallyFinishedSourcesITCase.test hangs on azure
>
[
https://issues.apache.org/jira/browse/FLINK-27169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-27169.
---
Fix Version/s: 1.15.5
Resolution: Fixed
Backported to 1.15 as
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31319:
Description:
As kafka option description, partitionDiscoveryIntervalMs <=0 means disabled.
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31319:
Description:
As kafka option description, partitionDiscoveryIntervalMs <=0 means disabled.
rkhachatryan merged PR #22023:
URL: https://github.com/apache/flink/pull/22023
--
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 merged PR #22088:
URL: https://github.com/apache/flink/pull/22088
--
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 merged PR #22086:
URL: https://github.com/apache/flink/pull/22086
--
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 merged PR #22087:
URL: https://github.com/apache/flink/pull/22087
--
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:
James Mcguire created FLINK-31320:
-
Summary: Modify DATE_FORMAT system (built-in) function to accepts
DATEs
Key: FLINK-31320
URL: https://issues.apache.org/jira/browse/FLINK-31320
Project: Flink
rkhachatryan commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124883714
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
rkhachatryan commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124883714
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
rkhachatryan commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124883714
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
rkhachatryan commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124883714
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696257#comment-17696257
]
Ran Tao edited comment on FLINK-31006 at 3/3/23 6:20 PM:
-
[~syhily] [~renqs] hi,
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696257#comment-17696257
]
Ran Tao edited comment on FLINK-31006 at 3/3/23 6:18 PM:
-
[~syhily] [~renqs] hi,
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696257#comment-17696257
]
Ran Tao edited comment on FLINK-31006 at 3/3/23 6:17 PM:
-
[~syhily] [~renqs] hi,
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696257#comment-17696257
]
Ran Tao commented on FLINK-31006:
-
[~syhily] [~renqs] hi, guys. I think Qingsheng's respond in
flinkbot commented on PR #22091:
URL: https://github.com/apache/flink/pull/22091#issuecomment-1453911937
## CI report:
* 63b51c7bf01363f78b8de1d9131fc84d0c588bda UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31319:
---
Labels: pull-request-available (was: )
> Inconsistent condition judgement about kafka
chucheng92 opened a new pull request, #22091:
URL: https://github.com/apache/flink/pull/22091
## What is the purpose of the change
Fix error kafka partitionDiscoveryIntervalMs checking for noMoreNewSplits
## Brief change log
Correct partitionDiscoveryIntervalMs checking
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31319:
Description:
As kafka option description, partitionDiscoveryIntervalMs <=0 means disabled.
[ https://issues.apache.org/jira/browse/FLINK-31006 ]
Ran Tao deleted comment on FLINK-31006:
-
was (Author: lemonjing):
Hi, guys. I think the PR is not work and may cause another bug.
If we set `noMoreNewPartitionSplits = true;` when
Ran Tao created FLINK-31319:
---
Summary: Inconsistent condition judgement about kafka
partitionDiscoveryIntervalMs cause potential bug
Key: FLINK-31319
URL: https://issues.apache.org/jira/browse/FLINK-31319
Gyula Fora created FLINK-31318:
--
Summary: Do not scale down operators while processing backlog
Key: FLINK-31318
URL: https://issues.apache.org/jira/browse/FLINK-31318
Project: Flink
Issue Type:
flinkbot commented on PR #22090:
URL: https://github.com/apache/flink/pull/22090#issuecomment-1453861541
## CI report:
* 2b7853f7bf56569a1f1b1d9c43db55f580b7f933 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
BoYiZhang opened a new pull request, #22090:
URL: https://github.com/apache/flink/pull/22090
## 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
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696234#comment-17696234
]
Ran Tao commented on FLINK-31006:
-
Hi, guys. I think the PR is not work and may cause another bug.
If
BoYiZhang closed pull request #22006: [Flink 31170] [docs]The spelling error of
the document word causes sql to fail to execute
URL: https://github.com/apache/flink/pull/22006
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
BoYiZhang commented on PR #22006:
URL: https://github.com/apache/flink/pull/22006#issuecomment-1453845141
?
--
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,
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-09-24-199.png
> job is not finished when using pipeline mode to run
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-08-29-042.png
> job is not finished when using pipeline mode to run
[
https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696230#comment-17696230
]
Roman Khachatryan commented on FLINK-31249:
---
Allowing to trigger a new checkpoint without
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-07-04-927.png
> job is not finished when using pipeline mode to run
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-07-36-168.png
> job is not finished when using pipeline mode to run
akalash commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124761808
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-05-25-335.png
> job is not finished when using pipeline mode to run
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31006:
Attachment: image-2023-03-04-01-04-18-658.png
> job is not finished when using pipeline mode to run
[
https://issues.apache.org/jira/browse/FLINK-31284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-31284.
--
Fix Version/s: 1.18.0
Resolution: Fixed
merged to master
gyfora merged PR #22061:
URL: https://github.com/apache/flink/pull/22061
--
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:
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696210#comment-17696210
]
Karthi Thyagarajan commented on FLINK-24379:
FYI - just letting folks know that I'm picking
[
https://issues.apache.org/jira/browse/FLINK-31317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31317:
--
Summary: Introduce data structures for managing resource requirements of a
job (was:
rkhachatryan commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124691916
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Fix Version/s: aws-connector-4.1.0
(was: 1.17.0)
> Support AWS Glue
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-24379:
-
Assignee: Karthi Thyagarajan (was: Brad Davis)
> Support AWS Glue Schema Registry
David Morávek created FLINK-31317:
-
Summary: Introduce data structure for managing resource
requirements of a job
Key: FLINK-31317
URL: https://issues.apache.org/jira/browse/FLINK-31317
Project:
[
https://issues.apache.org/jira/browse/FLINK-31316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31316:
--
Fix Version/s: 1.18.0
> FLIP-291: Externalized Declarative Resource Management
>
reta commented on PR #5:
URL:
https://github.com/apache/flink-connector-opensearch/pull/5#issuecomment-1453764023
Thanks a lot for review @dannycranmer
> @reta The PR looks good to me minus the Mockito comment. However I have
questions over the approach here. We are adding a new
David Morávek created FLINK-31316:
-
Summary: FLIP-291: Externalized Declarative Resource Management
Key: FLINK-31316
URL: https://issues.apache.org/jira/browse/FLINK-31316
Project: Flink
dannycranmer closed pull request #17360: [FLINK-24379][Formats] Add support for
Glue schema registry in Table API
URL: https://github.com/apache/flink/pull/17360
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dannycranmer commented on PR #17360:
URL: https://github.com/apache/flink/pull/17360#issuecomment-1453759473
This connector has been moved to
https://github.com/apache/flink-connector-aws/tree/main/flink-formats-aws/flink-avro-glue-schema-registry.
Closing PR. Please reopen targeting
Jingsong Lee created FLINK-31315:
Summary: FlinkActionsE2eTest.testMergeInto is unstable
Key: FLINK-31315
URL: https://issues.apache.org/jira/browse/FLINK-31315
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-31315:
-
Issue Type: Bug (was: Improvement)
> FlinkActionsE2eTest.testMergeInto is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31288.
--
Fix Version/s: 1.17.0
Resolution: Fixed
> Disable overdraft buffer for batch shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695780#comment-17695780
]
Weijie Guo edited comment on FLINK-31288 at 3/3/23 2:49 PM:
master(1.18) via
reswqa merged PR #22076:
URL: https://github.com/apache/flink/pull/22076
--
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:
akalash commented on code in PR #21923:
URL: https://github.com/apache/flink/pull/21923#discussion_r1124556907
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -733,8 +764,7 @@ void restoreInternal() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-26808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696167#comment-17696167
]
Tobias Hofer commented on FLINK-26808:
--
The expectation is that Flink behaves as documented.
In
reta commented on code in PR #11:
URL:
https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1124477439
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java:
##
@@ -122,10 +128,11 @@
} catch
[
https://issues.apache.org/jira/browse/FLINK-31239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-31239.
--
Fix Version/s: 1.18.0
Resolution: Fixed
Fixed in
1.18.0:
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696139#comment-17696139
]
Shengkai Fang commented on FLINK-30978:
---
Merged into master:
godfreyhe closed pull request #22031: [FLINK-31239][hive] Fix native sum
function can't get the corrected value when the argument type is string
URL: https://github.com/apache/flink/pull/22031
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30978:
---
Labels: pull-request-available test-stability (was: test-stability)
>
fsk119 merged PR #22055:
URL: https://github.com/apache/flink/pull/22055
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-31313.
---
Resolution: Duplicate
> Unsupported meta columns in column list of insert statement
>
[
https://issues.apache.org/jira/browse/FLINK-31185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31185.
---
Assignee: Juntao Hu
Resolution: Fixed
Fixed in:
- master: 8d52415a05bdc67eb67a59bbc2e53f48762da374
-
[
https://issues.apache.org/jira/browse/FLINK-31313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696129#comment-17696129
]
lincoln lee commented on FLINK-31313:
-
[~csq] Thanks for reminding, I've marked this duplicated.
dianfu closed pull request #22003: [FLINK-31185][Python] Support side-output in
broadcast processing
URL: https://github.com/apache/flink/pull/22003
--
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
lincoln-lil commented on code in PR #21897:
URL: https://github.com/apache/flink/pull/21897#discussion_r1124356820
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java:
##
@@ -68,6 +68,36 @@ public static TableSchema
[
https://issues.apache.org/jira/browse/FLINK-31154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-31154:
-
Assignee: Qingsheng Ren
> Build Release Candidate: 1.17.0-rc1
>
[
https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696116#comment-17696116
]
Renxiang Zhou commented on FLINK-31249:
---
[~roman] If it takes too long to finalize the checkpoint
[
https://issues.apache.org/jira/browse/FLINK-31294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31294.
Fix Version/s: table-store-0.4.0
Resolution: Fixed
master:
1 - 100 of 132 matches
Mail list logo
