(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 ... 167168169170171172173 ... 786

Topics (27508)

Replies

Last Post

Views

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...

[jira] [Created] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18332) Add error message to precondition in KeyGroupPartitionedPriorityQueue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18331) Hive NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18330) Python NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18329) Runtime NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18328) Blink planner NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18327) ML NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18326) Kubernetes NOTICE issues by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18325) SqlMapTypeNameSpec#unparse may throw NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18324) Translate updated data type and function page into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 167168169170171172173 ... 786