issues  

Messages by Thread

• [jira] [Resolved] (STORM-3799) Logging user information for blob delete req Ethan Li (Jira)
• [jira] [Created] (STORM-3800) Fix Resocue leak due to Files.list and Files.walk lujie (Jira)
• [jira] [Assigned] (STORM-3799) Logging user information for blob delete req Nikhil Singh (Jira)
• [jira] [Created] (STORM-3799) Logging user information for blob delete req Nikhil Singh (Jira)
• [jira] [Commented] (STORM-3638) Add fast and more reliable process liveness check jakapong bucha (Jira)
• [jira] [Updated] (STORM-3798) Nimbus keep on crash once restart nimbus machine Anandh kumar (Jira)
• [jira] [Updated] (STORM-3798) No nimbus leader participant host found, have you started your nimbus hosts? Anandh kumar (Jira)
• [jira] [Created] (STORM-3798) No nimbus leader participant host found, have you started your nimbus hosts? Anandh kumar (Jira)
• [jira] [Commented] (STORM-3685) Detect Loops in Topology at Submit Roshan Naik (Jira)
• [jira] [Updated] (STORM-3693) TimeOut ticks should be addressed to Executor instead of being addressed to a task or broadcasted. Ethan Li (Jira)
• [jira] [Created] (STORM-3797) Cannot generate storm.thrift using Golang generator Justin A Wilson (Jira)
• [jira] [Created] (STORM-3796) How many topologies can create in a cluster? prabhakaran (Jira)
• [jira] [Assigned] (STORM-3737) Share Worker Metric Registry For Guice AOP Based Metrics Integeration Ethan Li (Jira)
• [jira] [Updated] (STORM-3793) Add metric to track backpressure status for a task Ethan Li (Jira)
• [jira] [Resolved] (STORM-3793) Add metric to track backpressure status for a task Ethan Li (Jira)
• [jira] [Resolved] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
• [jira] [Updated] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
  • [jira] [Updated] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
  • [jira] [Updated] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
  • [jira] [Updated] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
• [jira] [Closed] (STORM-3794) storm list displays logs and execution information Kaushal Kumar (Jira)
• [jira] [Created] (STORM-3795) storm list displays logs and execution information Kaushal Kumar (Jira)
• [jira] [Resolved] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
• [jira] [Commented] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
• [jira] [Updated] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
  • [jira] [Updated] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
  • [jira] [Updated] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
• [jira] [Assigned] (STORM-3785) Rate metrics are wrongly divided by 1000000 Ethan Li (Jira)
• [jira] [Updated] (STORM-3794) storm list displays logs and execution information Kaushal Kumar (Jira)
  • [jira] [Updated] (STORM-3794) storm list displays logs and execution information Kaushal Kumar (Jira)
  • [jira] [Updated] (STORM-3794) storm list displays logs and execution information Kaushal Kumar (Jira)
• [jira] [Created] (STORM-3794) storm list displays logs and execution information Kaushal Kumar (Jira)
• [jira] [Assigned] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
• [jira] [Created] (STORM-3793) Add metric to track backpressure status for a task Aaron Gresch (Jira)
• [jira] [Updated] (STORM-3792) Change pom.xml to use more test JVM threads without reuse Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3792) Change pom.xml to use more test JVM threads without reuse Bipin Prasad (Jira)
• [jira] [Created] (STORM-3792) Change pom.xml to use more threads without reuse Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3791) update metric documentation Aaron Gresch (Jira)
• [jira] [Created] (STORM-3791) update metric documentation Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3790) Add meter to track failures WorkerTokenAuthorizer getPassword Aaron Gresch (Jira)
• [jira] [Created] (STORM-3790) Add meter to track failures WorkerTokenAuthorizer getPassword Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3388) Launch workers inside container using runc runtime Ethan Li (Jira)
• [jira] [Created] (STORM-3789) STORM-3388 follow up: answer unresolved questions in comments Ethan Li (Jira)
• [jira] [Created] (STORM-3788) Add more comments in docker-to-squash.py Ethan Li (Jira)
• [jira] [Created] (STORM-3787) Add error messages in worker-launcher c code where it is missing Ethan Li (Jira)
• [jira] [Commented] (STORM-3388) Launch workers inside container using runc runtime Ethan Li (Jira)
  • [jira] [Commented] (STORM-3388) Launch workers inside container using runc runtime Ethan Li (Jira)
