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
[
https://issues.apache.org/jira/browse/FLINK-31982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718790#comment-17718790
]
Gyula Fora commented on FLINK-31982:
Strange error, haven’t seen this before. We did not add any new
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:03 AM:
-
hey [~Swathi
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:03 AM:
-
hey [~Swathi
[
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=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 4:02 AM:
-
hey [~Swathi
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718781#comment-17718781
]
Zhihao Chen edited comment on FLINK-31135 at 5/3/23 3:59 AM:
-
hey [~Swathi
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718781#comment-17718781
]
Zhihao Chen commented on FLINK-31135:
-
hey [~Swathi Chandrashekar], thank you for looking into it.
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
[
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
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://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
[
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
[
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
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718754#comment-17718754
]
Mingliang Liu commented on FLINK-31984:
---
CC: [~markcho]
> Savepoint on S3 should be relocatable
[
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
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
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
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 {
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
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(
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=17718742#comment-17718742
]
Archit Goyal commented on FLINK-31983:
--
{*}Note{*}: This PR is based on an earlier PR and I have
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
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?
--
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=17718741#comment-17718741
]
Archit Goyal commented on FLINK-12869:
--
[~nfraison.criteo] I have raised a PR based on the
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
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:
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718710#comment-17718710
]
Charles Tan commented on FLINK-29692:
-
[~jark] your point makes sense. However, it can be cumbersome
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
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=17718686#comment-17718686
]
SwathiChandrashekar commented on FLINK-31135:
-
[~zhihaochen] , looks like for
jobId:
[ 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
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-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17718663#comment-17718663
]
SwathiChandrashekar commented on FLINK-31135:
-
[~zhihaochen] , looks flink was getting
[
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
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
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=17718610#comment-17718610
]
Piotr Nowojski commented on FLINK-31963:
Thanks for the answers [~tanee.kim]
{quote}
It happens
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718562#comment-17718562
]
Etienne Chauchot edited comment on FLINK-31927 at 5/2/23 2:54 PM:
--
This
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718573#comment-17718573
]
Etienne Chauchot commented on FLINK-31927:
--
Putting the summary of a private discussion with
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718562#comment-17718562
]
Etienne Chauchot commented on FLINK-31927:
--
This bug has slipped through the ITests because, in
[
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
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:
[
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
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
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 @@
+/*
+ *
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.
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:
[
https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718529#comment-17718529
]
Vishaal Selvaraj commented on FLINK-20794:
--
[~dian.fu] Can you assign this to me?
> Support to
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718528#comment-17718528
]
Sergey Nuyanzin commented on FLINK-30629:
-
[~Weijie Guo] could you please have a look here?
>
[
https://issues.apache.org/jira/browse/FLINK-31877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17718510#comment-17718510
]
Sergey Nuyanzin commented on FLINK-31877:
-
// cc [~xtsong], [~jark]
>
[
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=17718508#comment-17718508
]
Danny Cranmer commented on FLINK-31108:
---
Merged commit
[
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
[
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:
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718499#comment-17718499
]
Sergey Nuyanzin commented on FLINK-31669:
-
[
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
[
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
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
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
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 @@
+/*
+ *
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-31941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718481#comment-17718481
]
Usamah Jassat commented on FLINK-31941:
---
I believe this follows the convention that we use in
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 @@
+/*
+ *
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
96 matches
Mail list logo
