Satyam Shekhar created FLINK-20015:
--
Summary: Failure to execute streaming query
Key: FLINK-20015
URL: https://issues.apache.org/jira/browse/FLINK-20015
Project: Flink
Issue Type: Bug
Shuiqiang Chen created FLINK-20016:
--
Summary: Support TimestampAssigner and WatermarkGenerator for
Python DataStream API.
Key: FLINK-20016
URL: https://issues.apache.org/jira/browse/FLINK-20016
Alan Leong created FLINK-20014:
--
Summary: Resolve CVE-2020-11022 and CVE-2020-11023 in
scala-compiler
Key: FLINK-20014
URL: https://issues.apache.org/jira/browse/FLINK-20014
Project: Flink
Yingjie Cao created FLINK-20013:
---
Summary: BoundedBlockingSubpartition may leak network buffer if
task is failed or canceled
Key: FLINK-20013
URL: https://issues.apache.org/jira/browse/FLINK-20013
Hi, you can write a custom log appender that modifies the logs before they
are sent.
Thanks.
Diana El-Masri 于2020年11月6日周五 上午7:47写道：
> Hi,
>
> No the logs of the sources connected to flink.
>
> Thanks
>
> Chesnay Schepler a écrit :
>
> > Are you referring to the log files of Flink?
> >
> > On
Hi Robert,
I think this could be useful in flink-statefun.
StateFun currently has two modules that bundles dependencies, most
importantly the `flink-statefun-distribution` module which currently
bundles some Flink dependencies as well as Flink connectors (Kafka,
Kinesis).
Upgrading the Flink
Dino Zhang created FLINK-20012:
--
Summary: Hive 3.1 integration exception
Key: FLINK-20012
URL: https://issues.apache.org/jira/browse/FLINK-20012
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-20011:
---
Summary: PageRankITCase.testPrintWithRMatGraph hangs
Key: FLINK-20011
URL: https://issues.apache.org/jira/browse/FLINK-20011
Project: Flink
Issue Type: Improvement
Yingjie Cao created FLINK-20010:
---
Summary:
SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on
Azure Pipeline
Key: FLINK-20010
URL: https://issues.apache.org/jira/browse/FLINK-20010
Hi,
No the logs of the sources connected to flink.
Thanks
Chesnay Schepler a écrit :
Are you referring to the log files of Flink?
On 11/5/2020 7:01 PM, Diana El-Masri wrote:
Hi,
I am starting my PhD at "Ecole Polytechnique of Montreal" on IoT
log management. I am considering using
Are you referring to the log files of Flink?
On 11/5/2020 7:01 PM, Diana El-Masri wrote:
Hi,
I am starting my PhD at "Ecole Polytechnique of Montreal" on IoT log
management. I am considering using Flink for my edge layer processing.
Could please advise if there is a possibility to write a
Seth Wiesman created FLINK-20009:
Summary: Add 404 check to docs build
Key: FLINK-20009
URL: https://issues.apache.org/jira/browse/FLINK-20009
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-20008:
Summary: Java Deadlock in
ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement()
Key: FLINK-20008
URL: https://issues.apache.org/jira/browse/FLINK-20008
Hi,
I am starting my PhD at "Ecole Polytechnique of Montreal" on IoT log
management. I am considering using Flink for my edge layer processing.
Could please advise if there is a possibility to write a flink plugin
that intercepts and modify the logs before they are sent to the
Guowei Ma created FLINK-20007:
-
Summary: SinkTransformationTranslator fail to handle the
PartitionTransformation
Key: FLINK-20007
URL: https://issues.apache.org/jira/browse/FLINK-20007
Project: Flink
Robert Metzger created FLINK-20006:
--
Summary: FileSinkITCase.testFileSink: The record 0 should occur 4
times, but only occurs 8time expected:<4> but was:<8>
Key: FLINK-20006
URL:
Thanks Prasanna & Till for quick response.
Looks like my use case is very similar to yours ,I will try to run multiple
containers on the same machine and will update you accordingly.
Thanks ,
-Deep
On Thu, Nov 5, 2020 at 2:33 PM Till Rohrmann wrote:
> Hi Deep,
>
> you can increase the
Robert Metzger created FLINK-20005:
--
Summary: "Kerberized YARN application" test unstable
Key: FLINK-20005
URL: https://issues.apache.org/jira/browse/FLINK-20005
Project: Flink
Issue Type:
Flavio Pompermaier created FLINK-20004:
--
Summary: UpperLimitExceptionParameter description is misleading
Key: FLINK-20004
URL: https://issues.apache.org/jira/browse/FLINK-20004
Project: Flink
Hi all,
for the upcoming 1.12 release (and beyond ;) ), I added a utility [1] that
checks for the most common licensing issues. It doesn't find everything,
but the by far most common case of forgetting to add a version upgrade or
changed transitive dependency to the NOTICE file is covered.
Chesnay Schepler created FLINK-20003:
Summary: Improve slot report logging messages
Key: FLINK-20003
URL: https://issues.apache.org/jira/browse/FLINK-20003
Project: Flink
Issue Type:
For your information,
I executed the flink-benchmarks [1] twice within docker container based on
flink-1.11.1 scala_2.11-java8-debian image [2], from the results of state
benchmarks, I cannot see obvious performance changes whether to use jemalloc as
memory allocator:
RocksDB keyed state
Dawid Wysakowicz created FLINK-20002:
Summary: Add a
StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method
Key: FLINK-20002
URL: https://issues.apache.org/jira/browse/FLINK-20002
Aljoscha Krettek created FLINK-20001:
Summary: Don't use setAllVerticesInSameSlotSharingGroupByDefault
in StreamGraphGenerator
Key: FLINK-20001
URL: https://issues.apache.org/jira/browse/FLINK-20001
Robert Metzger created FLINK-2:
--
Summary: Extend the license checker to ensure that 3rd party
licenses are shipped
Key: FLINK-2
URL: https://issues.apache.org/jira/browse/FLINK-2
Nico Kruber created FLINK-1:
---
Summary: State Processor API classes leaking into savepoint
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Project: Flink
Issue Type:
Aditya Agarwal created FLINK-19998:
--
Summary: Invalid Link to checkpoints and Savepoints in stateful
stream processing concepts
Key: FLINK-19998
URL: https://issues.apache.org/jira/browse/FLINK-19998
Dawid Wysakowicz created FLINK-19997:
Summary: Implement an e2e test for sql-client with Confluent
Registry Avro format
Key: FLINK-19997
URL: https://issues.apache.org/jira/browse/FLINK-19997
Jark Wu created FLINK-19996:
---
Summary: Add end-to-end IT case for Debezium + Kafka + temporal
join
Key: FLINK-19996
URL: https://issues.apache.org/jira/browse/FLINK-19996
Project: Flink
Issue
zhisheng created FLINK-19995:
Summary: 【Flink SQL Client】Use Flink Kafka Connector has more one
exception
Key: FLINK-19995
URL: https://issues.apache.org/jira/browse/FLINK-19995
Project: Flink
Zhu Zhu created FLINK-19994:
---
Summary: All vertices in an DataSet iteration job will be eagerly
scheduled
Key: FLINK-19994
URL: https://issues.apache.org/jira/browse/FLINK-19994
Project: Flink
Hi Deep,
you can increase the average CPU load by reducing the number of overall
resources. Having fewer slots over which you can distribute the work should
increase the resource usage.
Cheers,
Till
On Thu, Nov 5, 2020 at 9:03 AM Prasanna kumar
wrote:
> Deep,
>
> 1) Is it a cpu/memory/io
Kostas Kloudas created FLINK-19993:
--
Summary: Remove the flink-connector-filesystem module
Key: FLINK-19993
URL: https://issues.apache.org/jira/browse/FLINK-19993
Project: Flink
Issue Type:
Jingsong Lee created FLINK-19992:
Summary: Integrate new orc to Hive source
Key: FLINK-19992
URL: https://issues.apache.org/jira/browse/FLINK-19992
Project: Flink
Issue Type: Sub-task
Hi all,
Given the current outcome of the voting process, the proposal for
removing the "flink-connector-filesystem module" has passed.
I will move on with opening a JIRA and actually removing the module
and all the related code.
Thank you all for voting,
Kostas
On Fri, Oct 30, 2020 at 5:05 PM
Yingjie Cao created FLINK-19991:
---
Summary:
UnalignedCheckpointITCase#shouldPerformUnalignedCheckpointMassivelyParallel
fails on Azure Pipeline
Key: FLINK-19991
URL:
Deep,
1) Is it a cpu/memory/io intensive job ??
Based on that you could allocate resources.
>From the question, if the CPU is not utilised , you could run multiple
containers on the same machine(tm) ...
Following may not be exact case as yours but to give you an idea.
Few months back I have
37 matches
Mail list logo
