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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-18364) A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of the 'rowtime' field of the TableSink consumed type" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18363) Add user classloader to context in DeSerializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18362) Shipping jdk by shipping archive by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18361) Support username and password options for new Elasticsearch connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18360) Flink History Server doesn't show correctly table of Completed jobs when there are no archived jobs are in the archive directory by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18359) Improve error-log strategy for Elasticsearch sink for large data documentId conflict when using create mode for `insert ignore` semantics by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18358) TableEnvironmentITCase.testSqlUpdateAndToDataSetWithTableSource:245 unstable: result mismatch by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18356) Exit code 137 returned from process when testing pyflink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18355) Simplify tests of SlotPoolImpl by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Table program cannot be compiled when enable checkpoint of StreamExecutionEnvironment by 杜斌

by Jark Wu-2

[jira] [Created] (FLINK-18354) when use ParquetAvroWriters.forGenericRecord(Schema schema) error java.lang.ClassCastException: org.apache.flink.api.java.tuple.Tuple2 cannot be cast to org.apache.avro.generic.IndexedRecord by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18350) [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Any good comparison on FSM of Flink vs Akka? by Rohit R

by Rohit R

[jira] [Created] (FLINK-18349) Add Flink 1.11 release notes to documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18348) RemoteInputChannel should checkError before checking partitionRequestClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18347) Error java.lang.NoSuchFieldError: NO_INTS by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Which is Best option between Flink or Flink Stateful Functions or Akka FSM for State Use-cases? by Rohit R

by Rohit R

[jira] [Created] (FLINK-18346) Support partition pruning for lookup table source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18345) Support filter push down for lookup table source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18343) Enable DEBUG logging for java e2e tests by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18342) SQLParser can not parse ROW() if it contains UDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Any python example with json data from Kafka using flink-statefun by Sunil Sattiraju

by Tzu-Li (Gordon) Tai

[jira] [Created] (FLINK-18340) Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18338) RocksDB tests crash the JVM on CI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18337) Introduce TableResult#await method to wait data ready by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18336) CheckpointFailureManager forgets failed checkpoints after a successful one by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18334) Exclude .dumpstream files that only contain JAVA_TOOL_OPTIONS logging by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 158159160161162163164 ... 778