snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
luoyuxia commented on PR #20907:
URL: https://github.com/apache/flink/pull/20907#issuecomment-1275678633
@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.
yunfengzhou-hub commented on code in PR #160:
URL: https://github.com/apache/flink-ml/pull/160#discussion_r993058402
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/splitter/Splitter.java:
##
@@ -0,0 +1,111 @@
+/*
Review Comment:
In order to align the functionality
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992266138
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/join/NestedLoopSemiAntiJoinTest.xml:
##
@@ -673,8 +673,8 @@ Calc(sele
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993052648
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
twalthr commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r993051603
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
It would
haoxins commented on PR #399:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/399#issuecomment-1275662962
> Can you please add a test case for this?
will do
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
luoyuxia commented on PR #20907:
URL: https://github.com/apache/flink/pull/20907#issuecomment-1275653694
@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.
Yunfeng Zhou created FLINK-29591:
Summary: Add built-in UDFs to convert between arrays and vectors
Key: FLINK-29591
URL: https://issues.apache.org/jira/browse/FLINK-29591
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616207#comment-17616207
]
Qingsheng Ren commented on FLINK-29492:
---
Thanks [~ruanhang1993] . I've assign the
[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616205#comment-17616205
]
Yufan Sheng commented on FLINK-29006:
-
[~hxb] I think we can close this issue if no
[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29492:
-
Assignee: Hang Ruan
> Kafka exactly-once sink causes OutOfMemoryError
> ---
[
https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616199#comment-17616199
]
waywtdcc commented on FLINK-3033:
-
[~pramod] Hello, where is the Redis connector you wrot
[
https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616198#comment-17616198
]
Tigran Manasyan commented on FLINK-28229:
-
Hello, [~martijnvisser] ! I have impl
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616187#comment-17616187
]
Sergey Troshkov edited comment on FLINK-28049 at 10/12/22 5:13 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616187#comment-17616187
]
Sergey Troshkov commented on FLINK-28049:
-
Thank you!
> Introduce FLIP-208 func
hehuiyuan commented on PR #21011:
URL: https://github.com/apache/flink/pull/21011#issuecomment-1275590651
@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.
[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-25409.
-
Resolution: Fixed
> Add cache metric to LookupFunction
> --
>
>
JingsongLi commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1275570471
Hi @zjureel can you do some benchmark to verify the improvement?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
JingsongLi commented on PR #313:
URL:
https://github.com/apache/flink-table-store/pull/313#issuecomment-1275570123
CC: @tsreaper
--
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 com
JingsongLi commented on PR #305:
URL:
https://github.com/apache/flink-table-store/pull/305#issuecomment-1275569659
Thanks for the update, just left one minor comment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-28618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-28618.
--
Resolution: Fixed
Close it since I haven't reproduced this problem using master branch. Feel
free to
JingsongLi commented on code in PR #305:
URL: https://github.com/apache/flink-table-store/pull/305#discussion_r992981418
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/WriteFunction.java:
##
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the Apache Softwar
flinkbot commented on PR #21026:
URL: https://github.com/apache/flink/pull/21026#issuecomment-1275560087
## CI report:
* b35021c3135509cbcb1a33f30180ffc2626f19b2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29590:
---
Labels: pull-request-available (was: )
> Fix literal issue in HiveDialect
> ---
luoyuxia opened a new pull request, #21026:
URL: https://github.com/apache/flink/pull/21026
## What is the purpose of the change
To fix the thrown excpetion with literal in Hive dialect.
1: some folded constant like `Double.NAN` and no-primitive type can't be
convert into calc
[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616169#comment-17616169
]
Hang Ruan commented on FLINK-29492:
---
I am interested in this bug. Maybe I could help t
zoltar9264 commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1275551163
@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
zoltar9264 commented on PR #20975:
URL: https://github.com/apache/flink/pull/20975#issuecomment-1275550883
@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
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616165#comment-17616165
]
Ran Tao commented on FLINK-28786:
-
[~grimsby] Yes, you are right. when i change to conda
luoyuxia commented on PR #20855:
URL: https://github.com/apache/flink/pull/20855#issuecomment-1275532530
@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.
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616152#comment-17616152
]
Xingbo Huang commented on FLINK-25343:
--
https://dev.azure.com/apache-flink/apache-f
HuangXingBo commented on PR #20920:
URL: https://github.com/apache/flink/pull/20920#issuecomment-1275520470
cc @PatrickRen
--
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.
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616151#comment-17616151
]
Xingbo Huang commented on FLINK-29405:
--
https://dev.azure.com/apache-flink/apache-f
HuangXingBo commented on PR #20919:
URL: https://github.com/apache/flink/pull/20919#issuecomment-1275520363
cc @PatrickRen
--
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.
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given l
JingsongLi commented on PR #314:
URL:
https://github.com/apache/flink-table-store/pull/314#issuecomment-1275519030
Thanks @zjureel , I just left one minor comment.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
JingsongLi commented on code in PR #314:
URL: https://github.com/apache/flink-table-store/pull/314#discussion_r992939690
##
flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/SparkE2eTest.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description:
in FLINK-26474, we try to fold constant, but it brings a issue that the folded
constant li
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616142#comment-17616142
]
Xintong Song commented on FLINK-29572:
--
After looking into this a bit more, I think
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given l
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description:
in FLINK-26474, we try to fold constant, but it may bring a issue that the
folded constant
libenchao commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1275500147
@qingwei91 Thanks for the updating, I'll review this PR in a few days.
> I didn't implement additional operators like IN and BETWEEN because I am
quite busy of late. Given they c
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992921852
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -47,10 +47,15 @@
/**
* A Transformer which combines a given l
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616135#comment-17616135
]
Aitozi commented on FLINK-29557:
Anyone can help confirm this issue ?
> The SinkOperat
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Summary: Fix literal issue for HiveDialect (was: Fix constant fold issue
for HiveDialect)
> Fix litera
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Description: in FLINK-26474, we try to fold constant, but it may bring a
issue that the folded constant
[
https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29590:
-
Summary: Fix literal issue in HiveDialect (was: Fix literal issue for
HiveDialect)
> Fix literal issue
luoyuxia created FLINK-29590:
Summary: Fix constant fold issue for HiveDialect
Key: FLINK-29590
URL: https://issues.apache.org/jira/browse/FLINK-29590
Project: Flink
Issue Type: Bug
Com
czy006 commented on PR #21012:
URL: https://github.com/apache/flink/pull/21012#issuecomment-1275495467
@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
zoucao commented on PR #19250:
URL: https://github.com/apache/flink/pull/19250#issuecomment-1275491596
> @zoucao Thanks for updating. Could you please open the same pr to
release-1.16/1.15/1.14? @wuchong Could you please help merge?
Yes, I will do the bp soon.
--
This is an automat
RocMarshal commented on code in PR #20989:
URL: https://github.com/apache/flink/pull/20989#discussion_r992912891
##
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala:
##
@@ -496,16 +496,16 @@ trait ImplicitExpressionC
RocMarshal commented on code in PR #20989:
URL: https://github.com/apache/flink/pull/20989#discussion_r992911391
##
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala:
##
@@ -496,16 +496,16 @@ trait ImplicitExpressionC
yunfengzhou-hub commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r992901815
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java:
##
@@ -21,11 +21,29 @@
import org.apache.flink.ml.common.pa
[
https://issues.apache.org/jira/browse/FLINK-26726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26726:
-
Issue Type: Bug (was: Improvement)
> Remove the unregistered task from readersAwaitingSplit
>
luoyuxia commented on PR #20855:
URL: https://github.com/apache/flink/pull/20855#issuecomment-1275467486
@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.
luoyuxia closed pull request #20883: [WIP] validate for
https://github.com/apache/flink/pull/20882
URL: https://github.com/apache/flink/pull/20883
--
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
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616111#comment-17616111
]
luoyuxia commented on FLINK-29585:
--
Sure. [~jark] Could you please assign this ticket
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-29495.
-
Fix Version/s: 1.16.0
1.17.0
1.15.3
Assignee: Martijn Viss
Cyberness commented on PR #20257:
URL: https://github.com/apache/flink/pull/20257#issuecomment-1275379856
> The code changes look good. Recognise that we specify a KryoSerializer
instead of making the SequenceNumber a POJO to maintain backwards
compatibility. Given that we are changing the
hlteoh37 commented on PR #20257:
URL: https://github.com/apache/flink/pull/20257#issuecomment-1275342620
The code changes look good. Recognise that we specify a KryoSerializer
instead of making the SequenceNumber a POJO to maintain backwards
compatibility. Given that we are changing the sta
snuyanzin commented on PR #20410:
URL: https://github.com/apache/flink/pull/20410#issuecomment-1275339899
@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.
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992793159
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
I've ju
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992793159
##
flink-table/flink-sql-parser/pom.xml:
##
@@ -193,6 +204,10 @@ under the License.
org.apiguardian
Review Comment:
I've ju
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992790858
##
flink-table/flink-sql-parser-hive/pom.xml:
##
@@ -56,6 +56,12 @@ under the License.
guava
${guava.version}
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616076#comment-17616076
]
Martijn Visser commented on FLINK-29589:
If there's indeed a reproducible case w
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29589:
---
Priority: Blocker (was: Major)
> Data Loss in Sink GlobalCommitter during Task Manager reco
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink architecture with global committer seems to be vulne
Krzysztof Chmielewski created FLINK-29589:
-
Summary: Data Loss in Sink GlobalCommitter during Task Manager
recovery
Key: FLINK-29589
URL: https://issues.apache.org/jira/browse/FLINK-29589
Proj
[
https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Chmielewski updated FLINK-29589:
--
Description:
Flink's Sink's architecture with global committer seems to be vul
hlteoh37 commented on PR #14737:
URL: https://github.com/apache/flink/pull/14737#issuecomment-1275238559
@MartijnVisser @dannycranmer Have picked it up here:
https://issues.apache.org/jira/browse/FLINK-29574
--
This is an automated message from the Apache Git Service.
To respond to the m
kristoffSC commented on PR #21025:
URL: https://github.com/apache/flink/pull/21025#issuecomment-1275215995
wrong target 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 specific comment
kristoffSC closed pull request #21025: [DRAFT] Flink 1.14 data loss sink global
committer
URL: https://github.com/apache/flink/pull/21025
--
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
kristoffSC opened a new pull request, #21025:
URL: https://github.com/apache/flink/pull/21025
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1275195142
Hi @libenchao I finally got around and implemented your suggestion. Do you
mind to take a look again?
I didn't implement additional operators like IN and BETWEEN because I am
qui
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616044#comment-17616044
]
Gyula Fora commented on FLINK-29588:
We don't really have a concept of application v
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616041#comment-17616041
]
Clara Xiong commented on FLINK-29588:
-
appVersion is the application version of the
XComp commented on code in PR #21019:
URL: https://github.com/apache/flink/pull/21019#discussion_r992679151
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java:
##
@@ -841,6 +842,12 @@ private StreamConfig createJobVertex(In
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29588:
---
Affects Version/s: (was: kubernetes-operator-1.2.0)
> Add Flink Version and Application Version
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616020#comment-17616020
]
Gyula Fora commented on FLINK-29588:
Since savepoints are compatible across version
[
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616018#comment-17616018
]
Gyula Fora commented on FLINK-29588:
What do you mean by appVersion here?
> Add Fli
flinkbot commented on PR #21024:
URL: https://github.com/apache/flink/pull/21024#issuecomment-1275081315
## CI report:
* 2196926d20b5bd63f416355928bc4c76d0bfa205 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616011#comment-17616011
]
Martijn Visser commented on FLINK-29495:
Tests alsof disabled for/via:
release-
MartijnVisser merged PR #21017:
URL: https://github.com/apache/flink/pull/21017
--
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...@flink
MartijnVisser merged PR #21018:
URL: https://github.com/apache/flink/pull/21018
--
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...@flink
kosigz opened a new pull request, #21024:
URL: https://github.com/apache/flink/pull/21024
The current version of cloudpickle has a bug in that locally / interactively
defined classes with `@property` cannot be serialized.
This makes it more difficult for MLP team to demo E2E flows.
htt
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1275067537
@zentol I see I have a lot of style issues and thanks for pointing them out.
I am wondering if you have a doc / pointer for those style rules so I won't
make those mistakes in the future.
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r992626495
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointTriggerHandlersTest.java:
##
@@ -0,0 +1,349 @@
+/*
+ * Licensed to the Apa
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r992624496
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerStatusHeaders.java:
##
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache
Clara Xiong created FLINK-29588:
---
Summary: Add Flink Version and Application Version to Savepoint
properties
Key: FLINK-29588
URL: https://issues.apache.org/jira/browse/FLINK-29588
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17613317#comment-17613317
]
Dawid Wysakowicz edited comment on FLINK-22243 at 10/11/22 5:19 PM:
--
dawidwys merged PR #21021:
URL: https://github.com/apache/flink/pull/21021
--
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...@flink.apac
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992562130
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r992562130
##
flink-table/flink-table-planner/pom.xml:
##
@@ -127,22 +127,22 @@ under the License.
${calcite.version}
1 - 100 of 320 matches
Mail list logo
