孙达 created FLINK-10660:
--
Summary: Failed index data to Elastic search using
Flink-connector-elasticsearch with JUNIT test
Key: FLINK-10660
URL: https://issues.apache.org/jira/browse/FLINK-10660
Project: Flink
Kan created FLINK-10659:
---
Summary: get rid of splitting by comma for
ProgramArgsQueryParameter
Key: FLINK-10659
URL: https://issues.apache.org/jira/browse/FLINK-10659
Project: Flink
Issue Type: Improv
@Erik, I’m working with Till regarding together for the Flink K8s native
integration, we have a draft of design document, and plan to post the document
next week and collect feedbacks.
@Anand, operator is a interesting topic, look forward to see your design
document.
I will keep you updated.
chauncy created FLINK-10658:
---
Summary: org.apache.flink.util.FlinkException: Releasing shared
slot parent.
Key: FLINK-10658
URL: https://issues.apache.org/jira/browse/FLINK-10658
Project: Flink
Is
JIN SUN created FLINK-10657:
---
Summary: TPCHQuery3 fail with IllegalAccessException
Key: FLINK-10657
URL: https://issues.apache.org/jira/browse/FLINK-10657
Project: Flink
Issue Type: Improvement
Hi Erik,
We @Flyte team within Lyft have been working on SparkK8Operator for quite
some time, and now we have built a FlinkK8Operator to run Flink
applications on Kubernetes.
We would be happy to demo the Flink Operator during the meeting.
Also I am in the process of fleshing out all the details
JIN SUN created FLINK-10656:
---
Summary: Refactor
org.apache.flink.runtime.io.network.api.reader.ReaderBase
Key: FLINK-10656
URL: https://issues.apache.org/jira/browse/FLINK-10656
Project: Flink
Iss
Hi Dom,
I think support for Kafka keys would be covered by Timo's proposal for
improvements of the source / sink connectors [1].
See the section on "Concat multiple formats for accessing
connector-specific properties" in the proposal document [2].
Best, Fabian
[1]
https://lists.apache.org/thread
Nico Kruber created FLINK-10655:
---
Summary: RemoteRpcInvocation not overwriting ObjectInputStream's
ClassNotFoundException
Key: FLINK-10655
URL: https://issues.apache.org/jira/browse/FLINK-10655
Project:
Dear community,
this is the weekly community update thread #43. Please post any news and
updates you want to share with the community to this thread.
# Release vote for Flink 1.5.5 and 1.6.2
The community is currently voting on the first release candidates for Flink
1.5.5 [1] and Flink 1.6.2 [2]
Thanks for publishing your ideas here on the dev ML Tony. Once you have a
first version of the design document ready let us know.
Cheers,
Till
On Mon, Oct 22, 2018 at 2:21 PM 宋辛童(五藏) wrote:
> Thanks, Tison~
>
> Thank You,
> Tony Xintong
> Song
Hi Erik,
thanks for reaching out to the Flink community. The Flink community is
actually actively working on improving our K8s support because we see a lot
of adoption and our users would like to run Flink on K8s. Apart from the
existing Flink docker images there are currently two development thre
Hey,
I don't think we are currently supporting this, but it would be a good idea
to have Kafka sink with support for keys. I have worked on something
similar to SQL Client before it was created, but the keys in Kafka are
crucial to us and this is currently the limitation that keeps us from
switchin
Jiayi Liao created FLINK-10654:
--
Summary: AllowNonRestoredState should skip state that cannot be
restored
Key: FLINK-10654
URL: https://issues.apache.org/jira/browse/FLINK-10654
Project: Flink
zhijiang created FLINK-10653:
Summary: Propose of external shuffle service for batch jobs
Key: FLINK-10653
URL: https://issues.apache.org/jira/browse/FLINK-10653
Project: Flink
Issue Type: New Fe
Stefan Richter created FLINK-10652:
--
Summary: Update StatefulJobWBroadcastStateMigrationITCase for 1.6
Key: FLINK-10652
URL: https://issues.apache.org/jira/browse/FLINK-10652
Project: Flink
Stefan Richter created FLINK-10650:
--
Summary: Update BucketingSinkMigrationTest for 1.6
Key: FLINK-10650
URL: https://issues.apache.org/jira/browse/FLINK-10650
Project: Flink
Issue Type: Sub
Stefan Richter created FLINK-10651:
--
Summary: Update CEPMigrationTest for 1.6
Key: FLINK-10651
URL: https://issues.apache.org/jira/browse/FLINK-10651
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-10649:
--
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.6
Key: FLINK-10649
URL: https://issues.apache.org/jira/browse/FLINK-10649
Project: Flink
Issue
Stefan Richter created FLINK-10648:
--
Summary: Update ContinuousFileProcessingMigrationTest for 1.6
Key: FLINK-10648
URL: https://issues.apache.org/jira/browse/FLINK-10648
Project: Flink
Issu
Stefan Richter created FLINK-10646:
--
Summary: Update AbstractOperatorRestoreTestBase for 1.6
Key: FLINK-10646
URL: https://issues.apache.org/jira/browse/FLINK-10646
Project: Flink
Issue Type
Stefan Richter created FLINK-10647:
--
Summary: Update WindowOperatorMigrationTest for 1.6
Key: FLINK-10647
URL: https://issues.apache.org/jira/browse/FLINK-10647
Project: Flink
Issue Type: Su
Stefan Richter created FLINK-10645:
--
Summary: Update StatefulJobSavepointMigrationITCase for 1.6
Key: FLINK-10645
URL: https://issues.apache.org/jira/browse/FLINK-10645
Project: Flink
Issue
23 matches
Mail list logo
