Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in
Toggle navigation
C
ctr-estimate
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
赵建伟
ctr-estimate
Commits
7a9d9504
Commit
7a9d9504
authored
Apr 03, 2020
by
赵建伟
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update codes
parent
51d50459
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
3 additions
and
3 deletions
+3
-3
start.sh
bin/start.sh
+1
-1
CtrEstimateMain.java
src/main/java/com/gmei/data/ctr/CtrEstimateMain.java
+2
-2
No files found.
bin/start.sh
View file @
7a9d9504
...
...
@@ -26,7 +26,7 @@ $JAR_DIR/ctr-estimate-1.0-SNAPSHOT.jar \
--retryInteral
3000
\
--checkpointPath
'hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate/checkpoint'
\
--parallelism
12
\
--startTime
'2020-04-03
19:4
0:00'
\
--startTime
'2020-04-03
20:3
0:00'
\
>>
/data/log/ctr-estimate/ctr-estimate.out 2>&1 &
tail
-10f
/data/log/ctr-estimate/ctr-estimate.out
...
...
src/main/java/com/gmei/data/ctr/CtrEstimateMain.java
View file @
7a9d9504
...
...
@@ -29,8 +29,8 @@ public class CtrEstimateMain {
String
maidianInGroupId
=
parameterTool
.
get
(
"maidianInGroupId"
,
"ctr-estimate"
);
Integer
windowSize
=
parameterTool
.
getInt
(
"windowSize"
,
60
);
Integer
slideSize
=
parameterTool
.
getInt
(
"slideSize"
,
60
);
String
jdbcUrl
=
parameterTool
.
get
(
"
outJ
dbcUrl"
,
"jdbc:mysql://
test002
:3306/jerry_test?user=root&password=5OqYM^zLwotJ3oSo&autoReconnect=true&useSSL=false"
);
String
jdbcUrl
=
parameterTool
.
get
(
"
j
dbcUrl"
,
"jdbc:mysql://
172.18.44.3
:3306/jerry_test?user=root&password=5OqYM^zLwotJ3oSo&autoReconnect=true&useSSL=false"
);
Integer
maxRetry
=
parameterTool
.
getInt
(
"maxRetry"
,
3
);
Long
retryInteral
=
parameterTool
.
getLong
(
"retryInteral"
,
3000
);
String
checkpointPath
=
parameterTool
.
get
(
"checkpointPath"
,
"hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate/checkpoint"
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment