[jira] [Created] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer

Zhanghao Chen created FLINK-36904: - Summary: Fix doc error on how to programmatically register a 3rd-party serializer Key: FLINK-36904 URL: https://issues.apache.org/jira/browse/FLINK-36904 Project

[jira] [Created] (FLINK-36650) ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists

Jerome Gagnon created FLINK-36650: - Summary: ConfluentRegistryAvroSerializationSchema always tries to register the schema on serialize even if it already exists Key: FLINK-36650 URL: https://issues.apache.org

[jira] [Created] (FLINK-36007) cdc load and register factory in once search

Hongshun Wang created FLINK-36007: - Summary: cdc load and register factory in once search Key: FLINK-36007 URL: https://issues.apache.org/jira/browse/FLINK-36007 Project: Flink Issue Type

[jira] [Created] (FLINK-34936) Register shared state files to FileMergingSnapshotManager

Jinzhong Li created FLINK-34936: --- Summary: Register shared state files to FileMergingSnapshotManager Key: FLINK-34936 URL: https://issues.apache.org/jira/browse/FLINK-34936 Project: Flink

Meet our keynote speakers and register to Community Over Code EU!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] * Merge with the ASF EUniverse!The registration for Community

[jira] [Created] (FLINK-33924) Register for INFRA's self-hosted runner trial

Matthias Pohl created FLINK-33924: - Summary: Register for INFRA's self-hosted runner trial Key: FLINK-33924 URL: https://issues.apache.org/jira/browse/FLINK-33924 Project: Flink Issue

[jira] [Created] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

melin created FLINK-30126: - Summary: Delay registration of the catalog, register the catalog as needed Key: FLINK-30126 URL: https://issues.apache.org/jira/browse/FLINK-30126 Project: Flink Issue

[jira] [Created] (FLINK-28866) Use DDL instead of legacy method to register the test source in JoinITCase

godfrey he created FLINK-28866: -- Summary: Use DDL instead of legacy method to register the test source in JoinITCase Key: FLINK-28866 URL: https://issues.apache.org/jira/browse/FLINK-28866 Project

[jira] [Created] (FLINK-28621) Register JavaTimeModule in all internal object mappers

Chesnay Schepler created FLINK-28621: Summary: Register JavaTimeModule in all internal object mappers Key: FLINK-28621 URL: https://issues.apache.org/jira/browse/FLINK-28621 Project: Flink

[jira] [Created] (FLINK-27658) Introduce MutableURLClassLoader allow to register and remove user jar dynamically

dalongliu created FLINK-27658: - Summary: Introduce MutableURLClassLoader allow to register and remove user jar dynamically Key: FLINK-27658 URL: https://issues.apache.org/jira/browse/FLINK-27658 Project

[jira] [Created] (FLINK-26775) PyFlink WindowOperator#process_element register wrong cleanup timer

Juntao Hu created FLINK-26775: - Summary: PyFlink WindowOperator#process_element register wrong cleanup timer Key: FLINK-26775 URL: https://issues.apache.org/jira/browse/FLINK-26775 Project: Flink

[jira] [Created] (FLINK-25862) Refactor SharedStateRegistry to limit StreamStateHandle to register/unregister

Yun Tang created FLINK-25862: Summary: Refactor SharedStateRegistry to limit StreamStateHandle to register/unregister Key: FLINK-25862 URL: https://issues.apache.org/jira/browse/FLINK-25862 Project

[jira] [Created] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

Lijie Wang created FLINK-25669: -- Summary: Support register operator coordinators for newly initialized ExecutionJobVertex. Key: FLINK-25669 URL: https://issues.apache.org/jira/browse/FLINK-25669 Project

[jira] [Created] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

ming li created FLINK-24086: --- Summary: Do not re-register SharedStateRegistry to reduce the recovery time of the job Key: FLINK-24086 URL: https://issues.apache.org/jira/browse/FLINK-24086 Project: Flink

回复：回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

