(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 ... 84858687888990 ... 778

Topics (27203)

Replies

Last Post

Views

Kafka Consumer Deserializer Exception on application mode by han guoguo

by Aljoscha Krettek-2

[jira] [Created] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Consumer fails to consume from Latest by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20627) Cancel Job button overlaps text in smaller windows by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20626) Canceling a job when it is failing will result in job hanging in CANCELING state by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20625) Refactor Google Cloud PubSub Source in accordance with FLIP-27 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20624) Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20623) Separate the implementation of StreamExecWatermarkAssigner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20622) Separate the implementation of StreamExecChangelogNormalize by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20621) Refactor the TypeInformation implementation in Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20620) Port StreamExecPythonCalc to java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20619) Remove InputDependencyConstraint and InputDependencyConstraintChecker by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20616) Support Row-based Operation Accept Function Name by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Fwd: Unit Test modify SourceFunction() Instance? Is this possible? by chrisgopherrong

by chrisgopherrong

[jira] [Created] (FLINK-20613) Update TableResult.collect()/TableResult.print() to the new type system by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Unexpected latency across operator instances by Antonis Papaioannou

by Antonis Papaioannou

[jira] [Created] (FLINK-20612) Add benchmarks for scheduler by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20611) Support mini batch for window aggregate operation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20610) Separate the implementation of BatchExecCalc and StreamExecCalc by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20609) Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20608) Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20607) a wrong example in udfs page. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20606) sql client cannot create function using user classes from jar which specified by -j option by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20605) DeclarativeSlotManager crashes if slot allocation notification is processed after taskexecutor shutdown by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20603) Update pyflink walkthrough playground for 1.12 release by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20604) Update table walkthrough playground for 1.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20602) Getting exception Connecting kinesis with mfa by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20601) Rework PyFlink CLI documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20600) Remove SlotSharingManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20599) Update operations playground for 1.12 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 84858687888990 ... 778