[
https://issues.apache.org/jira/browse/FLINK-31022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31022.
Resolution: Fixed
master: 5b6ff938922aa067b59a0132c62e6cd675680b63
> Using new Serializer for
JingsongLi merged PR #523:
URL: https://github.com/apache/flink-table-store/pull/523
--
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-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687779#comment-17687779
]
Yufan Sheng commented on FLINK-30489:
-
[~tison] Can you assign this issue to me?
>
[
https://issues.apache.org/jira/browse/FLINK-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30489:
---
Labels: pull-request-available (was: )
> flink-sql-connector-pulsar doesn't shade all
syhily opened a new pull request, #26:
URL: https://github.com/apache/flink-connector-pulsar/pull/26
This is a PR after https://github.com/apache/flink-connector-pulsar/pull/25,
but we split them for speeding up the reviews.
--
This is an automated message from the Apache Git Service.
To
FangYongs commented on PR #526:
URL:
https://github.com/apache/flink-table-store/pull/526#issuecomment-1427476456
>
Sounds good to me, then we should add `VisibleForTesting` to
`flink-table-store-common` only, I'll updated this PR later
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-30559:
---
Assignee: miamiaoxyz
> May get wrong result for `if` expression if it's string data type
>
[
https://issues.apache.org/jira/browse/FLINK-30966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687768#comment-17687768
]
lincoln lee commented on FLINK-30966:
-
[~csq] assigned to you
> Flink SQL IF FUNCTION logic error
>
flinkbot commented on PR #21913:
URL: https://github.com/apache/flink/pull/21913#issuecomment-1427459585
## CI report:
* 6a8d8ce72f8f9cad0907a1a057ff53b9d7cbe86e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-30966:
---
Assignee: Shuiqiang Chen
> Flink SQL IF FUNCTION logic error
>
[
https://issues.apache.org/jira/browse/FLINK-31027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31027:
---
Labels: pull-request-available (was: )
> Introduce annotation for table store
>
JingsongLi commented on PR #526:
URL:
https://github.com/apache/flink-table-store/pull/526#issuecomment-1427449782
Thanks @FangYongs for the contribution.
- `VisibleForTesting` looks good to me.
- `Documentation` is introduced in
https://github.com/apache/flink-table-store/pull/524
gaborgsomogyi commented on PR #530:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/530#issuecomment-1427448370
cc @gyfora @mbalassi
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687766#comment-17687766
]
Weijie Guo edited comment on FLINK-31025 at 2/13/23 7:04 AM:
-
BTW. I also
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687766#comment-17687766
]
Weijie Guo commented on FLINK-31025:
BTW. I also found a type in `explain.md`, I have created
reswqa opened a new pull request, #21913:
URL: https://github.com/apache/flink/pull/21913
## What is the purpose of the change
*Fix typo in explain.md.*
## Brief change log
- *Fix typo(`OHE_PHASE` -> `ONE_PHASE`) in explain.md.*
## Verifying this change
liming30 commented on code in PR #21503:
URL: https://github.com/apache/flink/pull/21503#discussion_r1104060745
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java:
##
@@ -177,6 +182,14 @@ class
[
https://issues.apache.org/jira/browse/FLINK-31031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-31031:
Description: See
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687761#comment-17687761
]
Weijie Guo commented on FLINK-31025:
I verified this feature according to the description, and
ruanhang1993 commented on PR #21889:
URL: https://github.com/apache/flink/pull/21889#issuecomment-1427435469
Hi, @zentol ,
I decide not to split it into two PRs and I have pushed the changes. Please
review it again if you have time. Thanks~
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31025:
---
Attachment: image-2023-02-13-14-52-41-855.png
> Release Testing: Verify FLINK-30650 Introduce
Dian Fu created FLINK-31031:
---
Summary: Disable the output buffer of Python process to make it
more convenient for interactive users
Key: FLINK-31031
URL: https://issues.apache.org/jira/browse/FLINK-31031
fsk119 commented on code in PR #21912:
URL: https://github.com/apache/flink/pull/21912#discussion_r1104041538
##
docs/content/docs/dev/table/sql/show.md:
##
@@ -747,4 +748,14 @@ Show all added jars in the session classloader which are
added by [`ADD JAR`]({{
Attention
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31025:
---
Attachment: image-2023-02-13-14-48-53-758.png
> Release Testing: Verify FLINK-30650 Introduce
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31025:
---
Attachment: test1.png
> Release Testing: Verify FLINK-30650 Introduce EXPLAIN PLAN_ADVICE to
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31025:
--
Assignee: Weijie Guo
> Release Testing: Verify FLINK-30650 Introduce EXPLAIN PLAN_ADVICE to
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687755#comment-17687755
]
Weijie Guo commented on FLINK-31025:
Thanks [~qingyue] for creating this, I'd like to do this
Fan Hong created FLINK-31030:
Summary: Support more binary classification evaluation metrics.
Key: FLINK-31030
URL: https://issues.apache.org/jira/browse/FLINK-31030
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31030:
-
Description: Current `BinaryClassificationEvaluator` only supports
'areaUnderROC', 'areaUnderPR', 'ks'
[
https://issues.apache.org/jira/browse/FLINK-31029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31029:
-
Description:
When one input column contains only 2 distinct values and their counts are
same,
[
https://issues.apache.org/jira/browse/FLINK-31029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31029:
-
Description: When a input column contains only 2 distinct values, and their
counts are same,
>
[
https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687750#comment-17687750
]
lincoln lee commented on FLINK-31007:
-
This is a bug for IfCallGen, all operands initialization and
[
https://issues.apache.org/jira/browse/FLINK-31029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31029:
-
Summary: KBinsDiscretizer gives wrong bin edges in 'quantile' strategy when
input data contains only 2
[
https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-31007:
---
Assignee: xzw0223
> The code generated by the IF function throws NullPointerException
>
Fan Hong created FLINK-31029:
Summary: KBinsDiscretizer gives wrong bin edges when input data
contains only 2 distinct values
Key: FLINK-31029
URL: https://issues.apache.org/jira/browse/FLINK-31029
Fanoid opened a new pull request, #211:
URL: https://github.com/apache/flink-ml/pull/211
## What is the purpose of the change
KBinsDiscretizer produces `{Double.MIN_VALUE, Double.MAX_VALUE}` for columns
whose input values are same which is not correct, as it doesn't cover negative
[
https://issues.apache.org/jira/browse/FLINK-31026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31026:
---
Labels: pull-request-available (was: )
> KBinsDiscretizer gives wrong bin edges when all
[
https://issues.apache.org/jira/browse/FLINK-31026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31026:
-
Summary: KBinsDiscretizer gives wrong bin edges when all values are same.
(was: KBinsDiscretizer
[
https://issues.apache.org/jira/browse/FLINK-31022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31022:
---
Labels: pull-request-available (was: )
> Using new Serializer for table store
>
FangYongs commented on PR #523:
URL:
https://github.com/apache/flink-table-store/pull/523#issuecomment-1427399487
LGTM +1
--
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-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30519:
--
Assignee: haiqingchen
> Add e2e tests for operator dynamic config
>
reswqa commented on PR #21573:
URL: https://github.com/apache/flink/pull/21573#issuecomment-1427386691
@yangjunhan Would you mind reviwing 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 above to go to
[
https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687738#comment-17687738
]
Benchao Li commented on FLINK-31021:
[~xccui] Thanks for involving me.
I totally agree that the
Jun Zhang created FLINK-31028:
-
Summary: Provide different compression methods for per level
Key: FLINK-31028
URL: https://issues.apache.org/jira/browse/FLINK-31028
Project: Flink
Issue Type:
Shammon created FLINK-31027:
---
Summary: Introduce annotation for table store
Key: FLINK-31027
URL: https://issues.apache.org/jira/browse/FLINK-31027
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687728#comment-17687728
]
Xingcan Cui commented on FLINK-31021:
-
I'm playing with
ruanhang1993 commented on code in PR #21889:
URL: https://github.com/apache/flink/pull/21889#discussion_r1103993973
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/InternalOperatorCoordinatorMetricGroup.java:
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the
reswqa commented on PR #607:
URL: https://github.com/apache/flink-web/pull/607#issuecomment-1427334809
Thanks @xintongsong for reminding me, I have removed the rebuild commit and
fixed yangze's incorrect order.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-31026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31026:
-
Description:
Current implements gives bin edges of \{Double.MIN_VALUE, Double.MAX_VALUE}
when all
[
https://issues.apache.org/jira/browse/FLINK-31026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31026:
-
Description:
Current implements gives bin edges of \{Double.MIN_VALUE, Double.MAX_VALUE}
when all
[
https://issues.apache.org/jira/browse/FLINK-31026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-31026:
-
Summary: KBinsDiscretizer should gives wrong bin edges when all values are
same. (was:
Fan Hong created FLINK-31026:
Summary: KBinsDiscretizer should gives binEdges wrong bin edges
when all values are same.
Key: FLINK-31026
URL: https://issues.apache.org/jira/browse/FLINK-31026
Project:
zhipeng93 commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1103973578
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/SwingParams.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
zhipeng93 commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1103974792
##
flink-ml-lib/src/test/java/org/apache/flink/ml/recommendation/SwingTest.java:
##
@@ -0,0 +1,236 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
zhipeng93 commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1103961097
##
flink-ml-examples/src/main/java/org/apache/flink/ml/examples/recommendation/SwingExample.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-30969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-30969.
---
Fix Version/s: (was: 1.18.0)
Assignee: Juntao Hu
Resolution: Fixed
Fixed in:
- master
dianfu closed pull request #21899: [FLINK-30969][Python] Fix pandas error when
running table example
URL: https://github.com/apache/flink/pull/21899
--
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
fsk119 commented on PR #21500:
URL: https://github.com/apache/flink/pull/21500#issuecomment-1427291971
@snuyanzin I am not familiar with janino... I think you may need to find
others to review this.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31025:
--
Description:
This ticket aims for verifying FLINK-30650: Introduce EXPLAIN PLAN_ADVICE to
provide
[
https://issues.apache.org/jira/browse/FLINK-30981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-30981.
---
Fix Version/s: (was: 1.18.0)
Assignee: Juntao Hu
Resolution: Fixed
Fixed in:
- master
dianfu closed pull request #21903: [FLINK-30981][Python] Fix explain_sql throws
method not exist
URL: https://github.com/apache/flink/pull/21903
--
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
liming30 commented on PR #519:
URL:
https://github.com/apache/flink-table-store/pull/519#issuecomment-1427286817
@JingsongLi Thanks for your comments, it has been resolved, please help to
review again.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687686#comment-17687686
]
Shipeng Xie commented on FLINK-29566:
-
Hi [~haoxin], did you start working on this issue? If not, I
fredia commented on PR #21858:
URL: https://github.com/apache/flink/pull/21858#issuecomment-1427268488
@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-31025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31025:
--
Description:
This ticket aims for verifying FLINK-30650: Adaptive Batch Scheduler should
also work
Jane Chan created FLINK-31025:
-
Summary: Release Testing: Verify FLINK-30650 Introduce EXPLAIN
PLAN_ADVICE to provide SQL advice
Key: FLINK-31025
URL: https://issues.apache.org/jira/browse/FLINK-31025
[
https://issues.apache.org/jira/browse/FLINK-30274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687685#comment-17687685
]
Ran Tao commented on FLINK-30274:
-
[~martijnvisser] I have updated the pr, PTAL if your are free.
[
https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687684#comment-17687684
]
Yao Zhang commented on FLINK-30857:
---
Hi [~lzljs3620320] ,
As the latest hotfix removed managed table
[
https://issues.apache.org/jira/browse/FLINK-30966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687683#comment-17687683
]
Shuiqiang Chen edited comment on FLINK-30966 at 2/13/23 2:51 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687683#comment-17687683
]
Shuiqiang Chen commented on FLINK-30966:
[~luoyuxia]The matter of
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687682#comment-17687682
]
Shuiqiang Chen commented on FLINK-31003:
[~luoyuxia] +1
> Flink SQL IF / CASE WHEN Funcation
[
https://issues.apache.org/jira/browse/FLINK-30486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687681#comment-17687681
]
Yufan Sheng commented on FLINK-30486:
-
I just copied the code from flink-docs and execute in
[
https://issues.apache.org/jira/browse/FLINK-30627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687680#comment-17687680
]
Yuxin Tan commented on FLINK-30627:
---
[~martijnvisser] Sorry that I underestimated the complexity of
[
https://issues.apache.org/jira/browse/FLINK-30969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30969:
--
Fix Version/s: (was: 1.15.4)
(was: 1.16.2)
Affects Version/s:
[
https://issues.apache.org/jira/browse/FLINK-30966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687676#comment-17687676
]
luoyuxia commented on FLINK-30966:
--
Seems same to FLINK-31003?
> Flink SQL IF FUNCTION logic error
>
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687674#comment-17687674
]
luoyuxia edited comment on FLINK-31003 at 2/13/23 2:36 AM:
---
Hi, everyone. For
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687674#comment-17687674
]
luoyuxia commented on FLINK-31003:
--
Hi, everyone. For me, it seems the same issue of FLINK-30559. Is
[
https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-30292:
Fix Version/s: 1.18.0
> Better support for conversion between DataType and TypeInformation
>
[
https://issues.apache.org/jira/browse/FLINK-30703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687673#comment-17687673
]
Yufan Sheng commented on FLINK-30703:
-
After debugging with Pulsar developers, we still can't
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687671#comment-17687671
]
Yufan Sheng commented on FLINK-31006:
-
No more splits is only used in Pulsar connector for
[
https://issues.apache.org/jira/browse/FLINK-28505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687669#comment-17687669
]
Yufan Sheng edited comment on FLINK-28505 at 2/13/23 2:25 AM:
--
[~tison] Can
[
https://issues.apache.org/jira/browse/FLINK-28351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687670#comment-17687670
]
Yufan Sheng commented on FLINK-28351:
-
[~tison] Where is the release note? I can't see the link.
>
[
https://issues.apache.org/jira/browse/FLINK-28505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687669#comment-17687669
]
Yufan Sheng commented on FLINK-28505:
-
[~Tison] Can you help me close this issue? It's fixed in
[
https://issues.apache.org/jira/browse/FLINK-30969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Juntao Hu updated FLINK-30969:
--
Fix Version/s: 1.15.4
1.16.2
Affects Version/s: 1.16.1
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687668#comment-17687668
]
Yanfei Lei commented on FLINK-29825:
Thanks for taking the time to review the evaluation results.
[
https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687666#comment-17687666
]
Yufan Sheng commented on FLINK-31006:
-
Hi [~jackylau], can you give me a clear reproduce steps on
[
https://issues.apache.org/jira/browse/FLINK-31003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687663#comment-17687663
]
weiqinpan commented on FLINK-31003:
---
BTW, CASE WHEN + IFNULL also have logic problem.
> Flink SQL IF
FangYongs commented on code in PR #522:
URL: https://github.com/apache/flink-table-store/pull/522#discussion_r1103924487
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##
@@ -69,6 +69,13 @@ public class
swuferhong commented on PR #21900:
URL: https://github.com/apache/flink/pull/21900#issuecomment-1427203536
@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-30967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30967:
---
Labels: pull-request-available (was: )
> Add MongoDB connector documentation
>
Jiabao-Sun opened a new pull request, #2:
URL: https://github.com/apache/flink-connector-mongodb/pull/2
## What is the purpose of the change
Add MongoDB connector documentation
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
SwimSweet commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1427078636
@wangyang0918 Please take a look..thx..
--
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
gaborgsomogyi commented on code in PR #530:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/530#discussion_r1103821473
##
e2e-tests/utils.sh:
##
@@ -175,20 +175,33 @@ function debug_and_show_logs {
echo "Flink logs:"
kubectl get pods -o
gaborgsomogyi commented on PR #530:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/530#issuecomment-1427056226
> Hi @gyfora @gaborgsomogyi , the pipeline checks with 1.35.0 busybox
version passed. Should we wait for
https://github.com/docker-library/busybox/issues/162 to be
jadireddi commented on PR #21594:
URL: https://github.com/apache/flink/pull/21594#issuecomment-1427037558
Thank you @dawidwys @liuml07 for the review. Will make changes as suggested.
--
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-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687572#comment-17687572
]
haiqingchen commented on FLINK-30519:
-
Hi [~gyfora] could you assign this ticket to me? I'd like
syhily commented on PR #25:
URL:
https://github.com/apache/flink-connector-pulsar/pull/25#issuecomment-1427018099
```
2023-02-12T12:00:08.6685939Z [10.449s][error][gc] Failed to commit memory
(Not enough space)
2023-02-12T12:00:08.6686284Z [19.855s][error][gc] Forced to lower max
syhily commented on PR #25:
URL:
https://github.com/apache/flink-connector-pulsar/pull/25#issuecomment-1426990810
This PR is completed on top of #24, we will rebase it until the #24 is
merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
lindong28 commented on code in PR #21589:
URL: https://github.com/apache/flink/pull/21589#discussion_r1103753156
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java:
##
@@ -479,6 +486,134 @@ public
99 matches
Mail list logo