• [jira] [Resolved] (STORM-3786) V2 metrics tick may overreport or not report at all Aaron Gresch (Jira)
• [jira] [Updated] (STORM-3786) V2 metrics tick may overreport or not report at all Aaron Gresch (Jira)
• [jira] [Commented] (STORM-3784) my supervisor will shut down on 2:00 am everyday Aaron Gresch (Jira)
• [jira] [Created] (STORM-3786) V2 metrics tick may overreport or not report at all Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3737) Share Worker Metric Registry For Guice AOP Based Metrics Integeration Aaron Gresch (Jira)
• [jira] [Created] (STORM-3785) Rate metrics are wrongly divided by 1000000 Rui Li (Jira)
• [jira] [Updated] (STORM-3784) my supervisor will shut down on 2:00 am everyday Sunsy Sun (Jira)
• [jira] [Created] (STORM-3784) my supervisor will shut down on 2:00 am everyday Sunsy Sun (Jira)
• [jira] [Commented] (STORM-3783) 500 Server Error - Internal error processing getComponentPageInfo Elvis Zhang (Jira)
  • [jira] [Commented] (STORM-3783) 500 Server Error - Internal error processing getComponentPageInfo Pedro Azevedo (Jira)
• [jira] [Updated] (STORM-3783) 500 Server Error - Internal error processing getComponentPageInfo Elvis Zhang (Jira)
• [jira] [Created] (STORM-3783) 500 Server Error - Internal error processing getComponentPageInfo Elvis Zhang (Jira)
• [jira] [Created] (STORM-3782) Refactor KafkaOffsetMetric to use V2 metrics Rui Li (Jira)
• [jira] [Resolved] (STORM-3780) switch ErrorReportingMetrics to V2 API Aaron Gresch (Jira)
• [jira] [Created] (STORM-3781) switch recv-iconnection to v2 metric api Aaron Gresch (Jira)
• [jira] [Created] (STORM-3780) switch ErrorReportingMetrics to V2 API Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3778) convert SpoutThrottlingMetrics to V2 API Aaron Gresch (Jira)
• [jira] [Updated] (STORM-3779) killed topology worker does not removed with warn and error that "Topology config is not localized yet..." sanghee park (Jira)
• [jira] [Created] (STORM-3779) killed topology worker does not removed with warn and error that "Topology config is not localized yet..." sanghee park (Jira)
• [jira] [Created] (STORM-3778) convert SpoutThrottlingMetrics to V2 API Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3775) topology.blobstore.map can cause supervisor restarts Aaron Gresch (Jira)
• [jira] [Resolved] (STORM-3774) Migrate Cgroup metrics to V2 Aaron Gresch (Jira)
• [jira] [Created] (STORM-3777) Ability to have a default doubling of resource when worker count increases Anton Alfred (Jira)
• [jira] [Created] (STORM-3776) Ability to change the configuration of a topology without restarting Anton Alfred (Jira)
• [jira] [Created] (STORM-3775) topology.blobstore.map can cause supervisor restarts Aaron Gresch (Jira)
• [jira] [Commented] (STORM-3773) Worker Reassignment - Difference between Storm 2.x and Storm 1.x Aaron Gresch (Jira)
  • [jira] [Commented] (STORM-3773) Worker Reassignment - Difference between Storm 2.x and Storm 1.x Surajeet (Jira)
  • [jira] [Commented] (STORM-3773) Worker Reassignment - Difference between Storm 2.x and Storm 1.x Pedro Azevedo (Jira)
  • [jira] [Commented] (STORM-3773) Worker Reassignment - Difference between Storm 2.x and Storm 1.x Pedro Azevedo (Jira)
• [jira] [Commented] (STORM-3760) Storm 2.2.0 not reporting newWorkerEvents metric Aaron Gresch (Jira)
• [jira] [Created] (STORM-3774) Migrate Cgroup metrics to V2 Aaron Gresch (Jira)
• [jira] [Created] (STORM-3773) Worker Reassignment - Difference between Storm 2.x and Storm 1.x Surajeet (Jira)
• [jira] [Updated] (STORM-3772) With pacemaker, zNode /strom/workerbeats entries are not removed once topology is killed Shiromani Bharti (Jira)
  • [jira] [Updated] (STORM-3772) With pacemaker, zNode /strom/workerbeats entries are not removed once topology is killed Shiromani Bharti (Jira)
