LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894982074
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
reswqa commented on PR #19927:
URL: https://github.com/apache/flink/pull/19927#issuecomment-1152862184
@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 commented on PR #19929:
URL: https://github.com/apache/flink/pull/19929#issuecomment-1152860667
@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-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553031#comment-17553031
]
Weijie Guo commented on FLINK-27667:
[
https://issues.apache.org/jira/browse/FLINK-22644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553027#comment-17553027
]
linqichen commented on FLINK-22644:
---
@[~jark] hello!!!
I am willing to translate "Native Kubernetes"
flinkbot commented on PR #19936:
URL: https://github.com/apache/flink/pull/19936#issuecomment-1152859112
## CI report:
* 5c23c2c64ad46c0e50c3bcd68b6bfc2d905aef59 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
littleeleventhwolf opened a new pull request, #19936:
URL: https://github.com/apache/flink/pull/19936
## What is the purpose of the change
Fix typos in `Source` interface.
## Brief change log
- delete useless '*' in comments
- modify @link format in
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
luoyuxia commented on PR #19931:
URL: https://github.com/apache/flink/pull/19931#issuecomment-1152848363
@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.
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1152847189
@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 commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553018#comment-17553018
]
Aitozi commented on FLINK-28008:
I don't know if there any trick with the new sdk version. cc
luoyuxia commented on PR #19929:
URL: https://github.com/apache/flink/pull/19929#issuecomment-1152844191
@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-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553014#comment-17553014
]
Aitozi commented on FLINK-28008:
I test with the last release version with
{code:java}
helm install
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553014#comment-17553014
]
Aitozi edited comment on FLINK-28008 at 6/11/22 3:01 AM:
-
I test with the last
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28008:
---
Summary: Can not get secondary resource from context after operator restart
(was: Can not get secondary
[
https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-28008:
---
Description:
how to reproduce:
* create session and submit session job
* delete session job
* restart
Aitozi created FLINK-28008:
--
Summary: Can not get secondary resource from after operator restart
Key: FLINK-28008
URL: https://issues.apache.org/jira/browse/FLINK-28008
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27613:
---
Labels: pull-request-available (was: )
> Add label for the session job to help list the
Aitozi opened a new pull request, #265:
URL: https://github.com/apache/flink-kubernetes-operator/pull/265
…jobs in the same session cluster
This PR is based on
https://github.com/apache/flink-kubernetes-operator/pull/215 but use the
mutator webhook to do the same thing
--
This is
[
https://issues.apache.org/jira/browse/FLINK-27963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552970#comment-17552970
]
Dmytro commented on FLINK-27963:
Hi [~martijnvisser], thank you for being involved!
I absolutely agree
coderappee commented on PR #19924:
URL: https://github.com/apache/flink/pull/19924#issuecomment-1152655897
@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
coderappee commented on PR #19924:
URL: https://github.com/apache/flink/pull/19924#issuecomment-1152653795
> @coderappee Let me know if you're stuck, and I can take care of this when
I merge the PR.
>
> In this particular situation, it should be enough to rollback the last
commit in
salvalcantara commented on code in PR #19366:
URL: https://github.com/apache/flink/pull/19366#discussion_r894761263
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java:
##
@@ -184,6 +184,18 @@
return
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned FLINK-27101:
Assignee: Jiale Tan
> Periodically break the chain of incremental checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Description:
h3. Background
The unit & integration tests for the aws connectors in the Flink
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Labels: (was: pull-request-available)
> Tests for AWS Connectors Using SDK v2 to use Synchronous
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Component/s: Connectors / Common
> Tests for AWS Connectors Using SDK v2 to use Synchronous Clients
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Affects Version/s: 1.15.0
1.15.1
1.15.2
> Tests for
Zichen Liu created FLINK-28007:
--
Summary: Tests for AWS Connectors Using SDK v2 to use Synchronous
Clients
Key: FLINK-28007
URL: https://issues.apache.org/jira/browse/FLINK-28007
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Priority: Minor (was: Major)
> Tests for AWS Connectors Using SDK v2 to use Synchronous Clients
>
flinkbot commented on PR #19935:
URL: https://github.com/apache/flink/pull/19935#issuecomment-1152536310
## CI report:
* 6e6751cbf94c00f35b023e2d945aaf76714ea3e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27884:
---
Labels: pull-request-available (was: )
> Introduce a flush mechanism for OutputFormats
>
echauchot opened a new pull request, #19935:
URL: https://github.com/apache/flink/pull/19935
## What is the purpose of the change
Move OutputFormatBase to flink-core to offer flush mechanism to all output
formats
## Brief change log
Move OutputFormatBase from
[
https://issues.apache.org/jira/browse/FLINK-27934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552830#comment-17552830
]
Frans King commented on FLINK-27934:
Pull request here with my changes -
[
https://issues.apache.org/jira/browse/FLINK-27934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27934:
---
Labels: pull-request-available (was: )
> Python API- Inefficient
fransking opened a new pull request, #315:
URL: https://github.com/apache/flink-statefun/pull/315
As per the JIRA in the Python SDK accessing a state variable multiple times
in a single function invocation or multiple times in sequency when many
function invocations are batched together is
wuchong commented on code in PR #19742:
URL: https://github.com/apache/flink/pull/19742#discussion_r894681266
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -1324,15 +1324,26 @@ void testCreateFunction() {
wuchong merged PR #19254:
URL: https://github.com/apache/flink/pull/19254
--
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-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27954:
-
Description:
The {{JobVertexFlameGraphHandler}} relies internally on the
[
https://issues.apache.org/jira/browse/FLINK-27972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-27972:
Assignee: Chesnay Schepler
> Race condition between task/savepoint notification
JingsongLi commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894603729
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r894608652
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainersConfig.java:
##
@@ -0,0 +1,599 @@
+/*
JingsongLi commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894605669
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/FileSystemCatalog.java:
##
@@ -0,0 +1,298 @@
+/*
+ * Licensed to the Apache
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
JingsongLi commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894604639
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalog.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the Apache
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
JingsongLi commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894603729
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
zentol commented on code in PR #19876:
URL: https://github.com/apache/flink/pull/19876#discussion_r894602361
##
flink-connectors/flink-connector-hive/pom.xml:
##
@@ -1024,9 +1024,25 @@ under the License.
-
luoyuxia commented on PR #19929:
URL: https://github.com/apache/flink/pull/19929#issuecomment-1152428093
@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.
alpinegizmo commented on PR #19833:
URL: https://github.com/apache/flink/pull/19833#issuecomment-1152418774
If they don't need to use the same naming scheme (but just happen to use the
same one), then I don't mind the duplication and wouldn't want to add the
dependency on table-common.
[
https://issues.apache.org/jira/browse/FLINK-27955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27955:
-
Fix Version/s: 1.16.0
> Fix the problem of windows installation failure in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-27933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552776#comment-17552776
]
Chesnay Schepler commented on FLINK-27933:
--
1.15: 0cd291ddae6581784e8d57e34fe3346607cb4f26
>
zentol merged PR #19930:
URL: https://github.com/apache/flink/pull/19930
--
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:
zentol commented on PR #19833:
URL: https://github.com/apache/flink/pull/19833#issuecomment-1152409972
That's a good question; they could definitely share it if we wanted to.
It would result in `table-code-splitter` having a new dependency on
`table-common` (presumably, if we move
gaborgsomogyi commented on code in PR #19933:
URL: https://github.com/apache/flink/pull/19933#discussion_r894579264
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityConfiguration.java:
##
@@ -138,25 +141,20 @@ public String getZooKeeperLoginContextName()
gaborgsomogyi commented on code in PR #19933:
URL: https://github.com/apache/flink/pull/19933#discussion_r894579264
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityConfiguration.java:
##
@@ -138,25 +141,20 @@ public String getZooKeeperLoginContextName()
gaborgsomogyi commented on PR #19825:
URL: https://github.com/apache/flink/pull/19825#issuecomment-1152406301
@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
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552772#comment-17552772
]
Chesnay Schepler commented on FLINK-15736:
--
[~jingge] No.
> Support Java 17 (LTS)
>
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Parent: (was: FLINK-27515)
Issue Type: New Feature (was: Sub-task)
> Submit compaction
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-27557.
-
Resolution: Won't Do
The impl has been refactored.
> Submit compaction when prepareCommit is triggered
[
https://issues.apache.org/jira/browse/FLINK-27707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27707:
--
Description:
As discussed offline, the new implementation has been modified.
* Don't perform a scan
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552765#comment-17552765
]
Jing Ge commented on FLINK-15736:
-
[~chesnay] do we have time schedule for resolving this ticket?
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894492796
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894339149
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
link3280 closed pull request #17320: [FLINK-24319][Tests] Fix invalid surefire
work directory for flink-tests
URL: https://github.com/apache/flink/pull/17320
--
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
link3280 commented on PR #17320:
URL: https://github.com/apache/flink/pull/17320#issuecomment-1152384164
OK, I'm closing this and will reopen it if necessary.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894339829
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894510200
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894510200
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
flinkbot commented on PR #19934:
URL: https://github.com/apache/flink/pull/19934#issuecomment-1152370787
## CI report:
* abdca0f3b9b75ed8e85ad913b491c31d95f21551 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28006:
---
Labels: pull-request-available (was: )
> Run architecture tests in single JVM
>
zentol opened a new pull request, #19934:
URL: https://github.com/apache/flink/pull/19934
The prod architecture tests use a surprising amount of memory. Since it's
difficult for us to really control that, let's run the whole thing in a single
JVM.
--
This is an automated message from
Chesnay Schepler created FLINK-28006:
Summary: Run architecture tests in single JVM
Key: FLINK-28006
URL: https://issues.apache.org/jira/browse/FLINK-28006
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-27975:
--
Assignee: Jeesmon Jacob
> Remove unnecessary RBAC rules from operator
>
[
https://issues.apache.org/jira/browse/FLINK-27975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552751#comment-17552751
]
Márton Balassi commented on FLINK-27975:
Sure, done.
> Remove unnecessary RBAC rules from
Chesnay Schepler created FLINK-28005:
Summary: Reduce network memory in UnalignedCheckpointITCase
Key: FLINK-28005
URL: https://issues.apache.org/jira/browse/FLINK-28005
Project: Flink
Chesnay Schepler created FLINK-28004:
Summary: Reduce CI heap space by 25%
Key: FLINK-28004
URL: https://issues.apache.org/jira/browse/FLINK-28004
Project: Flink
Issue Type: Technical
[
https://issues.apache.org/jira/browse/FLINK-27967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552748#comment-17552748
]
David Anderson commented on FLINK-27967:
[~vinay._.devadiga] You should expect to the find the
[
https://issues.apache.org/jira/browse/FLINK-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552742#comment-17552742
]
Martijn Visser commented on FLINK-27995:
Thanks for the input Jark and Lincoln!
> Upgrade
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894510200
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-27933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27933:
-
Summary: Savepoint status cannot be queried from standby jobmanager (was:
Savepoint
[
https://issues.apache.org/jira/browse/FLINK-27968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27968.
Resolution: Fixed
master: ca47e88a91ac28e962c9ac586bdcf983a36027d1
1.15.1:
zentol merged PR #19932:
URL: https://github.com/apache/flink/pull/19932
--
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:
zentol merged PR #19922:
URL: https://github.com/apache/flink/pull/19922
--
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-27995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552738#comment-17552738
]
lincoln lee commented on FLINK-27995:
-
Agree with Jark that try to bump up Janino separately.
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894339149
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
liujiawinds commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1152332374
@JingsongLi Could you help review this pr?
--
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
rkhachatryan commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r894476700
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java:
##
@@ -50,6 +56,9 @@ public class CheckpointsCleaner implements
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894492796
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalogFactory.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552732#comment-17552732
]
Alexis Sarda-Espinosa commented on FLINK-16686:
---
The reported problems were falling back
1996fanrui commented on PR #19499:
URL: https://github.com/apache/flink/pull/19499#issuecomment-1152319736
> @1996fanrui , Thanks for these changes. I have left a couple of minor
comments but in general, it looks good. I want to take some time to think about
how good the current tests are
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28003:
---
Description:
When I run the following sql in SqlClient using 'sql-client.sh -f zj_test.sql'
[ https://issues.apache.org/jira/browse/FLINK-28000 ]
Gabor Somogyi deleted comment on FLINK-28000:
---
was (Author: gaborgsomogyi):
Please see the parameter description
Jing Zhang created FLINK-28003:
--
Summary: 'pos ' field would be updated to 'POSITION' when use
SqlClient
Key: FLINK-28003
URL: https://issues.apache.org/jira/browse/FLINK-28003
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28003:
---
Description:
When I run the following sql in SqlClient when using 'sql-client.sh -f
zj_test.sql'
[
https://issues.apache.org/jira/browse/FLINK-28000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-28000:
--
Description:
Please see the parameter description
alpinegizmo commented on PR #19833:
URL: https://github.com/apache/flink/pull/19833#issuecomment-1152315518
Assuming the code generator and runtime need to agree on how the naming
works, why aren't they able to somehow share an implementation of this method?
--
This is an automated
flinkbot commented on PR #19933:
URL: https://github.com/apache/flink/pull/19933#issuecomment-1152315396
## CI report:
* 87e9d2ad0c76b8e5f356aec5d52c8d9a34f5f980 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1 - 100 of 288 matches
Mail list logo
