暖风的风 - 博客园

Flink 中的kafka何时commit?

摘要： https://ci.apache.org/projects/flink/flink-docs-release-1.6/internals/stream_checkpointing.html @OverridepublicfinalvoidnotifyCheckpointComplete(longc 阅读全文

posted @ 2018-09-27 15:56 暖风的风阅读(518) 评论(0) 推荐(0)

jar依赖

摘要： https://blog.csdn.net/honghailiang888/article/details/53019635 阅读全文

posted @ 2018-09-26 13:02 暖风的风阅读(137) 评论(0) 推荐(0)

AI重要算法

摘要： https://www.quora.com/Is-a-single-layered-ReLu-network-still-a-universal-approximator/answer/Conner-Davis-2 https://www.quora.com/Why-do-neural-networ 阅读全文

posted @ 2018-09-22 14:41 暖风的风阅读(140) 评论(0) 推荐(0)

NonWindowJoin

摘要： package org.apache.flink.table.runtime.join /** * Connect data for left stream and right stream. Base class for stream-stream non-window Join. * * @pa 阅读全文

posted @ 2018-09-19 19:02 暖风的风阅读(187) 评论(0) 推荐(0)

Rocket MQ 源码解析

摘要： http://rocketmq.apache.org/rocketmq/the-design-of-transactional-message/ http://www.iocoder.cn/RocketMQ/message-store/ http://www.iocoder.cn/RocketMQ/ 阅读全文

posted @ 2018-09-17 15:05 暖风的风阅读(248) 评论(0) 推荐(0)

linear algebra

摘要： https://www.youtube.com/watch?v=ZK3O402wf1c&list=PLE7DDD91010BC51F8 https://www.youtube.com/playlist?list=PLZHQObOWTQDPD3MizzM2xVFitgF8hE_ab 阅读全文

posted @ 2018-09-16 18:27 暖风的风阅读(338) 评论(0) 推荐(0)

Theories of Deep Learning

摘要： https://stats385.github.io/readings Lecture 1 – Deep Learning Challenge. Is There Theory? Readings Lecture 2 – Overview of Deep Learning From a Practi 阅读全文

posted @ 2018-09-16 18:23 暖风的风阅读(473) 评论(0) 推荐(0)

CNN及其可解释性

摘要： https://stats385.github.io/readings https://arxiv.org/pdf/1311.2901.pdf A Mathematical Theory of Deep Convolutional Neural Networks for Feature Extrac 阅读全文

posted @ 2018-09-16 17:35 暖风的风阅读(303) 评论(0) 推荐(0)

Why do people integrate Spark with TensorFlow even if there is a distributed TensorFlow framework?

摘要： https://www.quora.com/Why-do-people-integrate-Spark-with-TensorFlow-even-if-there-is-a-distributed-TensorFlow-framework https://www.quora.com/What-is- 阅读全文

posted @ 2018-09-16 00:08 暖风的风阅读(261) 评论(0) 推荐(0)

Maven

摘要： https://www.jianshu.com/p/fd43b3d0fdb0 http://maven.apache.org/guides/getting-started/index.html http://maven.apache.org/plugins/maven-assembly-plugin 阅读全文

posted @ 2018-09-14 16:30 暖风的风阅读(167) 评论(0) 推荐(0)

LL&LR parser

摘要： http://web.cse.ohio-state.edu/software/2231/web-sw2/extras/slides/27.Recursive-Descent-Parsing.pdf https://blog.csdn.net/qq_25104587/article/details/9 阅读全文

posted @ 2018-09-11 17:22 暖风的风阅读(545) 评论(0) 推荐(0)

JavaCC

摘要： https://www.codeproject.com/Articles/35748/An-Introduction-to-JavaCC https://javacc.org/javaccgrm https://www.javaworld.com/article/2076269/learn-java 阅读全文

posted @ 2018-09-08 22:38 暖风的风阅读(248) 评论(0) 推荐(0)

FLINK SQL Calcite原理

摘要： http://wuchong.me/blog/2017/03/30/flink-internals-table-and-sql-api/ https://cloud.tencent.com/developer/article/1243475 阅读全文

posted @ 2018-09-06 00:52 暖风的风阅读(455) 评论(0) 推荐(0)

calcite 理论

摘要： https://blog.csdn.net/yunlong34574/article/details/46375733 https://cloud.tencent.com/developer/article/1243475 https://www.slideshare.net/JordanHalte 阅读全文

posted @ 2018-09-06 00:48 暖风的风阅读(704) 评论(0) 推荐(0)

FLIP-24+-+SQL+Client

摘要： https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client 阅读全文

posted @ 2018-09-04 10:34 暖风的风阅读(177) 评论(0) 推荐(0)

github pull request

摘要： https://stackoverflow.com/questions/14680711/how-to-do-a-github-pull-request https://help.github.com/articles/about-pull-requests/ https://stackoverfl 阅读全文

posted @ 2018-09-03 13:37 暖风的风阅读(249) 评论(0) 推荐(0)

scala future

摘要： https://docs.scala-lang.org/overviews/core/futures.html https://docs.scala-lang.org/overviews/index.html https://docs.scala-lang.org/learn.html 阅读全文

posted @ 2018-09-02 23:01 暖风的风阅读(160) 评论(0) 推荐(0)

AKKA好文

摘要： https://richardimaoka.github.io/blog/ 阅读全文

posted @ 2018-09-01 15:05 暖风的风阅读(147) 评论(0) 推荐(0)

https://issues.apache.org/jira/browse/FLINK-10011

摘要： https://issues.apache.org/jira/browse/FLINK-10011 阅读全文

posted @ 2018-08-31 23:25 暖风的风阅读(384) 评论(0) 推荐(0)

Adding support for distinct operation for table API on DataStream

摘要： https://github.com/apache/flink/pull/6521/files/66c3bd5d52a5e4af1f83406035b95774e8b6f636#diff-680b30ea43d3038c905b1036011bbe30 https://github.com/apac 阅读全文

posted @ 2018-08-28 16:52 暖风的风阅读(146) 评论(0) 推荐(0)

在ZP的HA模式下 JM 重启失败

摘要： https://issues.apache.org/jira/browse/FLINK-10030 https://issues.apache.org/jira/browse/FLINK-10011 https://github.com/apache/flink/pull/6590/commits/ 阅读全文

posted @ 2018-08-28 16:35 暖风的风阅读(149) 评论(0) 推荐(0)

distinct aggregation

摘要： https://docs.google.com/document/d/1zj6OA-K2hi7ah8Fo-xTQB-mVmYfm6LsN2_NHgTCVmJI/edit# https://issues.apache.org/jira/browse/FLINK-5315 https://issues. 阅读全文

posted @ 2018-08-27 23:58 暖风的风阅读(233) 评论(0) 推荐(0)

window函数 resetAccumulator

摘要： /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this 阅读全文

posted @ 2018-08-27 22:10 暖风的风阅读(215) 评论(0) 推荐(0)

G1 Garbage Collector and Shenandoah

摘要： http://www.diva-portal.se/smash/get/diva2:754515/FULLTEXT01.pdf https://is.muni.cz/th/ifz8g/GarbageCollection.pdf?so=nx http://hllvm.group.iteye.com/g 阅读全文

posted @ 2018-08-27 00:08 暖风的风阅读(250) 评论(0) 推荐(0)

How To Download Youtube Videos Without any software

摘要： https://www.quora.com/What-is-the-best-way-to-download-YouTube-videos-for-free There are various methods to download YouTube video for free. How To Do 阅读全文

posted @ 2018-08-26 23:36 暖风的风阅读(115858) 评论(2) 推荐(0)

JVM源码分析之安全点safepoint

摘要： https://blog.csdn.net/iter_zc/article/details/41892567 https://www.jianshu.com/p/c79c5e02ebe6 阅读全文

posted @ 2018-08-26 02:09 暖风的风阅读(296) 评论(0) 推荐(0)

Debugging the Java HotSpot VM

摘要： Open Heart Surgery: Analyzing and Debugging the Java HotSpot VM at the OS Level https://www.youtube.com/watch?v=k7IX_diKCEo 阅读全文

posted @ 2018-08-25 21:31 暖风的风阅读(221) 评论(0) 推荐(0)

Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现

摘要： https://yq.aliyun.com/articles/457445?spm=a2c4e.11154873.tagmain.112.5a2f788dydzXjE 阅读全文

posted @ 2018-08-25 15:30 暖风的风阅读(660) 评论(0) 推荐(0)

jsack

摘要： https://docs.oracle.com/javase/8/docs/technotes/guides/troubleshoot/tooldescr016.html#BABGHEJB 阅读全文

posted @ 2018-08-25 13:40 暖风的风阅读(245) 评论(0) 推荐(0)

生产BackPressure 的代码

摘要： public class BackPressureStatsTrackerImpl implements BackPressureStatsTracker { private static final Logger LOG = LoggerFactory.getLogger(BackPressure 阅读全文

posted @ 2018-08-23 14:04 暖风的风阅读(286) 评论(0) 推荐(0)

org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint

摘要： org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint-Xms2024m -Xmx2024m -Dlog.file="D:/flink/flink-1.6.0-bin-scala_2.11/flink-1.6.0/ 阅读全文

posted @ 2018-08-23 00:29 暖风的风阅读(822) 评论(0) 推荐(0)

https://www.callicoder.com/java-8-completablefuture-tutorial/

摘要： https://www.callicoder.com/java-8-completablefuture-tutorial/ 阅读全文

posted @ 2018-08-21 23:27 暖风的风阅读(321) 评论(0) 推荐(0)

microservices kubernetes

摘要： http://blog.christianposta.com/microservices/netflix-oss-or-kubernetes-how-about-both/ http://blog.christianposta.com/our-book-has-been-released-intro 阅读全文

posted @ 2018-08-21 13:29 暖风的风阅读(143) 评论(0) 推荐(0)

flink metrics

摘要： https://stackoverflow.com/questions/50972168/flink-latency-metrics-not-being-shown/50982071#50982071 https://stackoverflow.com/questions/45211970/how- 阅读全文

posted @ 2018-08-18 23:44 暖风的风阅读(428) 评论(0) 推荐(0)

numRecordsIn 在哪里实现？

摘要： /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this 阅读全文

posted @ 2018-08-16 21:01 暖风的风阅读(563) 评论(0) 推荐(0)

flink Job提交过程

摘要： https://www.jianshu.com/p/0cdfa2a05ebd http://vinoyang.com/2017/04/02/flink-runtime-client-submit-jobgraph-submitJob-method/ http://vinoyang.com/2017/ 阅读全文

posted @ 2018-08-16 18:55 暖风的风阅读(325) 评论(0) 推荐(0)

https://jzh.12333sh.gov.cn/jzh/

摘要： https://jzh.12333sh.gov.cn/jzh/ https://superuser.com/questions/171917/force-a-program-to-run-without-administrator-privileges-or-uac http://pogostick 阅读全文

posted @ 2018-08-15 23:05 暖风的风阅读(590) 评论(0) 推荐(0)

blocking

摘要： package blockingtest;/** * Hello world! */public class Sync implements Runnable { int n; public static void main(String[] args) { Sync sync = new Sync 阅读全文

posted @ 2018-08-11 18:18 暖风的风阅读(550) 评论(0) 推荐(0)

at org.apache.catalina.webresources.CachedResource.validateResources

摘要： "catalina-exec-659" #5239 daemon prio=5 os_prio=0 tid=0x00007fcba8099800 nid=0x581 waiting for monitor entry [0x00007fcdac5d7000] java.lang.Thread.Sta 阅读全文

posted @ 2018-08-10 19:16 暖风的风阅读(476) 评论(0) 推荐(0)

Flink 平台

该文被密码保护。阅读全文

posted @ 2018-08-07 23:12 暖风的风阅读(6) 评论(0) 推荐(0)

导航

公告