flinkbot edited a comment on pull request #18966:
URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962
## CI report:
* 3968c560b0057d50f6f5ab312320f3453915d015 Azure:
flinkbot commented on pull request #18966:
URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962
## CI report:
* 3968c560b0057d50f6f5ab312320f3453915d015 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* b737720f52bd34e5e9bde6e0e87f45098f8ad27d Azure:
[
https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500562#comment-17500562
]
Yun Gao commented on FLINK-25771:
-
Same for {{{}CassandraConnectorITCase.testScalingUp{}}}:
[
https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500560#comment-17500560
]
Yun Gao commented on FLINK-25813:
-
[
https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25813:
Labels: pull-request-available test-stability (was:
auto-deprioritized-critical pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500557#comment-17500557
]
Dawid Wysakowicz commented on FLINK-25256:
--
I don't have an opinion on a more explicit control
[
https://issues.apache.org/jira/browse/FLINK-26321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500559#comment-17500559
]
Yun Gao commented on FLINK-26321:
-
zoucao commented on pull request #18966:
URL: https://github.com/apache/flink/pull/18966#issuecomment-1057763421
cc @slinkydeveloper , Could you help me to find somebody to review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* b737720f52bd34e5e9bde6e0e87f45098f8ad27d Azure:
[
https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26422:
---
Labels: chinese-translation pull-request-available (was:
chinese-translation)
> Update
zoucao opened a new pull request #18966:
URL: https://github.com/apache/flink/pull/18966
…line docs
## What is the purpose of the change
- update chinese doc with the new TablePipeline docs
https://github.com/apache/flink/pull/18804.
## Brief
[
https://issues.apache.org/jira/browse/FLINK-26313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26313:
---
Labels: pull-request-available (was: )
> Support Streaming KMeans in Flink ML
>
yunfengzhou-hub opened a new pull request #70:
URL: https://github.com/apache/flink-ml/pull/70
## What is the purpose of the change
This PR adds Estimator and Transformer for the Streaming KMeans operator.
Compared with the existing KMeans operator, Streaming KMeans allows to
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* 9f3ccd717c3d292cefeb49da137d03afd2c6710c Azure:
echauchot commented on pull request #18610:
URL: https://github.com/apache/flink/pull/18610#issuecomment-1057757502
Hey @dmvk thanks !
--
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
JingsongLi merged pull request #32:
URL: https://github.com/apache/flink-table-store/pull/32
--
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-26313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunfeng Zhou updated FLINK-26313:
-
Summary: Support Streaming KMeans in Flink ML (was: Support Online KMeans
in Flink ML)
>
LadyForest commented on a change in pull request #32:
URL: https://github.com/apache/flink-table-store/pull/32#discussion_r818373831
##
File path:
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/TestFileStore.java
##
@@ -55,13 +55,15 @@
LadyForest commented on a change in pull request #32:
URL: https://github.com/apache/flink-table-store/pull/32#discussion_r818373831
##
File path:
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/TestFileStore.java
##
@@ -55,13 +55,15 @@
JingsongLi commented on a change in pull request #32:
URL: https://github.com/apache/flink-table-store/pull/32#discussion_r818372717
##
File path:
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/TestFileStore.java
##
@@ -55,13 +55,15 @@
[
https://issues.apache.org/jira/browse/FLINK-26346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26346:
---
Labels: pull-request-available (was: )
> Add statistics collecting to sst files
>
tsreaper opened a new pull request #33:
URL: https://github.com/apache/flink-table-store/pull/33
Currently field statistics are not collected in sst files. With statistics
we can do filter and other operations with better performance.
Some formats like orc already record statistics
LadyForest opened a new pull request #32:
URL: https://github.com/apache/flink-table-store/pull/32
# What is the purpose of the change
This PR tries to fix the `ClassCastException` thrown when
`StoreSinkWriter#writeToFileStore` encountered non-pk value. When a record has
no pk,
flinkbot edited a comment on pull request #18958:
URL: https://github.com/apache/flink/pull/18958#issuecomment-1056725576
## CI report:
* c833ce87dd2f24289efe7ad83cc476c0689a043c Azure:
flinkbot edited a comment on pull request #18964:
URL: https://github.com/apache/flink/pull/18964#issuecomment-1057523838
## CI report:
* 43531c4f9e06f8c8b2d3595971161f61ea3008c6 Azure:
igalshilman commented on a change in pull request #306:
URL: https://github.com/apache/flink-statefun/pull/306#discussion_r818360880
##
File path:
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/remote-module/module.yaml
##
@@ -16,5 +16,11 @@
kind:
igalshilman commented on a change in pull request #306:
URL: https://github.com/apache/flink-statefun/pull/306#discussion_r818359939
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java
##
@@ -208,4
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500532#comment-17500532
]
Yun Tang commented on FLINK-26179:
--
I don't think Flink community should support automatic savepoints
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* b737720f52bd34e5e9bde6e0e87f45098f8ad27d Azure:
dianfu commented on a change in pull request #18957:
URL: https://github.com/apache/flink/pull/18957#discussion_r818274208
##
File path:
flink-python/pyflink/fn_execution/datastream/window/window_assigner.py
##
@@ -0,0 +1,376 @@
+import math
+from typing import Iterable,
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* b737720f52bd34e5e9bde6e0e87f45098f8ad27d Azure:
hongshuboy edited a comment on pull request #18851:
URL: https://github.com/apache/flink/pull/18851#issuecomment-1057716786
@knaufk Copy that, should i create an improvement on [Flink’s
Jira](http://issues.apache.org/jira/browse/FLINK) ? Or commit to this branch
directly
--
This is an
hongshuboy commented on pull request #18851:
URL: https://github.com/apache/flink/pull/18851#issuecomment-1057716786
@knaufk Coty that, should i create an improvement on [Flink’s
Jira](http://issues.apache.org/jira/browse/FLINK) ? Or commit to this branch
directly
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-26247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-26247.
Resolution: Fixed
master: 57134d35fdd7bf3db1fd5048207fc4bacf198667
> Introduce a better expire
[
https://issues.apache.org/jira/browse/FLINK-26399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26399.
--
Resolution: Fixed
Merged: 43e171627e5cf47a866958c1e88b5c182b686802
> Make some option of operator
JingsongLi merged pull request #30:
URL: https://github.com/apache/flink-table-store/pull/30
--
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-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500521#comment-17500521
]
Liu commented on FLINK-26416:
-
[~fpaul] Thanks. I would like to test it after the blocker finishes.
>
KarmaGYZ closed pull request #18959:
URL: https://github.com/apache/flink/pull/18959
--
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:
Jingsong Lee created FLINK-26458:
Summary: Rename Accumulator to MergeFunction
Key: FLINK-26458
URL: https://issues.apache.org/jira/browse/FLINK-26458
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-26457:
Summary: Introduce Join Accumulator for Wide table
Key: FLINK-26457
URL: https://issues.apache.org/jira/browse/FLINK-26457
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-26452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hjw updated FLINK-26452:
Description:
~/.kube/config
apiVersion:v1
kind:config
cluster:
-name: "yf-dev-cluster1"
cluster:
server:
flinkbot edited a comment on pull request #18965:
URL: https://github.com/apache/flink/pull/18965#issuecomment-1057611030
## CI report:
* 868aa2c455dd900823290ba207edf2ef81c7d2d5 Azure:
flinkbot edited a comment on pull request #18965:
URL: https://github.com/apache/flink/pull/18965#issuecomment-1057611030
## CI report:
* 868aa2c455dd900823290ba207edf2ef81c7d2d5 Azure:
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* 1cfecf5bdb46f6431f758fb299585a2b1ce4fcd7 Azure:
PatrickRen commented on pull request #18965:
URL: https://github.com/apache/flink/pull/18965#issuecomment-1057664371
Thanks @leonardBang for the review! I made another push just now. Please
have a look when you are available.
--
This is an automated message from the Apache Git Service.
flinkbot edited a comment on pull request #18838:
URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081
## CI report:
* 1cfecf5bdb46f6431f758fb299585a2b1ce4fcd7 Azure:
PatrickRen commented on a change in pull request #18965:
URL: https://github.com/apache/flink/pull/18965#discussion_r818310017
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
##
@@
PatrickRen commented on a change in pull request #18965:
URL: https://github.com/apache/flink/pull/18965#discussion_r818308240
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
##
@@
PatrickRen commented on pull request #18863:
URL: https://github.com/apache/flink/pull/18863#issuecomment-1057658378
Thanks for the update @shizhengchao ! I think we can preserve your initial
implementation of FlinkKafkaPartitioner to resolve the issue caused by
KAFKA-9965.
--
This is
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500489#comment-17500489
]
Qingsheng Ren commented on FLINK-26033:
---
Thanks [~tinny] for the explanation. I think this is
[
https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500488#comment-17500488
]
lincoln lee commented on FLINK-26408:
-
Agree with [~lzljs3620320] that it should be lenient for this
flinkbot edited a comment on pull request #18224:
URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830
## CI report:
* 26a4a291a18a03a7c5819c528b914ae2a95cd5bf Azure:
flinkbot edited a comment on pull request #18224:
URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830
## CI report:
* 26a4a291a18a03a7c5819c528b914ae2a95cd5bf Azure:
leonardBang commented on a change in pull request #18965:
URL: https://github.com/apache/flink/pull/18965#discussion_r818288213
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
##
@@
FilKarnicki commented on a change in pull request #306:
URL: https://github.com/apache/flink-statefun/pull/306#discussion_r818294287
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyClient.java
##
@@ -208,4
[
https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500484#comment-17500484
]
Yang Wang commented on FLINK-26179:
---
I hesitate to introduce this feature in the K8s operator since
FilKarnicki commented on a change in pull request #306:
URL: https://github.com/apache/flink-statefun/pull/306#discussion_r818290846
##
File path:
statefun-e2e-tests/statefun-smoke-e2e-java/src/test/resources/remote-module/module.yaml
##
@@ -16,5 +16,11 @@
kind:
[
https://issues.apache.org/jira/browse/FLINK-26403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-26403.
---
Fix Version/s: 1.15.0
Resolution: Fixed
> SinkWriter should emit all the pending committables on
[
https://issues.apache.org/jira/browse/FLINK-26403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500482#comment-17500482
]
Yun Gao commented on FLINK-26403:
-
Fix on master via 2c9d64e34cfd3025c87c1d3bbd2d1b596df11691.
>
gaoyunhaii closed pull request #18938:
URL: https://github.com/apache/flink/pull/18938
--
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-26447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26447:
---
Labels: pull-request-available (was: )
> Clean up webhook jar and dependency management
>
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500479#comment-17500479
]
shizhengchao edited comment on FLINK-26033 at 3/3/22, 3:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500479#comment-17500479
]
shizhengchao commented on FLINK-26033:
--
[~MartijnVisser] [~renqs] I got through testing that the
[
https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500475#comment-17500475
]
Yang Wang commented on FLINK-26454:
---
It seems that the MDC is a good solution. But I am not sure
igalshilman commented on a change in pull request #306:
URL: https://github.com/apache/flink-statefun/pull/306#discussion_r818262446
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/nettyclient/NettyRequestReplySpec.java
##
flinkbot edited a comment on pull request #18938:
URL: https://github.com/apache/flink/pull/18938#issuecomment-1055248048
## CI report:
* 6be86f37386c6962e3fbb6e7c2d7c506f44db30d Azure:
shizhengchao commented on pull request #18863:
URL: https://github.com/apache/flink/pull/18863#issuecomment-1057622360
@PatrickRen I got through testing that the RoundRobinPartitioner built into
kafka does not work either, that is it can't distribute the writes to all
partitions equally,
[
https://issues.apache.org/jira/browse/FLINK-26431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500470#comment-17500470
]
Liu commented on FLINK-26431:
-
[~nsemmler] I have no access to the project you mentioned. But I build my
[
https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500468#comment-17500468
]
Jiangjie Qin commented on FLINK-25256:
--
[~dwysakowicz] Pravega essentially uses an in-band
flinkbot edited a comment on pull request #18965:
URL: https://github.com/apache/flink/pull/18965#issuecomment-1057611030
## CI report:
* 868aa2c455dd900823290ba207edf2ef81c7d2d5 Azure:
flinkbot commented on pull request #18965:
URL: https://github.com/apache/flink/pull/18965#issuecomment-1057611030
## CI report:
* 868aa2c455dd900823290ba207edf2ef81c7d2d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* b6268adf337f01f20e13f8edd6e67608bb7f1afb Azure:
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500466#comment-17500466
]
Zhu Zhu edited comment on FLINK-26400 at 3/3/22, 2:44 AM:
--
Here's what I see on
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500466#comment-17500466
]
Zhu Zhu commented on FLINK-26400:
-
Here's what I see on the page "Limited integration with Flink’s Web
flinkbot edited a comment on pull request #18655:
URL: https://github.com/apache/flink/pull/18655#issuecomment-1032265310
## CI report:
* b6268adf337f01f20e13f8edd6e67608bb7f1afb Azure:
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26400:
Attachment: errors_on_opening_job_page_when_job_gets_no_resources.png
> Release Testing: Explicit
[
https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-26435.
-
Resolution: Fixed
Fixed via:
main: 47f02cb7e0318dee16d321c91867b9a94337b9da
> Provide the container
PatrickRen opened a new pull request #18965:
URL: https://github.com/apache/flink/pull/18965
## What is the purpose of the change
This pull request fixes a flaky broker failure test that should use
multi-broker cluster for replicating partitions during the test run.
##
[
https://issues.apache.org/jira/browse/FLINK-26447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-26447:
-
Assignee: Nicholas Jiang (was: Yang Wang)
> Clean up webhook jar and dependency management
>
[
https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-26444:
Fix Version/s: 1.16.0
> Window allocator supporting pyflink datastream API
>
[
https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-26444:
---
Assignee: zhangjingcun
> Window allocator supporting pyflink datastream API
>
[
https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-25152.
Resolution: Fixed
> FLIP-188: Introduce Built-in Dynamic Table Storage
>
[
https://issues.apache.org/jira/browse/FLINK-26293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-26293:
Assignee: Nicholas Jiang
> Store log offsets in snapshot
> -
JingsongLi commented on a change in pull request #31:
URL: https://github.com/apache/flink-table-store/pull/31#discussion_r818263016
##
File path:
flink-table-store-core/src/test/java/org/apache/flink/table/store/file/operation/FileStoreCommitTest.java
##
@@ -150,9 +150,12 @@
JingsongLi commented on a change in pull request #31:
URL: https://github.com/apache/flink-table-store/pull/31#discussion_r818260657
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java
##
@@ -276,7 +273,7 @@
JingsongLi commented on a change in pull request #31:
URL: https://github.com/apache/flink-table-store/pull/31#discussion_r818260224
##
File path:
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java
##
@@ -304,10 +301,17
[
https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500462#comment-17500462
]
zlzhang0122 commented on FLINK-25068:
-
[~airblader] can you help to review the pr?
> Show the
flinkbot edited a comment on pull request #18938:
URL: https://github.com/apache/flink/pull/18938#issuecomment-1055248048
## CI report:
* 6be86f37386c6962e3fbb6e7c2d7c506f44db30d Azure:
flinkbot edited a comment on pull request #18938:
URL: https://github.com/apache/flink/pull/18938#issuecomment-1055248048
## CI report:
* 6be86f37386c6962e3fbb6e7c2d7c506f44db30d Azure:
[
https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500460#comment-17500460
]
xinchenyuan commented on FLINK-26424:
-
:)Hope to get a conclusion desperately.
online serving
gaoyunhaii commented on pull request #18938:
URL: https://github.com/apache/flink/pull/18938#issuecomment-1057588616
@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
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500459#comment-17500459
]
Yuan Zhu commented on FLINK-26437:
--
In my local env(wsl-ubuntu-20.04), I can run "sql-client.sh
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Zhu updated FLINK-26437:
-
Attachment: image-2022-03-03-10-03-50-763.png
> Cannot discover a connector using option:
[
https://issues.apache.org/jira/browse/FLINK-26447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-26447:
-
Assignee: Yang Wang
> Clean up webhook jar and dependency management
>
Huang Xingbo created FLINK-26456:
Summary: StreamExecutionEnvironmentTests::test_add_python_file
failed with ModuleNotFoundError
Key: FLINK-26456
URL: https://issues.apache.org/jira/browse/FLINK-26456
KarmaGYZ commented on pull request #18959:
URL: https://github.com/apache/flink/pull/18959#issuecomment-1057583820
@xintongsong
--
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
rkhachatryan commented on pull request #18224:
URL: https://github.com/apache/flink/pull/18224#issuecomment-1057580942
One more thing, can production (DFS-based) changelog implementation be used
in this test?
(`FsStateChangelogStorageFactory.configure`)
--
This is an automated
rkhachatryan commented on a change in pull request #18224:
URL: https://github.com/apache/flink/pull/18224#discussion_r818237157
##
File path:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java
##
@@ -0,0 +1,206 @@
+/*
+
rkhachatryan commented on a change in pull request #18224:
URL: https://github.com/apache/flink/pull/18224#discussion_r818232919
##
File path:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationRescaleITCase.java
##
@@ -0,0 +1,129 @@
1 - 100 of 479 matches
Mail list logo
