Andrey Yegorov

JUnit ignores tests with "@FlakyTest" annotation unless they have "@Test" annotation too Affected test suites: - TestLedgerAllocator - TestDistributedLogAdmin - TestDynamicConfigurationFeatureProvider - TableClientSimpleTest - BookKeeperDiskSpaceWeightedLedgerPlacementTest - BookieDecommissionTest (I fixed this...

`mvn test -f stream/distributedlog/core/pom.xml` ``` [ERROR] Tests run: 7, Failures: 0, Errors: 3, Skipped: 0, Time elapsed: 112.456 s

from CI log of the "Remaining Tests" job: ``` org.apache.bookkeeper.bookie.FileInfoBackingCacheTest Test testRaceGuavaEvictAndReleaseBeforeRetain PASSED (47m 41s) Test testRefCountRace PASSED (10.1s) Test basicTest PASSED Test testNoKey PASSED Test testForDeadlocks PASSED (10s) org.apache.bookkeeper.bookie.ForceAuditorChecksCmdTest...

happens on attempt to create second writer immediately after the first one. i only was able to repro this by running the whole suite, rtest passses if I run just...

``` org.apache.bookkeeper.replication.BookieAutoRecoveryTest Test testEmptyLedgerLosesQuorumEventually FAILED (11.4s) java.lang.AssertionError: Should be marked as replicated at org.apache.bookkeeper.replication.BookieAutoRecoveryTest.testEmptyLedgerLosesQuorumEventually(BookieAutoRecoveryTest.java:407) org.apache.bookkeeper.test.BookieZKExpireTest Test testBookieServerZKExpireBehaviour PASSED (16.2s) org.apache.bookkeeper.client.TestReadLastConfirmedLongPoll Test testReadLACLongPollWhenSomeBookiesDown[2] PASSED (6.9s) org.apache.bookkeeper.replication.BookieAutoRecoveryTest Test testEmptyLedgerLosesQuorumEventually FAILED (11.3s) java.lang.AssertionError:...

[FLAKY TEST] :bookkeeper-server:test failed with SIGSEGV on CI

2

**BUG REPORT** Test failed ``` org.apache.bookkeeper.bookie.CheckpointOnNewLedgersTest Test testCheckpoint PASSED # # A fatal error has been detected by the Java Runtime Environment: # # SIGSEGV (0xb) at pc=0x00007f6668000840, pid=8491, tid=0x00007f66661e0700...

**BUG REPORT** MVCCStoreFactoryImplTest flaked on CI run ``` ./gradlew stream:storage:impl:test ... java.lang.AssertionError: expected same: was not: at org.apache.bookkeeper.stream.storage.impl.store.MVCCStoreFactoryImplTest.testOpenStore(MVCCStoreFactoryImplTest.java:149) ``` ***Expected behavior*** stable passing test

Docs: CLI docs are badly out of date

1

**BUG REPORT** Multiple utilities have new options added, these do not show up in the documentation on the web site. Docs: https://bookkeeper.apache.org/docs/reference/cli#bookkeeper-shell-listunderreplicated ``` -missingreplica N | Bookie Id of missing...

Now I have to debug through the connector to understand what it didn't like: ``` com.snowflake.kafka.connector.internal.SnowflakeKafkaConnectorException: [SF_KAFKA_CONNECTOR] Exception: Invalid input connector configuration [SF_KAFKA_CONNECTOR] Error Code: 0001 [SF_KAFKA_CONNECTOR] Detail: input kafka...

There is no way to trigger flush in the connector without writing a record

2

Looking at SnowflakeSinkServiceV1: https://github.com/snowflakedb/snowflake-kafka-connector/blob/ed1b37a3554be84892e99e165023d0b856ecd24f/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java#L144-L147 the only time so-called "timed flush" is called only on the record insert. This not the behavior one expects if e.g. a burst of writes is...