我试图通过Sqoop将一个包含3200万条记录的表从SQL Server导入Hive.连接是SQL Server成功的.但Map/Reduce作业无法成功执行.它给出以下错误:
18/07/19 04:00:11 INFO client.RMProxy: Connecting to ResourceManager at /127.0.0.1:8032
18/07/19 04:00:27 DEBUG db.DBConfiguration: Fetching password from job credentials store
18/07/19 04:00:27 INFO db.DBInputFormat: Using read commited transaction isolation
18/07/19 04:00:27 DEBUG db.DataDrivenDBInputFormat: Creating input split with lower bound '1=1' and upper bound '1=1'
18/07/19 04:00:28 INFO mapreduce.JobSubmitter: number of splits:1
18/07/19 04:00:29 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_1531917395459_0002
18/07/19 04:00:30 INFO impl.YarnClientImpl: Submitted application application_1531917395459_0002
18/07/19 04:00:30 INFO mapreduce.Job: The url to track the job: http://quickstart.cloudera:8088/proxy/application_1531917395459_0002/ …Run Code Online (Sandbox Code Playgroud) 我在 django 中有以下模型
Business ID
Business Name
Business Revenue
Date
Run Code Online (Sandbox Code Playgroud)
这是示例数据:
Business ID | Business Name | Business Revenue | Date
1 B1 1000 2012-10-13
2 B2 20000 2013-10-16
1 B1 2000 2013-04-13
2 B2 24000 2014-09-02
Run Code Online (Sandbox Code Playgroud)
我想获取所有具有最新日期的企业。
这是我想要的输出:
Business ID | Business Name | Business Revenue | Date
1 B1 2000 2013-04-13
2 B2 24000 2014-09-02
Run Code Online (Sandbox Code Playgroud)
我已经尝试过这个:
model.objects.filter(date__gte = date.today()).order_by('business_id', '-date')
Run Code Online (Sandbox Code Playgroud)
这为我提供了一组企业,每个组的顶部都有最新的业务。如何省略其余行?我需要一些帮助
我有10个文本框,现在我想检查单击按钮时它们都不是空的.我的代码是:
if (TextBox1.Text == "")
{
errorProvider1.SetError(TextBox1, "Please fill the required field");
}
Run Code Online (Sandbox Code Playgroud)
有什么方法可以一次检查所有文本框,而不是为每个人写作?
我在mongo db中写了一个查询.我有一个预订表,我希望在一个月内获得预订数量,即按月分组.我很困惑,如何从约会获得月份.
这是我的架构:
{
"_id" : ObjectId("5485dd6af4708669af35ffe6"),
"bookingid" : 1,
"operatorid" : 1,
"clientid" : null,
"callername" : "Sayem Hussain",
"contactno" : "0205661862",
"regular" : 0,
"bookingdetail" : [
{
"driverid" : 1,
"pickupdatetime" : "2011-04-14 11:00:00",
"from" : "white chapel",
"to" : "beach",
"cost" : 500,
"journeytime" : 60
},
{
"driverid" : 2,
"pickupdatetime" : "2012-05-14 12:00:00",
"from" : "walthamstow",
"to" : "mile end",
"cost" : 1000,
"journeytime" : 50
}
],
"bookingdatetime" : "2012-10-11T07:00:00Z"
}
{
"_id" …Run Code Online (Sandbox Code Playgroud) 我在 Zeppelin 笔记本中使用 pspark 并尝试使用 SELECT 语句获取数据。我只是想查询一个表,但以下命令出现奇怪的错误:
%pyspark
spark.sql('select * from default.abc').show()
Run Code Online (Sandbox Code Playgroud)
这是我得到的错误:
Py4JJavaError: An error occurred while calling o92.sql.
: java.lang.NoSuchMethodError: com.facebook.fb303.FacebookService$Client.sendBaseOneway(Ljava/lang/String;Lorg/apache/thrift/TBase;)V
at com.facebook.fb303.FacebookService$Client.send_shutdown(FacebookService.java:436)
at com.facebook.fb303.FacebookService$Client.shutdown(FacebookService.java:430)
at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.close(HiveMetaStoreClient.java:606)
at sun.reflect.GeneratedMethodAccessor37.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:154)
at com.sun.proxy.$Proxy39.close(Unknown Source)
at sun.reflect.GeneratedMethodAccessor37.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.hadoop.hive.metastore.HiveMetaStoreClient$SynchronizedHandler.invoke(HiveMetaStoreClient.java:2477)
at com.sun.proxy.$Proxy39.close(Unknown Source)
at org.apache.hadoop.hive.ql.metadata.Hive.close(Hive.java:414)
at org.apache.hadoop.hive.ql.metadata.Hive.create(Hive.java:330)
at org.apache.hadoop.hive.ql.metadata.Hive.getInternal(Hive.java:317)
at org.apache.hadoop.hive.ql.metadata.Hive.get(Hive.java:293)
at org.apache.spark.sql.hive.client.HiveClientImpl$$anonfun$withHiveState$1.apply(HiveClientImpl.scala:278)
at org.apache.spark.sql.hive.client.HiveClientImpl.liftedTree1$1(HiveClientImpl.scala:221)
at org.apache.spark.sql.hive.client.HiveClientImpl.retryLocked(HiveClientImpl.scala:220)
at org.apache.spark.sql.hive.client.HiveClientImpl.withHiveState(HiveClientImpl.scala:266)
at org.apache.spark.sql.hive.client.HiveClientImpl.databaseExists(HiveClientImpl.scala:356)
at org.apache.spark.sql.hive.HiveExternalCatalog$$anonfun$databaseExists$1.apply$mcZ$sp(HiveExternalCatalog.scala:217)
at org.apache.spark.sql.hive.HiveExternalCatalog$$anonfun$databaseExists$1.apply(HiveExternalCatalog.scala:217)
at org.apache.spark.sql.hive.HiveExternalCatalog$$anonfun$databaseExists$1.apply(HiveExternalCatalog.scala:217)
at org.apache.spark.sql.hive.HiveExternalCatalog.withClient(HiveExternalCatalog.scala:99)
at …Run Code Online (Sandbox Code Playgroud) 我正在尝试在 Zeppelin 笔记本中配置 ldap 身份验证。我通过此链接指定了 LDAP 服务器和其他配置。但是,当我尝试登录时出现以下错误:
ERROR [2019-12-23 17:52:12,196] ({qtp1580893732-66} LoginRestApi.java[proceedToLogin]:172) - Exception in login:
org.apache.shiro.authc.AuthenticationException: Authentication failed for token submission [org.apache.shiro.authc.UsernamePasswordToken - user1, rememberMe=false]. Possible unexpected error? (Typical or expected login exceptions should extend from AuthenticationException).
at org.apache.shiro.authc.AbstractAuthenticator.authenticate(AbstractAuthenticator.java:214)
at org.apache.shiro.mgt.AuthenticatingSecurityManager.authenticate(AuthenticatingSecurityManager.java:106)
at org.apache.shiro.mgt.DefaultSecurityManager.login(DefaultSecurityManager.java:270)
at org.apache.shiro.subject.support.DelegatingSubject.login(DelegatingSubject.java:256)
at org.apache.zeppelin.rest.LoginRestApi.proceedToLogin(LoginRestApi.java:140)
at org.apache.zeppelin.rest.LoginRestApi.postLogin(LoginRestApi.java:199)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:76)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:148)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:191)
at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:200)
at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:103)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:493)
at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:415)
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:305)
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:118) …Run Code Online (Sandbox Code Playgroud) 我正在尝试通过图库或相机捕获视频。我能够成功从图库中获取视频。然而,当我尝试从相机录制视频时,它丢失了轨道,并且我无法获取路径。它确实将视频保存在路径上。日志给出以下错误/警告。为什么录像机丢失踪迹?我哪里出错了?
2022-03-15 07:32:08.683 14318-14318/com.example.locationfetcher_v2 W/MirrorManager: this model don't Support
2022-03-15 07:32:13.864 14318-14318/com.example.locationfetcher_v2 D/DecorView: createDecorCaptionView windowingMode:1 mWindowMode 1 isFullscreen: true
2022-03-15 07:32:14.875 14318-14318/com.example.locationfetcher_v2 I/Timeline: Timeline: Activity_launch_request time:174742145
2022-03-15 07:32:14.912 14318-14395/com.example.locationfetcher_v2 D/OpenGLRenderer: endAllActiveAnimators on 0xb400007e4ade6e00 (AlertController$RecycleListView) with handle 0xb400007e52639220
2022-03-15 07:32:20.913 14318-14339/com.example.locationfetcher_v2 W/System: A resource failed to call close
Run Code Online (Sandbox Code Playgroud)
这是我的代码:
public void showPictureDialog(View view){
AlertDialog.Builder pictureDialog = new AlertDialog.Builder(this);
pictureDialog.setTitle("Select Action");
String[] pictureDialogItems = {
"Select video from gallery",
"Record video from camera" };
pictureDialog.setItems(pictureDialogItems,
new DialogInterface.OnClickListener() {
@Override
public void onClick(DialogInterface …Run Code Online (Sandbox Code Playgroud) 我正在创建一个WCF服务,我在其中执行sharepoint列表中的CRUD操作.我已通过REST成功从sharepoint列表中检索数据,即通过网络凭证对象传递凭据(用户名,密码,域),但遗憾的是无法插入数据.错误是指在sharepoint中插入数据时的未授权访问.然后我尝试了Sharepoint在线凭证对象,但没有运气.我需要一些帮助.
这是一个例外:
The remote server returned an error: (401) Unauthorized.
Run Code Online (Sandbox Code Playgroud)
这是代码:
try
{
string userPassword = "password";
WebClient webClient = new WebClient();
SecureString securePassword = new SecureString();
for (int i = 0; i < userPassword.Length; i++)
{
securePassword.AppendChar(userPassword[i]);
}
webClient.Credentials = new SharePointOnlineCredentials(@"username@domain", securePassword);
webClient.Headers.Add("Content-type", "application/json");
webClient.Headers.Add("Accept", "application/json;odata=verbose");
webClient.Headers.Add("user-agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/36.0.1985.143 Safari/537.36");
webClient.Encoding = Encoding.UTF8;
string msg = webClient.UploadString("http://abc:9211/sites/api/_api/web/lists/getbytitle('list_name')/Items", "POST", "{__metadata\":{\"type\":\"SP.Data.SubscriptionListItem\"},\"UserID\":\"user\",\"SubscriptionType\":\"Type1\",\"Title\":\"Testing\"}");
}
catch(WebException ex)
{
}
Run Code Online (Sandbox Code Playgroud)