• [jira] [Created] (STORM-3772) With pacemaker, zNode /strom/workerbeats entries are not removed once topology is killed Shiromani Bharti (Jira)
• [jira] [Created] (STORM-3771) Execute doCleanup in its own timer thread without lock Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3770) Workaround for Issue STORM-3677 (assignment was null) in version 2.2.0 Nikhil (Jira)
• [jira] [Created] (STORM-3770) Workaround for Issue STORM-3677 (assignment was null) in version 2.2.0 Nikhil (Jira)
• [jira] [Comment Edited] (STORM-3677) Fix Worker Suicide Function if assignment is null Nikhil (Jira)
  • [jira] [Comment Edited] (STORM-3677) Fix Worker Suicide Function if assignment is null Nikhil (Jira)
• [jira] [Commented] (STORM-3677) Fix Worker Suicide Function if assignment is null Nikhil (Jira)
• [jira] [Commented] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
• [jira] [Resolved] (STORM-3769) Failed adding references to blobs: FileNotFoundException Aaron Gresch (Jira)
• [jira] [Updated] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
  • [jira] [Updated] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
• [jira] [Resolved] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
• [jira] [Commented] (STORM-3769) Failed adding references to blobs: FileNotFoundException Aaron Gresch (Jira)
• [jira] [Created] (STORM-3769) Failed adding references to blobs: FileNotFoundException Aaron Gresch (Jira)
• [jira] [Created] (STORM-3768) Zero Values for Assigned Mem (MB) in Topology Summary and Used Mem (MB) in Supervisor Summary Jira
• [jira] [Created] (STORM-3767) NPE on getComponentPendingProfileActions Ethan Li (Jira)
• [jira] [Created] (STORM-3766) Update org.apache.calcite version to 1.26.0 due to security vulnerability Bipin Prasad (Jira)
• [jira] [Created] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
• [jira] [Assigned] (STORM-3765) NPE in DRPCSimpleACLAuthorizer.readAclFromConfig when drpc.authorizer.acl has no values Ethan Li (Jira)
• [jira] [Commented] (STORM-3764) Nimbus has internal scheduling errors when backtracking Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3764) Nimbus has internal scheduling errors when backtracking Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3764) Nimbus has internal scheduling errors when backtracking Bipin Prasad (Jira)
• [jira] [Created] (STORM-3764) While backtracking only remove the ackers that were skipped Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3763) Backpressure message ignored by the receiver caused the topology to not progress Ethan Li (Jira)
• [jira] [Assigned] (STORM-3763) Backpressure message ignored by the receiver caused the topology to not progress Ethan Li (Jira)
• [jira] [Updated] (STORM-3763) Backpressure message ignored by the receiver caused the topology to not progress Ethan Li (Jira)
  • [jira] [Updated] (STORM-3763) Backpressure message ignored by the receiver caused the topology to not progress Ethan Li (Jira)
• [jira] [Created] (STORM-3763) Backpressure message ignored by the receiver caused the topology to not progress Ethan Li (Jira)
• [jira] [Created] (STORM-3762) Set a default character set in InputStreamReader to solve potential garbled problems dbgp2021 (Jira)
• [jira] [Updated] (STORM-3759) Additional Trident Kafka Spout Metrics Jonathan Poholarz (Jira)
• [jira] [Created] (STORM-3761) Apache Storm 2.2.0 Paul A. Gureghian (Jira)
• [jira] [Resolved] (STORM-3744) IntelliJ does not find shaded classes Ethan Li (Jira)
• [jira] [Comment Edited] (STORM-3057) ERROR An exception occurred processing Appender syslog Cristian Rojas (Jira)
• [jira] [Updated] (STORM-3760) Storm 2.2.0 not reporting newWorkerEvents metric Cristian Rojas (Jira)
  • [jira] [Updated] (STORM-3760) Storm 2.2.0 not reporting newWorkerEvents metric Cristian Rojas (Jira)
