I can’t join feature groups on a shared column.
I am using the tutorial examples code and there seems to be errors on running query.show(5)
Here is the code:
query = trans_fg.select(["fraud_label", "category", "amount", "age_at_transaction", "days_until_card_expires", "loc_delta"]).join(window_aggs_fg.select_all(), on="cc_num")
Here is the output
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\pandas\io\sql.py:2023](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2023), in SQLiteDatabase.execute(self, *args, **kwargs) [2022](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2022) try: → [2023](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2023) cur.execute(*args, **kwargs) [2024](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2024) return cur File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\pyhive\hive.py:408](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:408), in Cursor.execute(self, operation, parameters, **kwargs) [407](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:407) response = self._connection.client.ExecuteStatement(req) → [408](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:408) _check_status(response) [409](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:409) self._operationHandle = response.operationHandle File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\pyhive\hive.py:538](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:538), in _check_status(response) [537](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:537) if response.status.statusCode != ttypes.TStatusCode.SUCCESS_STATUS: → [538](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:538) raise OperationalError(response) OperationalError: TExecuteStatementResp(status=TStatus(statusCode=3, infoMessages=[‘*org.apache.hive.service.cli.HiveSQLException:Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.tez.TezTask:28:27’, ‘org.apache.hive.service.cli.operation.Operation:toSQLException:Operation.java:343’, ‘org.apache.hive.service.cli.operation.SQLOperation:runQuery:SQLOperation.java:232’, ‘org.apache.hive.service.cli.operation.SQLOperation:runInternal:SQLOperation.java:269’, ‘org.apache.hive.service.cli.operation.Operation:run:Operation.java:255’, ‘org.apache.hive.service.cli.session.HiveSessionImpl:executeStatementInternal:HiveSessionImpl.java:541’, ‘org.apache.hive.service.cli.session.HiveSessionImpl:executeStatement:HiveSessionImpl.java:516’, ‘sun.reflect.GeneratedMethodAccessor221:invoke::-1’, ‘sun.reflect.DelegatingMethodAccessorImpl:invoke:DelegatingMethodAccessorImpl.java:43’, ‘java.lang.reflect.Method:invoke:Method.java:498’, ‘org.apache.hive.service.cli.session.HiveSessionProxy:invoke:HiveSessionProxy.java:78’, ‘org.apache.hive.service.cli.session.HiveSessionProxy:access$000:HiveSessionProxy.java:36’, ‘org.apache.hive.service.cli.session.HiveSessionProxy$1:run:HiveSessionProxy.java:63’, ‘java.security.AccessController:doPrivileged:AccessController.java:-2’, ‘javax.security.auth.Subject:doAs:Subject.java:422’, ‘org.apache.hadoop.security.UserGroupInformation:doAs:UserGroupInformation.java:1821’, ‘org.apache.hive.service.cli.session.HiveSessionProxy:invoke:HiveSessionProxy.java:59’, ‘com.sun.proxy.$Proxy53:executeStatement::-1’, ‘org.apache.hive.service.cli.CLIService:executeStatement:CLIService.java:281’, ‘org.apache.hive.service.cli.thrift.ThriftCLIService:ExecuteStatement:ThriftCLIService.java:712’, ‘org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement:getResult:TCLIService.java:1557’, ‘org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement:getResult:TCLIService.java:1542’, ‘org.apache.thrift.ProcessFunction:process:ProcessFunction.java:39’, ‘org.apache.thrift.TBaseProcessor:process:TBaseProcessor.java:39’, ‘org.apache.hive.service.auth.TSetIpAddressProcessor:process:TSetIpAddressProcessor.java:56’, ‘org.apache.thrift.server.TThreadPoolServer$WorkerProcess:run:TThreadPoolServer.java:286’, ‘java.util.concurrent.ThreadPoolExecutor:runWorker:ThreadPoolExecutor.java:1149’, ‘java.util.concurrent.ThreadPoolExecutor$Worker:run:ThreadPoolExecutor.java:624’, ‘java.lang.Thread:run:Thread.java:750’], sqlState=‘08S01’, errorCode=1, errorMessage=‘Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.tez.TezTask’), operationHandle=None) During handling of the above exception, another exception occurred: NotSupportedError Traceback (most recent call last) File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\pandas\io\sql.py:2027](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2027), in SQLiteDatabase.execute(self, *args, **kwargs) [2026](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2026) try: → [2027](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2027) self.con.rollback() [2028](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pandas/io/sql.py:2028) except Exception as inner_exc: # pragma: no cover File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\pyhive\hive.py:285](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:285), in Connection.rollback(self) [284](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:284) def rollback(self): → [285](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/pyhive/hive.py:285) raise NotSupportedError(“Hive does not have transactions”) NotSupportedError: Hive does not have transactions The above exception was the direct cause of the following exception: DatabaseError Traceback (most recent call last) Input In [26], in <cell line: 1>() ----> 1 query.show(5) File [c:\Users\User.conda\envs\NewEnv\lib\site-packages\hsfs\constructor\query.py:182](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:182), in Query.show(self, n, online) [179](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:179) read_options = {} [180](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:180) sql_query, online_conn = self._prep_read(online, read_options) → [182](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:182) return engine.get_instance().show( [183](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:183) sql_query, self._feature_store_name, n, online_conn, read_options [184](file:///C:/Users/User/.conda/envs/NewEnv/lib/site-packages/hsfs/constructor/query.py:184) )
…