An existing connection was forcibly closed by the remote host #169
Labels
question
Further information is requested
Comments
aysuays
changed the title
|
@fightlikeagirl can you share your program? |
|
First program I try : `using Microsoft.Spark.Sql;
namespace MySparkApp
{
class Program
{
static void Main(string[] args)
{
// Create a Spark session
var spark = SparkSession
.Builder()
.AppName("word_count_sample")
.GetOrCreate();
// Create initial DataFrame
DataFrame dataFrame = spark.Read().Text("input.txt");
// Count words
var words = dataFrame
.Select(Functions.Split(Functions.Col("value"), " ").Alias("words"))
.Select(Functions.Explode(Functions.Col("words"))
.Alias("word"))
.GroupBy("word")
.Count()
.OrderBy(Functions.Col("count").Desc());
// Show results
words.Show();
}
}
}` |
|
And the second one : `using Microsoft.Spark.Sql;
namespace HelloSpark
{
class Program
{
static void Main(string[] args)
{
var spark = SparkSession.Builder().GetOrCreate();
var df = spark.Read().Json("people.json");
df.Show();
}
}
}Both of them gave the true results then gave the above errors. |
|
Can you try to |
|
@fightlikeagirl Any update on this? |
|
Closing this due to inactivity. Feel free to reopen it. |
|
Hello: and the source had then spark.Stop(); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hello,
I installed correctly dotnet spark according to this Microsoft tutorial. I try the basic codes in above link and [Windows Instructions](https://github docs/getting-started/windows-instructions.md).
Both of them, I see the results of programs but then I get this error ;
I try to solve this error but I failed. I hope you can help me. Thank you so much.
The text was updated successfully, but these errors were encountered: