我正在开始使用 Apache Flink。我将发布我遇到的错误,然后复制它的步骤
这是我运行的命令-
./bin/flink run examples/streaming/WordCount.jar --input
这是错误文本 -
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unable to make field private final byte[] java.lang.String.value accessible: module java.base does not "opens java.lang" to unnamed module @3c60b7e7
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:812)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:246)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1054)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
Caused by: java.lang.reflect.InaccessibleObjectException: Unable to make field private final byte[] java.lang.String.value accessible: module java.base does not "opens java.lang" to unnamed module @3c60b7e7
at java.base/java.lang.reflect.AccessibleObject.checkCanSetAccessible(AccessibleObject.java:354)
at java.base/java.lang.reflect.AccessibleObject.checkCanSetAccessible(AccessibleObject.java:297) …Run Code Online (Sandbox Code Playgroud) 我有这个数据集 -
print(df)
object group
1 apple A
1 banana B
1 pear A
1 robot C
print(df2)
object group
1 apple A
1 apple B
1 apple A
1 robot C
1 robot C
1 robot C
1 banana C
Run Code Online (Sandbox Code Playgroud)
我想计算每个值在另一个数据集中出现的次数,该数据集看起来完全相同,但从不同的时间段提取数据。另一个数据集称为df2.
我使用了这段代码 -
x <- df %>%
mutate(reference = length(df2[df2$object == object,]$object))
Run Code Online (Sandbox Code Playgroud)
它给了我这个错误:longer object length is not a multiple of shorter object length。
当我在 dplyr 之外运行它时,它会起作用,如下所示 -
object <- "apple"
length(df2[df2$object == object,]$object)
Run Code Online (Sandbox Code Playgroud)
我可以做这样的相对引用,包括object …
我有一个 bash 脚本来锁定我的计算机。我想将其设置为从现在起 30 分钟后锁定。
这是我的 bash 脚本,用于我的 mac 计算机锁定屏幕
/System/Library/CoreServices/Menu\ Extras/User.menu/Contents/Resources/CGSession -suspend
Run Code Online (Sandbox Code Playgroud)
我可以用这段代码执行它
sh ~/Documents/Misc/lock_computer
Run Code Online (Sandbox Code Playgroud) 我有一个包含 ID 列表的数据框。我想将其过滤为一组 ID,我使用 .filter() 来做到这一点。
我遇到了这个错误。
java.lang.RuntimeException: Unsupported literal type class scala.collection.immutable.HashSet$HashTrieSet
Run Code Online (Sandbox Code Playgroud)
我的代码很简单。
val setofID = Set("112", "113", "114", "121", "118", "120")
val my_dfFiltered = my_df.filter($"id".isin(setofID)).persist
Run Code Online (Sandbox Code Playgroud) 我有这三个数据框和这个功能
set.seed(1)
df1 <-
data.frame(
x = c("cat", "dog"),
y = sample(1:100, 20),
z = seq(ymd("2020-01-01"), ymd("2020-01-20"), by = "1 day")
)
df2 <-
data.frame(
x = c("red", "green"),
y = sample(1:100, 20),
z = seq(ymd("2020-01-01"), ymd("2020-01-20"), by = "1 day")
)
df3 <-
data.frame(
x = c("up", "down"),
y = sample(1:100, 20),
z = seq(ymd("2020-01-01"), ymd("2020-01-20"), by = "1 day")
)
dataframes <-
c("df1", "df2", "df3")
exploreDataFrames <- function(dataframes, sequence = seq_along(dataframes)){
for (i in seq_along(sequence)){
print(get(dataframes[i]))
gg <- …Run Code Online (Sandbox Code Playgroud) 还有一个十一年前就有类似标题的问题。
我有一个 pandas 数据框,其中包含一列 datetime.time 值。
val time
a 12:30:01.323
b 12:48:04.583
c 14:38:29.162
Run Code Online (Sandbox Code Playgroud)
我想将时间列从 UTC 转换为 EST。
我尝试这样做dataframe.tz_localize('utc').tz_convert('US/Eastern'),但它给了我以下错误:RangeIndex Object has no attribute tz_localize
I want to find the maximum value in a JSON object. This is my data-
(3) [{…}, {…}, {…}]
0: {name: "a", value: 12}
1: {name: "b", value: 28}
2: {name: "c", value: 60}
Run Code Online (Sandbox Code Playgroud)
I'd like to get the maximum value, but they're nested. I could do something like this
arr = {}
for (x in jsonObj){
arr.push(x.value)
}
d3.max(arr)
Run Code Online (Sandbox Code Playgroud)
I was curious if there's a better way of dealing with this situation. My goal is to use d3.max() to …
我曾遇到过 RStudio 中止并且我失去进度的情况。
是否有自动保存,至少对于 R 脚本?
我认为 Windows 上可能有类似的东西。我在 Mac 上使用 RStudio。
我想向 ggplot 添加一条垂直线。我的 x 轴是一个字符值,我无法让它工作。
这是我的数据
my_data <- read.table(text="day value
11/15/19 0.23633
11/16/19 0.28485
11/17/19 0.63127
11/18/19 0.15434
11/19/19 0.47964
11/20/19 0.65967
11/21/19 0.48741
11/22/19 0.84541
11/23/19 0.10123
11/24/19 0.78169
11/25/19 0.23189
11/26/19 0.86665
11/27/19 0.55184
11/28/19 0.81410
11/29/19 0.25821
11/30/19 0.23576
12/1/19 0.46397
12/2/19 0.55764
12/3/19 0.95645
12/4/19 0.63954
12/5/19 0.76766
12/7/19 0.74505
12/8/19 0.65515
12/9/19 0.58222
12/10/19 0.17294", header=TRUE, stringsAsFactors=FALSE)
Run Code Online (Sandbox Code Playgroud)
这是我的代码
my_data %>%
ggplot(aes(day, value)) +
geom_line() +
geom_vline(xintercept=5)
Run Code Online (Sandbox Code Playgroud)
我的目标是有一条垂直线在值11/20/19上截取 x 。当我运行此代码时,我在图表上的任何位置都看不到水平线。
我有一个图表,显示操作系统的移动使用情况。我想添加垂直线来标识这些操作系统的发布时间。我将通过图表,然后是代码。
图表 -
编码 -
dev %>%
group_by(os) %>%
mutate(monthly_change = prop - lag(prop)) %>%
ggplot(aes(month, monthly_change, color = os)) +
geom_line() +
geom_vline(xintercept = as.numeric(ymd("2013-10-01"))) +
geom_text(label = "KitKat", x = as.numeric(ymd("2013-10-01")) + 80, y = -.5)
Run Code Online (Sandbox Code Playgroud)
我不想在图中添加文本,而是想创建一个图例来标识每一行。我想给他们每个人自己的颜色,然后有一个图例来识别每个人。像这样的东西——
我可以像这样制作自己的自定义图例吗?
r ×5
ggplot2 ×3
apache-flink ×1
apache-spark ×1
bash ×1
d3.js ×1
dplyr ×1
javascript ×1
pandas ×1
python ×1
rstudio ×1
scala ×1
time ×1
timezone ×1