• [jira] [Created] (STORM-3760) Storm 2.2.0 not reporting newWorkerEvents metric Cristian Rojas (Jira)
• [jira] [Resolved] (STORM-3758) Zookeeper reconnect events sometime cause workers to restart Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3758) Zookeeper reconnect events sometime cause workers to restart Bipin Prasad (Jira)
• [jira] [Comment Edited] (STORM-3759) Additional Trident Kafka Spout Metrics Jonathan Poholarz (Jira)
• [jira] [Commented] (STORM-3759) Additional Trident Kafka Spout Metrics Jonathan Poholarz (Jira)
• [jira] [Created] (STORM-3759) Additional Trident Kafka Spout Metrics Jonathan Poholarz (Jira)
• [jira] [Commented] (STORM-3758) Zookeeper reconnect events sometime cause workers to restart Bipin Prasad (Jira)
• [jira] [Created] (STORM-3758) Zookeeper reconnect events sometime cause workers to restart Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3755) While scheduling multiple ackers with executor use best effort basis Ethan Li (Jira)
• [jira] [Updated] (STORM-3753) Change String.getBytes() to DFSUtil.string2Bytes(String) to avoid Unsupported Encoding Exception dbgp2021 (Jira)
  • [jira] [Updated] (STORM-3753) Change String.getBytes() to DFSUtil.string2Bytes(String) to avoid Unsupported Encoding Exception dbgp2021 (Jira)
• [jira] [Comment Edited] (STORM-3751) NPE in WorkerState.transferLocalBatch Alexander Prokopyev (Jira)
  • [jira] [Comment Edited] (STORM-3751) NPE in WorkerState.transferLocalBatch Binh Le (Jira)
  • [jira] [Comment Edited] (STORM-3751) NPE in WorkerState.transferLocalBatch Binh Le (Jira)
  • [jira] [Comment Edited] (STORM-3751) NPE in WorkerState.transferLocalBatch Binh Le (Jira)
  • [jira] [Comment Edited] (STORM-3751) NPE in WorkerState.transferLocalBatch Binh Le (Jira)
• [jira] [Commented] (STORM-3751) NPE in WorkerState.transferLocalBatch Alexander Prokopyev (Jira)
  • [jira] [Commented] (STORM-3751) NPE in WorkerState.transferLocalBatch Arwin S Tio (Jira)
  • [jira] [Commented] (STORM-3751) NPE in WorkerState.transferLocalBatch Binh Le (Jira)
  • [jira] [Commented] (STORM-3751) NPE in WorkerState.transferLocalBatch Rhys Madigan (Jira)
• [jira] [Updated] (STORM-3757) Update jackson version to 2.10.0 Ethan Li (Jira)
• [jira] [Resolved] (STORM-3757) Update jackson version to 2.10.0 Ethan Li (Jira)
• [jira] [Created] (STORM-3757) Update jackson version to 2.10.0 Ethan Li (Jira)
• [jira] [Resolved] (STORM-3704) Cosmetic: columns shifted in "Topology summary" table Ethan Li (Jira)
• [jira] [Assigned] (STORM-3704) Cosmetic: columns shifted in "Topology summary" table Ethan Li (Jira)
• [jira] [Commented] (STORM-3704) Cosmetic: columns shifted in "Topology summary" table Ethan Li (Jira)
• [jira] [Created] (STORM-3756) build failed on AArch64, Fedora 33 Lutz Weischer (Jira)
• [jira] [Commented] (STORM-3755) While scheduling multiple ackers with executor use best effort basis Bipin Prasad (Jira)
• [jira] [Created] (STORM-3755) While scheduling multiple ackers with executor use best effort basis Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3754) Upgrade Guava version because of security vulnerability Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3739) Scheduling should sort numa zones by host groups Bipin Prasad (Jira)
• [jira] [Created] (STORM-3754) Upgrade Guava version because of security vulnerability Bipin Prasad (Jira)
• [jira] [Created] (STORM-3753) Change String.getBytes() to DFSUtil.string2Bytes(String) to avoid Unsupported Encoding Exception dbgp2021 (Jira)
• [ storm.apache.org ] Updates to the cPanel Services Agreement. cPanel on storm . apache . org
• [jira] [Resolved] (STORM-3749) improve logging on server error in StormServerHandler Aaron Gresch (Jira)
• [jira] [Created] (STORM-3752) Nimbus can't be run in MacOSX 10.13.x John Kostaras (Jira)
• [jira] [Updated] (STORM-3751) NPE in WorkerState.transferLocalBatch Arwin S Tio (Jira)
  • [jira] [Updated] (STORM-3751) NPE in WorkerState.transferLocalBatch Arwin S Tio (Jira)
