[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608582#comment-17608582
]
Martijn Visser commented on FLINK-29398:
[~renqs] What do you think?
> Utilize
gyfora merged PR #375:
URL: https://github.com/apache/flink-kubernetes-operator/pull/375
--
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
zjureel commented on PR #300:
URL:
https://github.com/apache/flink-table-store/pull/300#issuecomment-1255863925
Hi @JingsongLi @SteNicholas I have updated the codes, thanks
To @JingsongLi I have tried to decrease memory buffers in
`WritePreemptMemoryTest. createFileStoreTable`. Unfo
[
https://issues.apache.org/jira/browse/FLINK-29327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29327.
--
Resolution: Fixed
merged to main 7f7b77cc434e6c2b67071404c5c0a8c0a28e36db
> Operator configs are show
[
https://issues.apache.org/jira/browse/FLINK-29382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29382.
--
Resolution: Cannot Reproduce
> Flink fails to start when created using quick guide for flink operator
fsk119 commented on PR #20887:
URL: https://github.com/apache/flink/pull/20887#issuecomment-1255870285
Thanks for your review. Because the comment is not releated to the code, I
will this offline.
--
This is an automated message from the Apache Git Service.
To respond to the messa
fsk119 commented on PR #20887:
URL: https://github.com/apache/flink/pull/20887#issuecomment-1255870612
The failed test is not releated to the fix. Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608591#comment-17608591
]
Huang Xingbo commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608593#comment-17608593
]
Huang Xingbo commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
fsk119 closed pull request #20887: [FLINK-29274][hive] Fix ObjectStore leak
when different users has dif…
URL: https://github.com/apache/flink/pull/20887
--
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-29274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608598#comment-17608598
]
Shengkai Fang commented on FLINK-29274:
---
Merged into release-1.16: c653d162f224b8b
[
https://issues.apache.org/jira/browse/FLINK-29274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29274:
-
Assignee: Shengkai Fang (was: yuzelin)
> HiveServer2EndpointITCase.testGetFunctionWith
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608605#comment-17608605
]
Chesnay Schepler commented on FLINK-29315:
--
I'm -1 on adding some bespoke {{ls}
fsk119 opened a new pull request, #20891:
URL: https://github.com/apache/flink/pull/20891
…ferent config
## What is the purpose of the change
Cheery pick the fix #20887
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
flinkbot commented on PR #20891:
URL: https://github.com/apache/flink/pull/20891#issuecomment-1255894455
## CI report:
* 395f8780fc90b8963c9425c53309a7a19d0d77f5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on PR #20870:
URL: https://github.com/apache/flink/pull/20870#issuecomment-1255916874
I moved the diagrams into it's own repository under `XComp/flink-diagrams`
(with Github Actions support on the SVG generation). Feel free to propose a
change there if you're still keen to e
gaborgsomogyi commented on code in PR #20875:
URL: https://github.com/apache/flink/pull/20875#discussion_r978376452
##
flink-runtime-web/web-dashboard/src/app/app.interceptor.ts:
##
@@ -39,6 +46,16 @@ export class AppInterceptor implements HttpInterceptor {
return next.ha
gaborgsomogyi commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1255919386
I presume a rebase to the latest master is needed since second time the
following error arrived:
```
Sep 22 08:19:47 Suppressed: java.lang.AssertionError: Test failed Erro
[
https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608622#comment-17608622
]
Dian Fu commented on FLINK-28786:
-
[~lemonjing] Hi, could you provide more information?
lindong28 commented on code in PR #157:
URL: https://github.com/apache/flink-ml/pull/157#discussion_r978349873
##
flink-ml-python/pyflink/ml/lib/clustering/tests/test_agglomerativeclustering.py:
##
@@ -157,6 +163,30 @@ def test_transform(self):
self.verify_clustering_r
afedulov commented on PR #20865:
URL: https://github.com/apache/flink/pull/20865#issuecomment-1255953839
@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
dannycranmer commented on code in PR #20876:
URL: https://github.com/apache/flink/pull/20876#discussion_r978417586
##
docs/content.zh/docs/connectors/table/kinesis.md:
##
@@ -776,7 +776,7 @@ You can enable and configure EFO with the following
properties:
This is the prefer
[
https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607600#comment-17607600
]
Claude Warren edited comment on FLINK-29281 at 9/23/22 9:07 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-24296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24296:
---
Component/s: Connectors / Google Cloud PubSub
> [Umbrella] Refactor Google PubSub to new Sou
[
https://issues.apache.org/jira/browse/FLINK-24296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24296:
---
Summary: [Umbrella] Refactor Google PubSub to new Source/Sink interfaces
(was: Refactor Goo
lsyldliu commented on code in PR #20884:
URL: https://github.com/apache/flink/pull/20884#discussion_r978427558
##
docs/content.zh/docs/connectors/table/jdbc.md:
##
@@ -263,6 +279,47 @@ ON myTopic.key = MyUserTable.id;
+### 已弃用的配置
+这些弃用配置已经被上述的新配置代替，而且最终会被弃用。请优先考虑使用新配置。
zentol merged PR #20870:
URL: https://github.com/apache/flink/pull/20870
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-29375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29375.
Resolution: Fixed
master: 0154de9edb44b565e9b9cba614f42e7adae3a953
> Move getSelfGateway
Tartarus0zm commented on PR #20653:
URL: https://github.com/apache/flink/pull/20653#issuecomment-1256004961
@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
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r978475159
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java:
##
@@ -21,11 +21,31 @@
import org.apache.flink.ml.common.param.Ha
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r978475159
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssemblerParams.java:
##
@@ -21,11 +21,31 @@
import org.apache.flink.ml.common.param.Ha
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r978481060
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java:
##
@@ -74,38 +74,65 @@ public Table[] transform(Table... inputs) {
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978511255
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -1950,6 +1950,38 @@ void testCreateTableAsSelectWithPartit
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978511413
##
flink-table/flink-sql-parser-hive/src/test/java/org/apache/flink/sql/parser/hive/FlinkHiveSqlParserImplTest.java:
##
@@ -560,4 +560,36 @@ void testExplainUpsert() {
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978511413
##
flink-table/flink-sql-parser-hive/src/test/java/org/apache/flink/sql/parser/hive/FlinkHiveSqlParserImplTest.java:
##
@@ -560,4 +560,36 @@ void testExplainUpsert() {
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978511255
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -1950,6 +1950,38 @@ void testCreateTableAsSelectWithPartit
gyfora commented on PR #379:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/379#issuecomment-1256070218
Please rebase before we can merge this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608699#comment-17608699
]
Qingsheng Ren commented on FLINK-29398:
---
Thanks for starting the discussion [~jere
avocadomaster commented on PR #379:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/379#issuecomment-1256084073
> Please rebase before we can merge this
Rebased ✅
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
SteNicholas commented on code in PR #300:
URL: https://github.com/apache/flink-table-store/pull/300#discussion_r978544844
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/memory/sort/BinaryInMemorySortBuffer.java:
##
@@ -0,0 +1,237 @@
+/*
+ * Licensed to
SteNicholas commented on code in PR #300:
URL: https://github.com/apache/flink-table-store/pull/300#discussion_r978544844
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/memory/sort/BinaryInMemorySortBuffer.java:
##
@@ -0,0 +1,237 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978583021
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/CalcTest.xml:
##
@@ -279,7 +279,7 @@ LogicalProject(a=[$0], b=[$1],
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978583509
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/CalcTest.xml:
##
@@ -361,13 +361,13 @@ Calc(select=[a, (b + 1) AS E
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978587112
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/CalcTest.xml:
##
@@ -262,7 +262,7 @@ LogicalProject(a=[$0], b=[$1]
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978587582
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/CalcTest.xml:
##
@@ -344,13 +344,13 @@ Calc(select=[a, (b + 1) AS
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978592501
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/table/JoinTest.xml:
##
@@ -84,15 +84,15 @@ Calc(select=[a, b, d, e])
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978592824
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/table/JoinTest.xml:
##
@@ -84,15 +84,15 @@ Calc(select=[a, b, d, e])
Gyula Fora created FLINK-29401:
--
Summary: Improve observer structure
Key: FLINK-29401
URL: https://issues.apache.org/jira/browse/FLINK-29401
Project: Flink
Issue Type: Improvement
Comp
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608729#comment-17608729
]
Chesnay Schepler commented on FLINK-29315:
--
Experiment results:
- test fails wh
zentol commented on PR #20867:
URL: https://github.com/apache/flink/pull/20867#issuecomment-1256170114
Added a test, which found a few more violations.
--
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 g
zentol commented on code in PR #20867:
URL: https://github.com/apache/flink/pull/20867#discussion_r978603305
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java:
##
@@ -269,9 +269,10 @@ public class KubernetesConfigOptions {
afedulov commented on code in PR #20876:
URL: https://github.com/apache/flink/pull/20876#discussion_r978609413
##
docs/content.zh/docs/connectors/table/kinesis.md:
##
@@ -776,7 +776,7 @@ You can enable and configure EFO with the following
properties:
This is the preferred
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 1:09 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 1:13 PM:
---
twalthr closed pull request #20840: [FLINK-29309][streaming-java] Relax
allow-client-job-configurations for Table API and parameters
URL: https://github.com/apache/flink/pull/20840
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608738#comment-17608738
]
Jiabao Sun commented on FLINK-6573:
---
Hi there,
The discussion thread was opened on
[h
[
https://issues.apache.org/jira/browse/FLINK-29254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-29254:
--
Turns out this isn't actually that difficult.
> RpcGateway should have some form of Close
[
https://issues.apache.org/jira/browse/FLINK-29254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29254:
-
Parent: FLINK-29281
Issue Type: Sub-task (was: Technical Debt)
> RpcGateway sho
[
https://issues.apache.org/jira/browse/FLINK-29230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29230.
Resolution: Fixed
> Publish blogpost about the Akka license change
> -
[
https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608750#comment-17608750
]
Jeesmon Jacob commented on FLINK-27893:
---
[~gyfora] Can we mark this as closed base
[
https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608751#comment-17608751
]
Gyula Fora commented on FLINK-27893:
Ah I did not realize that this was a duplicate.
[
https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-27893.
--
Resolution: Duplicate
duplicate of FLINK-29383
> Add additionalPrinterColumns for Job Status and Reco
Donatien created FLINK-29402:
Summary: Add USE_DIRECT_READ configuration parameter for RocksDB
Key: FLINK-29402
URL: https://issues.apache.org/jira/browse/FLINK-29402
Project: Flink
Issue Type: I
gyfora merged PR #379:
URL: https://github.com/apache/flink-kubernetes-operator/pull/379
--
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
[
https://issues.apache.org/jira/browse/FLINK-29388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29388.
--
Resolution: Fixed
merged to main e2b829c7df7501760dec8f9aa47685c680b227cf
> Fix args in JobSpec not b
[
https://issues.apache.org/jira/browse/FLINK-29392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29392:
---
Fix Version/s: kubernetes-operator-1.2.0
> SessionJobs are lost when Session FlinkDeployment is upgr
[
https://issues.apache.org/jira/browse/FLINK-29391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29391.
--
Resolution: Not A Problem
> Add option to set labels and annotations in kubernetes deployment
> --
[
https://issues.apache.org/jira/browse/FLINK-29391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608778#comment-17608778
]
Gyula Fora commented on FLINK-29391:
you can use the following built in Flink config
PatrickRen commented on PR #20734:
URL: https://github.com/apache/flink/pull/20734#issuecomment-1256286903
The CI failed because of an unrelated issue FLINK-29315. Merging to master
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
PatrickRen merged PR #20734:
URL: https://github.com/apache/flink/pull/20734
--
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.ap
PatrickRen commented on PR #20890:
URL: https://github.com/apache/flink/pull/20890#issuecomment-1256289693
The CI failed because of an unrelated issue FLINK-29315. Merging to
release-1.16
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
PatrickRen merged PR #20890:
URL: https://github.com/apache/flink/pull/20890
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29093.
-
Resolution: Fixed
> LookupJoinITCase failed with InternalCompilerException
> ---
[
https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29093:
-
Assignee: Alexander Smirnov (was: Qingsheng Ren)
> LookupJoinITCase failed with Intern
[
https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608780#comment-17608780
]
Qingsheng Ren commented on FLINK-29093:
---
Fixed on master: 340b100f2de5e0d90ba475aa
PatrickRen commented on PR #20889:
URL: https://github.com/apache/flink/pull/20889#issuecomment-1256296543
The CI failed because of an unrelated issue FLINK-29315. Merging to
release-1.16
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
PatrickRen merged PR #20889:
URL: https://github.com/apache/flink/pull/20889
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-28890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608559#comment-17608559
]
Qingsheng Ren edited comment on FLINK-28890 at 9/23/22 2:35 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-28890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-28890.
-
Resolution: Fixed
> Incorrect semantic of latestLoadTime in CachingLookupFunction and
> Caching
PatrickRen merged PR #20884:
URL: https://github.com/apache/flink/pull/20884
--
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.ap
PatrickRen opened a new pull request, #20892:
URL: https://github.com/apache/flink/pull/20892
Unchanged backport of #20884
--
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_r978758053
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/table/SetOperatorsTest.xml:
##
@@ -99,13 +99,13 @@ HashJoin(joinType=[L
flinkbot commented on PR #20892:
URL: https://github.com/apache/flink/pull/20892#issuecomment-1256318703
## CI report:
* 01500feb824aee4a12ffbadc00540eee5e6e5c5b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #20850:
URL: https://github.com/apache/flink/pull/20850#discussion_r978763440
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/JoinTest.xml:
##
@@ -72,17 +72,17 @@ Join(joinType=[InnerJoin
[
https://issues.apache.org/jira/browse/FLINK-29309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-29309.
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master: 298b88842025da9ae218b598c1213f7238
dannycranmer merged PR #20876:
URL: https://github.com/apache/flink/pull/20876
--
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.
JingsongLi commented on PR #300:
URL:
https://github.com/apache/flink-table-store/pull/300#issuecomment-1256357112
> To @JingsongLi I have tried to decrease memory buffers in
WritePreemptMemoryTest. createFileStoreTable. Unfortunately, it causes
java.lang.RuntimeException: File deletion co
JingsongLi merged PR #300:
URL: https://github.com/apache/flink-table-store/pull/300
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-29276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29276.
Fix Version/s: table-store-0.2.1
Resolution: Fixed
master: 04418793c67d196b4056c5cb6730eb3e
[
https://issues.apache.org/jira/browse/FLINK-29396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608814#comment-17608814
]
Matthias Pohl commented on FLINK-29396:
---
I guess, you have a point here. Initially
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 4:40 PM:
---
reta opened a new pull request, #1:
URL: https://github.com/apache/flink-connector-opensearch/pull/1
Signed-off-by: Andriy Redko
## What is the purpose of the change
The goal of this change is to provide dedicated Opensearch connectors.
## Brief change log
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r978880123
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointBackupType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r978880123
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointBackupType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
ericxiao251 commented on PR #19983:
URL: https://github.com/apache/flink/pull/19983#issuecomment-1256536753
Hi @lincoln-lil, how would one use the retry strategies in their scala flink
pipelines? we noticed that the retry strategy builder classes were only exposed
in the java codebase.
--
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 6:41 PM:
---
Chesnay Schepler created FLINK-29403:
Summary: Streamline SimpleCondition usage
Key: FLINK-29403
URL: https://issues.apache.org/jira/browse/FLINK-29403
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-29403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29403:
-
Description:
CEP SimpleCondition are essentially filter functions, but since it's an
ab
[
https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608885#comment-17608885
]
Robert Metzger commented on FLINK-26999:
Is the idea for this ticket to use an e
zentol opened a new pull request, #20893:
URL: https://github.com/apache/flink/pull/20893
Add `SimpleCondition.of(FilterFunction)` and adjust all tests and docs
accordingly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
1 - 100 of 121 matches
Mail list logo
