[
https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-29492:
---
Description:
My Kafka exactly-once sinks are periodically failing with a {{OutOfMemoryError:
[
https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611829#comment-17611829
]
Robert Metzger commented on FLINK-28250:
Thanks a lot for the fix.
I've opened a
Robert Metzger created FLINK-29492:
--
Summary: Kafka exactly-once sink causes OutOfMemoryError
Key: FLINK-29492
URL: https://issues.apache.org/jira/browse/FLINK-29492
Project: Flink
Issue Typ
Jingsong Lee created FLINK-29491:
Summary: Primary key without partition field can be supported from
full changelog
Key: FLINK-29491
URL: https://issues.apache.org/jira/browse/FLINK-29491
Project: Fli
Jingsong Lee created FLINK-29490:
Summary: Timestamp LTZ is unsupported in table store
Key: FLINK-29490
URL: https://issues.apache.org/jira/browse/FLINK-29490
Project: Flink
Issue Type: Bug
flinkbot commented on PR #20935:
URL: https://github.com/apache/flink/pull/20935#issuecomment-1264115737
## CI report:
* 03bf998619ad1f5ceae2eb1c067a27837c7b0b37 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 commented on PR #20935:
URL: https://github.com/apache/flink/pull/20935#issuecomment-1264113384
CC @knaufk @MartijnVisser
--
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
liuml07 opened a new pull request, #20935:
URL: https://github.com/apache/flink/pull/20935
## What is the purpose of the change
Make referencing custom image clearer for Docker
## Brief change log
hotfix
## Verifying this change
Please make sure both new and
stevenzwu commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1264009972
@leletan we shall come back to this PR after the internal class renaming is
merged. Please create a jira and PR for that first.
--
This is an automated message from the Apache Git Ser
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1263952346
As per discussion
https://github.com/apache/flink/pull/20852#issuecomment-1260402519, will
address the internal class renaming in a follow up PR.
--
This is an automated message from t
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1263951145
@pnowojski Your comments and change requests should all be addressed. Please
let me know if I miss anything. Thanks!
--
This is an automated message from the Apache Git Service.
To resp
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1263949515
@stevenzwu All your comments should be addressed. Please let me know if
there is anything missing. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r984896568
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r984896981
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -511,6 +514,42 @@ public CompletableFuture
triggerCheckpoint(boolea
leletan commented on code in PR #20852:
URL: https://github.com/apache/flink/pull/20852#discussion_r984896360
##
flink-core/src/main/java/org/apache/flink/core/execution/CheckpointType.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+
flinkbot commented on PR #20934:
URL: https://github.com/apache/flink/pull/20934#issuecomment-1263891667
## CI report:
* 6cbcae8c6e692a220051d1361de480c41f106ef0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #20934:
URL: https://github.com/apache/flink/pull/20934
Bumps [pulsar-broker](https://github.com/apache/pulsar) from 2.10.0 to
2.10.1.
Release notes
Sourced from https://github.com/apache/pulsar/releases";>pulsar-broker's
releases.
stevenzwu commented on PR #19537:
URL: https://github.com/apache/flink/pull/19537#issuecomment-1263847172
@matriv is this PR blocked by
https://issues.apache.org/jira/browse/FLINK-17224 and
https://issues.apache.org/jira/browse/FLINK-27331? Without them, will the
converters btw Flink RowDa
lindong28 commented on code in PR #158:
URL: https://github.com/apache/flink-ml/pull/158#discussion_r984668405
##
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VarianceThresholdSelectorTest.java:
##
@@ -0,0 +1,294 @@
+/*
+ * Licensed to the Apache Software Foundation (A
Justin created FLINK-29489:
--
Summary: Display issue when querying complex, deeply nested fields
Key: FLINK-29489
URL: https://issues.apache.org/jira/browse/FLINK-29489
Project: Flink
Issue Type: Bug
alpinegizmo commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r984666197
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value, Co
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611629#comment-17611629
]
Huang Xingbo commented on FLINK-29427:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611628#comment-17611628
]
Huang Xingbo commented on FLINK-29427:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611627#comment-17611627
]
Huang Xingbo commented on FLINK-29419:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611617#comment-17611617
]
Huang Xingbo commented on FLINK-29483:
--
[~jackylau] You means your job runs in `thr
zentol commented on code in PR #20930:
URL: https://github.com/apache/flink/pull/20930#discussion_r984616865
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/OperatorIdentifier.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache Softwar
alpinegizmo commented on code in PR #20930:
URL: https://github.com/apache/flink/pull/20930#discussion_r984612707
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/OperatorIdentifier.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed to the Apache So
XComp commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r982266603
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java:
##
@@ -42,10 +51,10 @@ class RetryOnEx
RyanSkraba commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r984598630
##
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java:
##
@@ -42,10 +51,10 @@ class Retr
RyanSkraba commented on code in PR #20805:
URL: https://github.com/apache/flink/pull/20805#discussion_r984596066
##
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/retry/strategy/RetryOnExceptionStrategy.java:
##
@@ -37,6
[
https://issues.apache.org/jira/browse/FLINK-29484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot closed FLINK-29484.
Resolution: Won't Fix
Closing because it is already available by overriding
SourceTestSui
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611580#comment-17611580
]
Matthias Pohl commented on FLINK-29485:
---
A similar issue exists for {{StatefulJobS
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-29485:
-
Assignee: Matthias Pohl
> TypeSerializerUpgradeTestBase still uses 1.15 as the current
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29485:
--
Affects Version/s: (was: 1.17.0)
> TypeSerializerUpgradeTestBase still uses 1.15 as the cu
[
https://issues.apache.org/jira/browse/FLINK-29484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611578#comment-17611578
]
Etienne Chauchot commented on FLINK-29484:
--
It seems _UnorderedCollectIteratorA
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29485:
--
Priority: Blocker (was: Critical)
> TypeSerializerUpgradeTestBase still uses 1.15 as the curr
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-29485:
--
Summary: TypeSerializerUpgradeTestBase still uses 1.15 as the current
version on master and re
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611564#comment-17611564
]
Matthias Pohl edited comment on FLINK-29485 at 9/30/22 12:45 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611564#comment-17611564
]
Matthias Pohl commented on FLINK-29485:
---
Using {{FlinkVerions.current()}} doesn't
[
https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29476:
--
Fix Version/s: 1.16.1
> Kinesis Connector retry mechanism not applied to EOFException
> --
[
https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29476:
--
Fix Version/s: 1.17.0
> Kinesis Connector retry mechanism not applied to EOFException
> --
[
https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29476:
--
Fix Version/s: 1.15.3
> Kinesis Connector retry mechanism not applied to EOFException
> --
dannycranmer commented on PR #20927:
URL: https://github.com/apache/flink/pull/20927#issuecomment-1263505523
Thanks @afedulov, LGTM.
Can you please also open a PR against `release-1.16` and `release-1.15`?
--
This is an automated message from the Apache Git Service.
To respond to th
dannycranmer commented on PR #20927:
URL: https://github.com/apache/flink/pull/20927#issuecomment-1263505008
@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 comme
XComp commented on code in PR #19780:
URL: https://github.com/apache/flink/pull/19780#discussion_r983718553
##
flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java:
##
@@ -24,50 +24,52 @@
import org.apache.flink.core.memory.DataInput
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611543#comment-17611543
]
Chesnay Schepler commented on FLINK-29387:
--
Running the test multiple times in
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611537#comment-17611537
]
Samrat Deb commented on FLINK-29478:
haha :D Thank you
> Flink sql Connector hive
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-29478:
--
Assignee: Samrat Deb
> Flink sql Connector hive to support 3.1.3
> -
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611525#comment-17611525
]
Martijn Visser commented on FLINK-29478:
Ah lol that's even my own ticket :D
I
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611522#comment-17611522
]
Samrat Deb edited comment on FLINK-29478 at 9/30/22 11:36 AM:
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611522#comment-17611522
]
Samrat Deb commented on FLINK-29478:
Thanks [~martijnvisser] for your input
there
[
https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28291:
-
Fix Version/s: (was: 1.13.5)
> Add kerberos delegation token renewer feature instead
[
https://issues.apache.org/jira/browse/FLINK-29487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29487:
---
Labels: pull-request-available (was: )
> RpcService should implement AutoCloseableAsync
> -
[
https://issues.apache.org/jira/browse/FLINK-29488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29488:
---
Labels: pull-request-available (was: )
> MetricRegistryImpl should implement AutoCloseableA
flinkbot commented on PR #20933:
URL: https://github.com/apache/flink/pull/20933#issuecomment-1263450070
## CI report:
* 2b68e500b93936eba18d6d9352b5735d8f9ec898 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20932:
URL: https://github.com/apache/flink/pull/20932#issuecomment-1263449935
## CI report:
* 9255ea9840abf5ebeed5afef552f2feb9b86d59d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611520#comment-17611520
]
Chesnay Schepler commented on FLINK-29330:
--
Should LeaderRetrievalService reall
[
https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611520#comment-17611520
]
Chesnay Schepler edited comment on FLINK-29330 at 9/30/22 11:20 AM:
--
Chesnay Schepler created FLINK-29488:
Summary: MetricRegistryImpl should implement AutoCloseableAsync
Key: FLINK-29488
URL: https://issues.apache.org/jira/browse/FLINK-29488
Project: Flink
Chesnay Schepler created FLINK-29487:
Summary: RpcService should implement AutoCloseableAsync
Key: FLINK-29487
URL: https://issues.apache.org/jira/browse/FLINK-29487
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29487:
-
Component/s: Runtime / RPC
(was: Runtime / Coordination)
> RpcServi
[
https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16908:
---
Fix Version/s: (was: 1.17.0)
> FlinkKafkaProducerITCase testScaleUpAfterScalingDown Time
[
https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-21307:
---
Fix Version/s: (was: 1.17.0)
> Revisit activation model of FlinkSecurityManager
> --
[
https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15550:
---
Fix Version/s: (was: 1.17.0)
> testCancelTaskExceptionAfterTaskMarkedFailed failed on az
[
https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26568:
---
Fix Version/s: (was: 1.17.0)
> BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlo
[
https://issues.apache.org/jira/browse/FLINK-23970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-23970:
---
Fix Version/s: (was: 1.17.0)
> Split off the behaviour for finished StreamTask(s)
>
snuyanzin commented on PR #20922:
URL: https://github.com/apache/flink/pull/20922#issuecomment-1263431047
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
ferenc-csaky commented on code in PR #20542:
URL: https://github.com/apache/flink/pull/20542#discussion_r984470999
##
flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java:
##
@@ -191,8 +195,10 @@ private void chec
[
https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611505#comment-17611505
]
Ferenc Csaky commented on FLINK-28910:
--
My HBase knowledge is a bit rusty, so bear
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611497#comment-17611497
]
Martijn Visser commented on FLINK-29478:
Instead of keep adding newer versions o
zentol commented on code in PR #20893:
URL: https://github.com/apache/flink/pull/20893#discussion_r984453514
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java:
##
@@ -40,4 +40,13 @@
public boolean filter(T value, Context
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611494#comment-17611494
]
Zakelly Lan commented on FLINK-29437:
-
After offline sync with [~ym] , we agree to f
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-29480:
--
Description:
As reported in [1], it seems that it's not possible to skip invalid messages
when writing. More
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-29480:
--
Description:
As reported in [1], it seems that it's not possible to skip invalid messages
when writing. More
flinkbot commented on PR #20931:
URL: https://github.com/apache/flink/pull/20931#issuecomment-1263369448
## CI report:
* 32763443345314018b4c308bc6a8d83c43491fdf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20930:
URL: https://github.com/apache/flink/pull/20930#issuecomment-1263364132
## CI report:
* 3366ecff5109a8ba5c64a4b2b603f319d0bc3750 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuzelin opened a new pull request, #20931:
URL: https://github.com/apache/flink/pull/20931
## What is the purpose of the change
The current `SqlCommandParserImpl` for SQL client use the paser of embedded
`TableEnvironment`, which cannot be fetched in remote mode. So this PR
intro
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611478#comment-17611478
]
Samrat Deb commented on FLINK-29478:
Thank you [~dannycranmer] for addressing to thi
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29486:
---
Labels: pull-request-available (was: )
> Enable SQL Client to Connect SQL Gateway in Remote
[
https://issues.apache.org/jira/browse/FLINK-29455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29455:
---
Labels: pull-request-available (was: )
> Add OperatorIdentifier
> --
>
zentol opened a new pull request, #20930:
URL: https://github.com/apache/flink/pull/20930
This PR introduces an `OperatorIdentifier`, an abstraction over uid
(hashes), and integrates it into the internal state-processing APIs.
In a follow-up PR we'll adjust the user-facing APIs to all
zhipeng93 merged PR #155:
URL: https://github.com/apache/flink-ml/pull/155
--
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
zhipeng93 commented on PR #155:
URL: https://github.com/apache/flink-ml/pull/155#issuecomment-1263355508
Thanks for the update. Merging.
--
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 specif
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611469#comment-17611469
]
Huang Xingbo commented on FLINK-29479:
--
[~jackylau] From my side, the users depende
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29486:
Description: In [FLIP-24] and
[FLIP-91|https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%3A+Suppo
[
https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611467#comment-17611467
]
Chesnay Schepler commented on FLINK-29471:
--
elasticsearch-main: 6e30d5d63d395b2
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/1#issuecomment-1263341587
You can avoid a lot of boilerplate by using the preliminary
flink-connector-parent pom as shown here:
https://github.com/apache/flink-connector-elasticsearch/commit/6e30d5d63d3
[
https://issues.apache.org/jira/browse/FLINK-29372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29372.
Resolution: Fixed
> Add a suffix to keys that violate YAML spec
>
zentol merged PR #40:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/40
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29486:
Description: In
[FLIP-24|https://cwiki.apache.org/confluence/display/FLINK/FLIP-24%3A+SQL+Client]
and
[
[
https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29486:
Description: In [FLIP-24|http://example.com] and [FLIP-91|], the SQL
client was designed to has two mode:
[
https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29471:
-
Fix Version/s: elasticsearch-3.0.0
> Create a flink-connector-parent pom
> -
yuzelin created FLINK-29486:
---
Summary: Enable SQL Client to Connect SQL Gateway in Remote Mode
Key: FLINK-29486
URL: https://issues.apache.org/jira/browse/FLINK-29486
Project: Flink
Issue Type: New
Matthias Pohl created FLINK-29485:
-
Summary: TypeSerializerUpgradeTestBase doesn't use
FlinkVersions.current()
Key: FLINK-29485
URL: https://issues.apache.org/jira/browse/FLINK-29485
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29350:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Add a section for moving planner ja
[
https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-28071:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Support missing built-in functions
[
https://issues.apache.org/jira/browse/FLINK-27467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-27467:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Remove CliFrontendTestBase
> --
[
https://issues.apache.org/jira/browse/FLINK-29372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29372:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Add a suffix to keys that violate Y
[
https://issues.apache.org/jira/browse/FLINK-29430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29430:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Sanity check in InternalKeyContextI
[
https://issues.apache.org/jira/browse/FLINK-27432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-27432:
-
Fix Version/s: 1.17.0
(was: 1.16.0)
> Replace Time with Duration in TaskS
1 - 100 of 371 matches
Mail list logo