provide the dynamic register mechanism (e.g. CREATE TYPE user_enum AS ENUM ('enum1', 'enum2', 'enum3'); CREATE TABLE user_enum_tb( enum_column user_enum);). In summary Flink DataType provide the expansion for user to define custom type they want. But lack of expansion

Re: 回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

发件人：Jark Wu 发送时间：2021年6月23日(星期三) 23:13 收件人：dev ; 云华 主　题：Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValue

回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

Jark Wu 发送时间：2021年6月23日(星期三) 23:13 收件人：dev ; 云华 主　题：Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValueType which c

[RESULT][VOTE] FLIP-129 Register sources/sinks in Table API

Hi everyone, The vote for FLIP-129 has now been closed. We have five approving votes, four of which are binding: * Timo Walther (binding) * Jark Wu (binding) * Jingsong Li (binding) * Jing Zhang (binding) * Leonard Xu There are no disapproving votes. Thanks everyone for voting! Regards Ingo

Re: [DISCUSS] [FLINK-23122] Provide the Dynamic register converter

Hi, `TIMESTAMP_WITH_TIME_ZONE` is not supported in the Flink SQL engine, even though it is listed in the type API. I think what you are looking for is the RawValueType which can be used as user-defined type. You can use `DataTypes.RAW(TypeInformation)` to define a Raw type with the given TypeIn

