flinkbot commented on PR #21210:
URL: https://github.com/apache/flink/pull/21210#issuecomment-1298098013
## CI report:
* b258d8e33813d2678842df7673b5ba7bdb69942b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29652:
---
Labels: pull-request-available (was: )
> get duplicate result from sql-client in BATCH mode
CallMeSurprise opened a new pull request, #21210:
URL: https://github.com/apache/flink/pull/21210
## What is the purpose of the change
This pull request fixes the problem that user may get duplicate row records
occasionally even if querying from a hive/hudi table which contains only o
zjureel commented on PR #344:
URL:
https://github.com/apache/flink-table-store/pull/344#issuecomment-1298083836
@JingsongLi What do you think of this feature, and can you help to review
it? THX
--
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot commented on PR #21209:
URL: https://github.com/apache/flink/pull/21209#issuecomment-1298070041
## CI report:
* 028d3672b553885c08b327f3638241101b03 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29818:
---
Labels: pull-request-available (was: )
> HsResultPartitionTest.testAvailability fails
> -
reswqa opened a new pull request, #21209:
URL: https://github.com/apache/flink/pull/21209
## What is the purpose of the change
*Fix the unstable test HsResultPartitionTest.testAvailability*
## Brief change log
- *Fix an incorrect test case in NetworkBufferTest*
[
https://issues.apache.org/jira/browse/FLINK-29823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29823:
---
Labels: pull-request-available (was: )
> Support get schema for table snapshot
> --
zjureel opened a new pull request, #344:
URL: https://github.com/apache/flink-table-store/pull/344
Currently we can only query the latest snapshot data from table store. We
need to support reading the data of the specified snapshot, in this way, we can
read historical versions or compare d
[
https://issues.apache.org/jira/browse/FLINK-29823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-29823:
Summary: Support get schema for table snapshot (was: Support create schema
for table snapshot)
> Support
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-29825:
Assignee: Yanfei Lei
> Improve benchmark stability
> ---
>
>
lindong28 merged PR #169:
URL: https://github.com/apache/flink-ml/pull/169
--
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.apac
lindong28 commented on PR #169:
URL: https://github.com/apache/flink-ml/pull/169#issuecomment-1298031328
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 comm
sethsaperstein-lyft commented on PR #20844:
URL: https://github.com/apache/flink/pull/20844#issuecomment-1298029115
@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 specifi
lindong28 merged PR #164:
URL: https://github.com/apache/flink-ml/pull/164
--
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.apac
lindong28 commented on PR #164:
URL: https://github.com/apache/flink-ml/pull/164#issuecomment-1298028992
Thanks for the update. 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
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-29825:
---
Summary: Improve benchmark stability (was: Improve benchmark stablility)
> Improve benchmark stabil
Yanfei Lei created FLINK-29825:
--
Summary: Improve benchmark stablility
Key: FLINK-29825
URL: https://issues.apache.org/jira/browse/FLINK-29825
Project: Flink
Issue Type: Improvement
Co
[
https://issues.apache.org/jira/browse/FLINK-29792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-29792:
Fix Version/s: table-store-0.3.0
table-store-0.2.2
> FileStoreCommitTest is uns
[
https://issues.apache.org/jira/browse/FLINK-29792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29792.
---
Resolution: Fixed
master: 153804749deeb335083aeefc619b44a9276310e2
release-0.2: 2f97ff0c51d189685a1b
tsreaper merged PR #342:
URL: https://github.com/apache/flink-table-store/pull/342
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29824:
---
Labels: pull-request-available (was: )
> AgglomerativeClustering fails when the distanceThr
zhipeng93 opened a new pull request, #169:
URL: https://github.com/apache/flink-ml/pull/169
## What is the purpose of the change
Fix the bug in AgglomerativeClustering that we did not stop the clustering
process when the size of the active clusters is already one.
## Brief chan
[
https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reassigned FLINK-29824:
-
Assignee: Zhipeng Zhang
> AgglomerativeClustering fails when the distanceThreshold is v
Zhipeng Zhang created FLINK-29824:
-
Summary: AgglomerativeClustering fails when the distanceThreshold
is very large
Key: FLINK-29824
URL: https://issues.apache.org/jira/browse/FLINK-29824
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626950#comment-17626950
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Not sure that will be iss
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626947#comment-17626947
]
Mason Chen commented on FLINK-29711:
No, the fix is included in 1.17.
That's your i
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626946#comment-17626946
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Yes TripSerializer can re
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626944#comment-17626944
]
Weijie Guo commented on FLINK-8712:
---
[~mandarmohile] Hi, you should calculate the numbe
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626939#comment-17626939
]
Mason Chen edited comment on FLINK-29711 at 11/1/22 3:35 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626939#comment-17626939
]
Mason Chen commented on FLINK-29711:
Yes, I'm wondering about the TripSerializer imp
[
https://issues.apache.org/jira/browse/FLINK-29804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29804:
--
Component/s: Table SQL / Planner
(was: Table SQL / API)
> Support convert
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626933#comment-17626933
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Please find below example
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Durgesh Mishra updated FLINK-29711:
---
Attachment: image-2022-11-01-08-41-21-836.png
> Topic notification not present in metadata a
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626931#comment-17626931
]
Aitozi edited comment on FLINK-29800 at 11/1/22 3:09 AM:
-
The in
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626931#comment-17626931
]
Aitozi commented on FLINK-29800:
The inProgressPart seems only record current one inprog
[
https://issues.apache.org/jira/browse/FLINK-29567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626927#comment-17626927
]
Huang Xingbo commented on FLINK-29567:
--
Hi [~renqs], the fixed PR hasn't been back
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626926#comment-17626926
]
luoyuxia commented on FLINK-29800:
--
> The current inprogress files can be record in the
[ https://issues.apache.org/jira/browse/FLINK-29800 ]
luoyuxia deleted comment on FLINK-29800:
--
was (Author: luoyuxia):
Just one quick question, how do you know it's failover in the close method?
IIUC, there's no way to know whether it's closed b
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626923#comment-17626923
]
luoyuxia edited comment on FLINK-29800 at 11/1/22 2:42 AM:
---
Ju
[
https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-29822:
--
Assignee: Feifan Wang
> Fix wrong description in comments of
> StreamExecutionEnvironment#se
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626923#comment-17626923
]
luoyuxia edited comment on FLINK-29800 at 11/1/22 2:40 AM:
---
Ju
[
https://issues.apache.org/jira/browse/FLINK-29800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626923#comment-17626923
]
luoyuxia commented on FLINK-29800:
--
Just one quick question, how do you know it's failo
fredia commented on PR #21208:
URL: https://github.com/apache/flink/pull/21208#issuecomment-1297943248
Thanks for the PR, LGTM. In fact, in
https://issues.apache.org/jira/browse/FLINK-4380 the description was `0 <
maxParallelism <= 2^15`, but https://issues.apache.org/jira/browse/FLINK-5473
weibozhao commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r1010020986
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VectorAssemblerTest.java:
##
@@ -45,13 +45,16 @@
Review Comment:
I have refine code as spark's function
Shammon created FLINK-29823:
---
Summary: Support create schema for table snapshot
Key: FLINK-29823
URL: https://issues.apache.org/jira/browse/FLINK-29823
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29805:
---
Labels: pull-request-available (was: )
> Table Store sink continuously fails with "Trying t
tsreaper opened a new pull request, #343:
URL: https://github.com/apache/flink-table-store/pull/343
Table Store sink continuously fails with "Trying to add file which is
already added" when snapshot committing is slow.
This is due to a bug in `FileStoreCommitImpl#filterCommitted`. Whe
[
https://issues.apache.org/jira/browse/FLINK-29821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626907#comment-17626907
]
yuzelin edited comment on FLINK-29821 at 11/1/22 2:10 AM:
--
Hi A
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626912#comment-17626912
]
Leonard Xu commented on FLINK-29480:
[~Alcántara]You're welcome, this improvement wi
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29480:
---
Fix Version/s: 1.17.0
> Skip invalid messages when writing
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-29821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626907#comment-17626907
]
yuzelin edited comment on FLINK-29821 at 11/1/22 2:08 AM:
--
Hi A
[
https://issues.apache.org/jira/browse/FLINK-29821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626907#comment-17626907
]
yuzelin edited comment on FLINK-29821 at 11/1/22 2:07 AM:
--
Hi A
[
https://issues.apache.org/jira/browse/FLINK-29817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626911#comment-17626911
]
Huang Xingbo commented on FLINK-29817:
--
The `install_requirements` of PyFlink depen
tsreaper opened a new pull request, #342:
URL: https://github.com/apache/flink-table-store/pull/342
(Cherry-picked from #341)
`FileStoreCommitTest` may stuck because the `FileStoreCommit` in
`TestCommitThread` does not commit APPEND snapshot when no new files are
produced. In this ca
[
https://issues.apache.org/jira/browse/FLINK-29821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626907#comment-17626907
]
yuzelin commented on FLINK-29821:
-
Hi Alvin,
I did a simple test under the flink mast
flinkbot commented on PR #21208:
URL: https://github.com/apache/flink/pull/21208#issuecomment-1297915131
## CI report:
* 34787e18d80186d3e0079619b2d1b23c91a08f1c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tsreaper merged PR #341:
URL: https://github.com/apache/flink-table-store/pull/341
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-29822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29822:
---
Labels: pull-request-available (was: )
> Fix wrong description in comments of
> StreamExec
zoltar9264 opened a new pull request, #21208:
URL: https://github.com/apache/flink/pull/21208
…ironment#setMaxParallelism()
## What is the purpose of the change
As the [issue](https://issues.apache.org/jira/browse/FLINK-29822) said, fix
wrong description in comments of StreamEx
[
https://issues.apache.org/jira/browse/FLINK-29821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626905#comment-17626905
]
luoyuxia commented on FLINK-29821:
--
schemaBuilder.column("id", DataTypes.BIGINT().notNu
Feifan Wang created FLINK-29822:
---
Summary: Fix wrong description in comments of
StreamExecutionEnvironment#setMaxParallelism()
Key: FLINK-29822
URL: https://issues.apache.org/jira/browse/FLINK-29822
Pro
[
https://issues.apache.org/jira/browse/FLINK-28505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28505:
-
Assignee: Yufan Sheng
> Pulsar sink doesn't support topic auto creation
> -
[
https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28959:
-
Assignee: Yufan Sheng
> 504 gateway timeout when consume large number of topics using TopicPatt
[
https://issues.apache.org/jira/browse/FLINK-28870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28870:
-
Assignee: Yufan Sheng
> Pulsar Source hangs on the small incoming message rates
> -
[
https://issues.apache.org/jira/browse/FLINK-28351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-28351:
-
Assignee: Yufan Sheng
> Pulsar Sink should support dynamic generated topic from record
> --
[
https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-25686:
-
Assignee: Yufan Sheng (was: Yufei Zhang)
> Support Pulsar Schema evolution in Pulsar Source Co
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-26027:
-
Assignee: Yufan Sheng (was: Yufei Zhang)
> Add FLIP-33 metrics to Pulsar connector
> -
tisonkun closed pull request #18816: [FLINK-26027][pulsar] add sink metrics to
pulsar sink
URL: https://github.com/apache/flink/pull/18816
--
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
Alvin Ge created FLINK-29821:
Summary: Schema.Builder how to set not null column?
Key: FLINK-29821
URL: https://issues.apache.org/jira/browse/FLINK-29821
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626893#comment-17626893
]
Weijie Guo commented on FLINK-29818:
[~Sergey Nuyanzin] Thanks for reporting this, I
[
https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626892#comment-17626892
]
Gao Fei commented on FLINK-29647:
-
Our mysql database has no primary key and cannot achi
[
https://issues.apache.org/jira/browse/FLINK-29794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29794:
---
Labels: pull-request-available (was: )
> Flink Operator Need to Include Cause for Exception
jiangzho opened a new pull request, #422:
URL: https://github.com/apache/flink-kubernetes-operator/pull/422
## What is the purpose of the change
This PR attempts to add root cause (if exists) to RuntimeException, for a
consistent trace & easier debug.
## Brief chang
[
https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-29820:
Description:
Currently our queries can only read the latest snapshot from table store. We
need to support
[
https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-29820:
Description:
Currently our queries can only read the latest snapshot from table store. We
need to support
Shammon created FLINK-29820:
---
Summary: Support to read data from table store with specify
snapshot id
Key: FLINK-29820
URL: https://issues.apache.org/jira/browse/FLINK-29820
Project: Flink
Issue T
galenwarren commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297841266
OK, I got it working. I sent five messages and got what look like the
expected replies:
```
(base) galen@galen-ubuntu-20:~/projects/git/coachclientconnect$ curl -X PUT
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297819016
@galenwarren right, its actually a bit more complicated then what I
described indeed 😅
You'll have to edit the Dockerfile to manually copy the StateFun Java SDK
jar in, inst
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-26027:
Affects Version/s: 1.17.0
> Add FLIP-33 metrics to Pulsar connector
>
[
https://issues.apache.org/jira/browse/FLINK-26027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-26027:
Summary: Add FLIP-33 metrics to Pulsar connector (was: Add FLIP-33 metrics
to new PulsarSink)
>
flinkbot commented on PR #21207:
URL: https://github.com/apache/flink/pull/21207#issuecomment-1297744613
## CI report:
* a5d473d293dac03edf7d4387da01d4ec3ac31ae6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily commented on PR #18816:
URL: https://github.com/apache/flink/pull/18816#issuecomment-1297738425
@imaffe Since this is an outdated PR. Can you close 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 a
syhily opened a new pull request, #21207:
URL: https://github.com/apache/flink/pull/21207
## What is the purpose of the change
Currently the source connector reads all messages as `Message`, and
implements a deserialization abstraction to deserialize the byte array message.
This dese
galenwarren commented on code in PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#discussion_r1009894290
##
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java:
##
@@ -57,10 +57,12 @@ private
galenwarren commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297715423
@tzulitai I'm having a couple issues with the playground tests.
First issue, which I've worked around (I think!) is that the build of the
playground projects occurs in a Do
galenwarren commented on code in PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#discussion_r1009848504
##
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java:
##
@@ -57,10 +57,12 @@ private
galenwarren commented on code in PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#discussion_r1009848181
##
pom.xml:
##
@@ -79,11 +79,12 @@ under the License.
3.7.1
2.3.2
3.11.1
-1.14.3
+1.15.2
2.12
2.1
galenwarren commented on code in PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#discussion_r1009844967
##
README.md:
##
@@ -155,7 +155,7 @@ This section contains information for building this project.
2. Build Stateful Functions Docker image: This step requir
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1009804824
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,160 @@
+/*
tzulitai commented on code in PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#discussion_r1009778227
##
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigValidator.java:
##
@@ -57,10 +57,12 @@ private sta
galenwarren commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-129782
@tzulitai Yes, I will run the playground examples and report back.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297554015
@galenwarren could you try that out and report back? If all is good, then +1
to merge this.
--
This is an automated message from the Apache Git Service.
To respond to the message,
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297552879
What I usually like to do before merging a Flink upgrade in StateFun is to
manually test out the upgrade using some of our playground examples. If that
works + CI gives green light
galenwarren commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297546217
Thanks! Yes, you're right, and I didn't figure that out until after the
first commit. I've updated the Flink base image tag and the e2e tests ran
successfully locally. They're ru
tzulitai commented on PR #319:
URL: https://github.com/apache/flink-statefun/pull/319#issuecomment-1297542400
Thanks for opening a PR @galenwarren!
The e2e tests would first build a new local image (which would reference
Flink 1.15.2), and then use that to run the e2e tests.
--
Thi
flinkbot commented on PR #21206:
URL: https://github.com/apache/flink/pull/21206#issuecomment-1297542044
## CI report:
* 4d8f9013cde4d4a8002a5c3153b864a5af21e2e3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
syhily commented on PR #21176:
URL: https://github.com/apache/flink/pull/21176#issuecomment-1297528986
Does this mean that flink won't support Scala by default?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
syhily opened a new pull request, #21206:
URL: https://github.com/apache/flink/pull/21206
## What is the purpose of the change
Add the end-to-end encryption support for Pulsar.
## Brief change log
Add the `CryptoKeyReader` for both Pulsar source and sink. Add encryption
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1297518207
@libenchao
> Thanks for the update. Please do not use 'squash' or 'force-push' unless
you must or the reviewer asks you. (I go through all the codes again, and left
several mino
1 - 100 of 286 matches
Mail list logo
