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
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
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
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:
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
> >
> >
ted
> 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 all,
>
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,
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
; * 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.html
>
-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
gt;>>
>>> What do you think?
>>>
>>> [1] https://issues.apache.org/jira/projects/FLINK/versions/12343053
>>>
>>> [2]
>>> https://lists.apache.org/thread.html/1b8b0e627739d1f01b760fb722a1aeb2e786eec09ddd47b8303faadb@%3Cdev.flink.apache.org%3E
rg.apache.flink.runtime.operators.shipping.OutputCollector.collect(
>>> OutputCollector.java:65)
>>>> at
>>>> org.apache.flink.runtime.operators.util.metrics.
>>> CountingCollector.collect(CountingCollector.java:35)
>>>> at
>>>> org
he java classes:
>>>>> https://github.com/xseris/Flink-test-union/tree/master/src/
>>>>> main/java/okkam/it/flink/flink150SNAPSHOT (you first need to generate
>>>>> the test input csv [8 GB] through the RandomCsvGenerator.javaclass).
>>>>>
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
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:
>>
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
AV-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
>>> [4]
>>> https://repository.apache.org/content/r
gt; 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 job developer
le 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 23/05/2019 09:24, Nico Kruber wrote:
> >> Thank
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] https://github.com/apache/flink-web/pull/209
>>
equires 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 Ververica
--
Join Flink Forw
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
-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
ed 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>
>>>> [2]
>
四 下午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].
>>>&g
ommitters 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 despite the unfortunate perfor
; > > >>>
> > > > >>>> All of the prerequisites from 3rd party projects for both HBase
> >
> > [1]
> >
> > > > and
> > > >
> > > > >>>> Hive [2] to fully support Java 11 have been completed, so
ow 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.
>
> From: Nico Kruber
> Sent: Wednesday,
va 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, it
> > will write the length of the bytes first, which
gt; improvement
> >>
> >> to
> >>
> >> > this pattern usage, I'm interested in it. Do you have some POC work to
> >> > share for a closer look.
> >> > Besides, I have one question that can we support ex
is 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 believe, we have
> found a consensus on the
e'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 Apache Flink Conference
Stream Processing | Event Driven | Real Time
--
Ververica GmbH
Nico Kruber created FLINK-5613:
--
Summary: QueryableState: requesting a non-existing key in
RocksDBStateBackend is not consistent with the MemoryStateBackend and
FsStateBackend
Key: FLINK-5613
URL: https
Nico Kruber created FLINK-5615:
--
Summary: queryable state: execute the QueryableStateITCase for all
three state back-ends
Key: FLINK-5615
URL: https://issues.apache.org/jira/browse/FLINK-5615
Project
Nico Kruber created FLINK-5642:
--
Summary: queryable state: race condition with HeadListState
Key: FLINK-5642
URL: https://issues.apache.org/jira/browse/FLINK-5642
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5651:
--
Summary: state backends: forbid Iterator#remove() from the
Iterable returned by HeapListState#get()
Key: FLINK-5651
URL: https://issues.apache.org/jira/browse/FLINK-5651
Nico Kruber created FLINK-5591:
--
Summary: queryable state: request failures failing on the server
side do not contain client stack trace
Key: FLINK-5591
URL: https://issues.apache.org/jira/browse/FLINK-5591
Nico Kruber created FLINK-5814:
--
Summary: flink-dist creates wrong symlink when not used with
cleaned before
Key: FLINK-5814
URL: https://issues.apache.org/jira/browse/FLINK-5814
Project: Flink
Nico Kruber created FLINK-5576:
--
Summary: extend deserialization functions of
KvStateRequestSerializer to detect unconsumed bytes
Key: FLINK-5576
URL: https://issues.apache.org/jira/browse/FLINK-5576
Nico Kruber created FLINK-5507:
--
Summary: remove queryable list state sink
Key: FLINK-5507
URL: https://issues.apache.org/jira/browse/FLINK-5507
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-5515:
--
Summary: fix unused kvState.getSerializedValue call in
KvStateServerHandler
Key: FLINK-5515
URL: https://issues.apache.org/jira/browse/FLINK-5515
Project: Flink
Nico Kruber created FLINK-5521:
--
Summary: remove unused KvStateRequestSerializer#serializeList
Key: FLINK-5521
URL: https://issues.apache.org/jira/browse/FLINK-5521
Project: Flink
Issue Type
Nico Kruber created FLINK-5527:
--
Summary: QueryableState: requesting a non-existing key in
MemoryStateBackend or FsStateBackend does not return the default value
Key: FLINK-5527
URL: https://issues.apache.org/jira
Nico Kruber created FLINK-5526:
--
Summary: QueryableState: notify upon receiving a query but having
queryable state disabled
Key: FLINK-5526
URL: https://issues.apache.org/jira/browse/FLINK-5526
Project
Nico Kruber created FLINK-5528:
--
Summary: tests: reduce the retry delay in QueryableStateITCase
Key: FLINK-5528
URL: https://issues.apache.org/jira/browse/FLINK-5528
Project: Flink
Issue Type
Nico Kruber created FLINK-5530:
--
Summary: race condition in AbstractRocksDBState#getSerializedValue
Key: FLINK-5530
URL: https://issues.apache.org/jira/browse/FLINK-5530
Project: Flink
Issue
Nico Kruber created FLINK-5559:
--
Summary: queryable state:
KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException
without own failure message if deserialisation fails
Key: FLINK-5559
URL: https
Nico Kruber created FLINK-5561:
--
Summary: DataInputDeserializer#available returns one too few
Key: FLINK-5561
URL: https://issues.apache.org/jira/browse/FLINK-5561
Project: Flink
Issue Type
Nico Kruber created FLINK-5059:
--
Summary: only serialise events once in RecordWriter#broadcastEvent
Key: FLINK-5059
URL: https://issues.apache.org/jira/browse/FLINK-5059
Project: Flink
Issue
Nico Kruber created FLINK-5060:
--
Summary: only serialise records once in RecordWriter#emit and
RecordWriter#broadcastEmit
Key: FLINK-5060
URL: https://issues.apache.org/jira/browse/FLINK-5060
Project
Nico Kruber created FLINK-5066:
--
Summary: prevent LocalInputChannel#getNextBuffer from
de-serialising all events when looking for EndOfPartitionEvent only
Key: FLINK-5066
URL: https://issues.apache.org/jira/browse
Nico Kruber created FLINK-5178:
--
Summary: allow BLOB_STORAGE_DIRECTORY_KEY to point to a
distributed file system
Key: FLINK-5178
URL: https://issues.apache.org/jira/browse/FLINK-5178
Project: Flink
Nico Kruber created FLINK-5081:
--
Summary: unable to set yarn.maximum-failed-containers with flink
one-time YARN setup
Key: FLINK-5081
URL: https://issues.apache.org/jira/browse/FLINK-5081
Project: Flink
Nico Kruber created FLINK-5008:
--
Summary: Update IDE setup documentation
Key: FLINK-5008
URL: https://issues.apache.org/jira/browse/FLINK-5008
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-5308:
--
Summary: download links to previous releases are incomplete
Key: FLINK-5308
URL: https://issues.apache.org/jira/browse/FLINK-5308
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5309:
--
Summary: documentation links on the home page point to 1.2-SNAPSHOT
Key: FLINK-5309
URL: https://issues.apache.org/jira/browse/FLINK-5309
Project: Flink
Issue
Nico Kruber created FLINK-5334:
--
Summary: outdated scala SBT quickstart example
Key: FLINK-5334
URL: https://issues.apache.org/jira/browse/FLINK-5334
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-5482:
--
Summary: QueryableStateClient does not recover from a failed
lookup due to a non-running job
Key: FLINK-5482
URL: https://issues.apache.org/jira/browse/FLINK-5482
Nico Kruber created FLINK-5202:
--
Summary: test timeout (no output for 300s) in
YARNHighAvailabilityITCase
Key: FLINK-5202
URL: https://issues.apache.org/jira/browse/FLINK-5202
Project: Flink
Nico Kruber created FLINK-5204:
--
Summary: Flakey YARNSessionCapacitySchedulerITCase
(NullPointerException)
Key: FLINK-5204
URL: https://issues.apache.org/jira/browse/FLINK-5204
Project: Flink
Nico Kruber created FLINK-5203:
--
Summary: YARNHighAvailabilityITCase fails to deploy YARN cluster
Key: FLINK-5203
URL: https://issues.apache.org/jira/browse/FLINK-5203
Project: Flink
Issue Type
Nico Kruber created FLINK-5206:
--
Summary: Flakey PythonPlanBinderTest
Key: FLINK-5206
URL: https://issues.apache.org/jira/browse/FLINK-5206
Project: Flink
Issue Type: Bug
Environment
Nico Kruber created FLINK-5212:
--
Summary: Flakey ScalaShellITCase#testPreventRecreationBatch (out
of Java heap space)
Key: FLINK-5212
URL: https://issues.apache.org/jira/browse/FLINK-5212
Project: Flink
Nico Kruber created FLINK-6064:
--
Summary: wrong BlobServer hostname in TaskExecutor
Key: FLINK-6064
URL: https://issues.apache.org/jira/browse/FLINK-6064
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-6299:
--
Summary: make all IT cases extend from TestLogger
Key: FLINK-6299
URL: https://issues.apache.org/jira/browse/FLINK-6299
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-6270:
--
Summary: Port several network config parameters to ConfigOption
Key: FLINK-6270
URL: https://issues.apache.org/jira/browse/FLINK-6270
Project: Flink
Issue Type
Nico Kruber created FLINK-6287:
--
Summary: Flakey JobManagerRegistrationTest
Key: FLINK-6287
URL: https://issues.apache.org/jira/browse/FLINK-6287
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-6293:
--
Summary: Flakey JobManagerITCase
Key: FLINK-6293
URL: https://issues.apache.org/jira/browse/FLINK-6293
Project: Flink
Issue Type: Bug
Components: Job
Nico Kruber created FLINK-6292:
--
Summary: Travis: transfer.sh not accepting uploads via http://
anymore
Key: FLINK-6292
URL: https://issues.apache.org/jira/browse/FLINK-6292
Project: Flink
Nico Kruber created FLINK-6329:
--
Summary: refactor name-addressable accessors in BlobService
classes from returning a URL to a File or InputStream
Key: FLINK-6329
URL: https://issues.apache.org/jira/browse/FLINK
Nico Kruber created FLINK-6305:
--
Summary: flink-ml tests are executed in all flink-fast-test
profiles
Key: FLINK-6305
URL: https://issues.apache.org/jira/browse/FLINK-6305
Project: Flink
Issue
Nico Kruber created FLINK-6320:
--
Summary: Flakey JobManagerHAJobGraphRecoveryITCase
Key: FLINK-6320
URL: https://issues.apache.org/jira/browse/FLINK-6320
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-6008:
--
Summary: collection of BlobServer improvements
Key: FLINK-6008
URL: https://issues.apache.org/jira/browse/FLINK-6008
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-6005:
--
Summary: unit test ArrayList initializations without default size
Key: FLINK-6005
URL: https://issues.apache.org/jira/browse/FLINK-6005
Project: Flink
Issue
Nico Kruber created FLINK-6046:
--
Summary: Add support for oversized messages during deployment
Key: FLINK-6046
URL: https://issues.apache.org/jira/browse/FLINK-6046
Project: Flink
Issue Type
Nico Kruber created FLINK-5973:
--
Summary: check whether the direct memory size is always correctly
calculated
Key: FLINK-5973
URL: https://issues.apache.org/jira/browse/FLINK-5973
Project: Flink
Nico Kruber created FLINK-7315:
--
Summary: use flink's buffers in netty
Key: FLINK-7315
URL: https://issues.apache.org/jira/browse/FLINK-7315
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-7316:
--
Summary: always use off-heap network buffers
Key: FLINK-7316
URL: https://issues.apache.org/jira/browse/FLINK-7316
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-7311:
--
Summary: refrain from using fail(Exception#getMessage()) in core
memory tests
Key: FLINK-7311
URL: https://issues.apache.org/jira/browse/FLINK-7311
Project: Flink
Nico Kruber created FLINK-7312:
--
Summary: activate checkstyle for flink/core/memory/*
Key: FLINK-7312
URL: https://issues.apache.org/jira/browse/FLINK-7312
Project: Flink
Issue Type
Nico Kruber created FLINK-7310:
--
Summary: always use HybridMemorySegment
Key: FLINK-7310
URL: https://issues.apache.org/jira/browse/FLINK-7310
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-7351:
--
Summary: test instability in
JobClientActorRecoveryITCase#testJobClientRecovery
Key: FLINK-7351
URL: https://issues.apache.org/jira/browse/FLINK-7351
Project: Flink
Nico Kruber created FLINK-7346:
--
Summary:
EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow killed by
maven watchdog on Travis
Key: FLINK-7346
URL: https://issues.apache.org/jira/browse/FLINK
Nico Kruber created FLINK-7361:
--
Summary: flink-web doesn't build with ruby 2.4
Key: FLINK-7361
URL: https://issues.apache.org/jira/browse/FLINK-7361
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-7352:
--
Summary: ExecutionGraphRestartTest timeouts
Key: FLINK-7352
URL: https://issues.apache.org/jira/browse/FLINK-7352
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-7370:
--
Summary: rework operator documentation
Key: FLINK-7370
URL: https://issues.apache.org/jira/browse/FLINK-7370
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-7363:
--
Summary: add hashes and signatures to the download page
Key: FLINK-7363
URL: https://issues.apache.org/jira/browse/FLINK-7363
Project: Flink
Issue Type
Nico Kruber created FLINK-7412:
--
Summary: optimise NettyMessage.TaskEventRequest#readFrom() to read
from netty buffers directly
Key: FLINK-7412
URL: https://issues.apache.org/jira/browse/FLINK-7412
Nico Kruber created FLINK-7427:
--
Summary: integrate PartitionRequestProtocol into NettyProtocol
Key: FLINK-7427
URL: https://issues.apache.org/jira/browse/FLINK-7427
Project: Flink
Issue Type
Nico Kruber created FLINK-7428:
--
Summary: avoid one additional buffer copy when receiving messages
Key: FLINK-7428
URL: https://issues.apache.org/jira/browse/FLINK-7428
Project: Flink
Issue
Nico Kruber created FLINK-7431:
--
Summary: test instability in JobManagerFailsITCase
Key: FLINK-7431
URL: https://issues.apache.org/jira/browse/FLINK-7431
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-7467:
--
Summary: a slow client on the BlobServer may block writing
operations
Key: FLINK-7467
URL: https://issues.apache.org/jira/browse/FLINK-7467
Project: Flink
Nico Kruber created FLINK-7166:
--
Summary: generated avro sources not cleaned up or re-created after
changes
Key: FLINK-7166
URL: https://issues.apache.org/jira/browse/FLINK-7166
Project: Flink
Nico Kruber created FLINK-7196:
--
Summary: add a TTL to transient BLOB files
Key: FLINK-7196
URL: https://issues.apache.org/jira/browse/FLINK-7196
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-7212:
--
Summary: JobManagerLeaderSessionIDITSuite not executed
Key: FLINK-7212
URL: https://issues.apache.org/jira/browse/FLINK-7212
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-7140:
--
Summary: include a UUID/random name into the BlobKey
Key: FLINK-7140
URL: https://issues.apache.org/jira/browse/FLINK-7140
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-7141:
--
Summary: enable travis cache again
Key: FLINK-7141
URL: https://issues.apache.org/jira/browse/FLINK-7141
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-7262:
--
Summary: remove unused FallbackLibraryCacheManager
Key: FLINK-7262
URL: https://issues.apache.org/jira/browse/FLINK-7262
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-7261:
--
Summary: avoid unnecessary exceptions in the logs in non-HA cases
Key: FLINK-7261
URL: https://issues.apache.org/jira/browse/FLINK-7261
Project: Flink
Issue
1 - 100 of 427 matches
Mail list logo
