pravega/flink-connectors

Issues

• Move CheckpointSerializer into serialization package

  #627 opened 3 years ago by fyang86
  0

• Fix test failure in branch `r0.11-flink1.12`

  #626 opened 3 years ago by fyang86
  1

• Python API support for the new unified sink

  #624 opened 3 years ago by thekingofcity
  0

• Mismatch in ThrottledIntegerGeneratingSource between code and comment

  #619 opened 3 years ago by thekingofcity
  0

• Watermark support with the new FLIP-167 API

  #623 opened 3 years ago by crazyzhou
  0

• Multiple use of the nested FlinkSerializer

  #620 opened 3 years ago by thekingofcity
  0

• Increase Default Transaction Lease to 600 seconds

  #617 opened 3 years ago by maddisondavid
  1

• Update the compatibility matrix for 0.11 and 1.14

  #615 opened 3 years ago by thekingofcity
  0

• Update connector to 0.10.2-SNAPSHOT in branch r0.10

  #606 opened 3 years ago by fyang86
  1

• De-lombok

  #588 opened 3 years ago by crazyzhou
  0

• Update branch `r0.11-flink1.13`

  #611 opened 3 years ago by fyang86
  1

• Unused distribution plugin in gradle

  #607 opened 3 years ago by thekingofcity
  0

• Prepare for upgrading Flink 1.14

  #560 opened 3 years ago by crazyzhou
  0

• Update connector to 0.11.0-SNAPSHOT

  #605 opened 3 years ago by fyang86
  0

• Fix copy options from catalog options to table options

  #603 opened 3 years ago by fyang86
  0

• Use `get` method of `CompletableFuture` instead of scheduling a new cancel task

  #572 opened 3 years ago by fyang86
  1

• Add security options for pravega registry format factory

  #599 opened 3 years ago by fyang86
  0

• Update branch `r0.10-flink1.12`

  #589 opened 3 years ago by fyang86
  1

• Add catalog security options to table options and update document

  #590 opened 3 years ago by fyang86
  0

• Allow insecure HTTP connection in `build.gradle`

  #597 opened 3 years ago by fyang86
  0

• Allow insecure HTTP connection

  #595 opened 3 years ago by fyang86
  0

• Add Python datastream API support

  #571 opened 3 years ago by crazyzhou
  0

• Add support for security in Pravega catalog

  #577 opened 3 years ago by fyang86
  0

• Upgrade Pravega client and schema-registry version

  #586 opened 3 years ago by fyang86
  0

• Update doc to have the right table of content

  #584 opened 3 years ago by thekingofcity
  1

• Update the license header

  #554 opened 3 years ago by fyang86
  0

• Make `mkdocsBuild` great again

  #581 opened 3 years ago by thekingofcity
  0

• More badges😁

  #579 opened 3 years ago by thekingofcity
  0

• Turn on secure ZK for Pravega cluster in IT

  #574 opened 3 years ago by fyang86
  0

• Remove mavenLocal() in the Gradle build script

  #569 opened 3 years ago by crazyzhou
  0

• Add integration tests for unaligned checkpoints

  #559 opened 3 years ago by crazyzhou
  0

• Drop support for Scala 2.11

  #556 opened 3 years ago by crazyzhou
  0

• How to use such connector in pyflink

  #547 opened 3 years ago by Hoohaha
  2

• Refactor constants, validation helpers, and utilities into another class for Pravega options

  #566 opened 3 years ago by fyang86
  0

• Remove deprecated api

  #564 opened 3 years ago by thekingofcity
  0

• Fix type of some exceptions in Pravega catalog

  #561 opened 3 years ago by fyang86
  0

• Support SpecificRecordBase in DeserializerFromSchemaRegistry

  #552 opened 3 years ago by fyang86
  0

• Fix Json prefix for Pravega catalog factory

  #557 opened 3 years ago by fyang86
  0

• Wrong doc link in readme.md

  #546 opened 3 years ago by Hoohaha
  1

• Support new Json option in Flink 1.13

  #545 opened 3 years ago by fyang86
  0

• Generify method to set json related options in Pravega catalog

  #543 opened 3 years ago by fyang86
  0

• Update for Flink 1.13 release

  #540 opened 3 years ago by fyang86
  0

• NullPointerException when there's no credentials in Pravega client config

  #539 opened 3 years ago by fyang86
  0

• Enhance naming in Pravega catalog

  #531 opened 4 years ago by fyang86
  0

• Build documentation

  #536 opened 3 years ago by fpj
  1

• Support format metadata

  #534 opened 3 years ago by thekingofcity
  0

• Add collector to PravegaDeserializationSchema

  #530 opened 3 years ago by crazyzhou
  0

• Upsert table support investigation

  #535 opened 4 years ago by crazyzhou
  0

• Introduce dependency sorting in the checkstyle configurations in r0.10-flink1.10

  #523 opened 4 years ago by thekingofcity
  1

• Introduce dependency sorting in the checkstyle configurations in r0.10-flink1.11

  #525 opened 4 years ago by thekingofcity
  1