xintongsong commented on code in PR #20796:
URL: https://github.com/apache/flink/pull/20796#discussion_r969162160
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexImplTest.java:
##
@@ -54,23 +54,32 @@ void before() {
@Test
pvary commented on code in PR #366:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/366#discussion_r969157975
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java:
##
@@ -58,36 +58,40 @@ public
[
https://issues.apache.org/jira/browse/FLINK-29275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tally closed FLINK-29275.
-
Resolution: Later
> Temporal Table function: Cannot add expression of different type to set
>
JingsongLi commented on code in PR #291:
URL: https://github.com/apache/flink-table-store/pull/291#discussion_r969135349
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/memory/MemoryPoolFactory.java:
##
@@ -78,20 +85,27 @@ public int pageSize() {
[
https://issues.apache.org/jira/browse/FLINK-29276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29276:
-
Component/s: Table Store
> Flush all memory in SortBufferMemTable.clear
>
[
https://issues.apache.org/jira/browse/FLINK-29276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29276:
-
Fix Version/s: table-store-0.3.0
> Flush all memory in SortBufferMemTable.clear
>
Jingsong Lee created FLINK-29276:
Summary: Flush all memory in SortBufferMemTable.clear
Key: FLINK-29276
URL: https://issues.apache.org/jira/browse/FLINK-29276
Project: Flink
Issue Type:
Tally created FLINK-29275:
-
Summary: Temporal Table function: Cannot add expression of
different type to set
Key: FLINK-29275
URL: https://issues.apache.org/jira/browse/FLINK-29275
Project: Flink
fsk119 commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r969132854
##
docs/content.zh/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
reswqa commented on PR #20796:
URL: https://github.com/apache/flink/pull/20796#issuecomment-1244874893
@xintongsong Thanks for the review, comments of the first commit has been
resolved.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
reswqa commented on code in PR #20796:
URL: https://github.com/apache/flink/pull/20796#discussion_r969131791
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManagerTest.java:
##
@@ -340,6 +341,57 @@ void
[
https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29273:
---
Labels: pull-request-available (was: )
> Page not enough Exception in SortBufferMemTable
>
JingsongLi opened a new pull request, #291:
URL: https://github.com/apache/flink-table-store/pull/291
When there are many partitions, the partition writer will seize memory and
may have the memory not enough exceptions.
We need to make sure that the writer has enough memory before it can
[
https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29273:
Assignee: Jingsong Lee
> Page not enough Exception in SortBufferMemTable
>
reswqa commented on PR #20739:
URL: https://github.com/apache/flink/pull/20739#issuecomment-1244858068
@zhuzhurk Thank you for reviewing this pr, I have addressed your comments in
a fix-up commit, PTAL~
--
This is an automated message from the Apache Git Service.
To respond to the
flinkbot commented on PR #20819:
URL: https://github.com/apache/flink/pull/20819#issuecomment-1244857059
## CI report:
* d0888cfc13f74f8a2d932127529dda2e6592e995 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa commented on code in PR #20739:
URL: https://github.com/apache/flink/pull/20739#discussion_r969117632
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java:
##
@@ -301,10 +335,12 @@ private boolean
yuzelin commented on code in PR #20719:
URL: https://github.com/apache/flink/pull/20719#discussion_r966793400
##
docs/content/docs/dev/table/sql-gateway/overview.md:
##
@@ -0,0 +1,226 @@
+---
+title: Overview
+weight: 1
+type: docs
+aliases:
+- /dev/table/sql-gateway.html
+---
PatrickRen opened a new pull request, #20819:
URL: https://github.com/apache/flink/pull/20819
Unchanged backport of #20760 on release-1.16
--
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
reswqa commented on code in PR #20739:
URL: https://github.com/apache/flink/pull/20739#discussion_r969116344
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java:
##
@@ -281,10 +313,12 @@ private boolean
reswqa commented on code in PR #20739:
URL: https://github.com/apache/flink/pull/20739#discussion_r969115835
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java:
##
@@ -61,7 +62,8 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-29102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603317#comment-17603317
]
Xingbo Huang commented on FLINK-29102:
--
Hi [~Yanfei Lei] any updates on this issue?
>
[
https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-28398:
-
Priority: Major (was: Critical)
>
[
https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603316#comment-17603316
]
Xingbo Huang commented on FLINK-28398:
--
Given that it hasn't appeared for two months, I will
[
https://issues.apache.org/jira/browse/FLINK-28627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-28627.
Resolution: Cannot Reproduce
Given that it hasn't appeared for two months, I will close this
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-28898:
-
Priority: Major (was: Critical)
>
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603314#comment-17603314
]
Qingsheng Ren commented on FLINK-28975:
---
Fixed on master: d62df6899a1d7bd92ae998d3b610aa8b4de64505
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603313#comment-17603313
]
Xingbo Huang commented on FLINK-28898:
--
Given that it hasn't appeared for a month, I will downgrade
[
https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-28901:
-
Priority: Major (was: Critical)
> CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed
[
https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603312#comment-17603312
]
Xingbo Huang commented on FLINK-28901:
--
Given that it hasn't appeared for a month, I will downgrade
[
https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29031:
-
Priority: Major (was: Critical)
> FlinkKinesisConsumerTest.testSourceSynchronization failed
[
https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29008:
-
Priority: Major (was: Critical)
> SortMergeResultPartitionTest.testRelease failed with
[
https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603311#comment-17603311
]
Xingbo Huang commented on FLINK-29008:
--
Given that it hasn't appeared for a month, I will downgrade
[
https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603310#comment-17603310
]
Xingbo Huang commented on FLINK-29031:
--
Given that it hasn't appeared for a month, I will downgrade
PatrickRen merged PR #20760:
URL: https://github.com/apache/flink/pull/20760
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-29092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29092:
-
Priority: Major (was: Critical)
> HadoopPathBasedPartFileWriterTest.testWriteFile failed with
[
https://issues.apache.org/jira/browse/FLINK-29147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29147.
Resolution: Duplicate
> ChangelogLocalRecoveryITCase.testRestartTM failed with
[
https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-27691.
Resolution: Cannot Reproduce
Given that it hasn't appeared for a month, I will close this issue.
[
https://issues.apache.org/jira/browse/FLINK-29274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603306#comment-17603306
]
Xingbo Huang commented on FLINK-29274:
--
[~yzl] Could you help take a look? Thx.
>
Xingbo Huang created FLINK-29274:
Summary: HiveServer2EndpointITCase.testGetFunctionWithPattern
failed with Persistence Manager has been closed
Key: FLINK-29274
URL:
[
https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29273:
-
Description:
When there are many partitions, the partition writer will seize memory and may
[
https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29273:
-
Attachment: screenshot-1.png
> Page not enough Exception in SortBufferMemTable
>
[
https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-29273:
-
Description: !screenshot-1.png! (was:
!image-2022-09-13-11-03-07-855.png! )
> Page not
Jingsong Lee created FLINK-29273:
Summary: Page not enough Exception in SortBufferMemTable
Key: FLINK-29273
URL: https://issues.apache.org/jira/browse/FLINK-29273
Project: Flink
Issue Type:
Jingsong Lee created FLINK-29272:
Summary: Document DataStream API (DataStream to Table) for table
store
Key: FLINK-29272
URL: https://issues.apache.org/jira/browse/FLINK-29272
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiangjiguang0719 updated FLINK-29271:
-
Description: I have done a test to compare byte array and bytebuffer, 40%
performance
[
https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603303#comment-17603303
]
jiangjiguang0719 commented on FLINK-29271:
--
please assign me the issue, I will submit a pr.
jiangjiguang0719 created FLINK-29271:
Summary: Change to byte array from bytebuffer to improve
performance when reading parquet file
Key: FLINK-29271
URL: https://issues.apache.org/jira/browse/FLINK-29271
HuangXingBo closed pull request #20788: [hotfix][python] Fix typo in PyFlink's
JsonRowDeserializationSchema
URL: https://github.com/apache/flink/pull/20788
--
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
[
https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Hilmi Al Fatih updated FLINK-29270:
Description:
I did a very simple kafka-to-kafka pipeline with flink
[
https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammad Hilmi Al Fatih updated FLINK-29270:
Description:
I did a very simple kafka-to-kafka pipeline with flink
Muhammad Hilmi Al Fatih created FLINK-29270:
---
Summary: Wrong metrics kafka producer (FlinkKafkaProducer,
KafkaSink) in EXACTLY_ONCE
Key: FLINK-29270
URL:
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603301#comment-17603301
]
Qingsheng Ren commented on FLINK-24119:
---
Should be fixed by FLINK-29153. Please reopen the ticket
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-24119.
-
Fix Version/s: 1.16.0
Assignee: Qingsheng Ren
Resolution: Fixed
>
PatrickRen commented on PR #20760:
URL: https://github.com/apache/flink/pull/20760#issuecomment-1244815251
@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
[
https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29018.
-
Resolution: Fixed
> KafkaITCase.testMultipleSourcesOnePartition failed with
[
https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603300#comment-17603300
]
Qingsheng Ren commented on FLINK-29018:
---
Should be fixed by FLINK-29153. Please reopen the issue
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29153.
-
Resolution: Fixed
> KafkaConsumerThread should catch WakeupException when committing offsets
>
[
https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602076#comment-17602076
]
Qingsheng Ren edited comment on FLINK-29153 at 9/13/22 2:20 AM:
Fixed on
reswqa commented on code in PR #20796:
URL: https://github.com/apache/flink/pull/20796#discussion_r969078333
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManagerTest.java:
##
@@ -340,6 +341,57 @@ void
PatrickRen merged PR #20794:
URL: https://github.com/apache/flink/pull/20794
--
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:
reswqa commented on code in PR #20796:
URL: https://github.com/apache/flink/pull/20796#discussion_r969078015
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManager.java:
##
@@ -192,19 +192,22 @@ public void
reswqa commented on code in PR #20796:
URL: https://github.com/apache/flink/pull/20796#discussion_r969077225
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionView.java:
##
@@ -85,10 +86,12 @@ public BufferAndBacklog
bobby-richard commented on code in PR #20048:
URL: https://github.com/apache/flink/pull/20048#discussion_r969023378
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java:
##
@@ -59,6 +63,25 @@ public
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r968928532
##
flink-core/src/main/java/org/apache/flink/api/connector/source/SourceReaderContext.java:
##
@@ -63,4 +63,11 @@ public interface SourceReaderContext {
* @see
afedulov commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r968925284
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GuavaRateLimiter.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-29268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29268:
---
Labels: pull-request-available (was: )
> Sync 1.16.0 code to ES repo
>
zentol commented on PR #30:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/30#issuecomment-1244273840
Should be everything 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
[
https://issues.apache.org/jira/browse/FLINK-29269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29269:
-
Description:
Logging isn't setup on CI, which breaks some tests that rely on certain
Chesnay Schepler created FLINK-29269:
Summary: Setup CI logging
Key: FLINK-29269
URL: https://issues.apache.org/jira/browse/FLINK-29269
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #20818:
URL: https://github.com/apache/flink/pull/20818#issuecomment-1244205057
## CI report:
* 5a761b83274189f59204c52e11d2a14aa71fb343 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Chesnay Schepler created FLINK-29268:
Summary: Sync 1.16.0 code to ES repo
Key: FLINK-29268
URL: https://issues.apache.org/jira/browse/FLINK-29268
Project: Flink
Issue Type: Sub-task
zentol opened a new pull request, #20818:
URL: https://github.com/apache/flink/pull/20818
1.16 backport of #20814.
--
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
[
https://issues.apache.org/jira/browse/FLINK-25868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603228#comment-17603228
]
Chesnay Schepler commented on FLINK-25868:
--
master:
zentol merged PR #20817:
URL: https://github.com/apache/flink/pull/20817
--
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:
zentol merged PR #20814:
URL: https://github.com/apache/flink/pull/20814
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-29224.
-
Fix Version/s: 1.17.0
(was: 1.16.0)
Resolution: Fixed
> flink-mirror does
[
https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603225#comment-17603225
]
Jing Ge commented on FLINK-29224:
-
fixed
> flink-mirror does not pick up the new release branch 1.16
>
[
https://issues.apache.org/jira/browse/FLINK-26876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-26876.
--
Resolution: Duplicate
> flink-statebackend-rocksdb EmbeddedRocksDBStateBackend crashing on
[
https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-25756:
-
Component/s: (was: Connectors / Common)
> Dedicated Opensearch connectors
>
[
https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-25756:
-
Fix Version/s: opensearch-1.0.0
> Dedicated Opensearch connectors
>
[
https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-25756:
-
Component/s: Connectors / Opensearch
> Dedicated Opensearch connectors
>
[
https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-29267:
-
Description:
Many connectors and formats require supporting external data types. Postgres
dannycranmer commented on code in PR #569:
URL: https://github.com/apache/flink-web/pull/569#discussion_r968631259
##
_posts/2022-09-08-release-1.14.6.md:
##
@@ -0,0 +1,111 @@
+---
+layout: post
+title: "Apache Flink 1.14.6 Release Announcement"
+date: 2022-09-08T00:00:00.000Z
dannycranmer commented on PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#issuecomment-1243981647
Please rebase on `main` after this is merged
https://github.com/apache/flink-connector-dynamodb/pull/2
--
This is an automated message from the Apache Git Service.
To
dannycranmer commented on PR #2:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/2#issuecomment-1243980963
Github actions tested in separate dummy PR
https://github.com/apache/flink-connector-dynamodb/pull/3/checks
--
This is an automated message from the Apache Git
dannycranmer closed pull request #3: Dummy commit to test github actions
URL: https://github.com/apache/flink-connector-dynamodb/pull/3
--
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
dannycranmer commented on PR #3:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/3#issuecomment-1243980272
Github actions/checks work and pass.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dannycranmer merged PR #2:
URL: https://github.com/apache/flink-connector-dynamodb/pull/2
--
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 code in PR #2:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/2#discussion_r968612852
##
tools/maven/checkstyle.xml:
##
@@ -0,0 +1,567 @@
+
+
+http://www.puppycrawl.com/dtds/configuration_1_3.dtd;>
+
+
+
+
+
+
+
+
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-23886:
---
Affects Version/s: 1.14.4
1.13.5
> An exception is thrown out when
pnowojski commented on PR #20485:
URL: https://github.com/apache/flink/pull/20485#issuecomment-1243913279
> On another note, do you think it makes sense to add a configuration option
to disable using split alignment entirely? I'm a bit worried this feature might
cause issues with the
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603137#comment-17603137
]
Tommy Schnabel commented on FLINK-23886:
Hi there, reporting in from Twilio Segment that we've
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tommy Schnabel updated FLINK-23886:
---
Attachment: segment-drop-corrupted-timer-state.diff
> An exception is thrown out when
Timo Walther created FLINK-29267:
Summary: Support external type systems in DDL
Key: FLINK-29267
URL: https://issues.apache.org/jira/browse/FLINK-29267
Project: Flink
Issue Type: Improvement
morhidi commented on PR #366:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/366#issuecomment-1243870820
cc @gaborgsomogyi @pvary @tweise
--
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
zentol commented on PR #30:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/30#issuecomment-1243855723
more to come!
--
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
Chesnay Schepler created FLINK-29266:
Summary: Cleanup ES root pom
Key: FLINK-29266
URL: https://issues.apache.org/jira/browse/FLINK-29266
Project: Flink
Issue Type: Technical Debt
Chesnay Schepler created FLINK-29265:
Summary: Update ES version to 3.0-SNAPSHOT
Key: FLINK-29265
URL: https://issues.apache.org/jira/browse/FLINK-29265
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-29264:
Summary: Give ES parent module a proper artifact ID
Key: FLINK-29264
URL: https://issues.apache.org/jira/browse/FLINK-29264
Project: Flink
Issue
1 - 100 of 232 matches
Mail list logo
