Hi Martijn,
I fully comprehend your apprehensions regarding AWS's reliance on JDBC and
the resultant impact on the release cycle. However, an effective approach
is to utilize the latest version of flink-connector-jdbc as a Maven
dependency. In this arrangement, flink-connector-aws can be associated
AFAIK Apache Beam also used acummulators for metric collection, which is
indeed a major use case.
I’m not convinced that MetricGroup is fuĺly replacing what acummulators
have to offer though; OperatorCoordinators might be able to rplace
remaining capabilities, but this need bit more thoughts, the
Thanks for bringing this up, Matthias.
One thing that a user may achieve with an accumulator but not with a metric
group is to programmatically fetch the job execution result, rather than
outputting the results to an external sink, in attached mode. This can also
be achieved by using CollectSink,
lincoln lee created FLINK-32986:
---
Summary: The new createTemporaryFunction has some regression of
type inference compare to the deprecated registerFunction
Key: FLINK-32986
URL: https://issues.apache.org/jira/browse
Hi folks,
I would like to start the discussion about FLIP-158[1] which proposes to
clean up and enhance the Avro support in Flink. More specifically, it
proposes to:
1. Make it clear what are the public APIs in flink-avro components.
2. Fix a few buggy cases in flink-avro
3. Add more supported Av
Flink switched to using log4j2 with the 1.11 release. Looking at the
ticket involved [1] should give you some idea of the effort involved
in backporting that to 1.10.
My initial impression is that you might not have to do much to get it
working, The comments in [2] appear to outline what's needed.
SGTM
For future reference, responding here:
5) Any operator can introduce system (psedo) columns.
>
> This is clearly out of scope for this FLIP. The implementation effort
> would be huge and could introduce a lot of bugs.
>
I didn't imply any specific implementation or feature coverage in the
Hi Jinsong,
Thanks for your comments.
What is inputIndex in NestedFieldReferenceExpression?
I haven't looked at it before. Do you mean, given that it is now only used
to push filters it won't be subsequently used in further
planning/optimization and therefore it is not required at this time?
S
xiangyu feng created FLINK-32985:
Summary: Support setting env.java.opts.sql-gateway to specify the
jvm opts for sql gateway
Key: FLINK-32985
URL: https://issues.apache.org/jira/browse/FLINK-32985
Pro
Matt Wang created FLINK-32984:
-
Summary: Display the host port information on the suttasks page of
SubtaskExecution
Key: FLINK-32984
URL: https://issues.apache.org/jira/browse/FLINK-32984
Project: Flink
Zhanghao Chen created FLINK-32983:
-
Summary: Support setting env.java.opts.all & env.java.opts.cli
configs via dynamic properties on the CLI side
Key: FLINK-32983
URL: https://issues.apache.org/jira/browse/FLINK-3
luoyuxia created FLINK-32982:
Summary: Don't need to suggest to swap for using Hive dialect
Key: FLINK-32982
URL: https://issues.apache.org/jira/browse/FLINK-32982
Project: Flink
Issue Type: Impr
Gabor Somogyi created FLINK-32981:
-
Summary: Add python dynamic Flink home detection
Key: FLINK-32981
URL: https://issues.apache.org/jira/browse/FLINK-32981
Project: Flink
Issue Type: Improve
Zhanghao Chen created FLINK-32980:
-
Summary: Support env.java.opts.all & env.java.opts.cli config for
starting Session clusters
Key: FLINK-32980
URL: https://issues.apache.org/jira/browse/FLINK-32980
Wencong Liu created FLINK-32979:
---
Summary: Deprecate
WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env)
Key: FLINK-32979
URL: https://issues.apache.org/jira/browse/FLINK-32979
Project: Fli
Wencong Liu created FLINK-32978:
---
Summary: Deprecate RichFunction#open(Configuration parameters)
Key: FLINK-32978
URL: https://issues.apache.org/jira/browse/FLINK-32978
Project: Flink
Issue Typ
Feng Jin created FLINK-32976:
Summary: NullpointException when starting flink cluster
Key: FLINK-32976
URL: https://issues.apache.org/jira/browse/FLINK-32976
Project: Flink
Issue Type: Bug
Rui Xia created FLINK-32975:
---
Summary: Enhance equal() for ChangelogMapState's iterator
Key: FLINK-32975
URL: https://issues.apache.org/jira/browse/FLINK-32975
Project: Flink
Issue Type: Improvemen
Lijie Wang created FLINK-32974:
--
Summary: RestClusterClient leaks flink-rest-client-jobgraphs*
directories
Key: FLINK-32974
URL: https://issues.apache.org/jira/browse/FLINK-32974
Project: Flink
Nicolas Fraison created FLINK-32973:
---
Summary: Documentation for
kubernetes.operator.job.savepoint-on-deletion indicate that it can be set on
per resource level while it can't
Key: FLINK-32973
URL: https://issu
Sergey Nuyanzin created FLINK-32972:
---
Summary: TaskTest.testInterruptibleSharedLockInInvokeAndCancel
causes a JVM shutdown with exit code 239
Key: FLINK-32972
URL: https://issues.apache.org/jira/browse/FLINK-329
Gabor Somogyi created FLINK-32971:
-
Summary: Add pyflink proper development version support
Key: FLINK-32971
URL: https://issues.apache.org/jira/browse/FLINK-32971
Project: Flink
Issue Type:
RocMarshal mentioned the new connector API in the FLINK-26999 [1] , I
wonder if this refers to Sink V2 Api [2] Or other things? If someone can
help me troubleshoot this issue it will speed up my design progress
- [1] FLINK-26999: https://issues.apache.org/jira/browse/FLINK-26999
- [2] Sink
Spongebob created FLINK-32970:
-
Summary: could not load external class using "-C" option
Key: FLINK-32970
URL: https://issues.apache.org/jira/browse/FLINK-32970
Project: Flink
Issue Type: Bug
24 matches
Mail list logo
