Greg Hogan created FLINK-4673:
-
Summary: TypeFactory for Either type
Key: FLINK-4673
URL: https://issues.apache.org/jira/browse/FLINK-4673
Project: Flink
Issue Type: Improvement
Compone
Stephan Ewen created FLINK-4672:
---
Summary: TaskManager accidentally decorates Kill messages
Key: FLINK-4672
URL: https://issues.apache.org/jira/browse/FLINK-4672
Project: Flink
Issue Type: Bug
Timo Walther created FLINK-4671:
---
Summary: Table API can not be built
Key: FLINK-4671
URL: https://issues.apache.org/jira/browse/FLINK-4671
Project: Flink
Issue Type: Bug
Components:
Hi everyone,
We are trying to use elasticsearch (2.x) connector for Flink application.
However, we encounter a problem when we try to add mapping to elasticsearch
index.
The error message is below when we run the Flink application.
No support for request
[org.elasticsearch.action.admin.in
zhangjing created FLINK-4670:
Summary: Add watch mechanism on current RPC framework
Key: FLINK-4670
URL: https://issues.apache.org/jira/browse/FLINK-4670
Project: Flink
Issue Type: Sub-task
Hi Evgeny,
Welcome to the Flink community. I gave you Contributor permissions in JIRA
and assigned the issue to you. In the future you can assign issues to
yourself as well.
Best, Fabian
2016-09-23 12:10 GMT+02:00 Evgeny Kincharov :
> Hi folks.
>
> I want to do something for flink. As the first
Hi folks.
I want to do something for flink. As the first step I have started doing
https://issues.apache.org/jira/browse/FLINK-4315, could you assign it for me in
JIRA.
Thanks.
BR, Evgeny Kincharov
Hi Jagan,
could you please stop spamming the mailing list? This is at least the third
mail with the identical request in a very short time. You already got an
answer including a Java code snippet. Translating this into Scala code
should be possible.
The mailing list is for helping people such tha
Hello,
you are correct that metrics are not aggregated on the Task- or
JobManager. Their primary purpose is to expose fine-grained information
to an external metric system, which could then do aggregations if desired.
There are plans to aggregate metrics in the WebInterface though, like
the
Hi Guys,
We have a requirement like loading data from CSV file to postgress database
In Flink scala.
We need very basic script how to read data from file and write it to
postgress database.
Could you please some one help me on that guys
--
Regards.
Jagan.
shijinkui created FLINK-4669:
Summary: scala api createLocalEnvironment() function add default
Configuration parameter
Key: FLINK-4669
URL: https://issues.apache.org/jira/browse/FLINK-4669
Project: Flink
I don't think it's that easy. The streaming connectors have flink-streaming
as dependency while the batch connectors have the batch dependencies.
Combining them would mean that users always have all dependencies, right?
On Thu, 22 Sep 2016 at 15:41 Stephan Ewen wrote:
> +1 for Fabian's suggesti
Hi Flavio,
Thanks this script is very useful, however we need Flink scala script to
load data from csv to postgress.
if we have following java equivalent code in scala that will be really
helpful...thanks.
myResult.output(
// build and configure OutputFormat
JDBCOutputFormat.buildJDBCOut
Hi Jagan, I have a Java version of such a Job if you want (that requires
table-api in order to handle null values), I hope this could help!
Obviously you'll have to set all parameters properly..(e.g. jdbcOutputFormat ,
fieldTypes, etc...).
public static void main(String[] args) throws Exception {
14 matches
Mail list logo