• [jira] [Created] (STORM-3751) NPE in WorkerState.transferLocalBatch Arwin S Tio (Jira)
• [jira] [Resolved] (STORM-3742) Topology arguments starting with -c get removed Julien Nioche (Jira)
• [jira] [Assigned] (STORM-3742) Topology arguments starting with -c get removed Bipin Prasad (Jira)
• [jira] [Commented] (STORM-3742) Topology arguments starting with -c get removed Bipin Prasad (Jira)
  • [jira] [Commented] (STORM-3742) Topology arguments starting with -c get removed Bipin Prasad (Jira)
  • [jira] [Commented] (STORM-3742) Topology arguments starting with -c get removed Julien Nioche (Jira)
• [jira] [Resolved] (STORM-3748) prevent concurrent modification when fetching v2 metrics Aaron Gresch (Jira)
• [jira] [Commented] (STORM-3750) Deactivation throws java.nio.channels.ClosedSelectorException in KafkaSpout Max Schmidt (Jira)
• [jira] [Closed] (STORM-3750) Deactivation throws java.nio.channels.ClosedSelectorException in KafkaSpout Max Schmidt (Jira)
• [jira] [Updated] (STORM-3750) Deactivation throws java.nio.channels.ClosedSelectorException in KafkaSpout Max Schmidt (Jira)
• [jira] [Created] (STORM-3750) Deactivation throws java.nio.channels.ClosedSelectorException in KafkaSpout Max Schmidt (Jira)
• [jira] [Created] (STORM-3749) improve logging on server error in StormServerHandler Aaron Gresch (Jira)
• [jira] [Created] (STORM-3748) prevent concurrent modification when fetching v2 metrics Aaron Gresch (Jira)
• [jira] [Commented] (STORM-3032) NullPointerException in KafkaSpout emitOrRetryTuple Benjamin Marwell (Jira)
• [jira] [Updated] (STORM-3741) Maven Surefire plugin corrupts output and creates an excessive log file Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3739) Scheduling should sort numa zones by host groups Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3739) Scheduling should sort numa zones by host groups Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Created] (STORM-3747) Remove deprecated NodeSortTypes and related code Bipin Prasad (Jira)
• [jira] [Assigned] (STORM-3747) Remove deprecated NodeSortTypes and related code Bipin Prasad (Jira)
• [jira] [Commented] (STORM-3746) Outline steps to anonymize topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Created] (STORM-3746) Outline steps to anonymize topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Closed] (STORM-3745) Exclude blacklisted hosts when scheduling Bipin Prasad (Jira)
• [jira] [Created] (STORM-3745) Exclude blacklisted hosts when scheduling Bipin Prasad (Jira)
• [jira] [Commented] (STORM-3744) IntelliJ does not find shaded classes Bipin Prasad (Jira)
  • [jira] [Commented] (STORM-3744) IntelliJ does not find shaded classes Bipin Prasad (Jira)
• [jira] [Created] (STORM-3744) IntelliJ does not find shaded classes Bipin Prasad (Jira)
• [jira] [Commented] (STORM-3739) Scheduling should sort numa zones by host groups Bipin Prasad (Jira)
• [jira] [Resolved] (STORM-3741) Maven Surefire plugin corrupts output and creates an excessive log file Bipin Prasad (Jira)
• [jira] [Commented] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Updated] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
  • [jira] [Updated] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Assigned] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
• [jira] [Created] (STORM-3743) Add new topologies for TestLargeCluster Bipin Prasad (Jira)
• New sign-in on Email storm . apache . org Administrator
  • New sign-in on Email storm.apache.org Administrator
• [jira] [Created] (STORM-3742) Topology arguments starting with -c get removed Julien Nioche (Jira)
• [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)
  • [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)
  • [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)
  • [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)
  • [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)
  • [jira] [Updated] (STORM-3404) storm v1.2.2 KafkaOffsetLagUtil cant pull the offset correctly XingYiWang (Jira)

• Earlier messages
• Later messages