clear query| facets| time Search criteria: .   Results from 1 to 10 from 80265 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-10553] Unified sink and source table name in SQL statement - Flink - [issue]
...Since sink table can now be registered using ExternalCatalog, just the same as source table, the source and sink name in SQL statement should also be treated equally. Now we can only use `ca...
http://issues.apache.org/jira/browse/FLINK-10553    Author: wangsan , 2018-10-15, 15:57
[FLINK-6131] Add side inputs for DataStream API - Flink - [issue]
...This is an umbrella issue for tracking the implementation of FLIP-17: https://cwiki.apache.org/confluence/display/FLINK/FLIP-17+Side+Inputs+for+DataStream+API....
http://issues.apache.org/jira/browse/FLINK-6131    Author: Aljoscha Krettek , 2018-10-15, 15:51
[FLINK-8578] Implement rowtime DataStream to Table upsert conversion. - Flink - [issue]
...Flink-8577 implements upsert from stream under proctime. This task is going to solve the order problem introduce by proctime. As proposed by Fabian in FLINK-8545, it would be good to be able...
http://issues.apache.org/jira/browse/FLINK-8578    Author: Hequn Cheng , 2018-10-15, 15:51
[expand - 2 more] - Job Records In/Out metrics clarification - Flink - [mail # user]
...Awesome, thanks!On Mon, Oct 15, 2018, 17:36 Chesnay Schepler  wrote:> There is a known issue in 1.5.0 with the numRecordsIn/Out metrics for> chained tasks: https://issues.apache.o...
   Author: Rafi Aroch , Chesnay Schepler , ... , 2018-10-15, 15:37
[FLINK-10511] Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils - Flink - [issue]
...The TaskManagerRunner is using AkkaRpcServiceUtils to create RPC service, but the ClusterEntrypoint use a protected method to do the same job. I think it's better to use the same method in A...
http://issues.apache.org/jira/browse/FLINK-10511    Author: Shimin Yang , 2018-10-15, 15:11
[FLINK-10405] Port JobManagerFailsITCase to new code base - Flink - [issue]
...Port JobManagerFailsITCase to new code base....
http://issues.apache.org/jira/browse/FLINK-10405    Author: TisonKun , 2018-10-15, 15:07
[FLINK-9544] Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite - Flink - [issue]
...The amazon client do not downgrade from CBOR to JSON while setting env AWS_CBOR_DISABLE to true (or 1) and/or defining com.amazonaws.sdk.disableCbor=true via JVM options. This bug is due to ...
http://issues.apache.org/jira/browse/FLINK-9544    Author: Ph.Duveau , 2018-10-15, 15:06
[FLINK-10546] Remove StandaloneMiniCluster - Flink - [issue]
...Before doing as title, I want to check that is the StandaloneMiniCluster still in use? IIRC there once be a deprecation of start-local.sh but I don’t know if it is relevant. Furthe...
http://issues.apache.org/jira/browse/FLINK-10546    Author: TisonKun , 2018-10-15, 15:04
[Flink 1.6.1] local app infinitely hangs - Flink - [mail # user]
...Hi mates, during the migration to Flink 1.6.1, I've faced with the following issue - flink application hangs infinitely, when application is running from IDE, at the same time, everything wo...
   Author: Rinat , 2018-10-15, 14:48
[FLINK-9697] Provide connector for modern Kafka - Flink - [issue]
...Kafka 2.0.0 would be released soon.Here is vote thread:http://search-hadoop.com/m/Kafka/uyzND1vxnEd23QLxb?subj=+VOTE+2+0+0+RC1We should provide connector for Kafka 2.0.0 once it is released....
http://issues.apache.org/jira/browse/FLINK-9697    Author: Ted Yu , 2018-10-15, 14:44