[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

Hi everyone, I want to rework type conversion system in connector and flink table module to be resuable and scalability. I Postgres system, the type '_citext' will not supported in org.apache.flink.connector.jdbc.catalog.PostgresCatalog#fromJDBCType. what's more, org.apache.flink.table.runti

[jira] [Created] (FLINK-23122) Provide the Dynamic register converter

lqjacklee created FLINK-23122: - Summary: Provide the Dynamic register converter Key: FLINK-23122 URL: https://issues.apache.org/jira/browse/FLINK-23122 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

ast for at least 72 hours (Thu, Jun 24th 12:00 GMT) >>> unless >>>>> there is an objection or insufficient votes. >>>>> >>>>> >>>>> Thanks >>>>> Ingo >>>>> >>>>> [1] >>>>> >>>> >>> >> https://lists.apache.org/thread.html/rc75d64e889bf35592e9843dde86e82bdfea8fd4eb4c3df150112b305%40%3Cdev.flink.apache.org%3E >>>>> [2] >>>>> >>>> >>> >> https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API >>>>> >>>> >>>> >>> >> >> >> -- >> Best, Jingsong Lee >>

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

ed[2]. > > > > > > > > The vote will last for at least 72 hours (Thu, Jun 24th 12:00 GMT) > > unless > > > > there is an objection or insufficient votes. > > > > > > > > > > > > Thanks > > > > Ingo > > &

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

; Ingo > > > > > > [1] > > > > > > https://lists.apache.org/thread.html/rc75d64e889bf35592e9843dde86e82bdfea8fd4eb4c3df150112b305%40%3Cdev.flink.apache.org%3E > > > [2] > > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API > > > > > > > > -- Best, Jingsong Lee

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

insufficient votes. > > > > > > Thanks > > Ingo > > > > [1] > > > https://lists.apache.org/thread.html/rc75d64e889bf35592e9843dde86e82bdfea8fd4eb4c3df150112b305%40%3Cdev.flink.apache.org%3E > > [2] > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API > > > >

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API

[VOTE] FLIP-129 Register sources/sinks in Table API

insufficient votes. Thanks Ingo [1] https://lists.apache.org/thread.html/rc75d64e889bf35592e9843dde86e82bdfea8fd4eb4c3df150112b305%40%3Cdev.flink.apache.org%3E [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API

[jira] [Created] (FLINK-23062) FLIP-129: Register sources/sinks in Table API

Ingo Bürk created FLINK-23062: - Summary: FLIP-129: Register sources/sinks in Table API Key: FLINK-23062 URL: https://issues.apache.org/jira/browse/FLINK-23062 Project: Flink Issue Type: New

[jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark

Kezhu Wang created FLINK-21806: -- Summary: ContinuousEventTimeTrigger should register its first timer base on current watermark Key: FLINK-21806 URL: https://issues.apache.org/jira/browse/FLINK-21806

Re: Failed to register Protobuf Kryo serialization

Sorry, I realize I posted this to the wrong list, please ignore and I'll post it to the flink-user one. On Sun, Feb 14, 2021 at 11:41 AM Svend Vanderveken wrote: > Hi all, > > I'm failing to setup an example of wire serialization with Protobuf, could > you help me figure out what I'm doing wrong

Failed to register Protobuf Kryo serialization

Hi all, I'm failing to setup an example of wire serialization with Protobuf, could you help me figure out what I'm doing wrong? I'm using a simple protobuf schema: ``` syntax = "proto3"; import "google/protobuf/wrappers.proto"; option java_multiple_files = true; message DemoUserEvent { Meta

[jira] [Created] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

Yangze Guo created FLINK-20836: -- Summary: Register TaskManager with total and default slot resource profile in SlotManager Key: FLINK-20836 URL: https://issues.apache.org/jira/browse/FLINK-20836 Project

[jira] [Created] (FLINK-20749) Allow to register new slots listener at DeclarativeSlotPool

Till Rohrmann created FLINK-20749: - Summary: Allow to register new slots listener at DeclarativeSlotPool Key: FLINK-20749 URL: https://issues.apache.org/jira/browse/FLINK-20749 Project: Flink

Re: Register processing time timers when Operator.close() is called

Thanks, Aljoscha! Manually draining processing time timers during operator.close() is my current workaround as well. It's just not efficient for me since I may set the processing time timer for the callback after 5 mins but now I need to fire them immediately. https://issues.apache.org/jira/brows

Re: Register processing time timers when Operator.close() is called

Hi! This is an interesting topic and we recently created a Jira issue about this: https://issues.apache.org/jira/browse/FLINK-18647. In Beam we even have a workaround for this: https://github.com/apache/beam/blob/0c01636fc8610414859d946cb93eabc904123fc8/runners/flink/src/main/java/org/apache/

Register processing time timers when Operator.close() is called

Hi team, I'm writing my custom Operator as a high fan-out operation and I use processing time timers to defer processing some inputs When timers are firing, the operator will continue to process the deferred elements. One typical use case for my Operator is like: ImpulseOperator -> my Operator ->

[jira] [Created] (FLINK-20077) Cannot register a view with MATCH_RECOGNIZE clause

Dawid Wysakowicz created FLINK-20077: Summary: Cannot register a view with MATCH_RECOGNIZE clause Key: FLINK-20077 URL: https://issues.apache.org/jira/browse/FLINK-20077 Project: Flink

[jira] [Created] (FLINK-19677) TaskManager takes abnormally long time to register with JobManager on Kubernetes

Weike Dong created FLINK-19677: -- Summary: TaskManager takes abnormally long time to register with JobManager on Kubernetes Key: FLINK-19677 URL: https://issues.apache.org/jira/browse/FLINK-19677 Project

[jira] [Created] (FLINK-19422) Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002"

Dian Fu created FLINK-19422: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002" Key: FLINK-19422 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-19166) StreamingFileWriter should register Listener before the initialization of buckets

Jingsong Lee created FLINK-19166: Summary: StreamingFileWriter should register Listener before the initialization of buckets Key: FLINK-19166 URL: https://issues.apache.org/jira/browse/FLINK-19166

[jira] [Created] (FLINK-19012) E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument."

Robert Metzger created FLINK-19012: -- Summary: E2E test fails with "Cannot register Closeable, this subtaskCheckpointCoordinator is already closed. Closing argument." Key: FLINK-19012

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

gt;>> Timo > > >>> > > >>> On 24.07.20 12:42, Jark Wu wrote: > > >>>> Hi all, > > >>>> > > >>>> I would like to start the vote for FLIP-129 [1], which is discussed > > and > > >>>> rea

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

gt;>>>>> >>>>>> I would like to start the vote for FLIP-129 [1], which is discussed >> and >>>>>> reached consensus in the discussion thread [2]. >>>>>> >>>>>> The vote will be open until 27th July

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

the discussion thread [2]. > >>>> > >>>> The vote will be open until 27th July (72h), unless there is an > >> objection > >>>> or not enough votes. > >>>> > >>>> Best, > >>>> Jark > >>>> > >>>> [1]: > >>>> > >>> > >> > https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API > >>>> [2]: > >>>> > >>> > >> > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-129-Refactor-Descriptor-API-to-register-connector-in-Table-API-td42995.html > >>>> > >>> > >>> > >> > > -- Best, Jingsong Lee

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

hich is discussed and >>>> reached consensus in the discussion thread [2]. >>>> >>>> The vote will be open until 27th July (72h), unless there is an >> objection >>>> or not enough votes. >>>> >>>> Best, >>>>

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

there is an > objection > > > or not enough votes. > > > > > > Best, > > > Jark > > > > > > [1]: > > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API > > > [2]: > > > > > > http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-129-Refactor-Descriptor-API-to-register-connector-in-Table-API-td42995.html > > > > > > > >

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

nd > > reached consensus in the discussion thread [2]. > > > > The vote will be open until 27th July (72h), unless there is an objection > > or not enough votes. > > > > Best, > > Jark > > > > [1]: > > > https://cwiki.apache.org/confluence/

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

enough votes. Best, Jark [1]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API [2]: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-129-Refactor-Descriptor-API-to-register-connector-in-Table-API

[VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

-129%3A+Refactor+Descriptor+API+to+register+connectors+in+Table+API [2]: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-129-Refactor-Descriptor-API-to-register-connector-in-Table-API-td42995.html

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

Option { INCLUDING_ALL, INCLUDING_CONSTRAINTS, INCLUDING_GENERATED, INCLUDING_OPTIONS, INCLUDING_PARTITIONS, INCLUDING_WATERMARKS, EXCLUDING_ALL, EXCLUDING_CONSTRAINTS, EXCLUDING_GENERATED, EXCLUDING_OPTIONS, EXCLUDING_PARTITIONS, EXCLUDING_WATERMARKS, OVERWRITING_GENERAT

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

understand and use for users. > > public enum LikeOption { > INCLUDING_ALL, > INCLUDING_CONSTRAINTS, > INCLUDING_GENERATED, > INCLUDING_OPTIONS, > INCLUDING_PARTITIONS, > INCLUDING_WATERMARKS, > > EXCLUDING_ALL, > EXCLUDING_CONSTRAINTS, > EXCLUDING_GENER

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

ll be more > aligned with SQL DDL and easy to understand and use for users. > > public enum LikeOption { > INCLUDING_ALL, > INCLUDING_CONSTRAINTS, > INCLUDING_GENERATED, > INCLUDING_OPTIONS, > INCLUDING_PARTITIONS, > INCLUDING_WATERMARKS, > > EXCLUDING_ALL, > EXC

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

es/CatalogTable. That way you would have the > same digest for all inline tables with the same properties. In your > approach two scans of the same descriptor will have different digests. > (I am not saying this is particularly wrong, but different from > scan("test") ). Si

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

rent from scan("test") ). Similarly, we do not register filters/joins/groupings under generated names just to compute the digest. One additional problem you will have is you will need to add handling of that special tables when e.g. listing tables. Nevertheless I don't want to block t

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

{ INCLUDING_ALL, INCLUDING_CONSTRAINTS, INCLUDING_GENERATED, INCLUDING_OPTIONS, INCLUDING_PARTITIONS, INCLUDING_WATERMARKS, EXCLUDING_ALL, EXCLUDING_CONSTRAINTS, EXCLUDING_GENERATED, EXCLUDING_OPTIONS, EXCLUDING_PARTITIONS, EXCLUDING_WATERMARKS, OVERWRITING_GENERATED,

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

amp;& ...); | |        return new LikeOption(MergingStrategy.INCLUDING, option); | |    }| || |}| 3) TableEnvironment#from(descriptor) will register descriptor under a system generated table path (just like TableImpl#toString) first, and scan from the table path to derive the Table. Table#executeInsert(

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

.build()) .partitionedBy("part_field_0", "part_field_1") // Kafka doesn't support partitioned table yet, this is just an example for the API .build() ); I hope this resolves all your concerns. Welcome for further feedback! Updated FLIP: https:/

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

part_field_1") // Kafka doesn't support partitioned table yet, this is just an example for the API .build() ); I hope this resolves all your concerns. Welcome for further feedback! Updated FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-129%3A+Refactor+Descriptor+API+to+r

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

> .booleanType() >> .defaultValue(false) >> >> WDYT? >> >> Best, >> Leonard Xu >> >> >> > 在 2020年7月15日，16:37，Timo Walther 写道： >> > >> > Hi Jark, >> > >> > thanks for working on this issue. It is ti

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

core parts of the FLIP, esp. that > TableDescriptor is one entity that can be passed to different methods. Here > is some feedback from my side: > > > > 1) +1 for just `column(...)` > > > > 2) Expression DSL vs pure SQL string for computed columns > > I agre

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

