Dheeraj Panangat created FLINK-31985:
Summary: The currentDate() get transformed to TIMESTAMP_LTZ(3)
instead of DATE()
Key: FLINK-31985
URL: https://issues.apache.org/jira/browse/FLINK-31985
Proje
[
https://issues.apache.org/jira/browse/FLINK-31982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718790#comment-17718790
]
Gyula Fora commented on FLINK-31982:
Strange error, haven’t seen this before. We did
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:03 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:03 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment:
flink--kubernetes-application-0-parked-logs-ingestion-644b80-b4bc58747-lc865.log.zip
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:02 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 3:59 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718781#comment-17718781
]
Zhihao Chen commented on FLINK-31135:
-
hey [~Swathi Chandrashekar], thank you for lo
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-50-54-783.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-51-21-685.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-47-51-440.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment:
parked-logs-ingestion-644b80-3494e4c01b82eb7a75a76080974b41cd-config-map.yaml
> Confi
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: (was: image-2023-05-03-13-26-51-992.png)
> ConfigMap DataSize went > 1 MB and clus
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: (was: image-2023-05-03-13-27-58-256.png)
> ConfigMap DataSize went > 1 MB and clus
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: (was: image-2023-05-03-13-27-44-449.png)
> ConfigMap DataSize went > 1 MB and clus
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: (was: image-2023-05-03-13-27-50-513.png)
> ConfigMap DataSize went > 1 MB and clus
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-1532416372
Had a discussion with @vahmed-hamdy .
1. Added test for GlueCatalog
2. @vahmed-hamdy helped with addressing to review comment
https://github.com/apache/flink-connector-a
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-27-50-513.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-27-58-256.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-26-51-992.png
> ConfigMap DataSize went > 1 MB and cluster stopped
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: image-2023-05-03-13-27-44-449.png
> ConfigMap DataSize went > 1 MB and cluster stopped
Samrat002 commented on code in PR #21458:
URL: https://github.com/apache/flink/pull/21458#discussion_r1183195873
##
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStreamTest.java:
##
@@ -254,6 +254,16 @@ public void
cy2008 commented on code in PR #22498:
URL: https://github.com/apache/flink/pull/22498#discussion_r118318
##
flink-kubernetes/pom.xml:
##
@@ -32,8 +32,20 @@ under the License.
5.12.4
+ 1.6.20
+
+
+
flinkbot commented on PR #22510:
URL: https://github.com/apache/flink/pull/22510#issuecomment-1532284392
## CI report:
* f32dba269446d8d0e85f4c09aabd0accf61729be UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 commented on PR #22510:
URL: https://github.com/apache/flink/pull/22510#issuecomment-1532283384
CC: @dawidwys @pnowojski Could you take a look? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718754#comment-17718754
]
Mingliang Liu commented on FLINK-31984:
---
CC: [~markcho]
> Savepoint on S3 should
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31984:
---
Labels: pull-request-available (was: )
> Savepoint on S3 should be relocatable if entropy i
liuml07 opened a new pull request, #22510:
URL: https://github.com/apache/flink/pull/22510
## What is the purpose of the change
We have a limitation that if we create savepoints with an injected entropy,
they are not relocatable
(https://nightlies.apache.org/flink/flink-docs-master/d
Mingliang Liu created FLINK-31984:
-
Summary: Savepoint on S3 should be relocatable if entropy
injection is not effective
Key: FLINK-31984
URL: https://issues.apache.org/jira/browse/FLINK-31984
Project
mridulm commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1183111493
##
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java:
##
@@ -61,6 +61,9 @@
class YARNSessionFIFOITCase extends YarnTestBase {
privat
venkata91 commented on PR #22509:
URL: https://github.com/apache/flink/pull/22509#issuecomment-1532231171
Tagging @GJL who reviewed the previous PR as well. Please review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
venkata91 commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1183100983
##
flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java:
##
@@ -425,6 +426,8 @@ static ContainerLaunchContext createTaskExecutorContext(
ctx.setEnviro
venkata91 commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1183098373
##
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java:
##
@@ -231,6 +231,25 @@ public class YarnConfigOptions {
[
https://issues.apache.org/jira/browse/FLINK-31983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718742#comment-17718742
]
Archit Goyal commented on FLINK-31983:
--
{*}Note{*}: This PR is based on an earlier
architgyl commented on PR #22509:
URL: https://github.com/apache/flink/pull/22509#issuecomment-1532224535
Tagging @becketqin @venkata91 for review.
--
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
venkata91 commented on code in PR #22509:
URL: https://github.com/apache/flink/pull/22509#discussion_r1183095735
##
.idea/vcs.xml:
##
@@ -3,6 +3,14 @@
+
+
+ https://go/jira $0" />
Review Comment:
remove this file changes?
--
T
Archit Goyal created FLINK-31983:
Summary: Add yarn acls capability to flink containers
Key: FLINK-31983
URL: https://issues.apache.org/jira/browse/FLINK-31983
Project: Flink
Issue Type: New
flinkbot commented on PR #22509:
URL: https://github.com/apache/flink/pull/22509#issuecomment-1532216132
## CI report:
* 2985011adc158078a992871f3ade2e5724a907b5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718741#comment-17718741
]
Archit Goyal commented on FLINK-12869:
--
[~nfraison.criteo] I have raised a PR based
architgyl opened a new pull request, #22509:
URL: https://github.com/apache/flink/pull/22509
## What is the purpose of the change
[FLINK-12869](https://issues.apache.org/jira/browse/FLINK-12869)
This PR provides Yarn application Acl mechanism on Flink containers to be
able to provide s
alainbrown opened a new pull request, #42:
URL: https://github.com/apache/flink-playgrounds/pull/42
With this change, users will not have to create and permission flink job
directories. This is the preferred method of persisting data generated by the
docker container. More here:
http
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718710#comment-17718710
]
Charles Tan commented on FLINK-29692:
-
[~jark] your point makes sense. However, it c
flinkbot commented on PR #22508:
URL: https://github.com/apache/flink/pull/22508#issuecomment-1532017176
## CI report:
* 87d1032190818800f388de9760dc7eca2802799d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rbowen opened a new pull request, #22508:
URL: https://github.com/apache/flink/pull/22508
## What is the purpose of the change
Trivial word deduplication: "and and" and "the the"
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
James Busche created FLINK-31982:
Summary: Build image from source Dockerfile error in main
Key: FLINK-31982
URL: https://issues.apache.org/jira/browse/FLINK-31982
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718686#comment-17718686
]
SwathiChandrashekar commented on FLINK-31135:
-
[~zhihaochen] , looks like fo
[ https://issues.apache.org/jira/browse/FLINK-31135 ]
SwathiChandrashekar deleted comment on FLINK-31135:
-
was (Author: swathi chandrashekar):
[~zhihaochen] , looks flink was getting inconsistent state exception, while
trying to write t
Allison Chang created FLINK-31981:
-
Summary: Enabling waiting on the Flink Application to complete
before returning to Flink client for batch jobs
Key: FLINK-31981
URL: https://issues.apache.org/jira/browse/FLINK-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718663#comment-17718663
]
SwathiChandrashekar edited comment on FLINK-31135 at 5/2/23 5:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718663#comment-17718663
]
SwathiChandrashekar commented on FLINK-31135:
-
[~zhihaochen] , looks flink w
[
https://issues.apache.org/jira/browse/FLINK-31976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31976:
---
Labels: pull-request-available (was: )
> Once marked as an inefficient scale-up, further sc
tankim opened a new pull request, #579:
URL: https://github.com/apache/flink-kubernetes-operator/pull/579
## What is the purpose of the change
Trim the scaling history on get operations
## Brief change log
- *The trimming logic applied to the existing addScaling
eskabetxe commented on PR #22:
URL:
https://github.com/apache/flink-connector-jdbc/pull/22#issuecomment-1531833136
@MartijnVisser all tests pass now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
hlteoh37 commented on code in PR #21458:
URL: https://github.com/apache/flink/pull/21458#discussion_r1182740878
##
flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStreamTest.java:
##
@@ -254,6 +254,16 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718610#comment-17718610
]
Piotr Nowojski commented on FLINK-31963:
Thanks for the answers [~tanee.kim]
{q
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718562#comment-17718562
]
Etienne Chauchot edited comment on FLINK-31927 at 5/2/23 2:54 PM:
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718573#comment-17718573
]
Etienne Chauchot edited comment on FLINK-31927 at 5/2/23 1:31 PM:
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-31927:
-
Summary: Cassandra source raises an exception on Flink 1.16.0 if the user
enables the me
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718573#comment-17718573
]
Etienne Chauchot commented on FLINK-31927:
--
Putting the summary of a private di
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718562#comment-17718562
]
Etienne Chauchot commented on FLINK-31927:
--
This bug has slipped through the IT
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-31927:
-
Summary: Cassandra source raises an exception on Flink 1.16.0 (was:
Cassandra source ra
Hong Liang Teoh created FLINK-31980:
---
Summary: Implement support for EFO in new Source
Key: FLINK-31980
URL: https://issues.apache.org/jira/browse/FLINK-31980
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-16024:
--
Summary: Support filter pushdown in JDBC connector (was: support filter
pushdown in jdbc conn
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182458530
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumeratorStateSerializer.java:
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182451538
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,2
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182407574
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -0,0 +1,148 @@
+/*
+ * License
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-1531336427
1. Created Jira for Constructing Glue Client using AwsGeneralUtils
https://issues.apache.org/jira/browse/FLINK-31979. so i will remove the last
commit on this pr
2. Intiall
Samrat Deb created FLINK-31979:
--
Summary: Constructing Glue Client using AwsGeneralUtils
Key: FLINK-31979
URL: https://issues.apache.org/jira/browse/FLINK-31979
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718529#comment-17718529
]
Vishaal Selvaraj commented on FLINK-20794:
--
[~dian.fu] Can you assign this to m
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718528#comment-17718528
]
Sergey Nuyanzin commented on FLINK-30629:
-
[~Weijie Guo] could you please have a
[
https://issues.apache.org/jira/browse/FLINK-31877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718510#comment-17718510
]
Sergey Nuyanzin edited comment on FLINK-31877 at 5/2/23 10:14 AM:
[
https://issues.apache.org/jira/browse/FLINK-31877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718510#comment-17718510
]
Sergey Nuyanzin commented on FLINK-31877:
-
// cc [~xtsong], [~jark]
> StreamExe
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31108:
--
Fix Version/s: aws-connector-4.2.0
> Use StreamARN for API calls in Kinesis Connector
> --
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718508#comment-17718508
]
Danny Cranmer commented on FLINK-31108:
---
Merged commit
[{{a62e3d8}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31108:
--
Affects Version/s: aws-connector-4.1.0
(was: 1.16.1)
> Use StreamAR
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-31108:
-
Assignee: Hong Liang Teoh
> Use StreamARN for API calls in Kinesis Connector
>
[
https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31108.
---
Resolution: Done
> Use StreamARN for API calls in Kinesis Connector
> --
dannycranmer merged PR #65:
URL: https://github.com/apache/flink-connector-aws/pull/65
--
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..
dannycranmer commented on PR #65:
URL:
https://github.com/apache/flink-connector-aws/pull/65#issuecomment-1531177783
LGTM, thanks @hlteoh37, will merge after actions pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
hlteoh37 commented on code in PR #65:
URL:
https://github.com/apache/flink-connector-aws/pull/65#discussion_r1182318616
##
flink-connector-kinesis/src/main/resources/META-INF/NOTICE:
##
@@ -45,15 +45,15 @@ This project bundles the following dependencies under the
Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31669:
Affects Version/s: 1.18.0
> DynamicFilteringITCase failed fataly because of NoClassDefFoun
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718499#comment-17718499
]
Sergey Nuyanzin commented on FLINK-31669:
-
https://dev.azure.com/apache-flink/ap
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-25779:
-
Assignee: Aleksandr Pilipenko
> Define ConfigOption for aws, scan and sink map in Kines
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Fix Version/s: aws-connector-4.2.0
> Define ConfigOption for aws, scan and sink map in Kinesis
dannycranmer commented on code in PR #65:
URL:
https://github.com/apache/flink-connector-aws/pull/65#discussion_r1182228611
##
flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java:
##
@@ -140,6 +141,9 @@ public class Kinesi
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182231314
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,2
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182229673
##
flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/examples/SourceFromKinesis.java:
##
@@ -0,0 +1,55 @@
+/*
+ * Li
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182228770
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/PollingKinesisShardSplitReader.java:
##
Review Comment
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182228573
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java:
##
@@ -0,0 +1,369 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-31890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-31890:
--
Component/s: Runtime / Coordination
> Introduce JobMaster per-task failure enrichment/labeling
[
https://issues.apache.org/jira/browse/FLINK-31890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek reassigned FLINK-31890:
-
Assignee: Panagiotis Garefalakis
> Introduce JobMaster per-task failure enrichment/labe
[
https://issues.apache.org/jira/browse/FLINK-31941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718481#comment-17718481
]
Usamah Jassat commented on FLINK-31941:
---
I believe this follows the convention tha
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182224015
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java:
##
@@ -0,0 +1,369 @@
+/*
+ *
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1182224015
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java:
##
@@ -0,0 +1,369 @@
+/*
+ *
hlteoh37 commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-aws/pull/70#discussion_r1182191285
##
flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriterTest.java:
##
@@ -0,0 +1,120 @@
+/*
+ * L
ferenc-csaky commented on PR #5:
URL:
https://github.com/apache/flink-connector-hbase/pull/5#issuecomment-1530998138
Hello! The thing is, my original idea of using the `HBaseTestUtility` (HBase
minicluster) for the E2E tests did not work out, because I could not integrate
it with the docke
96 matches
Mail list logo
