yuzelin opened a new pull request, #20401:
URL: https://github.com/apache/flink/pull/20401
## What is the purpose of the change
Implement getSchemas in the HiveServer2 Endpoint.
## Brief change log
- Implement listDatabases in the SqlGatewayService.
- I
yangjunhan commented on PR #20380:
URL: https://github.com/apache/flink/pull/20380#issuecomment-1200789930
@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-28665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28665:
---
Labels: pull-request-available (was: )
> flink-table-store-benchmark-jar-with-dependencies.
tsreaper opened a new pull request, #258:
URL: https://github.com/apache/flink-table-store/pull/258
Currently the benchmark module does not have a correct NOTICE file. However
this module does not need to be released, so we can just skip its deployment.
--
This is an automated message fro
masteryhx commented on code in PR #20313:
URL: https://github.com/apache/flink/pull/20313#discussion_r934182431
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -365,4 +401,19 @@ public String toString() {
return "Emp
[
https://issues.apache.org/jira/browse/FLINK-28760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28760:
---
Labels: pull-request-available (was: )
> Hive table store support can't be fully enabled by
tsreaper opened a new pull request, #257:
URL: https://github.com/apache/flink-table-store/pull/257
Current table store Hive document states that, to enable support in Hive, we
should use ADD JAR statement to add hive connector jar.
However some types of queries, for example join stat
lincoln-lil commented on code in PR #20363:
URL: https://github.com/apache/flink/pull/20363#discussion_r934082373
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -1356,6 +1379,15 @@ public TableResultInternal
[
https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573568#comment-17573568
]
Zhu Zhu commented on FLINK-28759:
-
[~JunRuiLi] I have assign you the ticket. Go a head t
[
https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28759:
---
Assignee: JUNRUILi
> Enable speculative execution for in AdaptiveBatchScheduler TPC-DS e2e tests
>
[
https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573566#comment-17573566
]
JUNRUILi edited comment on FLINK-28759 at 8/1/22 6:27 AM:
--
[~zh
masteryhx commented on code in PR #20313:
URL: https://github.com/apache/flink/pull/20313#discussion_r934176373
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/SharedStateRegistryTest.java:
##
@@ -182,20 +194,113 @@ public void testRegisterChangelogStateBackendHand
[
https://issues.apache.org/jira/browse/FLINK-28759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573566#comment-17573566
]
JUNRUILi commented on FLINK-28759:
--
[~zhuzh] I will take a look at it
> Enable specula
Caizhi Weng created FLINK-28760:
---
Summary: Hive table store support can't be fully enabled by ADD
JAR statement
Key: FLINK-28760
URL: https://issues.apache.org/jira/browse/FLINK-28760
Project: Flink
Zhu Zhu created FLINK-28759:
---
Summary: Enable speculative execution for in
AdaptiveBatchScheduler TPC-DS e2e tests
Key: FLINK-28759
URL: https://issues.apache.org/jira/browse/FLINK-28759
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28096.
---
Resolution: Fixed
Fixed in master: a6a7063cfafd8cd5c1b04169839b92373bf96fde
> Hive dialect support set vari
wuchong merged PR #2:
URL: https://github.com/apache/flink/pull/2
--
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.apach
reswqa commented on PR #20216:
URL: https://github.com/apache/flink/pull/20216#issuecomment-1200755216
@wsry Thanks for the review, I have address all of your comments, please
take a look again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573559#comment-17573559
]
Maciej Bryński commented on FLINK-20969:
[~martijnvisser]
Maybe 2.12.16 ?
https:
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hjw updated FLINK-28758:
Description:
I post a save with savepoint request to Flink Job throught rest api.
A Error happened in Kafka connec
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hjw updated FLINK-28758:
Description:
I post a save with savepoint request to Flink Job throught rest api.
A Error happened in Kafka connec
zhipeng93 commented on code in PR #132:
URL: https://github.com/apache/flink-ml/pull/132#discussion_r934161874
##
flink-ml-lib/src/main/java/org/apache/flink/ml/stats/chisqtest/ChiSqTestParams.java:
##
@@ -0,0 +1,11 @@
+package org.apache.flink.ml.stats.chisqtest;
Review Commen
hjw created FLINK-28758:
---
Summary: Failed to stop with savepoint
Key: FLINK-28758
URL: https://issues.apache.org/jira/browse/FLINK-28758
Project: Flink
Issue Type: Bug
Components: Connectors
pltbkd commented on PR #20296:
URL: https://github.com/apache/flink/pull/20296#issuecomment-1200741155
Thanks you for all the comments!
I've squashed all fixups and rebased on to the latest master. The PR should
be ready for merging once the CI is passed.
--
This is an automated me
flinkbot commented on PR #20400:
URL: https://github.com/apache/flink/pull/20400#issuecomment-1200735191
## CI report:
* b3d03228a45419a8e0bdcf59f80d5e38e2b24b52 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx opened a new pull request, #20400:
URL: https://github.com/apache/flink/pull/20400
## What is the purpose of the change
This pull request adding more details about state latency tracking in the
metric documentation.
## Brief change log
- Added "Sta
[
https://issues.apache.org/jira/browse/FLINK-24787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24787:
---
Labels: pull-request-available (was: )
> Add more details of state latency tracking documen
sazzad16 commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis/pull/3#issuecomment-1200710378
@eskabetxe Let's discuss.
Would Slack be a good place for this? Or must we use mailing list?
@MartijnVisser
--
This is an automated message from the Apache Git S
HuangZhenQiu commented on PR #20176:
URL: https://github.com/apache/flink/pull/20176#issuecomment-1200702958
@lsyldliu Thanks for the review. Revised the code accordingly Would you
please take a look again?
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/FLINK-28664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28664.
---
Assignee: Juntao Hu
Resolution: Fixed
Merged to master via f8f2ebb34f18540f4bfdf2b5db591539199b65e7
>
dianfu closed pull request #20383: [FLINK-28664][python][format] FileSink
supports AvroWriters
URL: https://github.com/apache/flink/pull/20383
--
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 spe
zhipeng93 commented on code in PR #132:
URL: https://github.com/apache/flink-ml/pull/132#discussion_r934122580
##
flink-ml-lib/src/main/java/org/apache/flink/ml/stats/chisqtest/ChiSqTest.java:
##
@@ -0,0 +1,654 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
lincoln-lil commented on code in PR #20196:
URL: https://github.com/apache/flink/pull/20196#discussion_r934122365
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/cache/DefaultLookupCache.java:
##
@@ -0,0 +1,270 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-28151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-28151:
-
Assignee: WeiNan Zhao (was: Shengkai Fang)
> Allow to cancel the Operation for the Hiv
zhipeng93 merged PR #133:
URL: https://github.com/apache/flink-ml/pull/133
--
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
zhipeng93 commented on PR #133:
URL: https://github.com/apache/flink-ml/pull/133#issuecomment-1200665229
Thanks for the update @weibozhao. LGTM.
--
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 th
wuchong commented on code in PR #19017:
URL: https://github.com/apache/flink/pull/19017#discussion_r934110184
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserRowResolver.java:
##
@@ -170,6 +206,12 @@ public boo
yunfengzhou-hub commented on PR #20275:
URL: https://github.com/apache/flink/pull/20275#issuecomment-1200660902
@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-28757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573526#comment-17573526
]
Weike Dong commented on FLINK-28757:
Related to FLINK-17525 and FLINK-19872, but sti
dianfu commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934112786
##
flink-python/pyflink/datastream/connectors/file_system.py:
##
@@ -535,6 +568,51 @@ def for_row_format(base_path: str, encoder: Encoder) ->
'FileSink.RowFormatBuild
Weike Dong created FLINK-28757:
--
Summary: Increase precision of TIME fields in JSON Format
Key: FLINK-28757
URL: https://issues.apache.org/jira/browse/FLINK-28757
Project: Flink
Issue Type: Impr
wsry commented on code in PR #20216:
URL: https://github.com/apache/flink/pull/20216#discussion_r934106967
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferCompressor.java:
##
@@ -107,15 +107,28 @@ private int compress(Buffer buffer) {
wsry commented on code in PR #20216:
URL: https://github.com/apache/flink/pull/20216#discussion_r934105686
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/compression/AirCompressor.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
Aitozi commented on PR #20397:
URL: https://github.com/apache/flink/pull/20397#issuecomment-1200636421
I have not written a benchmark test for it now, I only run a production test
which seen 2~4 times improved. Do you mean add an extra test for it in the
flink-benchmark project?
--
This
wuchong commented on PR #20397:
URL: https://github.com/apache/flink/pull/20397#issuecomment-1200634296
Do you have any benchmark between the two implementations?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
WencongLiu commented on PR #20236:
URL: https://github.com/apache/flink/pull/20236#issuecomment-1200631190
@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
Vancior commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934082090
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetReaders.java:
##
@@ -51,15 +51,7 @@ public class AvroParquetReaders {
Vancior commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934093658
##
flink-python/pyflink/datastream/connectors/file_system.py:
##
@@ -535,6 +568,51 @@ def for_row_format(base_path: str, encoder: Encoder) ->
'FileSink.RowFormatBuild
[
https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26412:
Component/s: Connectors / Hive
> Hive dialect supports "CREATE FUNCTION USING xxx.jar"
> -
[
https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26366:
Component/s: Connectors / Hive
> Support "insert directory"
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-26366.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: a42c0041fc37595d07010c2077b2f806b2b34ef9
>
[
https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-26412.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: b0d2b2aeb28329d48ee0b89259dbb067175c545a
>
wuchong closed pull request #19520: [FLINK-26366][hive] support insert
overwrite directory
URL: https://github.com/apache/flink/pull/19520
--
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 specifi
wuchong closed pull request #20251: [FLINK-26412][hive] Hive dialect supports
"create function using jar"
URL: https://github.com/apache/flink/pull/20251
--
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
[
https://issues.apache.org/jira/browse/FLINK-28678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573515#comment-17573515
]
xuyang commented on FLINK-28678:
[~martijnvisser] I copied these steps to FLINK-28744
>
yangjunhan commented on PR #20380:
URL: https://github.com/apache/flink/pull/20380#issuecomment-1200602489
@simplejason Thanks for the advice. All mentioned above have been taken care
of.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-28744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573514#comment-17573514
]
xuyang commented on FLINK-28744:
Just for reminding, the following files should be remov
[
https://issues.apache.org/jira/browse/FLINK-28678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-28678:
---
Description:
Ref CALCITE-5107 . Mainly cherry pick it.
The following files should be removed from the Flink
leozhangsr commented on PR #20387:
URL: https://github.com/apache/flink/pull/20387#issuecomment-1200599164
@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
Vancior commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934082463
##
flink-python/pyflink/datastream/formats/avro.py:
##
@@ -63,6 +70,9 @@ class GenericRecordAvroTypeInfo(TypeInformation):
A :class:`TypeInformation` of Avro's Gene
Vancior commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934082286
##
flink-python/pyflink/datastream/formats/csv.py:
##
@@ -131,7 +131,7 @@ def add_columns_from(self, schema: 'CsvSchema') ->
'CsvSchemaBuilder':
:param schema:
Vancior commented on code in PR #20383:
URL: https://github.com/apache/flink/pull/20383#discussion_r934082090
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetReaders.java:
##
@@ -51,15 +51,7 @@ public class AvroParquetReaders {
yunfengzhou-hub commented on code in PR #135:
URL: https://github.com/apache/flink-ml/pull/135#discussion_r934072380
##
flink-ml-python/pyflink/ml/lib/feature/elementwiseproduct.py:
##
@@ -0,0 +1,73 @@
+
[
https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25686:
---
Labels: Pulsar pull-request-available stale-assigned (was: Pulsar
pull-request-available)
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-23944:
---
Labels: pull-request-available stale-assigned test-stability (was:
pull-request-available t
[
https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28078:
---
Labels: stale-assigned test-stability (was: test-stability)
I am the [Flink Jira Bot|https:
[
https://issues.apache.org/jira/browse/FLINK-25764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25764:
---
Labels: auto-deprioritized-minor usability (was: stale-minor usability)
Priority: Not
[
https://issues.apache.org/jira/browse/FLINK-27750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27750:
---
Labels: TOTAL_PROCESS_MEMORY auto-deprioritized-major
jobmanager.memory.process.size (was
[
https://issues.apache.org/jira/browse/FLINK-28347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28347:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-28082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28082:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1200444798
How can I construct `FINALIZE_CHECKPOINT_FAILURE`? I tried to implement a
`CheckpointStorage`, but I found that there are too many methods to implement.
`@Test(timeout = 20_00
[ https://issues.apache.org/jira/browse/FLINK-26270 ]
Jiankun Feng deleted comment on FLINK-26270:
--
was (Author: JIRAUSER284851):
hi [~martijnvisser] , I submitted a PR but so far no results , Can you take a
look ? thanks
> Flink SQL write da
sunshineJK commented on code in PR #20127:
URL: https://github.com/apache/flink/pull/20127#discussion_r916412976
##
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java:
##
@@ -87,5 +87,12 @@ public class CsvFormatOptions {
Jonathan diamant created FLINK-28756:
Summary: Can't write nested object to parquet flink 1.15.1
Key: FLINK-28756
URL: https://issues.apache.org/jira/browse/FLINK-28756
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-26410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-26410.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: faf37ebb2bbf385fbb9b6163bbf7a09353a0e39d
>
[
https://issues.apache.org/jira/browse/FLINK-26410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-26410:
Summary: support hive transform using syntax (was: support hive transform)
> support hive transform using
wuchong merged PR #19818:
URL: https://github.com/apache/flink/pull/19818
--
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.apach
eskabetxe commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis/pull/3#issuecomment-1200411096
Hi @sazzad16,
Im not an expert on Redis Streams, but I think bot ways must be implemented..
For my knowledge, Redis Streams is used like (sorry for the analogy) if you
are
sazzad16 commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis/pull/3#issuecomment-1200398428
@MartijnVisser The FLIP is great!
--
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
sazzad16 commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis/pull/3#issuecomment-1200398367
Hi @eskabetxe, nice to meet you.
I see that the user would have to set (and so know and understand) exact
Redis command which I feel not very intuitive from user's perspec
HuangXingBo commented on PR #20396:
URL: https://github.com/apache/flink/pull/20396#issuecomment-1200393131
@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 commen
HuangXingBo commented on PR #20396:
URL: https://github.com/apache/flink/pull/20396#issuecomment-1200393104
@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 commen
flinkbot commented on PR #20399:
URL: https://github.com/apache/flink/pull/20399#issuecomment-1200390146
## CI report:
* 956d62bec9fd45c3cbb04a535c4d270ad3d10d42 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
take-it-out commented on PR #20399:
URL: https://github.com/apache/flink/pull/20399#issuecomment-1200389179
@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
[
https://issues.apache.org/jira/browse/FLINK-28699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28699:
---
Labels: pull-request-available (was: )
> Native rocksdb full snapshot in non-incremental ch
take-it-out opened a new pull request, #20399:
URL: https://github.com/apache/flink/pull/20399
## What is the purpose of the change
When rocksdb statebackend is used and state.backend.incremental enabled,
flink will figure out newly created sst files generated by rocksdb during
c
Gyula Fora created FLINK-28755:
--
Summary: Error when switching from stateless to savepoint upgrade
mode
Key: FLINK-28755
URL: https://issues.apache.org/jira/browse/FLINK-28755
Project: Flink
Is
lincoln-lil commented on code in PR #20359:
URL: https://github.com/apache/flink/pull/20359#discussion_r933950487
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/logical/LogicalTableScan.java:
##
@@ -103,7 +105,9 @@ public RelNode copy(RelTraitSet traitSe
[
https://issues.apache.org/jira/browse/FLINK-28625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-28625:
--
Assignee: Aitozi
> Guard against changing target session deployment for sessionjob
>
89 matches
Mail list logo
