Skip to main content

2019 | OriginalPaper | Buchkapitel

BGElasor: Elastic-Scaling Framework for Distributed Streaming Processing with Deep Neural Network

verfasst von : Weimin Mu, Zongze Jin, Junwei Wang, Weilin Zhu, Weiping Wang

Erschienen in: Network and Parallel Computing

Verlag: Springer International Publishing

Aktivieren Sie unsere intelligente Suche, um passende Fachinhalte oder Patente zu finden.

search-config
loading …

Abstract

In face of constant fluctuations and sudden bursts of data stream, elasticity of distributed stream processing system has become increasingly important. The proactive policy offers a powerful means to realize the effective elastic scaling. The existing methods lack the latent features of data stream, it leads the poor prediction. Furthermore, the poor prediction results in the high cost of adaptation and the instability. To address these issues, we propose the framework named BGElasor, which is a proactive and low-cost elastic-scaling framework based on the accurate prediction using deep neural networks. It can capture the potentially-complicated pattern to enhance the accuracy of prediction, reduce the cost of adaptation and avoid adaptation bumps. The experimental results show that BGElasor not only improves the prediction accuracy with three kinds of typical loads, but also ensure the end-to-end latency on QoS with low cost.

Sie haben noch keine Lizenz? Dann Informieren Sie sich jetzt über unsere Produkte:

Springer Professional "Wirtschaft+Technik"

Online-Abonnement

Mit Springer Professional "Wirtschaft+Technik" erhalten Sie Zugriff auf:

  • über 102.000 Bücher
  • über 537 Zeitschriften

aus folgenden Fachgebieten:

  • Automobil + Motoren
  • Bauwesen + Immobilien
  • Business IT + Informatik
  • Elektrotechnik + Elektronik
  • Energie + Nachhaltigkeit
  • Finance + Banking
  • Management + Führung
  • Marketing + Vertrieb
  • Maschinenbau + Werkstoffe
  • Versicherung + Risiko

Jetzt Wissensvorsprung sichern!

Springer Professional "Technik"

Online-Abonnement

Mit Springer Professional "Technik" erhalten Sie Zugriff auf:

  • über 67.000 Bücher
  • über 390 Zeitschriften

aus folgenden Fachgebieten:

  • Automobil + Motoren
  • Bauwesen + Immobilien
  • Business IT + Informatik
  • Elektrotechnik + Elektronik
  • Energie + Nachhaltigkeit
  • Maschinenbau + Werkstoffe




 

Jetzt Wissensvorsprung sichern!

Springer Professional "Wirtschaft"

Online-Abonnement

Mit Springer Professional "Wirtschaft" erhalten Sie Zugriff auf:

  • über 67.000 Bücher
  • über 340 Zeitschriften

aus folgenden Fachgebieten:

  • Bauwesen + Immobilien
  • Business IT + Informatik
  • Finance + Banking
  • Management + Führung
  • Marketing + Vertrieb
  • Versicherung + Risiko




Jetzt Wissensvorsprung sichern!

