-fs:jar:1.10-SNAPSHOT: Failed to collect
>>>>> dependencies at com.mapr.hadoop:maprfs:jar:5.2.1-mapr: Failed to read
>>>>> artifact descriptor for com.mapr.hadoop:maprfs:jar:5.2.1-mapr:
>>>>> Could not
>>>>> transfer artifact com.mapr.ha
thanks a lot
On 06/08/2019 13:25, Chesnay Schepler wrote:
> Done.
>
> On 06/08/2019 13:17, Nico Kruber wrote:
>> Hi Chesnay,
>> can you backport these changes to the 1.7 release branch as well? Since
>> this is still a supported version (and may eventually receive a fu
requires asm-commons to be added to flink-shaded-asm
>
> Are there any other changes on anyone's radar that we will have to make
> for 1.10? (will bumping calcite require anything, for example)
>
>
--
Nico Kruber | Solutions Architect
Follow us @VervericaData Ver
non Credit-based model (
>>>> `taskmanager.network.credit-model: false`)? If so, why?
>>>>
>>>> Piotrek
>>>>
>>>> [1] https://flink.apache.org/2019/06/05/flink-network-stack.html <
>>>> https://flink.apache.org/2019/06/05/flink-network-stack.html>
>>&g
ki 于2020年1月9日周四 下午11:25写道：
>>>>>
>>>>>> Hi,
>>>>>>
>>>>>> I would like to start a vote for adding the N-Ary Stream Operator in
>>>>> Flink
>>>>>> as discussed in the discussion thread [1].
*
> * no projects
> * no merge commit button (rebase/squash merge button still enabled)
> * protected branch: asf-site
> * default branch: asf-site (while we're at it...)
>
> [1]
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-GitBox-td22328
>> ideally start the release process this week.
>>>
>>> What do you think?
>>>
>>> [1] https://issues.apache.org/jira/projects/FLINK/versions/12343053
>>>
>>> [2]
>>> https://lists.apache.org/thread.html/1b8b0e627739d1f01b760fb722a1
-9761
Nico
On 05/07/18 12:24, Nico Kruber wrote:
> FYI: I just merged this to master as well as release-1.5 (hopefully -
> this is my first merge since I became a committer)
>
> On 05/07/18 10:22, Zhijiang(wangzhijiang999) wrote:
>> I have reviewed FLINK-9676, wish it merged so
I know, DataStreamUtils#reinterpretAsKeyedStream() is marked experimental, but
would you nevertheless consider the following issue a blocker?
https://issues.apache.org/jira/browse/FLINK-10809
It has always been present since the introduction of
DataStreamUtils#reinterpretAsKeyedStream() and so fa
gt;
> [2] https://dist.apache.org/repos/dist/dev/flink/flink-shaded-6.0-rc1/
> [3] https://dist.apache.org/repos/dist/release/flink/KEYS
> [4] https://repository.apache.org/content/repositories/orgapacheflink-1204
> [5]
> https://gitbox.apache.org/repos/asf?p=flink-shaded.git;a=tag;h=refs/ta
t.apache.org/repos/dist/dev/flink/flink-shaded-7.0-rc2/
>> [3] https://dist.apache.org/repos/dist/release/flink/KEYS
>> [4] https://repository.apache.org/content/repositories/orgapacheflink-1218
>> [5] https://github.com/apache/flink-shaded/tree/release-7.0-rc2
>> [6] http
anyway since
> we aren't relocating hadoop classes.
>
> On 27/05/2019 10:50, Nico Kruber wrote:
>> Honestly, I'm not sure whether FLINK-12598 should be treated as a
>> blocker nonetheless: Although it does not affect the usage of
>> flink-shaded, it may affect Flink
Flink to provide certain dependencies are a bit brittle in general.
>
>
> On 23/05/2019 10:26, Chesnay Schepler wrote:
> > Worked for me; could you try again without parallel builds?
> >
> > Which maven version are you using?
> >
> > On
d=12315522&Create=Create&atl_token=A5KQ-2QAV-T4JA-FDED%7C8ba061049bec0c5a72dc0191c47bb53a73b82cb4%7Clin
>>>
>>> [2] https://dist.apache.org/repos/dist/dev/flink/flink-shaded-7.0-rc3/
>>> [3] https://dist.apache.org/repos/dist/release/flink/KEYS
>>
than before.
> AFAIK we do not work directly against the contained snakeyaml version,
> so we should be fine in any case.
>
> On 27/05/2019 16:45, Nico Kruber wrote:
>> +1 (mod jackson snakeyaml support; see below)
>>
>> - checked release notes
>> - verified s
not being
> used at all (I guess?)
>
> They have now removed the inclusion, meaning they now work against the
> snakeyaml version that we're including.
>
> So this is a safe change.
>
> On 28/05/2019 15:16, Nico Kruber wrote:
>> this is a bit different here:
>
> > I have look through the doc, I think it will be a good
> >> > improvement
> >>
> >> to
> >>
> >> > this pattern usage, I'm interested in it. Do you have some POC work to
> >> > share for a closer lo
state, especially you might need to
> consider how to store key bytes serialized by the new serializer (as we
> might not be able to write the length in the beginning of serialized bytes
> to make the order of bytes same as natural order).
> Best
> Yun Tang.
>
serialized bytes same as
> > original
> > java objects first.
> > For the fixed-length serializer, such as LongSerializer, we just need to
> > ensure all numbers are positive or inverting the sign bit.
> > However, for non-fixed-length serializer, such as StringSerializer,
uldn't require you
to read the whole list again.
Sorry for the long email - we'd be happy to get more feedback and will
incorporate this into the FLIP description soon.
Nico
--
Dr. Nico Kruber | Solutions Architect
Follow us @VervericaData Ververica
--
Join Flink Forward - The
appropriate extensions to read
and write this new form of state
Nico
On Friday, 29 April 2022 14:25:59 CEST Nico Kruber wrote:
> Hi all,
> Yun, David M, David A, and I had an offline discussion and talked through a
> couple of details that emerged from the discussion here. We b
t; > > >>> time.
> > > > >>>
> > > > >>>> All of the prerequisites from 3rd party projects for both HBase
> >
> > [1]
> >
> > > > and
> > > >
> > > > >>>> Hive [2] to fully
en one of the
> > committers can find the relevant patch from RocksDB master and backport
> > it.
> > That isn't the greatest user experience.
> >
> > Because of those disadvantages, we would prefer to do the upgrade to the
> > newer RocksDB version
IMHO, any release that improves things and does not break anything is worth
releasing and should not be blocked on bugs that it did not cause.
There will always be a next (minor/major) release that may fix this at a later
time, given that the time between releases is not too high.
Consider someo
while fixing build issues - what about FLINK-6654?
On Friday, 2 June 2017 11:05:34 CEST Robert Metzger wrote:
> Hi devs,
>
> I would like to release Apache Flink 1.3.1 with the following fixes:
>
> - FLINK-6812 Elasticsearch 5 release artifacts not published to Maven
> central
> - FLINK-6783 Wro
This is among the fixes for 1.3.1
see https://issues.apache.org/jira/browse/FLINK-6812
Nico
On Friday, 9 June 2017 08:57:39 CEST Dawid Wysakowicz wrote:
> Hi devs,
>
> I tried using flink-connector-elasticsearch5_2.10 dependency:
> >
> >
> > org.apache.flink
> >
> >
Hi all,
I'd like to initiate a discussion on some architectural changes for the BLOB
server which finally add a proper cleanup story, remove some dead code, and
extend the BLOB store's use for off-loaded (large) RPC messages.
Please have a look at FLIP-19 that details the proposed changes:
https
e distributed
> cache is not implemented
> via the blob store.
>
> The DC is essentially just a copy routine with local caching and
> automatic cleanup, so basically what
> the blob store is supposed to do (i guess).
>
> On 13.06.2017 16:31, Nico Kruber wrote:
> > Hi
I like the new template but also agree with the text being too long and would
move the intro to the contributors guide with a link in the PR template.
Regarding the questions to fill out - I'd like the headings to be short and
have the affected components last so that documentation is not lost (
+-1 (non-binding)
L.1 Check if checksums and GPG files match the corresponding release files
- found an issue with a malformed flink-1.3.2-src.tgz.md5 that gnu coreutils
8.27 was not accepting - already fixed by now
L.3 Check if the source release is building properly (mvn clean verify)
- found
I actually ran into the same thing again, when I needed to copy a file from
Netty's tests (an abstract test base class) and was not quite sure what 4d)
under the ASL 2.0 meant:
4. Redistribution. You may reproduce and distribute copies of the Work or
Derivative Works thereof in any medium, wit
I recently came across the fact, that if I changed anything S3 related, these
tests will only run if proper AWS credentials are set up via the environment
variables ARTIFACTS_AWS_BUCKET, ARTIFACTS_AWS_ACCESS_KEY, and
ARTIFACTS_AWS_SECRET_KEY.
I can set them in my personal Travis CI configuratio
machine), but it seems to run forever with flink
>>>>> 1.5-SNAPSHOT (I stopped it after about 2-3 hours multiple times). If
>>> you
>>>>> want to try to replicate this, here are the java classes:
>>>>> https://github.com/xseris/Flink-test-union/
.operators.shipping.OutputCollector.collect(
>>> OutputCollector.java:65)
>>>> at
>>>> org.apache.flink.runtime.operators.util.metrics.
>>> CountingCollector.collect(CountingCollector.java:35)
>>>> at
>>>> org.apache.flink.runtime.operators.chaining.ChainedMapDri
Nico Kruber created FLINK-13172:
---
Summary: JVM crash with dynamic netty-tcnative wrapper to openSSL
on some OS
Key: FLINK-13172
URL: https://issues.apache.org/jira/browse/FLINK-13172
Project: Flink
Nico Kruber created FLINK-13173:
---
Summary: Only run openSSL tests if desired
Key: FLINK-13173
URL: https://issues.apache.org/jira/browse/FLINK-13173
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13498:
---
Summary: Reduce Kafka producer startup time by aborting
transactions in parallel
Key: FLINK-13498
URL: https://issues.apache.org/jira/browse/FLINK-13498
Project: Flink
Nico Kruber created FLINK-13535:
---
Summary: Do not abort transactions twice during KafkaProducer
startup
Key: FLINK-13535
URL: https://issues.apache.org/jira/browse/FLINK-13535
Project: Flink
Nico Kruber created FLINK-13537:
---
Summary: Changing Kafka producer pool size and scaling out may
create overlapping transaction IDs
Key: FLINK-13537
URL: https://issues.apache.org/jira/browse/FLINK-13537
Nico Kruber created FLINK-13722:
---
Summary: Speed up documentation generation
Key: FLINK-13722
URL: https://issues.apache.org/jira/browse/FLINK-13722
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-13723:
---
Summary: Use liquid-c for faster doc generation
Key: FLINK-13723
URL: https://issues.apache.org/jira/browse/FLINK-13723
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13724:
---
Summary: Remove unnecessary whitespace from the docs' sitenav
Key: FLINK-13724
URL: https://issues.apache.org/jira/browse/FLINK-13724
Project: Flink
Nico Kruber created FLINK-13725:
---
Summary: Use sassc for faster doc generation
Key: FLINK-13725
URL: https://issues.apache.org/jira/browse/FLINK-13725
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13726:
---
Summary: Build docs with jekyll 4.0.0.pre.beta1
Key: FLINK-13726
URL: https://issues.apache.org/jira/browse/FLINK-13726
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13727:
---
Summary: Build docs with jekyll 4.0.0 (final)
Key: FLINK-13727
URL: https://issues.apache.org/jira/browse/FLINK-13727
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13728:
---
Summary: Fix wrong closing tag order in sidenav
Key: FLINK-13728
URL: https://issues.apache.org/jira/browse/FLINK-13728
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-13729:
---
Summary: Update website generation dependencies
Key: FLINK-13729
URL: https://issues.apache.org/jira/browse/FLINK-13729
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-13791:
---
Summary: Speed up sidenav by using group_by
Key: FLINK-13791
URL: https://issues.apache.org/jira/browse/FLINK-13791
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13793:
---
Summary: Build different language docs in parallel
Key: FLINK-13793
URL: https://issues.apache.org/jira/browse/FLINK-13793
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-14104:
---
Summary: Bump Jackson to 2.9.9.3
Key: FLINK-14104
URL: https://issues.apache.org/jira/browse/FLINK-14104
Project: Flink
Issue Type: Bug
Components
Nico Kruber created FLINK-16282:
---
Summary: Wrong exception using DESCRIBE SQL command
Key: FLINK-16282
URL: https://issues.apache.org/jira/browse/FLINK-16282
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-16301:
---
Summary: Annoying "Cannot find FunctionDefinition" messages with
SQL for f_proctime or =
Key: FLINK-16301
URL: https://issues.apache.org/jira/browse/F
Nico Kruber created FLINK-16459:
---
Summary: Add Serialization benchmark for Apache Thrift
Key: FLINK-16459
URL: https://issues.apache.org/jira/browse/FLINK-16459
Project: Flink
Issue Type: New
Nico Kruber created FLINK-16460:
---
Summary: Add Serialization benchmark for Protobuf
Key: FLINK-16460
URL: https://issues.apache.org/jira/browse/FLINK-16460
Project: Flink
Issue Type: New
Nico Kruber created FLINK-16461:
---
Summary: Multiple Bindings with SLF4J
Key: FLINK-16461
URL: https://issues.apache.org/jira/browse/FLINK-16461
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-16556:
---
Summary: TopSpeedWindowing should implement checkpointing for its
source
Key: FLINK-16556
URL: https://issues.apache.org/jira/browse/FLINK-16556
Project: Flink
Nico Kruber created FLINK-16576:
---
Summary: State inconsistency on restore with memory state backends
Key: FLINK-16576
URL: https://issues.apache.org/jira/browse/FLINK-16576
Project: Flink
Nico Kruber created FLINK-16664:
---
Summary: Unable to set DataStreamSource parallelism to default (-1)
Key: FLINK-16664
URL: https://issues.apache.org/jira/browse/FLINK-16664
Project: Flink
Nico Kruber created FLINK-16729:
---
Summary: Offer an out-of-the-box Set serializer
Key: FLINK-16729
URL: https://issues.apache.org/jira/browse/FLINK-16729
Project: Flink
Issue Type: New Feature
Nico Kruber created FLINK-16890:
---
Summary: Add AvroGeneric benchmark
Key: FLINK-16890
URL: https://issues.apache.org/jira/browse/FLINK-16890
Project: Flink
Issue Type: New Feature
Nico Kruber created FLINK-17056:
---
Summary: JMH main() methods call unrelated benchmarks
Key: FLINK-17056
URL: https://issues.apache.org/jira/browse/FLINK-17056
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-17057:
---
Summary: Add OpenSSL micro-benchmarks
Key: FLINK-17057
URL: https://issues.apache.org/jira/browse/FLINK-17057
Project: Flink
Issue Type: New Feature
Nico Kruber created FLINK-17143:
---
Summary: Blog feed.xml should only contain excerpts, not full
contents
Key: FLINK-17143
URL: https://issues.apache.org/jira/browse/FLINK-17143
Project: Flink
Nico Kruber created FLINK-17171:
---
Summary: Blink planner fails to compile Table program with POJO
source
Key: FLINK-17171
URL: https://issues.apache.org/jira/browse/FLINK-17171
Project: Flink
Nico Kruber created FLINK-17275:
---
Summary: Add core training exercises
Key: FLINK-17275
URL: https://issues.apache.org/jira/browse/FLINK-17275
Project: Flink
Issue Type: New Feature
Nico Kruber created FLINK-17276:
---
Summary: Add checkstyle to training exercises
Key: FLINK-17276
URL: https://issues.apache.org/jira/browse/FLINK-17276
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-17277:
---
Summary: Apply IntelliJ recommendations to training exercises
Key: FLINK-17277
URL: https://issues.apache.org/jira/browse/FLINK-17277
Project: Flink
Issue
Nico Kruber created FLINK-17278:
---
Summary: Add Travis to the training exercises
Key: FLINK-17278
URL: https://issues.apache.org/jira/browse/FLINK-17278
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-17279:
---
Summary: Use gradle build scans
Key: FLINK-17279
URL: https://issues.apache.org/jira/browse/FLINK-17279
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-17293:
---
Summary: Port training exercises data sets to a generator
Key: FLINK-17293
URL: https://issues.apache.org/jira/browse/FLINK-17293
Project: Flink
Issue Type
Nico Kruber created FLINK-14575:
---
Summary: Wrong (parent-first) class loader during serialization
while submitting jobs
Key: FLINK-14575
URL: https://issues.apache.org/jira/browse/FLINK-14575
Project
Nico Kruber created FLINK-14781:
---
Summary: clarify that a RocksDB dependency in pom.xml may not be
needed
Key: FLINK-14781
URL: https://issues.apache.org/jira/browse/FLINK-14781
Project: Flink
Nico Kruber created FLINK-15010:
---
Summary: Temp directories flink-netty-shuffle-* are not cleaned up
Key: FLINK-15010
URL: https://issues.apache.org/jira/browse/FLINK-15010
Project: Flink
Nico Kruber created FLINK-15011:
---
Summary: RocksDB temp directory not cleaned up
Key: FLINK-15011
URL: https://issues.apache.org/jira/browse/FLINK-15011
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-15012:
---
Summary: Checkpoint directory not cleaned up
Key: FLINK-15012
URL: https://issues.apache.org/jira/browse/FLINK-15012
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-15068:
---
Summary: Disable RocksDB's local LOG by default
Key: FLINK-15068
URL: https://issues.apache.org/jira/browse/FLINK-15068
Project: Flink
Issue Type: Improv
Nico Kruber created FLINK-15113:
---
Summary: fs.azure.account.key not hidden from global configuration
Key: FLINK-15113
URL: https://issues.apache.org/jira/browse/FLINK-15113
Project: Flink
Nico Kruber created FLINK-15335:
---
Summary: add-dependencies-for-IDEA not working anymore and
dangerous in general
Key: FLINK-15335
URL: https://issues.apache.org/jira/browse/FLINK-15335
Project: Flink
Nico Kruber created FLINK-15752:
---
Summary: Backpressure stats sometimes broken in WebUI
Key: FLINK-15752
URL: https://issues.apache.org/jira/browse/FLINK-15752
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-15753:
---
Summary: Show non-numeric metrics in Web UI
Key: FLINK-15753
URL: https://issues.apache.org/jira/browse/FLINK-15753
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-15863:
---
Summary: Fix docs stating that savepoints are relocatable
Key: FLINK-15863
URL: https://issues.apache.org/jira/browse/FLINK-15863
Project: Flink
Issue Type
Nico Kruber created FLINK-9274:
--
Summary: Add thread name to Kafka Partition Discovery
Key: FLINK-9274
URL: https://issues.apache.org/jira/browse/FLINK-9274
Project: Flink
Issue Type
Nico Kruber created FLINK-9275:
--
Summary: Set more distinctive output flusher thread names
Key: FLINK-9275
URL: https://issues.apache.org/jira/browse/FLINK-9275
Project: Flink
Issue Type
Nico Kruber created FLINK-9305:
--
Summary: Register flink-s3-fs-* for the s3a:// scheme as well
Key: FLINK-9305
URL: https://issues.apache.org/jira/browse/FLINK-9305
Project: Flink
Issue Type
Nico Kruber created FLINK-9409:
--
Summary: Missing assembly-dependencies in flink-dist/pom.xml
Key: FLINK-9409
URL: https://issues.apache.org/jira/browse/FLINK-9409
Project: Flink
Issue Type
Nico Kruber created FLINK-9434:
--
Summary: Test instability in YARNSessionCapacitySchedulerITCase#
Key: FLINK-9434
URL: https://issues.apache.org/jira/browse/FLINK-9434
Project: Flink
Issue Type
Nico Kruber created FLINK-9435:
--
Summary: Remove per-key selection Tuple instantiation via
reflection in KeySelectorUtil#ComparableKeySelector
Key: FLINK-9435
URL: https://issues.apache.org/jira/browse/FLINK-9435
Nico Kruber created FLINK-9708:
--
Summary: Network buffer leaks when buffer request fails during
buffer redistribution
Key: FLINK-9708
URL: https://issues.apache.org/jira/browse/FLINK-9708
Project: Flink
Nico Kruber created FLINK-9755:
--
Summary: Exceptions in RemoteInputChannel#notifyBufferAvailable()
are not propagated to the responsible thread
Key: FLINK-9755
URL: https://issues.apache.org/jira/browse/FLINK-9755
Nico Kruber created FLINK-9756:
--
Summary: Exceptions in BufferListener#notifyBufferAvailable do not
trigger further listeners in LocalBufferPool#recycle()
Key: FLINK-9756
URL: https://issues.apache.org/jira/browse
Nico Kruber created FLINK-9761:
--
Summary: Potential buffer leak in PartitionRequestClientHandler
during job failures
Key: FLINK-9761
URL: https://issues.apache.org/jira/browse/FLINK-9761
Project: Flink
Nico Kruber created FLINK-9764:
--
Summary: Failure in LocalRecoveryRocksDBFullITCase
Key: FLINK-9764
URL: https://issues.apache.org/jira/browse/FLINK-9764
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-9766:
--
Summary: Incomplete/incorrect cleanup in RemoteInputChannelTest
Key: FLINK-9766
URL: https://issues.apache.org/jira/browse/FLINK-9766
Project: Flink
Issue Type
Nico Kruber created FLINK-9785:
--
Summary: Add remote addresses to TransportException instances
Key: FLINK-9785
URL: https://issues.apache.org/jira/browse/FLINK-9785
Project: Flink
Issue Type
Nico Kruber created FLINK-9797:
--
Summary: Separate state serializers from network serializers
Key: FLINK-9797
URL: https://issues.apache.org/jira/browse/FLINK-9797
Project: Flink
Issue Type
Nico Kruber created FLINK-9816:
--
Summary: Support Netty SslEngine based on openSSL
Key: FLINK-9816
URL: https://issues.apache.org/jira/browse/FLINK-9816
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-9817:
--
Summary: Version not correctly bumped to 5.0
Key: FLINK-9817
URL: https://issues.apache.org/jira/browse/FLINK-9817
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-9838:
--
Summary: Slot request failed Exceptions after completing a job
Key: FLINK-9838
URL: https://issues.apache.org/jira/browse/FLINK-9838
Project: Flink
Issue Type
Nico Kruber created FLINK-9839:
--
Summary: End-to-end test: Streaming job with SSL
Key: FLINK-9839
URL: https://issues.apache.org/jira/browse/FLINK-9839
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-9842:
--
Summary: Job submission fails via CLI with SSL enabled
Key: FLINK-9842
URL: https://issues.apache.org/jira/browse/FLINK-9842
Project: Flink
Issue Type: Bug
1 - 100 of 439 matches
Mail list logo
