[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Trigger compaction when prepareCommit is triggered (was: Let
FileStoreWrite accept
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Submit compaction when prepareCommit is triggered (was: Trigger
compaction when
Alexander Preuss created FLINK-27779:
Summary: Connectors should not depend on `flink-table-planner`
Key: FLINK-27779
URL: https://issues.apache.org/jira/browse/FLINK-27779
Project: Flink
rkhachatryan commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r881739752
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java:
##
@@ -50,6 +54,9 @@ public class CheckpointsCleaner implements
Alexander Preuss created FLINK-27780:
Summary: Connector-cassandra should not depend on
`flink-table-planner`
Key: FLINK-27780
URL: https://issues.apache.org/jira/browse/FLINK-27780
Project:
Alexander Preuss created FLINK-27781:
Summary: Connector-kafka should not depend on `flink-table-planner`
Key: FLINK-27781
URL: https://issues.apache.org/jira/browse/FLINK-27781
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss reassigned FLINK-27779:
Assignee: Alexander Preuss
> Connectors should not depend on
morhidi commented on code in PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#discussion_r881784524
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -618,32 +623,51 @@ public
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description:
Currently, FileStoreWrite will scan and plan files when creating a non-empty
writer. We
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27557:
---
Labels: pull-request-available (was: )
> Submit compaction when prepareCommit is triggered
LadyForest opened a new pull request, #139:
URL: https://github.com/apache/flink-table-store/pull/139
Currently, `FileStoreWrite` will scan and plan files when creating a
non-empty writer. We should also create a non-empty writer for non-rescale
compaction cases but instead use the
zentol merged PR #19792:
URL: https://github.com/apache/flink/pull/19792
--
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-27740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27740.
Fix Version/s: 1.16.0
Assignee: Sergey Nuyanzin
Resolution: Fixed
master:
Alexander Preuss created FLINK-27782:
Summary: Connector-kinesis should not depend on
`flink-table-planner`
Key: FLINK-27782
URL: https://issues.apache.org/jira/browse/FLINK-27782
Project: Flink
Alexander Preuss created FLINK-27784:
Summary: Connector-jdbc should not depend on `flink-table-planner`
Key: FLINK-27784
URL: https://issues.apache.org/jira/browse/FLINK-27784
Project: Flink
Alexander Preuss created FLINK-27785:
Summary: Connector-hbase should not depend on `flink-table-planner`
Key: FLINK-27785
URL: https://issues.apache.org/jira/browse/FLINK-27785
Project: Flink
Alexander Preuss created FLINK-27783:
Summary: Connector-aws-kinesis should not depend on
`flink-table-planner`
Key: FLINK-27783
URL: https://issues.apache.org/jira/browse/FLINK-27783
Project:
[
https://issues.apache.org/jira/browse/FLINK-27781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27781:
-
Component/s: Connectors / Kafka
> Connector-kafka should not depend on
[
https://issues.apache.org/jira/browse/FLINK-27784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27784:
-
Component/s: Connectors / JDBC
> Connector-jdbc should not depend on
[
https://issues.apache.org/jira/browse/FLINK-27784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27784:
-
Priority: Minor (was: Major)
> Connector-jdbc should not depend on
rkhachatryan commented on code in PR #19819:
URL: https://github.com/apache/flink/pull/19819#discussion_r881765652
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/TestJobExecutor.java:
##
@@ -77,28 +77,28 @@ private TestJobExecutor(
public static
Alexander Preuss created FLINK-27786:
Summary: Connector-hive should not depend on `flink-table-planner`
Key: FLINK-27786
URL: https://issues.apache.org/jira/browse/FLINK-27786
Project: Flink
SteNicholas commented on code in PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#discussion_r881766813
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -618,32 +623,51 @@ public
[
https://issues.apache.org/jira/browse/FLINK-27787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephen Patel updated FLINK-27787:
--
Description:
I think I've found a bug with new task restoration from savepoints.
I have some
Stephen Patel created FLINK-27787:
-
Summary: New tasks think they've been restored from savepoint
(even when they weren't present in that savepoint)
Key: FLINK-27787
URL:
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r881847122
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java:
##
@@ -57,13 +63,30 @@ public interface SharedStateRegistry extends AutoCloseable
Sxnan commented on PR #19653:
URL: https://github.com/apache/flink/pull/19653#issuecomment-1137495948
@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.
Jaganathan Asokan created FLINK-27788:
-
Summary: Adding annotation to k8 operator Pod
Key: FLINK-27788
URL: https://issues.apache.org/jira/browse/FLINK-27788
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Attachment: 167908239-c6f3f0ad-af06-436f-87e2-85c60428b400.png
> The primary key obtained from MySQL is
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
rovboyko commented on PR #19648:
URL: https://github.com/apache/flink/pull/19648#issuecomment-1138154479
Hi Timo @twalthr !
I've rewritten the solution according to your idea to use the `generateCast`
method.
I had to change the `CodeGeneratorCastRule` to it be able to declare not
Zixuan Rao created FLINK-27796:
--
Summary: Document approaches to updating existing instances of
stateful functions
Key: FLINK-27796
URL: https://issues.apache.org/jira/browse/FLINK-27796
Project: Flink
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882251162
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -155,7 +155,7 @@ static Map
dependabot[bot] opened a new pull request, #32:
URL: https://github.com/apache/flink-statefun-playground/pull/32
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
dependabot[bot] opened a new pull request, #31:
URL: https://github.com/apache/flink-statefun-playground/pull/31
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqichen updated FLINK-27795:
--
Description:
i found a problem， when i try to insert null value.
i think it is very common to
curcur commented on PR #540:
URL: https://github.com/apache/flink-web/pull/540#issuecomment-1138164698
I do not have other questions & have accepted the blog post.
Please do not forget to rebuild the website before merging.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-27760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27760.
---
Fix Version/s: 1.13.7
1.14.5
1.16.0
1.15.1
[
https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Small Wong updated FLINK-2:
---
Description:
flink.version: 1.13
After set {*}table.exec.hive.fallback-mapred-writer=false{*},
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542311#comment-17542311
]
Huang Xingbo commented on FLINK-27667:
--
Huang Xingbo created FLINK-27792:
Summary: WindowDistinctAggregateITCase. testTumbleWindow_Rollup
failed with InterruptedException
Key: FLINK-27792
URL: https://issues.apache.org/jira/browse/FLINK-27792
[
https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542312#comment-17542312
]
Huang Xingbo commented on FLINK-26621:
--
[
https://issues.apache.org/jira/browse/FLINK-27788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27788:
-
Fix Version/s: (was: kubernetes-operator-0.1.0)
(was:
[
https://issues.apache.org/jira/browse/FLINK-27788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned FLINK-27788:
Assignee: Jaganathan Asokan
> Adding annotation to k8 operator Pod
>
dusukang created FLINK-27794:
Summary: The primary key obtained from MySQL is incorrect by using
MysqlCatalog
Key: FLINK-27794
URL: https://issues.apache.org/jira/browse/FLINK-27794
Project: Flink
curcur commented on code in PR #540:
URL: https://github.com/apache/flink-web/pull/540#discussion_r879488407
##
_posts/2022-05-20-changelog-state-backend.md:
##
@@ -0,0 +1,353 @@
+---
+layout: post
+title: "Improving speed and stability of checkpointing with generic log-based
liuzhuang2017 opened a new pull request, #19820:
URL: https://github.com/apache/flink/pull/19820
## What is the purpose of the change
- **This is the English document：**
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542309#comment-17542309
]
Xintong Song commented on FLINK-27721:
--
bq. Which server are we going to use for the archive?
I'd
[
https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542320#comment-17542320
]
Feifan Wang commented on FLINK-27734:
-
Hi [~junhany] ， can you help me confirm this problem ?
> Not
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqichen updated FLINK-27795:
--
Description:
Hello , I found a problem， when i try to insert null value.
i think it is very common
linqichen created FLINK-27795:
-
Summary: SqlValidatorException when insert null value
Key: FLINK-27795
URL: https://issues.apache.org/jira/browse/FLINK-27795
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The
dianfu closed pull request #19816: [FLINK-27760][python] Fix the issue that NPE
is thrown when executing PyFlink Table API jobs in batch mode
URL: https://github.com/apache/flink/pull/19816
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
fanrui created FLINK-27789:
--
Summary: LegacySource compatible with overdraft buffer
Key: FLINK-27789
URL: https://issues.apache.org/jira/browse/FLINK-27789
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-27790:
-
Summary: Move ADD/Remove Jar syntax code implementation from
SqlClient to TableEnvironment side
Key: FLINK-27790
URL: https://issues.apache.org/jira/browse/FLINK-27790
dependabot[bot] opened a new pull request, #30:
URL: https://github.com/apache/flink-statefun-playground/pull/30
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
Huang Xingbo created FLINK-27791:
Summary: SlotCountExceedingParallelismTest tests failed with
NoResourceAvailableException
Key: FLINK-27791
URL: https://issues.apache.org/jira/browse/FLINK-27791
jinshuangxian created FLINK-27793:
-
Summary: After upgrading to flink-1.15.0, flink jobmanager cannot
shutdown
Key: FLINK-27793
URL: https://issues.apache.org/jira/browse/FLINK-27793
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Labels: pull-request-available (was: )
> The primary key obtained from MySQL is incorrect by using
flinkbot commented on PR #19820:
URL: https://github.com/apache/flink/pull/19820#issuecomment-1138019010
## CI report:
* 57553025921f2fb7db332973b0d88c75aa0d32bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #29:
URL: https://github.com/apache/flink-statefun-playground/pull/29
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the information of the database table `user`.
The
[
https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542352#comment-17542352
]
Xintong Song commented on FLINK-27722:
--
I tried but couldn't update it.
- w/o checking the override
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r881266473
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-27615.
-
Fix Version/s: kubernetes-operator-1.0.0
Resolution: Fixed
Fixed via:
main:
Huang Xingbo created FLINK-27765:
Summary:
TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure
failed with FlinkJobNotFoundException
Key: FLINK-27765
URL:
[
https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541863#comment-17541863
]
fanrui commented on FLINK-27251:
[~pnowojski] Thanks a lot for your guidance and help. In the process of
MartijnVisser merged PR #19810:
URL: https://github.com/apache/flink/pull/19810
--
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:
wangyang0918 commented on PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#issuecomment-1136875026
I will have a look later today.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser merged PR #20:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/20
--
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-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-15472:
---
Priority: Major (was: Not a Priority)
> [FLIP-91] Support SQL Gateway
>
[
https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-15472:
---
Summary: [FLIP-91] Support SQL Gateway (was: Support SQL Gateway )
> [FLIP-91] Support
[
https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-15472:
---
Labels: (was: auto-deprioritized-major auto-deprioritized-minor)
> [FLIP-91] Support SQL
[
https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-15472:
---
Description: FLIP-91:
[
https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27725:
---
Labels: pull-request-available (was: )
> Create tests for TypeInformation and
alpreu opened a new pull request, #19814:
URL: https://github.com/apache/flink/pull/19814
## What is the purpose of the change
We found out that the connectors rely heavily on the `flink-table-planner`
test dependency (for running the DynamicTableFactory ITCases). This is not the
rkhachatryan commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r880787079
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java:
##
@@ -57,13 +58,30 @@ public interface SharedStateRegistry extends
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541896#comment-17541896
]
zoucan edited comment on FLINK-27762 at 5/25/22 8:45 AM:
-
[~martijnvisser]
luoyuxia commented on PR #19806:
URL: https://github.com/apache/flink/pull/19806#issuecomment-1136967265
@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-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin resolved FLINK-25558.
--
Resolution: Fixed
> TableResult OK may be empty if returned by multiple queries
>
yunfengzhou-hub commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r881176285
##
flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java:
##
@@ -71,6 +71,43 @@ public static double dot(DenseVector x, DenseVector y) {
return
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zoucan updated FLINK-27762:
---
Description:
We enable dynamic partition discovery in our flink job, but job is failed when
kafka
zoucan created FLINK-27762:
--
Summary: Kafka WakeUpException during handling splits changes
Key: FLINK-27762
URL: https://issues.apache.org/jira/browse/FLINK-27762
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zoucan updated FLINK-27762:
---
Description:
We enable dynamic partition discovery in our flink job, but job is failed when
kafka
JingsongLi merged PR #136:
URL: https://github.com/apache/flink-table-store/pull/136
--
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:
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r881275210
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache
Shengkai Fang created FLINK-27769:
-
Summary: Introduce the REST endpoint framework
Key: FLINK-27769
URL: https://issues.apache.org/jira/browse/FLINK-27769
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-27770:
-
Summary: Introduce the script to start/stop/stop-all gateway
Key: FLINK-27770
URL: https://issues.apache.org/jira/browse/FLINK-27770
Project: Flink
Issue
Shengkai Fang created FLINK-27768:
-
Summary: Allow to execute sql for the SqlGatewayService
Key: FLINK-27768
URL: https://issues.apache.org/jira/browse/FLINK-27768
Project: Flink
Issue Type:
flinkbot commented on PR #19814:
URL: https://github.com/apache/flink/pull/19814#issuecomment-1136934185
## CI report:
* af89757c9fb110da03a959898a5ce8460ba76b0e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yangjunhan commented on PR #19712:
URL: https://github.com/apache/flink/pull/19712#issuecomment-1136953209
Hi @Airblader. I understand the concerns from your perspectives. Let me
elaborate a bit more and talk about the main advantages it brings:
- This change helps to make each
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541891#comment-17541891
]
Robert Metzger commented on FLINK-27721:
Thanks a lot for working on this!
I'm not surprised
snuyanzin commented on code in PR #19807:
URL: https://github.com/apache/flink/pull/19807#discussion_r881243667
##
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java:
##
@@ -279,7 +279,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zoucan updated FLINK-27762:
---
Description:
We enable dynamic partition discovery in our flink job, but job failed when
kafka
[
https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zoucan updated FLINK-27762:
---
Description:
We enable dynamic partition discovery in our flink job, but job failed when
kafka
1 - 100 of 244 matches
Mail list logo
