Folks, We have an application that uses Ray and Apache Arrow flight. It has been working with ray-2.0.0.dev0-cp37-cp37m-macosx_10_15_intel.whl.
commit = “7e109a3266016a35501ddd897f279576fe7bfc3d”
version = “2.0.0.dev0”
Now, it can not start with Ray 1.7.0 or Ray daily builds. Below code throws Segmentation fault 11 error message.
I really appreciate your help to resolve this issues.
import ray
import pyarrow.flight as fl
@ray.remote
def f(x):
return x * x
class FlightServer(fl.FlightServerBase):
def __init__(self, location="grpc://0.0.0.0:8815", **kwargs):
super().__init__(location, **kwargs)
print("init done")
self.tables = {}
futures = [f.remote(i) for i in range(4)]
print(ray.get(futures)) # [0, 1, 4, 9]
def main():
FlightServer().serve()
if __name__ == '__main__':
main()