hlteoh37 commented on PR #20543:
URL: https://github.com/apache/flink/pull/20543#issuecomment-1211612232
@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
dalongliu created FLINK-28917:
-
Summary: Add sql test for adaptive hash join
Key: FLINK-28917
URL: https://issues.apache.org/jira/browse/FLINK-28917
Project: Flink
Issue Type: Bug
Compo
dalongliu created FLINK-28916:
-
Summary: Add e2e test for create function using jar syntax
Key: FLINK-28916
URL: https://issues.apache.org/jira/browse/FLINK-28916
Project: Flink
Issue Type: Bug
Sxnan commented on PR #20534:
URL: https://github.com/apache/flink/pull/20534#issuecomment-1211598957
@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.
To
luoyuxia commented on code in PR #20469:
URL: https://github.com/apache/flink/pull/20469#discussion_r943034014
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java:
##
@@ -81,11 +91,29 @@ private FileSystemOutp
hlteoh37 commented on PR #20543:
URL: https://github.com/apache/flink/pull/20543#issuecomment-1211587835
@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-26682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-26682:
-
Issue Type: Technical Debt (was: New Feature)
> Migrate regression check script to pyth
[
https://issues.apache.org/jira/browse/FLINK-24433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-24433:
-
Issue Type: Technical Debt (was: Bug)
> "No space left on device" in Azure e2e tests
>
SteNicholas commented on code in PR #265:
URL: https://github.com/apache/flink-table-store/pull/265#discussion_r943118712
##
flink-table-store-hive/flink-table-store-hive-catalog/pom.xml:
##
@@ -476,7 +476,6 @@ under the License.
shade
yunfengzhou-hub commented on code in PR #20454:
URL: https://github.com/apache/flink/pull/20454#discussion_r943118408
##
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java:
##
@@ -299,9 +352,67 @@ public void resetToCheckpo
[
https://issues.apache.org/jira/browse/FLINK-28840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28840.
Assignee: Nicholas Jiang
Resolution: Fixed
master: 26786fad4df2fb889bc339cf93e5ce08e3ee8652
JingsongLi merged PR #263:
URL: https://github.com/apache/flink-table-store/pull/263
--
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-28794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28794.
Resolution: Fixed
master: 49491377b93223e914f5656d8d2c2f7ade7999bb
> Publish flink-table-store sn
[
https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578248#comment-17578248
]
Jingsong Lee commented on FLINK-28903:
--
We can change this to `support hive 2.1&2.2
JingsongLi merged PR #261:
URL: https://github.com/apache/flink-table-store/pull/261
--
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-28754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28754.
Fix Version/s: table-store-0.2.0
Assignee: Nicholas Jiang
Resolution: Fixed
master
[
https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-28897:
---
Assignee: dalongliu
> Fail to use udf in added jar when enabling checkpoint
> -
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-27492:
Priority: Major (was: Critical)
> Flink table scala example does not including the scala-api jars
> -
JingsongLi merged PR #264:
URL: https://github.com/apache/flink-table-store/pull/264
--
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...@
JingsongLi commented on code in PR #265:
URL: https://github.com/apache/flink-table-store/pull/265#discussion_r943089140
##
flink-table-store-hive/flink-table-store-hive-catalog/pom.xml:
##
@@ -476,7 +476,6 @@ under the License.
shade
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578245#comment-17578245
]
luoyuxia edited comment on FLINK-28883 at 8/11/22 4:28 AM:
---
I'
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578245#comment-17578245
]
luoyuxia commented on FLINK-28883:
--
I'll try to fix it.
> Fix HiveTableSink failed to
[
https://issues.apache.org/jira/browse/FLINK-27622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-27622.
---
Resolution: Fixed
> Make `AsyncDataStream.OutputMode` configurable for table module
> --
flinkbot commented on PR #20543:
URL: https://github.com/apache/flink/pull/20543#issuecomment-1211541061
## CI report:
* e7ea1da8a04947eb501c702e1f5280af009a5530 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 opened a new pull request, #20543:
URL: https://github.com/apache/flink/pull/20543
…rategy
## What is the purpose of the change
Implement slow start for `AIMDRateLimitingStrategy` by starting from the
`maxBatchSize` specified as the `initialRate`.
## Brief change lo
flinkbot commented on PR #20542:
URL: https://github.com/apache/flink/pull/20542#issuecomment-1211531027
## CI report:
* 6983e1350a69cfa945b353fe51efe5ab64c27946 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on PR #20405:
URL: https://github.com/apache/flink/pull/20405#issuecomment-1211529169
> Do you mean that the performance of Point Lookups and Range Scans should
be verified again in Flink's benchmark?
Not Flink's benchmark, the tests in Flink bechmark are fine-grained
ganlute closed pull request #20542: [FLINK-28910]CDC From Mysql To Hbase Bugs
URL: https://github.com/apache/flink/pull/20542
--
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
ganlute opened a new pull request, #20542:
URL: https://github.com/apache/flink/pull/20542
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-28910
## Brief change log
- *Add reduce when hbase connector process mutation.
## Verifying this ch
hjw created FLINK-28915:
---
Summary: Flink Native k8s mode jar localtion support s3 schema
Key: FLINK-28915
URL: https://issues.apache.org/jira/browse/FLINK-28915
Project: Flink
Issue Type: Improvement
wangyang0918 commented on code in PR #20516:
URL: https://github.com/apache/flink/pull/20516#discussion_r943071236
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java:
##
@@ -419,12 +420,18 @@ public static FlinkPod loadPodFromTemplateFile(
JesseAtSZ commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1211521274
@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-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578235#comment-17578235
]
Yanfei Lei commented on FLINK-28909:
Hi [~zlzhang0122], {{rocksjni}} does not suppo
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578226#comment-17578226
]
luoyuxia edited comment on FLINK-28913 at 8/11/22 3:32 AM:
---
Th
wangyang0918 commented on PR #20516:
URL: https://github.com/apache/flink/pull/20516#issuecomment-1211516437
My bad. I will take closer look now.
--
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 t
yunfengzhou-hub commented on code in PR #140:
URL: https://github.com/apache/flink-ml/pull/140#discussion_r943061498
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/InteractionTest.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
liming30 commented on PR #20405:
URL: https://github.com/apache/flink/pull/20405#issuecomment-1211512386
@fredia If we want to test the performance of RocksDB after `deleteRange`,
the conclusion should have been given in the last part of this
[blog](https://rocksdb.org/blog/2018/11/21/delet
flinkbot commented on PR #20541:
URL: https://github.com/apache/flink/pull/20541#issuecomment-1211512020
## CI report:
* 32b13f534278fa93d96f55c96f707ad6dbce595e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943054862
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerParams.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foun
Dongming WU created FLINK-28914:
---
Summary: Could not find any factories that implement
Key: FLINK-28914
URL: https://issues.apache.org/jira/browse/FLINK-28914
Project: Flink
Issue Type: Bug
liuzhuang2017 commented on PR #20541:
URL: https://github.com/apache/flink/pull/20541#issuecomment-1211509812
@MartijnVisser , Sorry to bother you again, can you help me review this pr?
Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
liuzhuang2017 opened a new pull request, #20541:
URL: https://github.com/apache/flink/pull/20541
## What is the purpose of the change
- **In english document:**
-
[
https://issues.apache.org/jira/browse/FLINK-22679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huzeming updated FLINK-22679:
-
Priority: Minor (was: Not a Priority)
> code optimization：Transformation.equals
>
[
https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26771:
-
Priority: Critical (was: Major)
> Fix incomparable exception between boolean type and numeric type in H
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28883:
-
Fix Version/s: 1.16.0
> Fix HiveTableSink failed to report metrics to hive metastore
> -
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28883:
-
Priority: Critical (was: Major)
> Fix HiveTableSink failed to report metrics to hive metastore
> --
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578226#comment-17578226
]
luoyuxia commented on FLINK-28913:
--
The workaround way is to swap `opt/flink-table-plan
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943059908
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerModel.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foun
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943059908
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerModel.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foun
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943059908
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerModel.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-23944:
-
Priority: Critical (was: Major)
> PulsarSourceITCase.testTaskManagerFailure is instable
> -
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943059550
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578225#comment-17578225
]
Huang Xingbo commented on FLINK-23944:
--
https://dev.azure.com/apache-flink/apache-f
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943058613
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
fredia commented on PR #20405:
URL: https://github.com/apache/flink/pull/20405#issuecomment-1211500562
@liming30 This optimization may increase the number of tombstones. As the
[blog](https://rocksdb.org/blog/2018/11/21/delete-range.html) says,
`deleteRange` would bring some regression on
Grypse commented on PR #20516:
URL: https://github.com/apache/flink/pull/20516#issuecomment-1211500213
> Could we fix this issue in the `KubernetesUtils#loadPodFromTemplateFile`?
Set an empty spec if not specified.
This PR fixes the issue in KubernetesUtils#loadPodFromTemplateFile. Wh
flinkbot commented on PR #20540:
URL: https://github.com/apache/flink/pull/20540#issuecomment-1211497477
## CI report:
* 00fd582ca5f2a7d429428f72158c4b18e844d12f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943055570
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/FLINK-28887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28887:
---
Labels: pull-request-available (was: )
> Fix the bug of custom metrics in Thread Mode
> ---
HuangXingBo opened a new pull request, #20540:
URL: https://github.com/apache/flink/pull/20540
## What is the purpose of the change
*This pull request will fix the bug of custom metrics in Thread Mode*
## Brief change log
- *Fix the bug of custom metrics in Thread Mode*
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943054862
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerParams.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foun
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943054862
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerParams.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Priority: Critical (was: Major)
> Fix fail to open HiveCatalog when it's for hive3
> --
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Fix Version/s: 1.16.0
> Fix fail to open HiveCatalog when it's for hive3
> -
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943053798
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizerParams.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Description:
When use HiveCatalog for hive3, it will throw such exception:
{code:java}
java.lang.NoClass
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943052952
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
flinkbot commented on PR #20539:
URL: https://github.com/apache/flink/pull/20539#issuecomment-1211492362
## CI report:
* ff8cfa1ac0d586f0e7575c772d53181e4bdf1e19 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943052952
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
zhipeng93 commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943052952
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/FLINK-28908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28908:
---
Labels: pull-request-available (was: )
> Coder for LIST type is incorrectly chosen is PyFli
luoyuxia created FLINK-28913:
Summary: Fix fail to open HiveCatalog when it's for hive3
Key: FLINK-28913
URL: https://issues.apache.org/jira/browse/FLINK-28913
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Component/s: Connectors / Hive
> Fix fail to open HiveCatalog when it's for hive3
>
Vancior opened a new pull request, #20539:
URL: https://github.com/apache/flink/pull/20539
## What is the purpose of the change
This PR fixes incorrect coder for deserializing `Types.LIST` data from Java.
This needs to be cherry-picked to release-1.14 too.
## Verifying this cha
yunfengzhou-hub commented on code in PR #139:
URL: https://github.com/apache/flink-ml/pull/139#discussion_r943030312
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/kbinsdiscretizer/KBinsDiscretizer.java:
##
@@ -0,0 +1,340 @@
+/*
+ * Licensed to the Apache Software Fou
tweise commented on PR #20530:
URL: https://github.com/apache/flink/pull/20530#issuecomment-1211466504
@zhongqishang thanks for the PR, I'm going to take a look soon.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-28903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28903:
---
Labels: pull-request-available (was: )
> flink-table-store-hive-catalog could not shade hiv
SteNicholas opened a new pull request, #265:
URL: https://github.com/apache/flink-table-store/pull/265
flink-table-store-hive-catalog could not shade hive-shims-0.23 because
`artifactSet` doesn't include `hive-shims-0.23` and the `minimizeJar` is set to
true.
**The brief change log**
luoyuxia commented on PR #20536:
URL: https://github.com/apache/flink/pull/20536#issuecomment-1211461202
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
luoyuxia commented on code in PR #20469:
URL: https://github.com/apache/flink/pull/20469#discussion_r943034014
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemOutputFormat.java:
##
@@ -81,11 +91,29 @@ private FileSystemOutp
[
https://issues.apache.org/jira/browse/FLINK-18631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-18631:
---
Labels: auto-deprioritized-major performance pull-request-available
stale-minor (was: auto-
dannycranmer commented on PR #20522:
URL: https://github.com/apache/flink/pull/20522#issuecomment-1211234037
@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 merged PR #20521:
URL: https://github.com/apache/flink/pull/20521
--
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.
[
https://issues.apache.org/jira/browse/FLINK-28900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-28900:
Assignee: Yunfeng Zhou
> RecreateOnResetOperatorCoordinatorTest compile failed in jdk11
> ---
[
https://issues.apache.org/jira/browse/FLINK-28900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-28900.
Resolution: Fixed
> RecreateOnResetOperatorCoordinatorTest compile failed in jdk11
> -
reswqa commented on PR #20529:
URL: https://github.com/apache/flink/pull/20529#issuecomment-1210961697
@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.
T
lindong28 merged PR #20532:
URL: https://github.com/apache/flink/pull/20532
--
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.apa
lindong28 commented on PR #20532:
URL: https://github.com/apache/flink/pull/20532#issuecomment-1210958640
Thanks for the PR. LGTM.
--
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 com
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-28898.
-
Resolution: Fixed
Merged as 3268ec6a7ce0e060eb401917f7d169969334d07d.
> ChangelogRecove
rkhachatryan merged PR #20537:
URL: https://github.com/apache/flink/pull/20537
--
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.
[
https://issues.apache.org/jira/browse/FLINK-28694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28694.
--
Resolution: Fixed
Merged to main 0a1a68c9a88ad3055dcf6630e23ce89df7d23a97
> Set pipeline.name to reso
gyfora merged PR #345:
URL: https://github.com/apache/flink-kubernetes-operator/pull/345
--
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
zentol commented on PR #28:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/28#issuecomment-1210806450
Have a look at
https://github.com/apache/flink/commit/fb95798b1c301152b912c4b8ec4a737ea16d8641
how I solved it for the version in Flink.
--
This is an automated messa
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578007#comment-17578007
]
Danny Cranmer commented on FLINK-28027:
---
This is fixed by FLINK-28487 in 1.16.
>
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-28027:
--
Affects Version/s: 1.15.1
> Initialise Async Sink maximum number of in flight messages to low
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-28027:
-
Assignee: Hong Liang Teoh
> Initialise Async Sink maximum number of in flight messages
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-28027:
--
Fix Version/s: 1.15.2
(was: 1.16.0)
> Initialise Async Sink maximum num
[
https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577980#comment-17577980
]
Aleksandra Sarna commented on FLINK-28609:
--
Hi [~martijnvisser] ,
Could you pl
sthm closed pull request #20509: [FLINK-28027][connectors/async-sink] Implement
slow start strategy fo…
URL: https://github.com/apache/flink/pull/20509
--
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 t
sthm commented on PR #20509:
URL: https://github.com/apache/flink/pull/20509#issuecomment-1210619982
This is superseded by FLINK-28487.
--
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 specifi
1 - 100 of 188 matches
Mail list logo