Literatur
1.
Zurück zum Zitat Arasu, A., et al.: STREAM: the stanford stream data manager. IEEE Data Eng. Bull. 26(1), 19–26 (2003)MathSciNet Arasu, A., et al.: STREAM: the stanford stream data manager. IEEE Data Eng. Bull. 26(1), 19–26 (2003)MathSciNet
2.
Zurück zum Zitat Abadi, D.J., et al.: The design of the borealis stream processing engine. In: CIDR 2005, Second Biennial Conference on Innovative Data Systems Research, pp. 277–289 (2005) Abadi, D.J., et al.: The design of the borealis stream processing engine. In: CIDR 2005, Second Biennial Conference on Innovative Data Systems Research, pp. 277–289 (2005)
3.
Zurück zum Zitat Neumeyer, L., Robbins, B., Nair, A., Kesari, A.: S4: distributed stream computing platform. In: ICDMW 2010, The 10th IEEE International Conference on Data Mining Workshops, pp. 170–177 (2010) Neumeyer, L., Robbins, B., Nair, A., Kesari, A.: S4: distributed stream computing platform. In: ICDMW 2010, The 10th IEEE International Conference on Data Mining Workshops, pp. 170–177 (2010)
5.
Zurück zum Zitat Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache flink™: stream and batch processing in a single engine. IEEE Data Eng. Bull. 38(4), 28–38 (2015) Carbone, P., Katsifodimos, A., Ewen, S., Markl, V., Haridi, S., Tzoumas, K.: Apache flink™: stream and batch processing in a single engine. IEEE Data Eng. Bull. 38(4), 28–38 (2015)
6.
Zurück zum Zitat Fernandez, R.C., Migliavacca, M., Kalyvianaki, E., Pietzuch, P.R.: Integrating scale out and fault tolerance in stream processing using operator state management. In: Proceedings of the ACM SIGMOD International Conference on Management of Data, SIGMOD 2013, pp. 725–736 (2013) Fernandez, R.C., Migliavacca, M., Kalyvianaki, E., Pietzuch, P.R.: Integrating scale out and fault tolerance in stream processing using operator state management. In: Proceedings of the ACM SIGMOD International Conference on Management of Data, SIGMOD 2013, pp. 725–736 (2013)
7.
Zurück zum Zitat Gulisano, V., Jiménez-Peris, R., Patiño-Martínez, M., Soriente, C., Valduriez, P.: Streamcloud: an elastic and scalable data streaming system. IEEE Trans. Parallel Distrib. Syst. 23(12), 2351–2365 (2012)CrossRef Gulisano, V., Jiménez-Peris, R., Patiño-Martínez, M., Soriente, C., Valduriez, P.: Streamcloud: an elastic and scalable data streaming system. IEEE Trans. Parallel Distrib. Syst. 23(12), 2351–2365 (2012)CrossRef
8.
Zurück zum Zitat Gedik, B., Schneider, S., Hirzel, M., Wu, K.: Elastic scaling for data stream processing. IEEE Trans. Parallel Distrib. Syst. 25(6), 1447–1463 (2014)CrossRef Gedik, B., Schneider, S., Hirzel, M., Wu, K.: Elastic scaling for data stream processing. IEEE Trans. Parallel Distrib. Syst. 25(6), 1447–1463 (2014)CrossRef
9.
Zurück zum Zitat Herbst, N.R., Huber, N., Kounev, S., Amrehn, E.: Self-adaptive workload classification and forecasting for proactive resource provisioning. In: ACM/SPEC International Conference on Performance Engineering, ICPE 2013, pp. 187–198 (2013) Herbst, N.R., Huber, N., Kounev, S., Amrehn, E.: Self-adaptive workload classification and forecasting for proactive resource provisioning. In: ACM/SPEC International Conference on Performance Engineering, ICPE 2013, pp. 187–198 (2013)
10.
Zurück zum Zitat Balkesen, C., Tatbul, N., Özsu, M.T.: Adaptive input admission and management for parallel stream processing. In: The 7th ACM International Conference on Distributed Event-Based Systems, DEBS 2013, pp. 15–26 (2013) Balkesen, C., Tatbul, N., Özsu, M.T.: Adaptive input admission and management for parallel stream processing. In: The 7th ACM International Conference on Distributed Event-Based Systems, DEBS 2013, pp. 15–26 (2013)
11.
Zurück zum Zitat Zacheilas, N., Kalogeraki, V., Zygouras, N., Panagiotou, N., Gunopulos, D.: Elastic complex event processing exploiting prediction. In: 2015 IEEE International Conference on Big Data, Big Data 2015, pp. 213–222 (2015) Zacheilas, N., Kalogeraki, V., Zygouras, N., Panagiotou, N., Gunopulos, D.: Elastic complex event processing exploiting prediction. In: 2015 IEEE International Conference on Big Data, Big Data 2015, pp. 213–222 (2015)
12.
Zurück zum Zitat Repantis, T., Kalogeraki, V.: Hot-spot prediction and alleviation in distributed stream processing applications. In: The 38th Annual IEEE/IFIP International Conference on Dependable Systems and Networks, DSN 2008, pp. 346–355 (2008) Repantis, T., Kalogeraki, V.: Hot-spot prediction and alleviation in distributed stream processing applications. In: The 38th Annual IEEE/IFIP International Conference on Dependable Systems and Networks, DSN 2008, pp. 346–355 (2008)
13.
Zurück zum Zitat Hidalgo, N., Wladdimiro, D., Rosas, E.: Self-adaptive processing graph with operator fission for elastic stream processing. J. Syst. Softw. 127, 205–216 (2017)CrossRef Hidalgo, N., Wladdimiro, D., Rosas, E.: Self-adaptive processing graph with operator fission for elastic stream processing. J. Syst. Softw. 127, 205–216 (2017)CrossRef
14.
Zurück zum Zitat Xing, Y., Hwang, J., Çetintemel, U., Zdonik, S.B.: Providing resiliency to load variations in distributed stream processing. In: Proceedings of the 32nd International Conference on Very Large Data Bases, pp. 775–786 (2006) Xing, Y., Hwang, J., Çetintemel, U., Zdonik, S.B.: Providing resiliency to load variations in distributed stream processing. In: Proceedings of the 32nd International Conference on Very Large Data Bases, pp. 775–786 (2006)
15.
Zurück zum Zitat Xing, Y., Zdonik, S.B., Hwang, J.: Dynamic load distribution in the borealis stream processor. In: Proceedings of the 21st International Conference on Data Engineering, ICDE 2005, pp. 791–802 (2005) Xing, Y., Zdonik, S.B., Hwang, J.: Dynamic load distribution in the borealis stream processor. In: Proceedings of the 21st International Conference on Data Engineering, ICDE 2005, pp. 791–802 (2005)
Metadaten
Titel
BGElasor: Elastic-Scaling Framework for Distributed Streaming Processing with Deep Neural Network
verfasst von
Weimin Mu
Zongze Jin
Junwei Wang
Weilin Zhu
Weiping Wang
Copyright-Jahr
2019
DOI
https://doi.org/10.1007/978-3-030-30709-7_10

Premium Partner