[
https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18887.
---
Resolution: Fixed
Merged to master via 72ef7e010546f41f8fa7ac01cdb3f9a90f100ac2
> Add ElasticSearch connect
[
https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18887:
Component/s: Connectors / ElasticSearch
> Add ElasticSearch connector for Python DataStream API
>
[
https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555383#comment-17555383
]
godfrey he edited comment on FLINK-26051 at 6/17/22 7:04 AM:
-
zhoulii commented on PR #19984:
URL: https://github.com/apache/flink/pull/19984#issuecomment-1158562510
> Would you open a JIRA ticket to fix this test issue? @zhoulii
Hi @zhuzhurk , thanks for your reply.
I thought the change is minor, So I did not open a jira ticket. I am not
[
https://issues.apache.org/jira/browse/FLINK-28016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555436#comment-17555436
]
Chesnay Schepler commented on FLINK-28016:
--
Not sure either, but I built it wit
zentol merged PR #19990:
URL: https://github.com/apache/flink/pull/19990
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-28095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28095.
Resolution: Fixed
master: 9aaf09c3db753ef805e3c7e3889a1f919d6362a5
> Replace IOUtils depe
zentol commented on PR #19968:
URL: https://github.com/apache/flink/pull/19968#issuecomment-1158571238
@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
dianfu commented on PR #19958:
URL: https://github.com/apache/flink/pull/19958#issuecomment-1158572228
@shuiqiangchen It seems that the new stack is used when adding new
functions. It makes adding new functions easier. Regarding to this PR, its
purpose is to expose existing functions first_
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555442#comment-17555442
]
Weijie Guo commented on FLINK-28102:
You can set an io.tmp.dirs yourself using -D
c
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555442#comment-17555442
]
Weijie Guo edited comment on FLINK-28102 at 6/17/22 7:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555445#comment-17555445
]
LuNing Wang commented on FLINK-28071:
-
[~twalthr] I only support existing built-in f
JingsongLi merged PR #162:
URL: https://github.com/apache/flink-table-store/pull/162
--
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-27542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533700#comment-17533700
]
Jingsong Lee edited comment on FLINK-27542 at 6/17/22 7:29 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-27542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27542.
Resolution: Fixed
> Add end to end tests for Hive to read external table store files
> ---
[
https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555445#comment-17555445
]
LuNing Wang edited comment on FLINK-28071 at 6/17/22 7:33 AM:
yunfengzhou-hub opened a new pull request, #112:
URL: https://github.com/apache/flink-ml/pull/112
This PR reduces Flink ML iteration's latency by enforcing flush at each
iteration epoch watermark.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
zhuzhurk commented on PR #19984:
URL: https://github.com/apache/flink/pull/19984#issuecomment-1158591560
It's better to open a JIRA ticket for it so that fixes can be tracked. You
can change the priority to minor though.
There do exist some hotfix commits but they are usually parts of PRs
wuchong commented on code in PR #19851:
URL: https://github.com/apache/flink/pull/19851#discussion_r899829796
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala:
##
@@ -313,6 +313,7 @@ object ScalarOperatorGens
luoyuxia created FLINK-28104:
Summary: Drop the unused order parameter in
FirstValueFunction/LastValueFunction
Key: FLINK-28104
URL: https://issues.apache.org/jira/browse/FLINK-28104
Project: Flink
shuiqiangchen commented on PR #19958:
URL: https://github.com/apache/flink/pull/19958#issuecomment-1158602558
@dianfu Yes, the implementation of LastValueAggFunction and
FirstValueAggFunction have followed the new form. This PR is mainly to expose
builtin functions to TableAPI.
--
This i
[
https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28104:
-
Fix Version/s: 1.16.0
> Drop the unused order parameter in FirstValueFunction/LastValueFunction
> --
zl created FLINK-28105:
--
Summary: We should test the copied object in
GlobFilePathFilterTest#testGlobFilterSerializable
Key: FLINK-28105
URL: https://issues.apache.org/jira/browse/FLINK-28105
Project: Flink
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899866865
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -98,6 +98,9 @@ static ChannelStateWriteRequest buildFuture
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555455#comment-17555455
]
Prabhu Joseph commented on FLINK-28102:
---
Yes setting io.tmp.dirs to the actual dir
JingsongLi opened a new pull request, #163:
URL: https://github.com/apache/flink-table-store/pull/163
In FileStoreCommitImpl, currently, it uses `rename` to support atomic commit.
But this is not work for object store like S3. We can use RecoverableWriter
to support atomic commit for obje
[
https://issues.apache.org/jira/browse/FLINK-28066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28066:
Assignee: Jingsong Lee
> Use FileSystem.createRecoverableWriter in FileStoreCommit
>
[
https://issues.apache.org/jira/browse/FLINK-28066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28066:
---
Labels: pull-request-available (was: )
> Use FileSystem.createRecoverableWriter in FileStor
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555457#comment-17555457
]
zl commented on FLINK-28105:
Hi [~zhuzh] ，can you take a look ?
> We should test the copied
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899880554
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildFutu
alpinegizmo commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1158622294
Would love to see this in 1.16. Hope someone can review it soon!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899884298
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildFutu
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460
]
EMing Zhou commented on FLINK-28027:
Hi [~CrynetLogistics] ，When I use jdbc sink, I
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460
]
EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:21 AM:
-
pnowojski commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899887457
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildF
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555461#comment-17555461
]
Piotr Nowojski commented on FLINK-27792:
What is causing this `InterruptedExcept
pnowojski commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899893420
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -98,6 +98,9 @@ static ChannelStateWriteRequest buildFut
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460
]
EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:28 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460
]
EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:28 AM:
-
pnowojski commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899887457
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildF
JingsongLi merged PR #147:
URL: https://github.com/apache/flink-table-store/pull/147
--
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...@
lsyldliu opened a new pull request, #20001:
URL: https://github.com/apache/flink/pull/20001
## What is the purpose of the change
*Planner support to use jar which is registered by 'CREATE FUNTION USING
JAR' syntax*
## Brief change log
- *Planner support to use jar
[
https://issues.apache.org/jira/browse/FLINK-27947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27947.
Resolution: Fixed
master: c58576eb3bd3d860c5ba5a940b4d0e0b3cb5f55a
> Introduce Spark Reader for t
[
https://issues.apache.org/jira/browse/FLINK-27659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27659:
---
Labels: pull-request-available (was: )
> Planner support to use jar which is registered by
pnowojski commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899899066
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildF
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Component/s: Tests
(was: API / Core)
> We should test the copied object in
> GlobFil
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Fix Version/s: 1.16.0
> We should test the copied object in
> GlobFilePathFilterTest#testGlobFilterSerial
Jingsong Lee created FLINK-28106:
Summary: Create flink-table-store-connector-base to shade all
flink dependencies
Key: FLINK-28106
URL: https://issues.apache.org/jira/browse/FLINK-28106
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28105:
Affects Version/s: 1.14.4
1.15.0
1.16.0
> We should test the
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-28105:
---
Assignee: zl
> We should test the copied object in
> GlobFilePathFilterTest#testGlobFilterSerializ
[
https://issues.apache.org/jira/browse/FLINK-28105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555467#comment-17555467
]
Zhu Zhu commented on FLINK-28105:
-
Thanks for reporting this problem! [~Leo Zhou]
The
flinkbot commented on PR #20001:
URL: https://github.com/apache/flink/pull/20001#issuecomment-1158639485
## CI report:
* e0586d561301b1356fccad5c01ce0e1fbf88bcfb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899904091
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -98,6 +98,9 @@ static ChannelStateWriteRequest buildFuture
dannycranmer merged PR #19937:
URL: https://github.com/apache/flink/pull/19937
--
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.
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899906279
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildFutu
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555473#comment-17555473
]
Danny Cranmer commented on FLINK-28007:
---
Merged to master
https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-28007.
---
Resolution: Fixed
> Tests for AWS Connectors Using SDK v2 to use Synchronous Clients
> -
LuNing Wang created FLINK-28107:
---
Summary: Support id of document is null
Key: FLINK-28107
URL: https://issues.apache.org/jira/browse/FLINK-28107
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNing Wang updated FLINK-28107:
Description:
{code:java}
es7_sink = Elasticsearch7SinkBuilder() \
.set_emitter(ElasticsearchEmit
pnowojski commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899910882
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildF
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28035:
--
Summary: Support rescale overwrite (was: Don't check num of buckets for
rescale bucket condition)
>
deadwind4 opened a new pull request, #20002:
URL: https://github.com/apache/flink/pull/20002
## What is the purpose of the change
Support id of document is null
## Brief change log
- *Add IndexRequest in SimpleElasticsearchEmitter*
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28107:
---
Labels: pull-request-available (was: )
> Support id of document is null
> -
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555482#comment-17555482
]
Martijn Visser commented on FLINK-28107:
[~afedulov] [~alexanderpreuss] Should t
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28035:
--
Description:
For an ordinary read-write job, the scan will check the numBuckets read from
manifests a
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28035:
--
Description:
For an ordinary read-write job, the scan will check the numBuckets read from
manifests a
[
https://issues.apache.org/jira/browse/FLINK-28103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555484#comment-17555484
]
Martijn Visser commented on FLINK-28103:
[~ldwnt] Thanks, can you verify this wi
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555485#comment-17555485
]
Weijie Guo commented on FLINK-28102:
We can handle symlinks correctly before FLINK-
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555485#comment-17555485
]
Weijie Guo edited comment on FLINK-28102 at 6/17/22 8:58 AM:
-
flinkbot commented on PR #20002:
URL: https://github.com/apache/flink/pull/20002#issuecomment-1158658645
## CI report:
* 8b75c0fc11b7ac3e83a73c317d0a12f5cd1116bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555485#comment-17555485
]
Weijie Guo edited comment on FLINK-28102 at 6/17/22 8:59 AM:
-
[ https://issues.apache.org/jira/browse/FLINK-28021 ]
jackwangcs deleted comment on FLINK-28021:
was (Author: jackwangcs):
Hi [~martijnvisser] , I'd like to implement this feature, could you assign this
ticket to me?
> Add FLIP-33 metrics to F
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555488#comment-17555488
]
LuNing Wang commented on FLINK-28107:
-
[~martijnvisser] When this PR merge the main
Jane Chan created FLINK-28108:
-
Summary: Support compaction for append-only table
Key: FLINK-28108
URL: https://issues.apache.org/jira/browse/FLINK-28108
Project: Flink
Issue Type: Sub-task
lsyldliu opened a new pull request, #20003:
URL: https://github.com/apache/flink/pull/20003
## What is the purpose of the change
In table module, we need an `URLClassLoader` which exposes the `addURL`
method because we need to load jar dynamically in sql job. Although the
SafetyNetWr
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555492#comment-17555492
]
Shubham Bansal commented on FLINK-28021:
As [~jackwangcs] has retracted his comm
lsyldliu commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158679157
cc @wuchong @zhuzhurk
--
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 commen
[
https://issues.apache.org/jira/browse/FLINK-28080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28080:
---
Labels: pull-request-available (was: )
> Introduce MutableURLClassLoader as parent class of
flinkbot commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158682088
## CI report:
* 738c2db31de828155396b1f89076459f6957607c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r899942581
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest buildFutu
LuNing Wang created FLINK-28109:
---
Summary: Delete useful code in the row emitter.
Key: FLINK-28109
URL: https://issues.apache.org/jira/browse/FLINK-28109
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LuNing Wang updated FLINK-28109:
Description:
The `.id(key)` in the RowElasticsearchEmitter make users get confused.
The follow
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1708#comment-1708
]
Martijn Visser commented on FLINK-28021:
[~shubham.bansal] I've assigned it to y
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-28021:
--
Assignee: Shubham Bansal
> Add FLIP-33 metrics to FileSystem connector
>
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1709#comment-1709
]
Martijn Visser commented on FLINK-28021:
[~shubham.bansal] I think that both htt
zentol commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158691051
Why do you need to modify the class loader instead of adding another child
classloader?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
deadwind4 opened a new pull request, #20004:
URL: https://github.com/apache/flink/pull/20004
## Brief change log
- *Delete id(key) in the RowElasticsearchEmitter class*
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-28021:
---
Assignee: Shubham Bansal (was: Shubham Pathak)
> Add FLIP-33 metrics to FileSystem connector
> ---
[
https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28109:
---
Labels: pull-request-available (was: )
> Delete useful code in the row emitter.
> -
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-28021:
---
Assignee: Shubham Pathak (was: Shubham Bansal)
> Add FLIP-33 metrics to FileSystem connector
> ---
deadwind4 opened a new pull request, #21:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/21
Delete id(key) in the RowElasticsearchEmitter class
the key is always null, this makes users get confused.
--
This is an automated message from the Apache Git Service.
To r
flinkbot commented on PR #20004:
URL: https://github.com/apache/flink/pull/20004#issuecomment-1158694368
## CI report:
* 040d7e2a0e2a0bacf44ea0629d6161a93a43cefe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158696541
> Why do you need to modify the class loader instead of adding another child
classloader?
Because we want the classlaoder has the ability of
`SafetyNetWrapperClassLoader` and `Fli
reswqa commented on code in PR #19974:
URL: https://github.com/apache/flink/pull/19974#discussion_r899950625
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/emitter/PulsarRecordEmitter.java:
##
@@ -20,26 +20,69 @@
impor
zentol commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158699288
What prevents you from creating such a classloader as a child classloader?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1711#comment-1711
]
Chesnay Schepler commented on FLINK-27792:
--
A potential source {{ChannelStateWr
[
https://issues.apache.org/jira/browse/FLINK-28103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1713#comment-1713
]
Chesnay Schepler commented on FLINK-28103:
--
Why are you doing a POST request wi
Jingsong Lee created FLINK-28110:
Summary: Table Store Hive Reader supports projection pushdown
Key: FLINK-28110
URL: https://issues.apache.org/jira/browse/FLINK-28110
Project: Flink
Issue Ty
jmd300 opened a new pull request, #20005:
URL: https://github.com/apache/flink/pull/20005
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them on
zhuzhurk commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1158708046
Is it possible to add the `FlinkUserCodeClassLoader` to the table module,
and use it to wrap the existing classloader in the case that a classloader
needs to be mutated, i.e. in CTAS cod
1 - 100 of 256 matches
Mail list logo