gree with Dawid. Using the Expression DSL is desireable for a consistent > API. Furthermore, otherwise people need to register functions if they want to > use them in an expression. Refactoring TableSchema is definitely on the list > for 1.12. Maybe we can come up with some intermediate

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

(...)` 2) Expression DSL vs pure SQL string for computed columns I agree with Dawid. Using the Expression DSL is desireable for a consistent API. Furthermore, otherwise people need to register functions if they want to use them in an expression. Refactoring TableSchema is definitely on the list for

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

enough. Sorry for the confusion. Nevertheless I'd still like > to see a bit more explanation on the LikeOptions. > > On 07/07/2020 04:32, Jark Wu wrote: > > Hi everyone, > > > > Leonard and I prepared a FLIP about refactoring current Descriptor API, > > i.e

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

ut refactoring current Descriptor API, > i.e. TableEnvironment#connect(). We would like to propose a new descriptor > API to register connectors in Table API. > > Since Flink 1.9, the community focused more on the new SQL DDL feature. > After a series of releases, the SQL DDL is powerful

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

ype("kafka") // I am not strong on the "type" keyword here. I can also see for/of/... Best, Dawid On 07/07/2020 04:32, Jark Wu wrote: > Hi everyone, > > Leonard and I prepared a FLIP about refactoring current Descriptor API, > i.e. TableEnvironment#connect(). We

[DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

Hi everyone, Leonard and I prepared a FLIP about refactoring current Descriptor API, i.e. TableEnvironment#connect(). We would like to propose a new descriptor API to register connectors in Table API. Since Flink 1.9, the community focused more on the new SQL DDL feature. After a series of

[jira] [Created] (FLINK-18275) Register the DataStream as table how to write multiple fields

robert created FLINK-18275: -- Summary: Register the DataStream as table how to write multiple fields Key: FLINK-18275 URL: https://issues.apache.org/jira/browse/FLINK-18275 Project: Flink Issue

[jira] [Created] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers

Adam Laczynski created FLINK-17499: -- Summary: LazyTimerService used to register timers via State Processing API incorectly mixes event time timers with processing time timers Key: FLINK-17499 URL: https

[jira] [Created] (FLINK-16692) flink joblistener can register from config

jackylau created FLINK-16692: Summary: flink joblistener can register from config Key: FLINK-16692 URL: https://issues.apache.org/jira/browse/FLINK-16692 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16117) Avoid register source in TableTestBase#addTableSource

Zhenghua Gao created FLINK-16117: Summary: Avoid register source in TableTestBase#addTableSource Key: FLINK-16117 URL: https://issues.apache.org/jira/browse/FLINK-16117 Project: Flink Issue

[jira] [Created] (FLINK-16029) Remove register source and sink in test cases of planner

Zhenghua Gao created FLINK-16029: Summary: Remove register source and sink in test cases of planner Key: FLINK-16029 URL: https://issues.apache.org/jira/browse/FLINK-16029 Project: Flink

[jira] [Created] (FLINK-15990) Remove register source and sink in ConnectTableDescriptor

Jingsong Lee created FLINK-15990: Summary: Remove register source and sink in ConnectTableDescriptor Key: FLINK-15990 URL: https://issues.apache.org/jira/browse/FLINK-15990 Project: Flink

Re: [DISCUSS] Register user jar files in {Stream}ExecutionEnvironment

jars. And SQL-CLI need it too. > > Best, > Jingsong Lee > > On Wed, Dec 11, 2019 at 9:18 AM 50man wrote: > > > Hi everyone, > > > > > > I propose an important API feature to register user jar files in > > {Stream}ExecutionEnvironment. > >

Re: [DISCUSS] Register user jar files in {Stream}ExecutionEnvironment

I propose an important API feature to register user jar files in > {Stream}ExecutionEnvironment. > > The proposal is here, > > https://issues.apache.org/jira/browse/FLINK-14319 > > Let's discuss it and I hope we can acquire a consent ASAP cause this > feature is potentia

[DISCUSS] Register user jar files in {Stream}ExecutionEnvironment

Hi everyone, I propose an important API feature to register user jar files in {Stream}ExecutionEnvironment. The proposal is here, https://issues.apache.org/jira/browse/FLINK-14319 Let's discuss it and I hope we can acquire a consent ASAP cause this feature is potentially helpful for

[jira] [Created] (FLINK-14912) register,drop, and alter catalog functions from DDL to FunctionCatalog

Bowen Li created FLINK-14912: Summary: register,drop, and alter catalog functions from DDL to FunctionCatalog Key: FLINK-14912 URL: https://issues.apache.org/jira/browse/FLINK-14912 Project: Flink

[jira] [Created] (FLINK-14911) register temp catalog functions created by DDL to FunctionCatalog

Bowen Li created FLINK-14911: Summary: register temp catalog functions created by DDL to FunctionCatalog Key: FLINK-14911 URL: https://issues.apache.org/jira/browse/FLINK-14911 Project: Flink

[jira] [Created] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

hehuiyuan created FLINK-14550: - Summary: can't use proctime attribute when register datastream for table and exist nested fields Key: FLINK-14550 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

Leo Zhang created FLINK-14319: - Summary: Register user jar files in {Stream}ExecutionEnvironment Key: FLINK-14319 URL: https://issues.apache.org/jira/browse/FLINK-14319 Project: Flink Issue

[jira] [Created] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

Xintong Song created FLINK-14188: Summary: TaskExecutor derive and register with default slot resource profile Key: FLINK-14188 URL: https://issues.apache.org/jira/browse/FLINK-14188 Project: Flink

[jira] [Created] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

xymaqingxiang created FLINK-14094: - Summary: Fix OperatorIOMetricGroup repeat register problem Key: FLINK-14094 URL: https://issues.apache.org/jira/browse/FLINK-14094 Project: Flink Issue

[jira] [Created] (FLINK-12626) Client should not register table-source-sink twice in TableEnvironment

Bowen Li created FLINK-12626: Summary: Client should not register table-source-sink twice in TableEnvironment Key: FLINK-12626 URL: https://issues.apache.org/jira/browse/FLINK-12626 Project: Flink

[jira] [Created] (FLINK-12604) Register TableSource/Sink as CatalogTable

Dawid Wysakowicz created FLINK-12604: Summary: Register TableSource/Sink as CatalogTable Key: FLINK-12604 URL: https://issues.apache.org/jira/browse/FLINK-12604 Project: Flink Issue Type

[jira] [Created] (FLINK-12601) Register DataStream/DataSet as DataStream/SetTableOperations in Catalog

Dawid Wysakowicz created FLINK-12601: Summary: Register DataStream/DataSet as DataStream/SetTableOperations in Catalog Key: FLINK-12601 URL: https://issues.apache.org/jira/browse/FLINK-12601

[jira] [Created] (FLINK-12404) Translate the "Register a custom serializer for your Flink program" page into Chinese

YangFei created FLINK-12404: --- Summary: Translate the "Register a custom serializer for your Flink program" page into Chinese Key: FLINK-12404 URL: https://issues.apache.org/jira/browse/FLINK-12404

[jira] [Created] (FLINK-12202) Consider introducing batch metric register in NetworkEnviroment

Andrey Zagrebin created FLINK-12202: --- Summary: Consider introducing batch metric register in NetworkEnviroment Key: FLINK-12202 URL: https://issues.apache.org/jira/browse/FLINK-12202 Project: Flink

[jira] [Created] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment

Xuefu Zhang created FLINK-10542: --- Summary: Register Hive metastore as an external catalog in TableEnvironment Key: FLINK-10542 URL: https://issues.apache.org/jira/browse/FLINK-10542 Project: Flink

[jira] [Created] (FLINK-10239) Register eventtime timer only once in eventtrigger

buptljy created FLINK-10239: --- Summary: Register eventtime timer only once in eventtrigger Key: FLINK-10239 URL: https://issues.apache.org/jira/browse/FLINK-10239 Project: Flink Issue Type

[jira] [Created] (FLINK-10079) Automatically resolve and register sink table name from external catalogs

Jun Zhang created FLINK-10079: - Summary: Automatically resolve and register sink table name from external catalogs Key: FLINK-10079 URL: https://issues.apache.org/jira/browse/FLINK-10079 Project: Flink

Re: Register

To subscribe to the dev list you have to send a mail to dev-subscr...@flink.apache.org On 11.07.2018 09:17, 陈梓立 wrote: Register

Register

Register

Register now for ApacheCon and save $250

be going up from $550 to $800 so register NOW to save $250, at http://apachecon.com/acna18 And don’t forget to reserve your hotel room. We have negotiated a special rate and the room block closes August 24. http://www.apachecon.com/acna18/venue.html Our schedule includes over 100 talks and

[jira] [Created] (FLINK-9741) Register JVM metrics for each JM separately

Chesnay Schepler created FLINK-9741: --- Summary: Register JVM metrics for each JM separately Key: FLINK-9741 URL: https://issues.apache.org/jira/browse/FLINK-9741 Project: Flink Issue Type

[jira] [Created] (FLINK-9362) Document that Flink doesn't guarantee transaction of modifying state and register timers in processElement()

Bowen Li created FLINK-9362: --- Summary: Document that Flink doesn't guarantee transaction of modifying state and register timers in processElement() Key: FLINK-9362 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

Yun Tang created FLINK-9328: --- Summary: RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs Key: FLINK-9328 URL: https

[jira] [Created] (FLINK-9305) Register flink-s3-fs-* for the s3a:// scheme as well

Nico Kruber created FLINK-9305: -- Summary: Register flink-s3-fs-* for the s3a:// scheme as well Key: FLINK-9305 URL: https://issues.apache.org/jira/browse/FLINK-9305 Project: Flink Issue Type

Subject: Last chance to register for Flink Forward SF (April 10). Get 25% discount

Hi all! There are still some spots left to attend Flink Forward San Francisco, so sign up soon before registration closes. Use this promo code to get 25% off: MailingListFFSF The 1-day conference takes place on Tuesday, April 10 in downtown SF. We have a great lineup of speakers from companies w

[jira] [Created] (FLINK-8885) The DispatcherThreadFactory should register uncaught exception handlers

Stephan Ewen created FLINK-8885: --- Summary: The DispatcherThreadFactory should register uncaught exception handlers Key: FLINK-8885 URL: https://issues.apache.org/jira/browse/FLINK-8885 Project: Flink

[jira] [Created] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

Stephan Ewen created FLINK-8884: --- Summary: The DispatcherThreadFactory should register uncaught exception handlers Key: FLINK-8884 URL: https://issues.apache.org/jira/browse/FLINK-8884 Project: Flink

Sessions online for #flinkforward SF. Register with 25% discount code.

Hi Flink Community, On behalf of the data Artisans team, I’d like to announce that the sessions for Flink Forward San Francisco are now online! Check out the great lineup of speakers from companies such as American Express, Comcast, Capital One, eBay, Google, Lyft, Netflix, Uber, Yelp, and others

  1   2   >