[
https://issues.apache.org/jira/browse/FLINK-30118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30118:
--
Fix Version/s: aws-connector-3.0.0
(was: aws-connector-2.0.0)
>
[
https://issues.apache.org/jira/browse/FLINK-29908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29908:
--
Parent: (was: FLINK-29438)
Issue Type: Improvement (was: Sub-task)
> Externalize
[
https://issues.apache.org/jira/browse/FLINK-29908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29908:
--
Fix Version/s: aws-connector-3.0.0
> Externalize and configure E2E tests
>
[
https://issues.apache.org/jira/browse/FLINK-29908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29908:
--
Component/s: Connectors / AWS
> Externalize and configure E2E tests
>
[
https://issues.apache.org/jira/browse/FLINK-29907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29907:
--
Issue Type: Improvement (was: New Feature)
> Externalize AWS connectors from Flink core
>
[
https://issues.apache.org/jira/browse/FLINK-29907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29907:
--
Parent: (was: FLINK-29438)
Issue Type: New Feature (was: Sub-task)
> Externalize
[
https://issues.apache.org/jira/browse/FLINK-28991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637602#comment-17637602
]
Matthias Pohl commented on FLINK-28991:
---
[~renqs] what's the status of this issue? It feels like
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030088540
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/DeduplicateMergeFunction.java:
##
@@ -48,8 +48,17 @@ public
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030087733
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/PartialUpdateITCase.java:
##
@@ -65,8 +65,10 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-30144.
--
Resolution: Fixed
> Guarantee Flink ML operators function correctly with object-reuse enabled
>
lindong28 commented on PR #179:
URL: https://github.com/apache/flink-ml/pull/179#issuecomment-1324624261
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
lindong28 merged PR #179:
URL: https://github.com/apache/flink-ml/pull/179
--
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-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30144:
Assignee: Yunfeng Zhou
> Guarantee Flink ML operators function correctly with object-reuse
lincoln-lil commented on PR #20745:
URL: https://github.com/apache/flink/pull/20745#issuecomment-1324621288
>
@shuiqiangchen another case we need to consider:
for an upsert source, e.g., upsert-kafka,
1. without this (partial) filter pushdown optimization, when the upsert
lincoln-lil commented on code in PR #20745:
URL: https://github.com/apache/flink/pull/20745#discussion_r1030076295
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -128,7 +129,9 @@ protected void
shuiqiangchen commented on PR #20745:
URL: https://github.com/apache/flink/pull/20745#issuecomment-1324613690
Hi @lincoln-lil, I have updated the pr, please have a look. The overall
implementation seems a bit straight forward but can cover most of cases. Please
point it out if there is
shuiqiangchen commented on code in PR #20745:
URL: https://github.com/apache/flink/pull/20745#discussion_r1030072896
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -128,7 +129,9 @@ protected
shuiqiangchen commented on code in PR #20745:
URL: https://github.com/apache/flink/pull/20745#discussion_r1030072896
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -128,7 +129,9 @@ protected
Shammon created FLINK-30161:
---
Summary: Add TableSchema validation before it is commited
Key: FLINK-30161
URL: https://issues.apache.org/jira/browse/FLINK-30161
Project: Flink
Issue Type:
SteNicholas commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030044691
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/DeduplicateMergeFunction.java:
##
@@ -48,8 +48,17 @@ public
SteNicholas commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030044159
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/PreAggregationITCase.java:
##
@@ -711,6 +710,10 @@ public void
SteNicholas commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030043673
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/PartialUpdateITCase.java:
##
@@ -65,8 +65,10 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-30103.
-
Resolution: Duplicate
I guess, [~pnowojski] is right. I went through the failed builds of
SmirAlex commented on PR #21365:
URL: https://github.com/apache/flink/pull/21365#issuecomment-1324532462
cc @PatrickRen @leonardBang @zentol Can you please review this fix?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
tsreaper commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030008452
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/FullChangelogMergeTreeCompactRewriter.java:
##
@@ -78,7 +78,7 @@
[
https://issues.apache.org/jira/browse/FLINK-30110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30110:
---
Labels: pull-request-available (was: )
> Enable from-timestamp log scan when
SteNicholas opened a new pull request, #398:
URL: https://github.com/apache/flink-table-store/pull/398
When `log.scan.timestamp-millis` is configured and `log.scan` isn't
configured, the `log.scan` should be setting to `from-timestamp` by default.
**The brief change log**
-
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1030001343
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTable.java:
##
@@ -246,4 +245,65 @@ public List
flinkbot commented on PR #21367:
URL: https://github.com/apache/flink/pull/21367#issuecomment-1324514277
## CI report:
* 94860af2fa21560e9a4e647d882c599f4ba31434 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28741:
---
Labels: pull-request-available (was: )
> Unexpected result if insert 'false' to boolean
luoyuxia opened a new pull request, #21367:
URL: https://github.com/apache/flink/pull/21367
## What is the purpose of the change
To fix the un-expect behavior for cast to boolean
## Brief change log
- Define a custom cast to boolean function and overwrite the
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1029996831
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/MergeFunctionFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1029996540
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java:
##
@@ -169,7 +172,7 @@ public RecordReader
JingsongLi commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1029996389
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/MergeFunctionFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-29073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637552#comment-17637552
]
yuzelin commented on FLINK-29073:
-
[~eric.xiao] Hi, it's very nice that you can provide help. Recently,
[
https://issues.apache.org/jira/browse/FLINK-29073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637552#comment-17637552
]
yuzelin edited comment on FLINK-29073 at 11/23/22 3:28 AM:
---
[~eric.xiao] Hi,
tsreaper commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1029984979
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/MergeFunctionFactory.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
tsreaper commented on code in PR #395:
URL: https://github.com/apache/flink-table-store/pull/395#discussion_r1029984725
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTable.java:
##
@@ -246,4 +245,65 @@ public List
[
https://issues.apache.org/jira/browse/FLINK-30159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30159:
---
Labels: pull-request-available (was: )
> Add Transformer for ANOVATest
>
jiangxin369 opened a new pull request, #180:
URL: https://github.com/apache/flink-ml/pull/180
## What is the purpose of the change
Add Transformer for ANOVATest.
## Brief change log
- Adds shared parameter `HaSFlatten`
- Adds Transformer implementation of
[
https://issues.apache.org/jira/browse/FLINK-30159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-30159:
--
Description:
Add Transformer for ANOVATest.
Its function would be at least equivalent to Spark's
Jiang Xin created FLINK-30160:
-
Summary: Add Transformer for FValueTest
Key: FLINK-30160
URL: https://issues.apache.org/jira/browse/FLINK-30160
Project: Flink
Issue Type: Sub-task
Jiang Xin created FLINK-30159:
-
Summary: Add Transformer for ANOVATest
Key: FLINK-30159
URL: https://issues.apache.org/jira/browse/FLINK-30159
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30139.
Resolution: Fixed
master: ae96b335e470a068a7e87f3d1a22c58bf2d82256
> CodeGenLoader fails when
JingsongLi merged PR #397:
URL: https://github.com/apache/flink-table-store/pull/397
--
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-30143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-30143.
---
Resolution: Duplicate
> Table Store fails when temporary directory is a symlink
>
[
https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30101.
Resolution: Won't Do
> Always use StandaloneClientHAServices to create RestClusterClient when
>
[
https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reopened FLINK-30101:
--
> Always use StandaloneClientHAServices to create RestClusterClient when
> retriving a Flink on
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637541#comment-17637541
]
Matthias Pohl commented on FLINK-29427:
---
[
https://issues.apache.org/jira/browse/FLINK-29661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng closed FLINK-29661.
-
Resolution: Not A Bug
> DatabaseCalciteSchema$getTable() cannot get statistics for partition
[
https://issues.apache.org/jira/browse/FLINK-29661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637526#comment-17637526
]
Yunhong Zheng commented on FLINK-29661:
---
[~martijnvisser] Hi, this is not a bug as we already
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637525#comment-17637525
]
Lu commented on FLINK-30131:
[~gaoyunhaii] ，I heard from [~Weijie Guo] that you are very professional in
[
https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637524#comment-17637524
]
luoyuxia commented on FLINK-30158:
--
I have no much knowledge about protobuf format. But I had a quick
[
https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637523#comment-17637523
]
Lu commented on FLINK-30131:
[~Weijie Guo] , Thanks for your reply.
# yes, my job hanging forever
# i run
yunfengzhou-hub commented on code in PR #174:
URL: https://github.com/apache/flink-ml/pull/174#discussion_r1029954520
##
docs/content/docs/operators/feature/countvectorizer.md:
##
@@ -0,0 +1,182 @@
+---
+title: "Count Vectorizer"
+weight: 1
+type: docs
+aliases:
+-
[
https://issues.apache.org/jira/browse/FLINK-30030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30030:
-
Description:
When overwrite a table in hive dialect, it might not overwrite but to append.
It can
James Mcguire created FLINK-30158:
-
Summary: [Flink SQL][Protobuf] NullPointerException when querying
Kafka topic using repeated or map attributes
Key: FLINK-30158
URL:
hlteoh37 opened a new pull request, #27:
URL: https://github.com/apache/flink-connector-aws/pull/27
…able API sink follow the standard AWS and HTTP client convention
## What is the purpose of the change
Update DynamoDB Table API table configurations to follow the same convention
Matyas Orhidi created FLINK-30157:
-
Summary: Trigger Events Before JM Recovery and Unhealthy Job
Restarts
Key: FLINK-30157
URL: https://issues.apache.org/jira/browse/FLINK-30157
Project: Flink
hlteoh37 commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029864477
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+---
+
+
+# Amazon DynamoDB Sink
dannycranmer commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029850320
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+---
+
+
+# Amazon DynamoDB
dannycranmer commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029848582
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+---
+
+
+# Amazon DynamoDB
dannycranmer commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029845175
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+---
+
+
+# Amazon DynamoDB
dannycranmer commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029842814
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
Review Comment:
Not
[
https://issues.apache.org/jira/browse/FLINK-29475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29475.
--
Fix Version/s: kubernetes-operator-1.3.0
Resolution: Fixed
merged to main
gyfora merged PR #446:
URL: https://github.com/apache/flink-kubernetes-operator/pull/446
--
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:
hlteoh37 commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1029786873
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,170 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+---
+
+
+# Amazon DynamoDB Sink
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029752612
##
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/IndexGeneratorTest.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
reta commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1324052597
> The architecture tests are missing. Have a look at the ES connector.
Added
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-30156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30156:
---
Labels: pull-request-available (was: )
> [FLIP-242] Blogpost about the customisable
hlteoh37 opened a new pull request, #584:
URL: https://github.com/apache/flink-web/pull/584
…tegy
Documentation for the custom RateLimitingStrategy for the Async Sink
[FLINK-28487](https://issues.apache.org/jira/browse/FLINK-28487).
--
This is an automated message from the Apache
Hong Liang Teoh created FLINK-30156:
---
Summary: [FLIP-242] Blogpost about the customisable
RateLimitingStrategy in the AsyncSinkBase
Key: FLINK-30156
URL: https://issues.apache.org/jira/browse/FLINK-30156
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29938:
--
Fix Version/s: 1.17.0
> Add open() Method to AsyncSink ElementConverter
>
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-29938.
---
Resolution: Done
> Add open() Method to AsyncSink ElementConverter
>
[
https://issues.apache.org/jira/browse/FLINK-29938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637367#comment-17637367
]
Danny Cranmer commented on FLINK-29938:
---
Merged commit
dannycranmer merged PR #21265:
URL: https://github.com/apache/flink/pull/21265
--
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:
flinkbot commented on PR #21366:
URL: https://github.com/apache/flink/pull/21366#issuecomment-1323993083
## CI report:
* 6d29e95a6af0f8848858df622efcc885f98650ad UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30155:
---
Labels: pull-request-available (was: )
> Pretty print MutatedConfigurationException
>
pnowojski opened a new pull request, #21366:
URL: https://github.com/apache/flink/pull/21366
The new message will look like:
org.apache.flink.client.program.MutatedConfigurationException: Not allowed
configuration change(s) were detected:
- Configuration
Piotr Nowojski created FLINK-30155:
--
Summary: Pretty print MutatedConfigurationException
Key: FLINK-30155
URL: https://issues.apache.org/jira/browse/FLINK-30155
Project: Flink
Issue Type:
snuyanzin commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323964883
or just cherry-picked commits from this PR to rebased version
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
rkhachatryan commented on PR #21264:
URL: https://github.com/apache/flink/pull/21264#issuecomment-1323953503
Rebased and resolved the conflict.
@AlanConfluent do you have any further feedback?
--
This is an automated message from the Apache Git Service.
To respond to the message,
ashmeet-kandhari commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323938824
Doesn't show any diff,
I tried checking the history as well and shows nothing
snuyanzin commented on PR #16532:
URL: https://github.com/apache/flink/pull/16532#issuecomment-1323929870
@yiduwangkai @lirui-apache @fsk119
i'd like to revive it a bit
do you mind if I continue work here based on what was done here?
--
This is an automated message from the Apache
snuyanzin commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323924577
what are the changes there?
from my point of view they should not be changed and should not be a part of
this PR
--
This is an automated message from the Apache Git Service.
To
ashmeet-kandhari commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323920168
Oh not sure why are they here, but this is what I found from the rat.txt logs
```
14 Unknown Licenses
*
snuyanzin commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323917212
it means that there are some new files in your PR without license...
I guess there should be no any new files within this PR.
A list of new files you can find in already mentioned
ashmeet-kandhari commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1323914415
Hi @snuyanzin
I tried resolving the conflicts (haven't pushed yet), but when I try to
build locally getting the following error
```
Too many files with
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029500963
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java:
##
@@ -0,0 +1,222 @@
+/*
+ *
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029481239
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java:
##
@@ -0,0 +1,449 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-30145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-30145.
---
Resolution: Won't Fix
No action needed since this is just a metric
> Evaluate operator
[
https://issues.apache.org/jira/browse/FLINK-30145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-30145.
-
Assignee: Gabor Somogyi
> Evaluate operator error log whitelist entry:
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029467392
##
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util/IgnoringFailureHandler.java:
##
@@ -0,0 +1,38 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-30116:
Assignee: ConradJam
> Don't Show Env Vars in Web UI
>
[
https://issues.apache.org/jira/browse/FLINK-30116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30116:
-
Fix Version/s: 1.17.0
> Don't Show Env Vars in Web UI
> -
>
[
https://issues.apache.org/jira/browse/FLINK-30116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30116:
-
Priority: Blocker (was: Critical)
> Don't Show Env Vars in Web UI
>
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029448617
##
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/util/IgnoringFailureHandler.java:
##
@@ -0,0 +1,38 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637303#comment-17637303
]
Martijn Visser commented on FLINK-30062:
[~ferenc-csaky] The repo is created and I've assigned
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1029441900
##
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java:
##
@@ -0,0 +1,222 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30061.
--
Fix Version/s: hbase-3.0.0
Resolution: Fixed
Repository created at
1 - 100 of 261 matches
Mail list logo
