wuchong opened a new pull request, #20761:
URL: https://github.com/apache/flink/pull/20761
This is a cherry-pick back to release-1.16 branch
--
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 sp
[
https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600618#comment-17600618
]
Martijn Visser commented on FLINK-29031:
[~dannycranmer] Can you have a look at
Sergey Nuyanzin created FLINK-29204:
---
Summary: JoinITCase#testUncorrelatedScalar fails with Cannot
generate a valid execution plan for the given query after calcite update 1.27
Key: FLINK-29204
URL: https://issu
Sergey Nuyanzin created FLINK-29203:
---
Summary: SetOperatorsITCase#testUnionAllWithCommonType is failing
after Calcite update to 1.27
Key: FLINK-29203
URL: https://issues.apache.org/jira/browse/FLINK-29203
[
https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600615#comment-17600615
]
Shengkai Fang commented on FLINK-28953:
---
[~junhe] hi. If we have no other problems
[
https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28952.
-
Resolution: Resolved
> Release Testing: Veify Hive dialect
> --
Sergey Nuyanzin created FLINK-29202:
---
Summary: CliClient fails with NPE during start (after calcite
update to 1.27)
Key: FLINK-29202
URL: https://issues.apache.org/jira/browse/FLINK-29202
Project: F
yunfengzhou-hub commented on PR #20754:
URL: https://github.com/apache/flink/pull/20754#issuecomment-1237725256
@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 co
JingsongLi commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963311013
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/FileStoreLookupFunction.java:
##
@@ -0,0 +1,216 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600610#comment-17600610
]
Sergey Nuyanzin commented on FLINK-27998:
-
Thanks for the suggestion [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600607#comment-17600607
]
Xingbo Huang commented on FLINK-29153:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600606#comment-17600606
]
Xingbo Huang commented on FLINK-28941:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot commented on PR #20760:
URL: https://github.com/apache/flink/pull/20760#issuecomment-1237713764
## CI report:
* cc9b32b44e9ff76369f720d6df229c52ddae7773 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SteNicholas commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963300347
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/FileStoreLookupFunction.java:
##
@@ -0,0 +1,216 @@
+/*
+ * License
SteNicholas commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963299506
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/FileStoreLookupFunction.java:
##
@@ -0,0 +1,216 @@
+/*
+ * License
PatrickRen commented on PR #20760:
URL: https://github.com/apache/flink/pull/20760#issuecomment-1237710097
@pnowojski Could you take a look on this PR when you are available? Thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
SteNicholas commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963297323
##
docs/content/docs/development/lookup-join.md:
##
@@ -0,0 +1,87 @@
+---
+title: "Lookup Join"
+weight: 6
+type: docs
+aliases:
+- /development/lookup-join.
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28975:
---
Labels: pull-request-available (was: )
> withIdleness marks all streams from FLIP-27 source
PatrickRen opened a new pull request, #20760:
URL: https://github.com/apache/flink/pull/20760
## What is the purpose of the change
This pull request adds IdlenessManager for main and per-split output in
source operator to mark idleness only if both output are idle
## Brief
flinkbot commented on PR #20759:
URL: https://github.com/apache/flink/pull/20759#issuecomment-1237699403
## CI report:
* d29ea49eed1299366482c16399f19865eb8f4499 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HeChuanXUPT commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1237699265
Wow, Thanks, It works for me~
--
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 speci
snuyanzin opened a new pull request, #20759:
URL: https://github.com/apache/flink/pull/20759
## What is the purpose of the change
`CassandraOutputFormat` is deprecated and in javadoc [1] it is mentioned
that it's better to use `CassandraTupleOutputFormat`.
The PR replaces usage
Aitozi commented on PR #20654:
URL: https://github.com/apache/flink/pull/20654#issuecomment-1237692206
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29196:
Assignee: Xingbo Huang
> flink-python NOTICE is incorrect
> -
nielsbasjes closed pull request #28: [FLINK-28911] Ensure the
SerializationSchema has been opened.
URL: https://github.com/apache/flink-connector-elasticsearch/pull/28
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
yunfengzhou-hub commented on PR #20754:
URL: https://github.com/apache/flink/pull/20754#issuecomment-1237675969
@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 co
[
https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-27402:
--
Assignee: Yunhong Zheng
> Unexpected boolean expression simplification for AND expression
>
HuangXingBo commented on PR #20758:
URL: https://github.com/apache/flink/pull/20758#issuecomment-1237661371
cc @zentol
--
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 u
JingsongLi commented on PR #281:
URL:
https://github.com/apache/flink-table-store/pull/281#issuecomment-1237642739
@tsreaper @SteNicholas Thanks for your reviews, addressed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JingsongLi commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963238410
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/RocksDBSetState.java:
##
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the
flinkbot commented on PR #20758:
URL: https://github.com/apache/flink/pull/20758#issuecomment-1237638175
## CI report:
* 14bb315404851da5b5bdc7c3a315fc0486a08659 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29196:
---
Labels: pull-request-available (was: )
> flink-python NOTICE is incorrect
> ---
HuangXingBo opened a new pull request, #20758:
URL: https://github.com/apache/flink/pull/20758
## What is the purpose of the change
*This pull request fixes the license problem of flink-python module*
## Verifying this change
*This change is a trivial rework without any test
SteNicholas commented on code in PR #281:
URL: https://github.com/apache/flink-table-store/pull/281#discussion_r963226417
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/lookup/FileStoreLookupFunction.java:
##
@@ -0,0 +1,212 @@
+/*
+ * License
dingweiqings commented on PR #20755:
URL: https://github.com/apache/flink/pull/20755#issuecomment-1237623670
@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 comme
yunfengzhou-hub commented on PR #20754:
URL: https://github.com/apache/flink/pull/20754#issuecomment-1237610459
@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 co
yunfengzhou-hub commented on PR #20752:
URL: https://github.com/apache/flink/pull/20752#issuecomment-1237610386
@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 co
[
https://issues.apache.org/jira/browse/FLINK-28882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600556#comment-17600556
]
Shuiqiang Chen edited comment on FLINK-28882 at 9/6/22 3:00 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-28882:
Assignee: Shuiqiang Chen
> ENCODE return error
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-28882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600556#comment-17600556
]
Shuiqiang Chen edited comment on FLINK-28882 at 9/6/22 2:56 AM:
--
lindong28 commented on code in PR #20752:
URL: https://github.com/apache/flink/pull/20752#discussion_r963209555
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java:
##
@@ -207,8 +204,8 @@ void markForCheckpoint(long checkpointId
[
https://issues.apache.org/jira/browse/FLINK-28882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600556#comment-17600556
]
Shuiqiang Chen commented on FLINK-28882:
I have encountered the same problem in
xintongsong commented on code in PR #20739:
URL: https://github.com/apache/flink/pull/20739#discussion_r963204271
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java:
##
@@ -37,22 +38,28 @@ static List
sortExecutionVerticesInT
[
https://issues.apache.org/jira/browse/FLINK-28882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-28882:
---
Attachment: screenshot-1.png
> ENCODE return error
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600554#comment-17600554
]
Hangxiang Yu commented on FLINK-29195:
--
Actually, you could get the latest checkpoi
yunfengzhou-hub commented on PR #20754:
URL: https://github.com/apache/flink/pull/20754#issuecomment-1237593595
@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 co
yunfengzhou-hub commented on PR #20752:
URL: https://github.com/apache/flink/pull/20752#issuecomment-1237593478
@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 co
weibozhao commented on code in PR #154:
URL: https://github.com/apache/flink-ml/pull/154#discussion_r963199026
##
flink-ml-examples/src/main/java/org/apache/flink/ml/examples/feature/NormalizerExample.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (
[
https://issues.apache.org/jira/browse/FLINK-29189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29189.
Resolution: Fixed
master: 3b149792a9b106a748fe60d787c14daf55635d43
> Pass KeyValue to MergeFuncti
JingsongLi merged PR #286:
URL: https://github.com/apache/flink-table-store/pull/286
--
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: issues-unsubscr...@
zhipeng93 commented on code in PR #154:
URL: https://github.com/apache/flink-ml/pull/154#discussion_r963183034
##
flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java:
##
@@ -129,6 +129,33 @@ private static double norm2(SparseVector x) {
return JAVA_BLAS.dnr
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600545#comment-17600545
]
Xingbo Huang commented on FLINK-29196:
--
Thanks [~chesnay] for the check, I will fix
yunfengzhou-hub commented on code in PR #153:
URL: https://github.com/apache/flink-ml/pull/153#discussion_r963180773
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/ngram/NGram.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/FLINK-29194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600531#comment-17600531
]
Gyula Fora commented on FLINK-29194:
I don’t really see why it’s important to be abl
snuyanzin commented on PR #20753:
URL: https://github.com/apache/flink/pull/20753#issuecomment-1237493195
I've created a follow-up tasks for that
https://issues.apache.org/jira/browse/FLINK-29201
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
Sergey Nuyanzin created FLINK-29201:
---
Summary: Some tests from flink-sql-client, flink-connector-hive
are not compiling in IntellijIdea with new maven
Key: FLINK-29201
URL: https://issues.apache.org/jira/browse/
snuyanzin commented on PR #20663:
URL: https://github.com/apache/flink/pull/20663#issuecomment-1237460389
@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 speci
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963124501
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSinkTest.java:
##
@@ -122,15 +123,15 @@ protected void verifyResult
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963123365
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java:
##
@@ -46,15 +47,15 @@
import
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963123365
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java:
##
@@ -46,15 +47,15 @@
import
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963121344
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseTest.java:
##
@@ -46,15 +47,15 @@
import
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963120183
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSinkTest.java:
##
@@ -122,15 +123,15 @@ protected void verifyResult
snuyanzin commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r963120183
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSinkTest.java:
##
@@ -122,15 +123,15 @@ protected void verifyResult
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r963029722
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -282,4 +282,21 @@ public enum VertexDescriptionMode {
.withDescri
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r963060391
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java:
##
@@ -559,14 +577,67 @@ private void createOutputForSplits(List
newSpli
syhily commented on code in PR #20725:
URL: https://github.com/apache/flink/pull/20725#discussion_r963040227
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java:
##
@@ -64,17 +67,35 @@
publ
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r963034437
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -282,4 +282,21 @@ public enum VertexDescriptionMode {
.withDescri
mxm commented on code in PR #20485:
URL: https://github.com/apache/flink/pull/20485#discussion_r963030325
##
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherTest.java:
##
@@ -255,6 +256,23 @@ public void testC
gaborgsomogyi commented on code in PR #18118:
URL: https://github.com/apache/flink/pull/18118#discussion_r963004146
##
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/IntervalJoinITCase.java:
##
@@ -155,6 +157,134 @@ public void testJoinsCorrectlyWithMultipleKe
flinkbot commented on PR #20757:
URL: https://github.com/apache/flink/pull/20757#issuecomment-1237199667
## CI report:
* e2742167e79e6f58e5f2522c448306bc59a74bbd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29200:
---
Description:
Currently, if the TaskManager heartbeat timeout the pod will be deleted
immediately. It's not
[
https://issues.apache.org/jira/browse/FLINK-27919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27919:
---
Labels: pull-request-available (was: )
> Add FLIP-27-based Data Generator Source
>
afedulov opened a new pull request, #20757:
URL: https://github.com/apache/flink/pull/20757
## What is the purpose of the change
Implements
[FLIP-238](https://cwiki.apache.org/confluence/display/FLINK/FLIP-238%3A+Introduce+FLIP-27-based+Data+Generator+Source)
## Brief change lo
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600461#comment-17600461
]
Yufan Sheng edited comment on FLINK-27917 at 9/5/22 3:11 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-29200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600462#comment-17600462
]
Aitozi commented on FLINK-29200:
cc [~wangyang0918] do you think it's worth to support i
Aitozi created FLINK-29200:
--
Summary: Provide the way to delay the pod deletion for debugging
purpose
Key: FLINK-29200
URL: https://issues.apache.org/jira/browse/FLINK-29200
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600461#comment-17600461
]
Yufan Sheng commented on FLINK-27917:
-
It seems like a bug on Pulsar broker:
https:
gaborgsomogyi commented on PR #20265:
URL: https://github.com/apache/flink/pull/20265#issuecomment-1237174092
@ferenc-csaky I think you're right in general and I would give support if
this general question would pop-up somewhere in the community. I think the
solution need to be considered w
XComp commented on code in PR #20663:
URL: https://github.com/apache/flink/pull/20663#discussion_r962985807
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java:
##
@@ -187,7 +187,7 @@ public FlinkCalciteCatalogReader
cr
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600457#comment-17600457
]
Yufan Sheng edited comment on FLINK-27917 at 9/5/22 2:55 PM:
-
liuzhuang2017 commented on PR #20640:
URL: https://github.com/apache/flink/pull/20640#issuecomment-1237164884
@MartijnVisser , Sorry to bother you, can you help me review this pull
request? grateful.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
[
https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600457#comment-17600457
]
Yufan Sheng commented on FLINK-27917:
-
[~hxbks2ks] I'll check this.
> PulsarUnorder
XComp commented on code in PR #19916:
URL: https://github.com/apache/flink/pull/19916#discussion_r962898568
##
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSinkTest.java:
##
@@ -39,17 +40,18 @@
liuzhuang2017 commented on PR #20660:
URL: https://github.com/apache/flink/pull/20660#issuecomment-1237163569
@MartijnVisser , Sorry to bother you, can you help` @liujingmao ` review
this pull request? grateful.
--
This is an automated message from the Apache Git Service.
To respond to th
Aitozi commented on PR #20654:
URL: https://github.com/apache/flink/pull/20654#issuecomment-1237160028
@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.
T
twalthr commented on code in PR #20663:
URL: https://github.com/apache/flink/pull/20663#discussion_r962971966
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java:
##
@@ -187,7 +187,7 @@ public FlinkCalciteCatalogReader
dependabot[bot] opened a new pull request, #61:
URL: https://github.com/apache/flink-benchmarks/pull/61
Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1.
Release notes
Sourced from https://github.com/junit-team/junit4/releases";>junit's
releases.
JUnit
dependabot[bot] opened a new pull request, #60:
URL: https://github.com/apache/flink-benchmarks/pull/60
Bumps [libthrift](https://github.com/apache/thrift) from 0.13.0 to 0.14.0.
Release notes
Sourced from https://github.com/apache/thrift/releases";>libthrift's
releases.
Ver
dependabot[bot] opened a new pull request, #59:
URL: https://github.com/apache/flink-benchmarks/pull/59
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from
3.11.4 to 3.16.1.
Release notes
Sourced from https://github.com/protocolbuffers/protobuf/releases";>protob
Oleg Vorobev created FLINK-29199:
Summary: Support blue-green deployment type
Key: FLINK-29199
URL: https://issues.apache.org/jira/browse/FLINK-29199
Project: Flink
Issue Type: Improvement
SteNicholas commented on code in PR #286:
URL: https://github.com/apache/flink-table-store/pull/286#discussion_r962933579
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/ValueCountMergeFunction.java:
##
@@ -41,8 +43,11 @@ public void r
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600441#comment-17600441
]
Chesnay Schepler commented on FLINK-29196:
--
There are numerous issues in the fl
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29196:
-
Summary: flink-python NOTICE is incorrect (was: Check 1.16 licensing)
> flink-python NO
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-29196:
Assignee: (was: Chesnay Schepler)
> Check 1.16 licensing
> --
[
https://issues.apache.org/jira/browse/FLINK-29196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600441#comment-17600441
]
Chesnay Schepler edited comment on FLINK-29196 at 9/5/22 1:53 PM:
SteNicholas opened a new pull request, #362:
URL: https://github.com/apache/flink-kubernetes-operator/pull/362
## What is the purpose of the change
Java Operator SDK has released 3.2.0 version. Bump the JOSDK version to
3.2.0.
## Brief change log
- Bump the fab
XComp commented on PR #20753:
URL: https://github.com/apache/flink/pull/20753#issuecomment-1237062757
Thanks @snuyanzin . Could you also create the follow-up ticket (or check
whether there is something like that already) in Jira?
--
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/FLINK-29129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29129.
Resolution: Fixed
master: 769f19d8566f0a30d3a7c09b297b9dce3280ac1e
> Try best to push down value
JingsongLi merged PR #280:
URL: https://github.com/apache/flink-table-store/pull/280
--
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: issues-unsubscr...@
Matthias Pohl created FLINK-29198:
-
Summary: RetryExtension doesn't make the test fail if the retries
are exhausted
Key: FLINK-29198
URL: https://issues.apache.org/jira/browse/FLINK-29198
Project: Fli
1 - 100 of 231 matches
Mail list logo
