Francesco Guardiani created FLINK-24499:
---
Summary: OVER IGNORE NULLS support
Key: FLINK-24499
URL: https://issues.apache.org/jira/browse/FLINK-24499
Project: Flink
Issue Type: New Featu
Francesco Guardiani created FLINK-24500:
---
Summary: Move SqlDateTimeUtils to table-common
Key: FLINK-24500
URL: https://issues.apache.org/jira/browse/FLINK-24500
Project: Flink
Issue Typ
Hello Devs,
Here is my custom sink code.
`
public class FlinkNeptuneSink extends RichSinkFunction {
static HttpClient client = HttpClient.newHttpClient();
private static final long serialVersionUID = 1L;
NeptuneClientFactory neptuneClientFactory;
JsonLDWr
JING ZHANG created FLINK-24501:
--
Summary: Unexpected behavior of cumulate window aggregate for late
event after recover from sp/cp
Key: FLINK-24501
URL: https://issues.apache.org/jira/browse/FLINK-24501
Thanks a lot for this effort Chesnay! The improvements sound really good.
Cheers,
Till
On Mon, Oct 11, 2021 at 8:46 AM David Morávek wrote:
> Nice! Thanks for the effort Chesnay, this is really a huge step forward!
>
> Best,
> D.
>
> On Mon, Oct 11, 2021 at 6:02 AM Xintong Song
> wrote:
>
> >
Hi Jigar,
in order to run the Sink function on the Flink cluster, it will be
serialized. Since you marked the repository as transient, it won't be
shipped to the cluster. So if Repository is Serializable, you can ship it
to the cluster. If not, then you need to reconstruct the Repository on the
cl
Xintong Song created FLINK-24502:
Summary: Automate updating of `MigrationVersion` and migration
tests.
Key: FLINK-24502
URL: https://issues.apache.org/jira/browse/FLINK-24502
Project: Flink
LI Zhennan created FLINK-24503:
--
Summary: Security: native kubernetes exposes REST service via
LoadBalancer in default
Key: FLINK-24503
URL: https://issues.apache.org/jira/browse/FLINK-24503
Project: Fli
Lyn Zhang created FLINK-24504:
-
Summary: Flink udf common expression elimination
Key: FLINK-24504
URL: https://issues.apache.org/jira/browse/FLINK-24504
Project: Flink
Issue Type: Improvement
Matthias created FLINK-24505:
Summary:
org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest
Key: FLINK-24505
URL: https://issues.apache.org/jira/browse/FLINK-24505
Projec
Matthias created FLINK-24506:
Summary: checkpoint directory is not configurable through the
Flink configuration passed into the StreamExecutionEnvironment
Key: FLINK-24506
URL: https://issues.apache.org/jira/browse/FL
Hi all,
Looking at the TableResult type I was wondering, given the interface has
await methods, should we instead implement the JDK's Future as
Future> and deprecate the await methods?
This should allow users to integrate with other JDK types without going
through the conversion from TableResult t
Great initiative, thanks for doing this!
On Mon, Oct 11, 2021 at 10:52 AM Till Rohrmann wrote:
> Thanks a lot for this effort Chesnay! The improvements sound really good.
>
> Cheers,
> Till
>
> On Mon, Oct 11, 2021 at 8:46 AM David Morávek wrote:
>
> > Nice! Thanks for the effort Chesnay, this
Francesco Guardiani created FLINK-24507:
---
Summary: Cleanup all the various date/time/timestamp utils
Key: FLINK-24507
URL: https://issues.apache.org/jira/browse/FLINK-24507
Project: Flink
LI Zhennan created FLINK-24508:
--
Summary: Add ThrottledMapper in flink-examples
Key: FLINK-24508
URL: https://issues.apache.org/jira/browse/FLINK-24508
Project: Flink
Issue Type: Improvement
Hi Francesco,
Do you have a use case for "Future>"?
When do users need this?
Best,
Jark
On Mon, 11 Oct 2021 at 21:27, Francesco Guardiani
wrote:
> Hi all,
> Looking at the TableResult type I was wondering, given the interface has
> await methods, should we instead implement the JDK's Future as
Ali Bahadir Zeybek created FLINK-24509:
--
Summary: FlinkKafkaProducer example is not compiling due to
incorrect constructer signature used
Key: FLINK-24509
URL: https://issues.apache.org/jira/browse/FLINK-2450
Thanks, Piotr and Arvid. Like Thomas even I'm interested in this feature
and was wondering if I can also contribute in some means in this effort.
Thanks
Akshay
On 2021/09/08 15:44:01, Thomas Weise wrote:
> Thank you Piotr and Arvid for the context.
>
> I'm interested in helping with this fe
Thanks for your effort!
Best,
Guowei
On Mon, Oct 11, 2021 at 9:26 PM Stephan Ewen wrote:
> Great initiative, thanks for doing this!
>
> On Mon, Oct 11, 2021 at 10:52 AM Till Rohrmann
> wrote:
>
> > Thanks a lot for this effort Chesnay! The improvements sound really good.
> >
> > Cheers,
> > T
xiangqiao created FLINK-24510:
-
Summary: Fix the duplicate log output of libraries/connectors，when
logback is used
Key: FLINK-24510
URL: https://issues.apache.org/jira/browse/FLINK-24510
Project: Flink
Jark Wu created FLINK-24511:
---
Summary: "sink.parallelism" doesn't work for upsert "values" sink
Key: FLINK-24511
URL: https://issues.apache.org/jira/browse/FLINK-24511
Project: Flink
Issue Type: Bu
Jark Wu created FLINK-24512:
---
Summary: Allow metadata columns can also be part of primary key
Key: FLINK-24512
URL: https://issues.apache.org/jira/browse/FLINK-24512
Project: Flink
Issue Type: Bug
Awesome!
On Tue, Oct 12, 2021 at 3:11 AM Guowei Ma wrote:
> Thanks for your effort!
>
> Best,
> Guowei
>
>
> On Mon, Oct 11, 2021 at 9:26 PM Stephan Ewen wrote:
>
> > Great initiative, thanks for doing this!
> >
> > On Mon, Oct 11, 2021 at 10:52 AM Till Rohrmann
> > wrote:
> >
> > > Thanks a l
23 matches
Mail list logo
