(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 54555657585960 ... 783

Topics (27371)

Replies

Last Post

Views

[jira] [Created] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.BufferUnderflowException" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21705) Add a SliceType to the StateFun Java SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21704) Support StreamExecChangelogNormalize json serde by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21703) Add option `table.dml-sync` by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21701) Extend the `RESET` command in the sql client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21699) SecurityUtils JaasModule make JVM dirty by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21698) Disable problematic cast conversion between NUMERIC type and TIMESTAMP type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Flink-RocketMQ connector by heng du

by heng du

[DISCUSS] FLIP-162 follow-up discussion by Leonard Xu

by Leonard Xu

[jira] [Created] (FLINK-21697) Support StreamExecMiniBatchAssigner json serialization/deserialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21696) scala code in "Writing WatermarkGenerators" documentation missing/deprecated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Statefun] Interaction Protocol for Statefun by Guillaume Vauvert

by Guillaume Vauvert

[jira] [Created] (FLINK-21695) Increase default value for number of KeyGroups by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21694) Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21693) TestStreamEnvironment does not implement executeAsync by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21692) Update the Python SDK to reflect the latest changes in the request-reply protocol by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21691) KafkaSource fails with NPE when setting it up by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

QUESTION: Local Dev Setup by Jan Brusch

by Till Rohrmann

[jira] [Created] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21689) UnalignedCheckpointITCase does not terminate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21688) we use setIncreaseParallelism function, can cause slow flush in restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21687) e2e "Run kubernetes session test (default input)" timed out due to k8s issue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup by Shang Yuanchun (Jira...

by 戴林巍

[jira] [Created] (FLINK-21684) Fix typo in StreamExecDeduplicate by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21683) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21682) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21681) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21680) Table Created with LIKE clause may get unexpected options "is_generic" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-165: Operator's Flame Graphs by Alexander Fedulov

by Zhu Zhu

[jira] [Created] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 54555657585960 ... 783