[
https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29098:
-
Fix Version/s: table-store-0.2.1
> StoreWriteOperator#prepareCommit should let logSinkFunction
[
https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17596979#comment-17596979
]
Jingsong Lee edited comment on FLINK-29098 at 9/24/22 2:38 AM:
---
master:
SteNicholas commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r979133150
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value,
SteNicholas commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r979133150
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value,
SteNicholas commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r979133150
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value,
SteNicholas commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r979133150
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value,
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979107588
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -878,7 +879,8 @@ public CompletableFuture triggerSavepoint(
}
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979107588
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -878,7 +879,8 @@ public CompletableFuture triggerSavepoint(
}
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979072658
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointBackupType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
pnowojski commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979065292
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointBackupType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979055803
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -878,7 +879,8 @@ public CompletableFuture triggerSavepoint(
}
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979042504
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointTriggerHandlers.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979038031
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java:
##
@@ -39,30 +40,66 @@ public class
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979033459
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -853,6 +855,12 @@ public CompletableFuture
requestJob(Time timeout) {
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979032943
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -863,11 +871,6 @@ public CompletableFuture triggerSavepoint(
return
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979031935
##
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java:
##
@@ -39,30 +40,66 @@ public class
stevenzwu commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r979025202
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -511,6 +514,45 @@ public CompletableFuture
flinkbot commented on PR #20893:
URL: https://github.com/apache/flink/pull/20893#issuecomment-1256555052
## CI report:
* 2c7d41b3202605d407993c12fec8aa85e8aa22ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r978975202
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value,
[
https://issues.apache.org/jira/browse/FLINK-29403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29403:
---
Labels: pull-request-available (was: )
> Streamline SimpleCondition usage
>
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
[
https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608885#comment-17608885
]
Robert Metzger commented on FLINK-26999:
Is the idea for this ticket to use an existing
[
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
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:
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 6:41 PM:
---
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.
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)
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)
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
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 4:40 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608814#comment-17608814
]
Matthias Pohl commented on FLINK-29396:
---
I guess, you have a point here. Initially, I thought that
[
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:
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:
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
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:
[
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:
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 @@
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_r978758053
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/table/SetOperatorsTest.xml:
##
@@ -99,13 +99,13 @@
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.
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:
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-28890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608559#comment-17608559
]
Qingsheng Ren edited comment on FLINK-28890 at 9/23/22 2:35 PM:
Fixed 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:
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
[
https://issues.apache.org/jira/browse/FLINK-29093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608780#comment-17608780
]
Qingsheng Ren commented on FLINK-29093:
---
Fixed on master: 340b100f2de5e0d90ba475aa8a00e359a61442ce
[
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
[
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
>
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:
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
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:
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
[
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=17608778#comment-17608778
]
Gyula Fora commented on FLINK-29391:
you can use the following built in Flink configs:
[
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
[
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
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:
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608751#comment-17608751
]
Gyula Fora commented on FLINK-27893:
Ah I did not realize that this was a duplicate. Closing
> Add
[
https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608750#comment-17608750
]
Jeesmon Jacob commented on FLINK-27893:
---
[~gyfora] Can we mark this as closed based on
[
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-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
[
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
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608738#comment-17608738
]
Jiabao Sun commented on FLINK-6573:
---
Hi there,
The discussion thread was opened on
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-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 1:13 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608729#comment-17608729
]
Chesnay Schepler edited comment on FLINK-29315 at 9/23/22 1:09 PM:
---
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
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 {
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
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608729#comment-17608729
]
Chesnay Schepler commented on FLINK-29315:
--
Experiment results:
- test fails when using a
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
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])
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_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_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],
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
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],
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608699#comment-17608699
]
Qingsheng Ren commented on FLINK-29398:
---
Thanks for starting the discussion [~jeremy.degroot] !
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
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
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
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) {
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
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
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
[
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
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:
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;
+### 已弃用的配置
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607600#comment-17607600
]
Claude Warren edited comment on FLINK-29281 at 9/23/22 9:07 AM:
I am
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
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
1 - 100 of 146 matches
Mail list logo
